handling worker state and mode

1 files changed, 18 insertions, 2 deletions

diff --git a/src/worker.c b/src/worker.c
index 77ae401..70cb64b 100644
--- a/src/worker.c
+++ b/src/worker.c
@@ -152,8 +152,24 @@ static void *worker_func( void *thread_data )
                     
 int worker_init( worker_t *worker )
 {
-	if( worker->state == WORKER_STATE_RUNNING ) {
-		return 0;
+	switch( worker->state ) {
+		case WORKER_STATE_RUNNING:
+			fprintf( stderr, "worker %s is already running\n", worker->name );
+			return 0;
+			
+		case WORKER_STATE_STOPPED:
+			// execute, skip
+			break;
+	}
+	
+	switch( worker->mode ) {
+		case WORKER_EXECUTION_DIRECT:
+			// execute, skip
+			break;
+			
+		case WORKER_EXECUTION_DISABLED:
+			fprintf( stderr, "worker %s is disabled, won't execute\n", worker->name );
+			return 0;
 	}
 
 	pthread_attr_t attr;