Lines Matching refs:sendqueue
184 if (ctx->sendqueue) { in coap_adjust_basetime()
187 ctx->sendqueue->t -= delta; in coap_adjust_basetime()
194 coap_queue_t *q = ctx->sendqueue; in coap_adjust_basetime()
291 if ( !context || !context->sendqueue ) in coap_peek_next()
294 return context->sendqueue; in coap_peek_next()
301 if ( !context || !context->sendqueue ) in coap_pop_next()
304 next = context->sendqueue; in coap_pop_next()
305 context->sendqueue = context->sendqueue->next; in coap_pop_next()
306 if (context->sendqueue) { in coap_pop_next()
307 context->sendqueue->t += next->t; in coap_pop_next()
424 coap_delete_all(context->sendqueue); in coap_free_context()
427 context->sendqueue = NULL; in coap_free_context()
741 if (context->sendqueue == NULL) { in coap_send_confirmed()
749 coap_insert_node(&context->sendqueue, node); in coap_send_confirmed()
752 …if (node == context->sendqueue) /* don't bother with timer stuff if there are earlier retransmits … in coap_send_confirmed()
782 coap_insert_node(&context->sendqueue, node); in coap_retransmit()
784 …if (node == context->sendqueue) /* don't bother with timer stuff if there are earlier retransmits … in coap_retransmit()
990 while (context->sendqueue && in coap_cancel_all_messages()
991 coap_address_equals(dst, &context->sendqueue->remote) && in coap_cancel_all_messages()
993 context->sendqueue->pdu->hdr->token, in coap_cancel_all_messages()
994 context->sendqueue->pdu->hdr->token_length)) { in coap_cancel_all_messages()
995 q = context->sendqueue; in coap_cancel_all_messages()
996 context->sendqueue = q->next; in coap_cancel_all_messages()
1001 if (!context->sendqueue) in coap_cancel_all_messages()
1004 p = context->sendqueue; in coap_cancel_all_messages()
1557 coap_remove_from_queue(&context->sendqueue, rcvd->id, &sent);
1584 coap_remove_from_queue(&context->sendqueue, rcvd->id, &sent);
1645 return !context || (context->sendqueue == NULL);
1749 if (ctx->sendqueue != NULL)
1753 if (ctx->sendqueue->t >= elapsed) {
1754 delay = ctx->sendqueue->t - elapsed;