summaryrefslogtreecommitdiff
path: root/src/master.c
diff options
context:
space:
mode:
authorAndreas Baumann <mail@andreasbaumann.cc>2014-12-14 17:48:43 +0100
committerAndreas Baumann <mail@andreasbaumann.cc>2014-12-14 17:48:43 +0100
commit391222b8a5d4a69018b530859c8a0bcad05cf08a (patch)
treeb79ad18b9944726583b31bed6d9384695f4f12e0 /src/master.c
parent259ca5ed40b727de03c45479ff374d1bb7c39630 (diff)
downloadbiruda-391222b8a5d4a69018b530859c8a0bcad05cf08a.tar.gz
biruda-391222b8a5d4a69018b530859c8a0bcad05cf08a.tar.bz2
..
Diffstat (limited to 'src/master.c')
-rw-r--r--src/master.c7
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;