Home
last modified time | relevance | path

Searched refs:pending (Results 1 – 25 of 31) sorted by relevance

12

/subsys/net/lib/coap/
A Dcoap_server.c214 if (pending) { in coap_server_process()
310 pending = coap_pending_next_to_expire(service->data->pending, MAX_PENDINGS); in coap_server_retransmit()
311 if (pending == NULL) { in coap_server_retransmit()
317 remaining = pending->t0 + pending->timeout - now; in coap_server_retransmit()
323 ret = zsock_sendto(service->data->sock_fd, pending->data, pending->len, 0, in coap_server_retransmit()
324 &pending->addr, ADDRLEN(&pending->addr)); in coap_server_retransmit()
354 pending = coap_pending_next_to_expire(svc->data->pending, MAX_PENDINGS); in coap_server_poll_timeout()
355 if (pending == NULL) { in coap_server_poll_timeout()
359 remaining = pending->t0 + pending->timeout - now; in coap_server_poll_timeout()
627 pending->data = coap_server_alloc(pending->len); in coap_service_send()
[all …]
A Dcoap_client.c84 request->pending.timeout = 0; in release_internal_request()
108 if (internal_req->pending.t0 == 0) { in exchange_lifetime_exceeded()
435 internal_req->pending.retries = 0; in coap_client_req()
437 coap_pending_cycle(&internal_req->pending); in coap_client_req()
475 if (internal_req->pending.timeout == 0) { in timeout_expired()
480 internal_req->pending.timeout <= (k_uptime_get() - internal_req->pending.t0)); in timeout_expired()
492 internal_req->pending.timeout != 0 && in resend_request()
514 internal_req->pending = tmp; in resend_request()
814 internal_req->pending.retries = 0; in handle_response()
850 internal_req->pending.params; in handle_response()
[all …]
A Dcoap.c1607 memset(pending, 0, sizeof(*pending)); in coap_pending_init()
1614 pending->params = *params; in coap_pending_init()
1622 pending->retries = pending->params.max_retransmission; in coap_pending_init()
1755 if (pending->timeout == 0) { in coap_pending_cycle()
1757 pending->timeout = init_ack_timeout(&pending->params); in coap_pending_cycle()
1761 if (pending->retries == 0) { in coap_pending_cycle()
1765 pending->t0 += pending->timeout; in coap_pending_cycle()
1766 pending->timeout = pending->timeout * pending->params.coap_backoff_percent / 100; in coap_pending_cycle()
1767 pending->retries--; in coap_pending_cycle()
1774 pending->timeout = 0; in coap_pending_clear()
[all …]
A DKconfig60 This value is used as a base value to retry pending CoAP packets.
209 int "CoAP service pending messages"
212 Maximum number of pending CoAP messages to retransmit per active service.
225 bool "No pending packets"
227 Never allocate data for pending requests, this disables retransmits for confirmable
233 Static memory will be reserved for pending messages. The total size is equal to
240 Use k_malloc/k_free for pending data.
245 int "Number of pending data blocks"
249 The number of data blocks to reserve for pending messages to retransmit.
/subsys/jwt/
A Djwt.c84 if (st->pending < 1) { in base64_flush()
92 if (st->pending >= 2) { in base64_flush()
96 if (st->pending >= 3) { in base64_flush()
100 st->pending = 0; in base64_flush()
106 st->wip[st->pending++] = byte; in base64_addbyte()
107 if (st->pending == 3) { in base64_addbyte()
212 builder->pending = 0; in jwt_init_builder()
/subsys/net/ip/
A Dipv6_nbr.c354 struct net_pkt *pending; in ipv6_ns_reply_timeout() local
418 net_pkt_unref(pending); in ipv6_ns_reply_timeout()
2094 if (pending != NULL) { in net_ipv6_send_ns()
2097 pending = net_pkt_ref(pending); in net_ipv6_send_ns()
2114 pending)) { in net_ipv6_send_ns()
2116 pending, nbr); in net_ipv6_send_ns()
2118 pending = net_pkt_ref(pending); in net_ipv6_send_ns()
2122 pending, nbr); in net_ipv6_send_ns()
2138 pending = NULL; in net_ipv6_send_ns()
2153 if (pending != NULL) { in net_ipv6_send_ns()
[all …]
A Dutils.c574 size_t pending = len; in calc_chksum() local
587 if ((((uintptr_t)data & 0x01) != 0) && (pending >= 1)) { in calc_chksum()
590 pending--; in calc_chksum()
593 pending -= sizeof(uint16_t); in calc_chksum()
600 while (pending >= sizeof(uint32_t) * 4) { in calc_chksum()
604 pending -= sizeof(uint32_t) * 4; in calc_chksum()
610 while (pending >= sizeof(uint32_t)) { in calc_chksum()
611 pending -= sizeof(uint32_t); in calc_chksum()
615 if (pending >= 2) { in calc_chksum()
616 pending -= sizeof(uint16_t); in calc_chksum()
[all …]
A Dipv6.h134 int net_ipv6_send_ns(struct net_if *iface, struct net_pkt *pending,
/subsys/bluetooth/mesh/
A Dproxy_msg.c61 k_fifo_put(&role->pending, &(adv->gatt_bearer[bt_conn_index(role->conn)])); in proxy_queue_put()
68 gatt_bearer = k_fifo_get(&role->pending, K_NO_WAIT); in proxy_queue_get()
86 while (!k_fifo_is_empty(&role->pending)) { in proxy_sar_timeout()
294 if (!k_fifo_is_empty(&role->pending)) { in proxy_msg_send_pending()
316 k_fifo_init(&role->pending); in proxy_msg_init()
A Dlpn.c285 group_zero(lpn->pending); in clear_friendship()
415 group_zero(lpn->pending); in req_send_end()
761 atomic_test_bit(lpn->pending, i)) { in lpn_group_del()
831 atomic_set_bit(lpn->pending, i); in sub_update()
839 group_zero(lpn->pending); in sub_update()
847 group_zero(lpn->pending); in sub_update()
1009 group_set(lpn->added, lpn->pending); in bt_mesh_lpn_friend_sub_cfm()
1010 group_zero(lpn->pending); in bt_mesh_lpn_friend_sub_cfm()
1014 group_clear(lpn->added, lpn->pending); in bt_mesh_lpn_friend_sub_cfm()
1017 if (atomic_test_and_clear_bit(lpn->pending, i) && in bt_mesh_lpn_friend_sub_cfm()
A Dproxy_msg.h40 struct k_fifo pending; member
A Dblob_cli.c433 if (cli->tx.ctx.acked && cli->tx.pending) { in tx_complete()
447 cli->tx.pending = 0; in drop_remaining_targets()
527 cli->tx.pending = targets_reset(cli); in blob_cli_broadcast()
529 LOG_DBG("%u targets", cli->tx.pending); in blob_cli_broadcast()
553 LOG_DBG("0x%04x, pending: %d", target->addr, cli->tx.pending); in blob_cli_broadcast_rsp()
557 if (!--cli->tx.pending && !cli->tx.sending) { in blob_cli_broadcast_rsp()
A Dpb_adv.c451 bool pending = atomic_test_and_set_bit(link.flags, ADV_ACK_PENDING); in gen_prov_ack_send() local
456 if (pending && link.tx.pending_ack == xact_id) { in gen_prov_ack_send()
467 if (!pending) { in gen_prov_ack_send()
475 err = send_unacked(adv, pending ? NULL : ack_complete, NULL); in gen_prov_ack_send()
A Dnet.h177 ATOMIC_DEFINE(pending, LPN_GROUPS);
/subsys/net/l2/ethernet/
A Darp.c45 static void arp_entry_cleanup(struct arp_entry *entry, bool pending) in arp_entry_cleanup() argument
49 if (pending) { in arp_entry_cleanup()
257 struct net_pkt *pending, in arp_prepare() argument
268 pkt = pending; in arp_prepare()
278 if (IS_ENABLED(CONFIG_NET_CAPTURE) && pending) { in arp_prepare()
279 net_pkt_set_captured(pkt, net_pkt_is_captured(pending)); in arp_prepare()
282 if (IS_ENABLED(CONFIG_NET_VLAN) && pending) { in arp_prepare()
283 net_pkt_set_vlan_tag(pkt, net_pkt_vlan_tag(pending)); in arp_prepare()
301 net_pkt_ref(pending); in arp_prepare()
302 k_fifo_put(&entry->pending_queue, pending); in arp_prepare()
[all …]
/subsys/net/lib/lwm2m/
A Dlwm2m_message_handling.c519 if (!pending && !reply) { in find_msg()
525 if (pending != NULL && msg->pending == pending) { in find_msg()
535 if (pending != NULL && messages[i].ctx && messages[i].pending == pending) { in find_msg()
569 if (msg->pending) { in lm2m_message_clear_allocations()
571 msg->pending = NULL; in lm2m_message_clear_allocations()
675 if (!msg->pending) { in lwm2m_init_message()
2662 if (msg->pending) { in lwm2m_response_promote_to_con()
2670 if (!msg->pending) { in lwm2m_response_promote_to_con()
2746 struct coap_pending *pending; in lwm2m_udp_receive() local
2773 coap_pending_clear(pending); in lwm2m_udp_receive()
[all …]
A Dlwm2m_message_handling.h46 struct lwm2m_message *find_msg(struct coap_pending *pending, struct coap_reply *reply);
A Dlwm2m_engine.c247 msg->pending->t0 = k_uptime_get(); in lwm2m_push_queued_buffers()
756 coap_pending_cycle(msg->pending); in socket_send_message()
/subsys/shell/
A DKconfig.template.shell_log_queue_timeout8 If queue with pending log messages is full, oldest log message is
/subsys/mgmt/mcumgr/grp/img_mgmt_client/src/
A Dimg_mgmt_client.c54 bool bootable, pending, confirmed, active, permanent, ok; in image_state_res_fn() local
64 ZCBOR_MAP_DECODE_KEY_DECODER("pending", zcbor_bool_decode, &pending), in image_state_res_fn()
110 pending = false; in image_state_res_fn()
154 image_info->image_list[image_info->image_list_length].flags.pending = in image_state_res_fn()
155 pending; in image_state_res_fn()
/subsys/fs/
A Dfuse_fs_access_bottom.c49 bool pending; /* Is there a pending operation */ member
99 op_queue.pending = true; in queue_op()
108 return op_queue.pending; in ffa_is_op_pended()
181 op_queue.pending = false; in ffa_run_pending_op()
/subsys/bluetooth/controller/ticker/
A Dticker.c1949 uint8_t pending;
1954 pending = 0U;
2055 pending = 1U;
2061 return pending;
3233 uint8_t pending;
3305 pending = ticker_job_list_manage(instance, ticks_now, ticks_elapsed,
3347 if (!pending) {
3355 ARG_UNUSED(pending);
/subsys/bluetooth/host/classic/
A DKconfig148 int "Maximum number of pending TX buffers for RFCOMM"
152 Maximum number of pending TX buffers that have an associated
315 Maximum number of pending TX buffers that have an associated
/subsys/bluetooth/audio/
A Dtbs.c107 bool pending: 1; member
363 if (svc_insts[i].cp_ntf.pending && conn_index == svc_insts[i].cp_ntf.conn_index) { in disconnected()
981 if (inst->cp_ntf.pending && bt_conn_index(conn) == inst->cp_ntf.conn_index && in notify_handler_cb()
992 inst->cp_ntf.pending = false; in notify_handler_cb()
1718 if (inst->cp_ntf.pending) { in write_call_cp()
1857 inst->cp_ntf.pending = true; in write_call_cp()
/subsys/mgmt/mcumgr/grp/img_mgmt/
A DKconfig88 bool "Allow to erase pending slot"

Completed in 101 milliseconds

12