summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
d23382b)
cds_wfcq_splice_blocking() internally takes the locks.
Signed-off-by: Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
*/
if (cds_wfcq_empty(&sibling->head, &sibling->tail))
return false;
*/
if (cds_wfcq_empty(&sibling->head, &sibling->tail))
return false;
- cds_wfcq_dequeue_lock(&sibling->head, &sibling->tail);
- splice_ret = __cds_wfcq_splice_blocking(&worker->head,
+ splice_ret = cds_wfcq_splice_blocking(&worker->head,
&worker->tail,
&sibling->head,
&sibling->tail);
&worker->tail,
&sibling->head,
&sibling->tail);
- cds_wfcq_dequeue_unlock(&sibling->head, &sibling->tail);
/* Ensure that we preserve FIFO work order. */
assert(splice_ret != CDS_WFCQ_RET_DEST_NON_EMPTY);
return splice_ret != CDS_WFCQ_RET_SRC_EMPTY;
/* Ensure that we preserve FIFO work order. */
assert(splice_ret != CDS_WFCQ_RET_DEST_NON_EMPTY);
return splice_ret != CDS_WFCQ_RET_SRC_EMPTY;