/ ticker plant

\m i 12401

P:12400                                          / f port
G:*_gtime _t                                     / today
L..d:"\"l/\",$G"                                 / log directory
F:R:0N                                           / feed, rdb

start:{
 while[*r:@[3::;(`;P);:];_sleep 1000];F::r 1     / connect to f
 S::F 4:(`schema;)                               / get schema
}

tick:{[d]
 if[G<g:*_gtime*d;G::g;set[`end]_n]              / roll-over?
 L 5:,d                                          / log record
 set[`app;,d]]                                   / append record
}

set:{[f;a]if[0<R;R 3:(f;a)]}                     / send to r

sub:{R::_w;S}                                    / return scheme to r

close:{:[x~F;start`;R::0N]}                      / f or r closes
.m.c:".k.close _w"                               / close callback

start`                                           / initialize t