summaryrefslogtreecommitdiff
path: root/src/coordinator.c
diff options
context:
space:
mode:
authorAndreas Baumann <mail@andreasbaumann.cc>2014-11-30 16:42:35 +0100
committerAndreas Baumann <mail@andreasbaumann.cc>2014-11-30 16:42:35 +0100
commit55f9c3d2f3320917dba48c4c532c54483a0bce2b (patch)
treed28cac3ffca7e4467390149f15073d0530e730c8 /src/coordinator.c
parent1cb35fad9924bfa1ae33a6e6aff2e6c5d5b5f454 (diff)
downloadbiruda-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.c6
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++;