added stopping of worker

1 files changed, 27 insertions, 0 deletions

diff --git a/src/master.c b/src/master.c
index d7bc64c..9a35a73 100644
--- a/src/master.c
+++ b/src/master.c
@@ -217,6 +217,25 @@ static char *create_start_request( const char *name )
 	return res;
 }
 
+static char *create_stop_request( const char *name )
+{
+	json_object *obj = json_object_new_object( );
+	json_object *op = json_object_new_string( "stop" );
+	json_object_object_add( obj, "op", op );
+	json_object *role = json_object_new_string( "master" );
+	json_object_object_add( obj, "role", role );
+	json_object *worker = json_object_new_string( name );
+	json_object_object_add( obj, "worker", worker );
+
+	/* produce message as string, caller must free it */
+	const char *msg = json_object_to_json_string( obj );
+	char *res = alloc_message( msg );
+           
+	json_object_put( obj );
+	
+	return res;
+}
+
 #define MAX_NOF_COMMANDS 12
 
 static int nof_queued_commands = 0;
@@ -408,3 +427,11 @@ int master_start_worker( const char *name )
 
 	return res;
 }
+
+int master_stop_worker( const char *name )
+{
+	char *msg = create_stop_request( name );
+	int res = enqueue_request( msg );
+
+	return res;
+}