|
|
@ -8444,14 +8444,15 @@ check_turns:
|
|
|
|
break;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/* If using dynamic realtime members, we should regenerate the member list for this queue */
|
|
|
|
|
|
|
|
update_realtime_members(qe.parent);
|
|
|
|
|
|
|
|
/* OK, we didn't get anybody; wait for 'retry' seconds; may get a digit to exit with */
|
|
|
|
/* OK, we didn't get anybody; wait for 'retry' seconds; may get a digit to exit with */
|
|
|
|
res = wait_a_bit(&qe);
|
|
|
|
res = wait_a_bit(&qe);
|
|
|
|
if (res) {
|
|
|
|
if (res) {
|
|
|
|
goto stop;
|
|
|
|
goto stop;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* If using dynamic realtime members, we should regenerate the member list for this queue */
|
|
|
|
|
|
|
|
update_realtime_members(qe.parent);
|
|
|
|
|
|
|
|
|
|
|
|
/* Since this is a priority queue and
|
|
|
|
/* Since this is a priority queue and
|
|
|
|
* it is not sure that we are still at the head
|
|
|
|
* it is not sure that we are still at the head
|
|
|
|
* of the queue, go and check for our turn again.
|
|
|
|
* of the queue, go and check for our turn again.
|
|
|
|