..

1 files changed, 13 insertions, 1 deletions

diff --git a/src/biruda.c b/src/biruda.c
index 1ec8d5a..362ca50 100644
--- a/src/biruda.c
+++ b/src/biruda.c
@@ -202,8 +202,20 @@ static int create_coordinator( cfg_t *cfg )
 {
 	cfg_t *master_cfg = cfg_getnsec( cfg, "coordinator", 0 );
 	char *control = cfg_getstr( master_cfg, "control" );
+
+	int ret = coordinator_init( control );
+
+	unsigned int nof_workers = cfg_size( cfg, "worker" );
+	if( nof_workers > 0 ) {
+		for( unsigned int i = 0; i < nof_workers; i++ ) {
+			cfg_t *worker_cfg = cfg_getnsec( cfg, "worker", i );
+			coordinator_add_worker( cfg_title( worker_cfg ),
+				(worker_execution_mode_t)cfg_getint( worker_cfg, "execution" ),
+				cfg_getstr( worker_cfg, "command" ) );
+		}
+	}
 	
-	return coordinator_init( control );
+	return ret;
 }
 
 #ifndef _WIN32