diff options
author | Andreas Baumann <mail@andreasbaumann.cc> | 2014-11-30 16:42:35 +0100 |
---|---|---|
committer | Andreas Baumann <mail@andreasbaumann.cc> | 2014-11-30 16:42:35 +0100 |
commit | 55f9c3d2f3320917dba48c4c532c54483a0bce2b (patch) | |
tree | d28cac3ffca7e4467390149f15073d0530e730c8 /src/coordinator.c | |
parent | 1cb35fad9924bfa1ae33a6e6aff2e6c5d5b5f454 (diff) | |
download | biruda-55f9c3d2f3320917dba48c4c532c54483a0bce2b.tar.gz biruda-55f9c3d2f3320917dba48c4c532c54483a0bce2b.tar.bz2 |
updating worker state now in master from coordinator state messages
Diffstat (limited to 'src/coordinator.c')
-rw-r--r-- | src/coordinator.c | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/coordinator.c b/src/coordinator.c index 69027ba..d65060d 100644 --- a/src/coordinator.c +++ b/src/coordinator.c @@ -121,6 +121,9 @@ static char *create_register_answer( ) json_object_object_add( worker_obj, "command", command_obj ); } + json_object *state_obj = json_object_new_string( worker_state_str( w->state ) ); + json_object_object_add( worker_obj, "state", state_obj ); + json_object_array_add( worker_array_obj, worker_obj ); } json_object_object_add( obj, "workers", worker_array_obj ); @@ -152,7 +155,7 @@ static int coordinator_start_worker( const char *name, bool *found ) printf( "STARTING WORKER '%s'\n", name ); worker_init( w ); - + return 0; } @@ -326,6 +329,7 @@ int coordinator_add_worker( const char *name, worker_execution_mode_t mode, cons } else { w->mode = WORKER_EXECUTION_DISABLED; } + w->state = WORKER_STATE_STOPPED; w->execution_data = NULL; nof_workers++; |