first starting worker

1 files changed, 7 insertions, 2 deletions

diff --git a/src/coordinator.c b/src/coordinator.c
index 8c34997..6ac9a6e 100644
--- a/src/coordinator.c
+++ b/src/coordinator.c
@@ -1,4 +1,5 @@
 #include "coordinator.h"
+#include "worker.h"
 
 #include "pthread.h"
 
@@ -135,8 +136,9 @@ static char *create_register_answer( )
 
 static int coordinator_start_worker( const char *name, bool *found )
 {
+	worker_t *w = NULL;
 	for( int i = 0; i < nof_workers; i++ ) {
-		worker_t *w = &worker[i];
+		w = &worker[i];
 		if( strcmp( name, w->name ) == 0 ) {
 			*found = true;
 			break;
@@ -149,6 +151,8 @@ static int coordinator_start_worker( const char *name, bool *found )
 	
 	printf( "STARTING WORKER '%s'\n", name );
 	
+	worker_init( w );
+	
 	return 0;
 }
 
@@ -203,7 +207,8 @@ static void *coordinator_func( void *thread_data )
 				const char *worker = json_object_get_string( worker_obj );
 
 				bool found;
-				int res = coordinator_start_worker( worker, &found );
+				/*int res = */
+				(void)coordinator_start_worker( worker, &found );
 				
 				char *msg = create_worker_started_answer( worker, found );
 				size_t msg_size = strlen( msg ) + 1;