Lines Matching refs:pending

132 	struct coap_pending *pending;  in coap_server_process()  local
212 pending = coap_pending_received(&request, service->data->pending, MAX_PENDINGS); in coap_server_process()
213 if (pending) { in coap_server_process()
223 coap_server_free(pending->data); in coap_server_process()
224 coap_pending_clear(pending); in coap_server_process()
297 struct coap_pending *pending; in coap_server_retransmit() local
309 pending = coap_pending_next_to_expire(service->data->pending, MAX_PENDINGS); in coap_server_retransmit()
310 if (pending == NULL) { in coap_server_retransmit()
316 remaining = pending->t0 + pending->timeout - now; in coap_server_retransmit()
321 if (coap_pending_cycle(pending)) { in coap_server_retransmit()
322 ret = zsock_sendto(service->data->sock_fd, pending->data, pending->len, 0, in coap_server_retransmit()
323 &pending->addr, ADDRLEN(&pending->addr)); in coap_server_retransmit()
328 __ASSERT_NO_MSG(ret == pending->len); in coap_server_retransmit()
332 coap_service_remove_observer(service, NULL, &pending->addr, NULL, 0U); in coap_server_retransmit()
333 coap_server_free(pending->data); in coap_server_retransmit()
334 coap_pending_clear(pending); in coap_server_retransmit()
343 struct coap_pending *pending; in coap_server_poll_timeout() local
353 pending = coap_pending_next_to_expire(svc->data->pending, MAX_PENDINGS); in coap_server_poll_timeout()
354 if (pending == NULL) { in coap_server_poll_timeout()
358 remaining = pending->t0 + pending->timeout - now; in coap_server_poll_timeout()
584 struct coap_pending *pending = coap_pending_next_unused(service->data->pending, in coap_service_send() local
587 if (pending == NULL) { in coap_service_send()
592 ret = coap_pending_init(pending, cpkt, addr, params); in coap_service_send()
599 pending->data = coap_server_alloc(pending->len); in coap_service_send()
600 if (pending->data == NULL) { in coap_service_send()
602 coap_pending_clear(pending); in coap_service_send()
605 memcpy(pending->data, cpkt->data, pending->len); in coap_service_send()
607 coap_pending_cycle(pending); in coap_service_send()