SINK thread (not INTERM) notify its termination
Use !!node_param->type & SINK in likely macro to test wether we are a SINK node or an INTERM node.
This commit is contained in:
parent
bd7379e73a
commit
f0c75c7570
|
@ -490,7 +490,7 @@ static int consumer_data(node_param_t *node_param)
|
||||||
/*printf("[%p] Just received %d word-sized data%s\n", (void *) pthread_self(), WORDS_PER_LINE, WORDS_PER_LINE ? "s" : "");*/
|
/*printf("[%p] Just received %d word-sized data%s\n", (void *) pthread_self(), WORDS_PER_LINE, WORDS_PER_LINE ? "s" : "");*/
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (unlikely(!(node_param->type & SINK)))
|
if (unlikely(!!(node_param->type & SINK)))
|
||||||
printf("[%p] Consumer finished !\n", (void*) pthread_self());
|
printf("[%p] Consumer finished !\n", (void*) pthread_self());
|
||||||
if (delayed_error)
|
if (delayed_error)
|
||||||
return -1;
|
return -1;
|
||||||
|
|
Loading…
Reference in New Issue