}
/* Notify waiting tasks. */
struct kr_query *leader_qry = array_tail(task->req.rplan.pending);
- for (size_t i = task->waiting.len; i --> 0;) {
- struct qr_task *follower = task->waiting.at[i];
+ for (size_t i = task->waiting.len; i > 0; i--) {
+ struct qr_task *follower = task->waiting.at[i - 1];
/* Reuse MSGID and 0x20 secret */
if (follower->req.rplan.pending.len > 0) {
struct kr_query *qry = array_tail(follower->req.rplan.pending);
}
/* Find the query, it will likely be on top */
- for (size_t i = rplan->pending.len; i --> 0;) {
- if (rplan->pending.at[i] == qry) {
- array_del(rplan->pending, i);
+ for (size_t i = rplan->pending.len; i > 0; i--) {
+ if (rplan->pending.at[i - 1] == qry) {
+ array_del(rplan->pending, i - 1);
array_push(rplan->resolved, qry);
break;
}