diff options
author | Andreas Baumann <mail@andreasbaumann.cc> | 2014-12-14 17:48:43 +0100 |
---|---|---|
committer | Andreas Baumann <mail@andreasbaumann.cc> | 2014-12-14 17:48:43 +0100 |
commit | 391222b8a5d4a69018b530859c8a0bcad05cf08a (patch) | |
tree | b79ad18b9944726583b31bed6d9384695f4f12e0 /src/master.c | |
parent | 259ca5ed40b727de03c45479ff374d1bb7c39630 (diff) | |
download | biruda-391222b8a5d4a69018b530859c8a0bcad05cf08a.tar.gz biruda-391222b8a5d4a69018b530859c8a0bcad05cf08a.tar.bz2 |
..
Diffstat (limited to 'src/master.c')
-rw-r--r-- | src/master.c | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/master.c b/src/master.c index fc4768e..c2997da 100644 --- a/src/master.c +++ b/src/master.c @@ -81,6 +81,7 @@ static void update_workers( coordinator_t *coord, json_object *obj ) typedef struct { FILE *spool_file; + off_t read_pos; } execution_worker_data_t; static int register_coordinator( json_object *obj ) @@ -324,6 +325,7 @@ static int master_output_init( const char *spool_dir, const char *name ) execution_worker_data_t *wed = (execution_worker_data_t *)worker->execution_data; wed->spool_file = fopen( filename, "a+" ); + wed->read_pos = 0; return 0; } @@ -450,6 +452,11 @@ static int master_output_write_terminated( const char *spool_dir, json_object *o return 0; } +void master_output_tail( const char *name, char *s, size_t len ) +{ + //~ snprintf( s, len, "messages worker '%s'..\n", name ); +} + static void *master_func( void *thread_data ) { master_thread_data_t *tdata = (master_thread_data_t *)thread_data; |