Lines Matching refs:rs_queue
38 struct queue *rs_queue;
151 rs_queue = queue_create("rsqueue", CONFIG(resend_queue_size), 0);
152 if (rs_queue == NULL) {
168 queue_destroy(rs_queue);
176 if (queue_in(rs_queue, &cn->qnode)) {
216 size = sprintf(buf, "resent queue (len=%u)\n", queue_len(rs_queue));
218 queue_iterate(rs_queue, &fd, rs_queue_dump);
341 queue_iterate(rs_queue, h, rs_queue_empty);
350 queue_iterate(rs_queue, nack, rs_queue_to_tx);
399 queue_iterate(rs_queue, NULL, rs_queue_empty);
463 n = queue_del_head(rs_queue);
504 if (queue_add(rs_queue, n) < 0) {
507 queue_add(rs_queue, n);
529 if (queue_add(rs_queue, &cn->qnode) < 0) {
532 queue_add(rs_queue, &cn->qnode);
548 queue_len(tx_queue), queue_len(rs_queue));
554 if (queue_in(rs_queue, &cn->qnode)) {