Lines Matching refs:pending

132 	struct coap_pending *pending;  in coap_server_process()  local
173 pending = coap_pending_received(&request, service->data->pending, MAX_PENDINGS); in coap_server_process()
174 if (pending) { in coap_server_process()
184 coap_server_free(pending->data); in coap_server_process()
185 coap_pending_clear(pending); in coap_server_process()
258 struct coap_pending *pending; in coap_server_retransmit() local
270 pending = coap_pending_next_to_expire(service->data->pending, MAX_PENDINGS); in coap_server_retransmit()
271 if (pending == NULL) { in coap_server_retransmit()
277 remaining = pending->t0 + pending->timeout - now; in coap_server_retransmit()
282 if (coap_pending_cycle(pending)) { in coap_server_retransmit()
283 ret = zsock_sendto(service->data->sock_fd, pending->data, pending->len, 0, in coap_server_retransmit()
284 &pending->addr, ADDRLEN(&pending->addr)); in coap_server_retransmit()
289 __ASSERT_NO_MSG(ret == pending->len); in coap_server_retransmit()
293 coap_service_remove_observer(service, NULL, &pending->addr, NULL, 0U); in coap_server_retransmit()
294 coap_server_free(pending->data); in coap_server_retransmit()
295 coap_pending_clear(pending); in coap_server_retransmit()
304 struct coap_pending *pending; in coap_server_poll_timeout() local
314 pending = coap_pending_next_to_expire(svc->data->pending, MAX_PENDINGS); in coap_server_poll_timeout()
315 if (pending == NULL) { in coap_server_poll_timeout()
319 remaining = pending->t0 + pending->timeout - now; in coap_server_poll_timeout()
545 struct coap_pending *pending = coap_pending_next_unused(service->data->pending, in coap_service_send() local
548 if (pending == NULL) { in coap_service_send()
553 ret = coap_pending_init(pending, cpkt, addr, params); in coap_service_send()
560 pending->data = coap_server_alloc(pending->len); in coap_service_send()
561 if (pending->data == NULL) { in coap_service_send()
563 coap_pending_clear(pending); in coap_service_send()
566 memcpy(pending->data, cpkt->data, pending->len); in coap_service_send()
568 coap_pending_cycle(pending); in coap_service_send()