diff --git a/src/queue.c b/src/queue.c index 66429a4c56e5706aa43eb6c4fb383a22425c0700..105a3969249b3256f8139aa1353203d2003fb388 100644 --- a/src/queue.c +++ b/src/queue.c @@ -118,9 +118,9 @@ void queue_insert ( struct queue *q , struct task *t ) { } */ /* Verify queue consistency. */ - /* for ( int k = 1 ; k < q->count ; k++ ) + for ( int k = 1 ; k < q->count ; k++ ) if ( q->tasks[ q->tid[(k-1)/2] ].weight < q->tasks[ q->tid[k] ].weight ) - error( "Queue not heaped." ); */ + error( "Queue not heaped." ); /* Unlock the queue. */ if ( lock_unlock( &q->lock ) != 0 ) @@ -269,9 +269,9 @@ struct task *queue_gettask ( struct queue *q , int qid , int blocking ) { } */ /* Verify queue consistency. */ - /* for ( k = 1 ; k < q->count ; k++ ) + for ( k = 1 ; k < q->count ; k++ ) if ( q->tasks[ q->tid[(k-1)/2] ].weight < q->tasks[ q->tid[k] ].weight ) - error( "Queue not heaped." ); */ + error( "Queue not heaped." ); } else diff --git a/src/scheduler.c b/src/scheduler.c index 468d4f75adcb8e4f34233a82e8b6d251f16b3afb..66708fb14ca4ac6014502771bc1029659b889b9e 100644 --- a/src/scheduler.c +++ b/src/scheduler.c @@ -563,7 +563,7 @@ void scheduler_start ( struct scheduler *s , unsigned int mask ) { // #pragma omp parallel for schedule(static) private(t,j) for ( k = s->nr_tasks-1 ; k >= 0 ; k-- ) { t = &tasks[ tid[k] ]; - if ( !( (1 << t->type) & mask ) || !t->skip ) + if ( !( (1 << t->type) & mask ) || t->skip ) continue; for ( j = 0 ; j < t->nr_unlock_tasks ; j++ ) atomic_inc( &t->unlock_tasks[j]->wait );