Changeset: 94bd26a9b1a3 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=94bd26a9b1a3
Modified Files:
        monetdb5/mal/mal_dataflow.c
Branch: Feb2013
Log Message:

mal_dataflow.c: simplify code


diffs (25 lines):

diff --git a/monetdb5/mal/mal_dataflow.c b/monetdb5/mal/mal_dataflow.c
--- a/monetdb5/mal/mal_dataflow.c
+++ b/monetdb5/mal/mal_dataflow.c
@@ -386,17 +386,14 @@ DFLOWinitialize(int index)
        }
        todo[index] = q_create(2048);
        limit = GDKnr_threads ? GDKnr_threads : 1;
-       for (worker = 0; worker < THREADS; worker++)
-               if( workers[worker] == 0)
-                       break;
-       for (i = 0; i < limit; i++){
+       for (worker = 0, i = 0; i < limit; i++){
+               for (; worker < THREADS; worker++)
+                       if( workers[worker] == 0)
+                               break;
                assert(workers[worker] == 0);
                MT_create_thread(&workers[worker], DFLOWworker, (void *) 
&workers[worker], MT_THR_JOINABLE);
                assert(workers[worker] > 0);
                workerqueue[worker] = index + 1;
-               for (; worker < THREADS; worker++)
-                       if( workers[worker] == 0)
-                               break;
        }
        MT_lock_unset(&mal_contextLock, "DFLOWinitialize");
 }
_______________________________________________
checkin-list mailing list
[email protected]
http://mail.monetdb.org/mailman/listinfo/checkin-list

Reply via email to