Home
last modified time | relevance | path

Searched refs:rx (Results 1 – 25 of 143) sorted by relevance

123456

/subsys/bluetooth/mesh/
A Dtransport.c727 rx->len - (i * seg_len(rx->ctl)))); in seg_rx_assemble()
1156 rx->block != BLOCK_COMPLETE(rx->seg_n)) { in seg_rx_reset()
1158 bt_mesh_friend_clear_incomplete(rx->sub, rx->src, rx->dst, in seg_rx_reset()
1204 if (!rx->in_use || rx->block == BLOCK_COMPLETE(rx->seg_n)) { in seg_ack()
1216 send_ack(rx->sub, rx->dst, rx->src, rx->ttl, &rx->seq_auth, in seg_ack()
1217 rx->block, rx->obo); in seg_ack()
1276 if (rx->hdr != *hdr || rx->seg_n != seg_n) { in seg_rx_is_valid()
1426 seq_auth, rx->block, rx->obo); in trans_seg()
1630 rx->seq, rx->friend_match); in bt_mesh_trans_recv()
1638 bt_mesh_test_net_recv(rx->ctx.recv_ttl, rx->ctl, rx->ctx.addr, rx->ctx.recv_dst, in bt_mesh_trans_recv()
[all …]
A Dpb_adv.c90 } rx; member
491 if (!link.rx.seg && link.rx.id == rx->xact_id) { in gen_prov_cont()
512 link.rx.id = rx->xact_id; in gen_prov_cont()
520 } else if (rx->xact_id != link.rx.id) { in gen_prov_cont()
589 if (rx->xact_id == link.rx.id && !link.rx.seg) { in gen_prov_start()
606 if (rx->xact_id == link.rx.id) { in gen_prov_start()
619 link.rx.id = rx->xact_id; in gen_prov_start()
623 link.rx.buf->len, link.rx.fcs); in gen_prov_start()
631 if (link.rx.buf->len > link.rx.buf->size) { in gen_prov_start()
652 link.rx.last_seg = START_LAST_SEG(rx->gpc); in gen_prov_start()
[all …]
A Dnet.c695 if (rx->net_if == BT_MESH_NET_IF_ADV && !rx->friend_cred && !bridge && in bt_mesh_net_relay()
702 LOG_DBG("TTL %u CTL %u dst 0x%04x", rx->ctx.recv_ttl, rx->ctl, rx->ctx.recv_dst); in bt_mesh_net_relay()
708 if (rx->net_if == BT_MESH_NET_IF_ADV && !rx->friend_cred && !bridge) { in bt_mesh_net_relay()
727 cred = &rx->sub->keys[SUBNET_KEY_TX_IDX(rx->sub)].msg; in bt_mesh_net_relay()
757 if (relay_to_adv(rx->net_if) || rx->friend_cred || bridge) { in bt_mesh_net_relay()
856 LOG_DBG("src 0x%04x dst 0x%04x ttl %u", rx->ctx.addr, rx->ctx.recv_dst, rx->ctx.recv_ttl); in bt_mesh_net_decode()
859 msg_cache_add(rx); in bt_mesh_net_decode()
889 rx.local_match = (bt_mesh_fixed_group_match(rx.ctx.recv_dst) || in bt_mesh_net_recv()
927 (!rx.local_match && !rx.friend_match)) { in bt_mesh_net_recv()
936 .rx = &rx, in bt_mesh_net_recv()
[all …]
A Dsar_cfg.c30 const struct bt_mesh_sar_rx *rx) in bt_mesh_sar_rx_encode() argument
32 net_buf_simple_add_u8(buf, (rx->seg_thresh & 0x1f) | in bt_mesh_sar_rx_encode()
33 (rx->ack_delay_inc << 5)); in bt_mesh_sar_rx_encode()
34 net_buf_simple_add_u8(buf, (rx->discard_timeout & 0xf) | in bt_mesh_sar_rx_encode()
35 ((rx->rx_seg_int_step & 0xf) << 4)); in bt_mesh_sar_rx_encode()
58 struct bt_mesh_sar_rx *rx) in bt_mesh_sar_rx_decode() argument
63 rx->seg_thresh = (val & 0x1f); in bt_mesh_sar_rx_decode()
64 rx->ack_delay_inc = (val >> 5); in bt_mesh_sar_rx_decode()
66 rx->discard_timeout = (val & 0xf); in bt_mesh_sar_rx_decode()
67 rx->rx_seg_int_step = (val >> 4); in bt_mesh_sar_rx_decode()
[all …]
A Dfriend.h21 void bt_mesh_friend_enqueue_rx(struct bt_mesh_net_rx *rx,
37 int bt_mesh_friend_poll(struct bt_mesh_net_rx *rx, struct net_buf_simple *buf);
38 int bt_mesh_friend_req(struct bt_mesh_net_rx *rx, struct net_buf_simple *buf);
39 int bt_mesh_friend_clear(struct bt_mesh_net_rx *rx, struct net_buf_simple *buf);
40 int bt_mesh_friend_clear_cfm(struct bt_mesh_net_rx *rx,
42 int bt_mesh_friend_sub_add(struct bt_mesh_net_rx *rx,
44 int bt_mesh_friend_sub_rem(struct bt_mesh_net_rx *rx,
A Dlpn.h7 int bt_mesh_lpn_friend_update(struct bt_mesh_net_rx *rx,
9 int bt_mesh_lpn_friend_offer(struct bt_mesh_net_rx *rx,
11 int bt_mesh_lpn_friend_clear_cfm(struct bt_mesh_net_rx *rx,
13 int bt_mesh_lpn_friend_sub_cfm(struct bt_mesh_net_rx *rx,
45 void bt_mesh_lpn_msg_received(struct bt_mesh_net_rx *rx);
A Drpl.c86 struct bt_mesh_net_rx *rx) in bt_mesh_rpl_update() argument
91 if (rpl->old_iv && !rx->old_iv) { in bt_mesh_rpl_update()
95 rpl->src = rx->ctx.addr; in bt_mesh_rpl_update()
96 rpl->seq = rx->seq; in bt_mesh_rpl_update()
97 rpl->old_iv = rx->old_iv; in bt_mesh_rpl_update()
121 if (!rx->local_match && !bridge) { in bt_mesh_rpl_check()
134 if (rpl->src == rx->ctx.addr) { in bt_mesh_rpl_check()
146 if (rx->old_iv && !rpl->old_iv) { in bt_mesh_rpl_check()
150 if ((!rx->old_iv && rpl->old_iv) || in bt_mesh_rpl_check()
151 rpl->seq < rx->seq) { in bt_mesh_rpl_check()
[all …]
A Dsar_cfg_srv.c70 const struct bt_mesh_sar_rx *rx = &bt_mesh.sar_rx; in receiver_status() local
72 LOG_DBG("SAR RX {0x%02x 0x%02x 0x%02x 0x%02x 0x%02x}", rx->seg_thresh, in receiver_status()
73 rx->ack_delay_inc, rx->discard_timeout, rx->rx_seg_int_step, in receiver_status()
74 rx->ack_retrans_count); in receiver_status()
77 bt_mesh_sar_rx_encode(&msg, rx); in receiver_status()
124 struct bt_mesh_sar_rx *rx = &bt_mesh.sar_rx; in receiver_set() local
128 bt_mesh_sar_rx_decode(buf, rx); in receiver_set()
A Dfriend.c255 .sub = rx->sub, in bt_mesh_friend_clear()
256 .ctx = &rx->ctx, in bt_mesh_friend_clear()
635 frnd = bt_mesh_friend_find(rx->sub->net_idx, rx->ctx.addr, true, true); in bt_mesh_friend_sub_add()
670 frnd = bt_mesh_friend_find(rx->sub->net_idx, rx->ctx.addr, true, true); in bt_mesh_friend_sub_rem()
723 frnd = bt_mesh_friend_find(rx->sub->net_idx, rx->ctx.addr, true, false); in bt_mesh_friend_poll()
1025 frnd = bt_mesh_friend_find(rx->sub->net_idx, rx->ctx.addr, true, false); in bt_mesh_friend_req()
1459 info.ctl = rx->ctl; in friend_lpn_enqueue_rx()
1657 if ((src == rx.ctx.addr) && (seq == rx.seq)) { in friend_queue_check_dup()
1705 (rx->ctx.recv_ttl <= 1U && rx->net_if != BT_MESH_NET_IF_LOCAL) || in bt_mesh_friend_enqueue_rx()
1711 rx->sub->net_idx, rx->ctx.addr, rx->ctx.recv_dst); in bt_mesh_friend_enqueue_rx()
[all …]
A Dsubnet.c903 rx->new_key = (j > 0); in bt_mesh_net_cred_find()
904 rx->friend_cred = 1U; in bt_mesh_net_cred_find()
905 rx->ctx.net_idx = rx->sub->net_idx; in bt_mesh_net_cred_find()
926 rx->sub = frnd->subnet; in bt_mesh_net_cred_find()
934 rx->new_key = (j > 0); in bt_mesh_net_cred_find()
935 rx->friend_cred = 1U; in bt_mesh_net_cred_find()
936 rx->ctx.net_idx = rx->sub->net_idx; in bt_mesh_net_cred_find()
944 rx->sub = &subnets[i]; in bt_mesh_net_cred_find()
954 if (cb(rx, in, out, &rx->sub->keys[j].msg)) { in bt_mesh_net_cred_find()
956 rx->friend_cred = 0U; in bt_mesh_net_cred_find()
[all …]
/subsys/bluetooth/controller/ll_sw/nordic/lll/
A Dlll_peripheral_iso.c600 (cis_lll->rx.bn_curr <= cis_lll->rx.bn) && in isr_rx()
656 if ((cis_lll->rx.bn_curr > cis_lll->rx.bn) && in isr_rx()
658 cis_lll->rx.payload_count += cis_lll->rx.bn; in isr_rx()
1330 if ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) == in payload_count_flush()
1339 if (cis_lll->rx.bn_curr > cis_lll->rx.bn) { in payload_count_flush()
1361 if (((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.bn_curr) > in payload_count_rx_flush_or_txrx_inc()
1373 while ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) < in payload_count_rx_flush_or_txrx_inc()
1375 ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) == in payload_count_rx_flush_or_txrx_inc()
1380 if (cis_lll->rx.bn_curr > cis_lll->rx.bn) { in payload_count_rx_flush_or_txrx_inc()
1437 while ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) < in payload_count_lazy()
[all …]
A Dlll_central_iso.c255 (cis_lll->rx.bn_curr > cis_lll->rx.bn); in prepare_cb()
768 (cis_lll->rx.bn_curr <= cis_lll->rx.bn) && in isr_rx()
824 if ((cis_lll->rx.bn_curr > cis_lll->rx.bn) && in isr_rx()
1205 if ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) == in payload_count_flush()
1214 if (cis_lll->rx.bn_curr > cis_lll->rx.bn) { in payload_count_flush()
1264 if (((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.bn_curr) > in payload_count_flush_or_inc_on_close()
1276 while ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) < in payload_count_flush_or_inc_on_close()
1278 ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) == in payload_count_flush_or_inc_on_close()
1283 if (cis_lll->rx.bn_curr > cis_lll->rx.bn) { in payload_count_flush_or_inc_on_close()
1340 while ((((cis_lll->rx.payload_count / cis_lll->rx.bn) + cis_lll->rx.ft) < in payload_count_lazy_update()
[all …]
A Dlll_prof.c164 struct node_rx_pdu *rx; in lll_prof_send() local
168 if (rx) { in lll_prof_send()
178 if (!rx) { in lll_prof_reserve()
184 return rx; in lll_prof_reserve()
189 if (rx) { in lll_prof_reserve_send()
192 err = send(rx); in lll_prof_reserve_send()
196 ull_rx_put_sched(rx->hdr.link, rx); in lll_prof_reserve_send()
257 if (!rx) { in send()
259 if (!rx) { in send()
268 pdu = (void *)rx->pdu; in send()
[all …]
/subsys/bluetooth/host/classic/
A Dgoep.c62 goep->obex.rx.mtu = dlc->mtu; in goep_rfcomm_connected()
200 if (!goep->obex.rx.mtu) { in goep_rfcomm_accept()
201 goep->obex.rx.mtu = mtu; in goep_rfcomm_accept()
212 goep->obex.rx.mtu = mtu; in goep_rfcomm_accept()
277 if (!goep->obex.rx.mtu) { in bt_goep_transport_rfcomm_connect()
278 goep->obex.rx.mtu = mtu; in bt_goep_transport_rfcomm_connect()
289 goep->obex.rx.mtu = mtu; in bt_goep_transport_rfcomm_connect()
372 goep->obex.rx.mtu = goep->_transport.chan.rx.mtu; in goep_l2cap_connected()
376 goep->obex.rx.mopl = goep->_transport.chan.rx.mtu; in goep_l2cap_connected()
525 goep->_transport.chan.rx.mtu = goep->obex.rx.mtu; in goep_l2cap_accept()
[all …]
A Dl2cap_br.c300 if (br_chan->rx.cid > 0) { in l2cap_br_chan_alloc_cid()
310 br_chan->rx.cid = cid; in l2cap_br_chan_alloc_cid()
2083 br_chan->rx.mtu = MIN(br_chan->rx.mtu, BT_L2CAP_RX_MTU); in l2cap_br_check_chan_config()
2084 br_chan->rx.mps = br_chan->rx.mtu; in l2cap_br_check_chan_config()
2200 br_chan->rx.fcs = 0; in l2cap_br_check_chan_config()
2230 br_chan->rx.max_window = MIN(br_chan->rx.max_window, 0x3fff); in l2cap_br_check_chan_config()
2695 BR_CHAN(chan)->rx.mtu = MIN(BR_CHAN(chan)->rx.mtu, BT_L2CAP_RX_MTU); in l2cap_br_conn_req()
2774 BR_CHAN(chan)->rx.mtu); in l2cap_br_conf_rsp_opt_mtu()
2779 BR_CHAN(chan)->rx.mtu); in l2cap_br_conf_rsp_opt_mtu()
4778 if (!br_chan->rx.mtu) { in bt_l2cap_br_chan_connect()
[all …]
/subsys/bluetooth/controller/ll_sw/
A Dull_scan_aux.c145 ll_rx_put(rx->hdr.link, rx); in rx_release_put()
1400 if (rx) { in flush()
1403 ll_rx_put(rx->hdr.link, rx); in flush()
1409 if (rx) { in flush()
1442 LL_ASSERT(rx); in aux_sync_partial()
1445 ll_rx_put_sched(rx->hdr.link, rx); in aux_sync_partial()
1474 LL_ASSERT(rx); in aux_sync_incomplete()
2646 if (rx) { in flush()
2649 ll_rx_put(rx->hdr.link, rx); in flush()
2658 if (rx) { in flush()
[all …]
A Dull.c1076 *node_rx = rx; in ll_rx_get()
1451 rx = *node_rx; in ll_rx_mem_release()
1452 while (rx) { in ll_rx_mem_release()
1455 rx_free = rx; in ll_rx_mem_release()
1456 rx = rx->hdr.next; in ll_rx_mem_release()
1742 *node_rx = rx; in ll_rx_mem_release()
2493 if (!rx) { in rx_replenish()
2526 if (!rx) { in rx_replenish()
2942 if (rx && rx->type != NODE_RX_TYPE_RETAIN) { in rx_demux_rx()
3164 if (!rx) { in ull_rxfifo_alloc()
[all …]
A Dull_llcp_local.c244 struct node_rx_pdu *rx) in llcp_lr_rx() argument
256 if (!ctx->node_ref.rx) { in llcp_lr_rx()
258 ctx->node_ref.rx = rx; in llcp_lr_rx()
265 llcp_lp_comm_rx(conn, ctx, rx); in llcp_lr_rx()
269 llcp_lp_comm_rx(conn, ctx, rx); in llcp_lr_rx()
282 llcp_lp_enc_rx(conn, ctx, rx); in llcp_lr_rx()
287 llcp_lp_pu_rx(conn, ctx, rx); in llcp_lr_rx()
292 llcp_lp_cu_rx(conn, ctx, rx); in llcp_lr_rx()
319 llcp_lp_cc_rx(conn, ctx, rx); in llcp_lr_rx()
334 if (ctx->node_ref.rx && ctx->node_ref.rx->hdr.type != NODE_RX_TYPE_RETAIN) { in llcp_lr_rx()
[all …]
A Dull_llcp_remote.c238 struct node_rx_pdu *rx) in llcp_rr_rx() argument
241 if (!ctx->node_ref.rx) { in llcp_rr_rx()
243 ctx->node_ref.rx = rx; in llcp_rr_rx()
253 llcp_rp_comm_rx(conn, ctx, rx); in llcp_rr_rx()
270 llcp_rp_enc_rx(conn, ctx, rx); in llcp_rr_rx()
275 llcp_rp_pu_rx(conn, ctx, rx); in llcp_rr_rx()
280 llcp_rp_cu_rx(conn, ctx, rx); in llcp_rr_rx()
302 llcp_rp_cc_rx(conn, ctx, rx); in llcp_rr_rx()
327 if (ctx->node_ref.rx && ctx->node_ref.rx->hdr.type != NODE_RX_TYPE_RETAIN) { in llcp_rr_rx()
328 ctx->node_ref.rx = NULL; in llcp_rr_rx()
[all …]
A Dull_peripheral.c100 pdu_adv = (void *)rx->pdu;
123 link = rx->hdr.link;
302 ll_rx_put(link, rx);
305 rx = rx_csa;
306 link = rx->hdr.link;
328 ll_rx_put(link, rx);
334 link = rx->hdr.link;
340 rx->hdr.handle = handle;
648 ll_rx_put(link, rx);
651 rx = rx_csa;
[all …]
A Dull_sync_iso.c291 *rx = node_rx; in ll_big_sync_terminate()
716 struct node_rx_pdu *rx; in ull_sync_iso_estab_done() local
732 se = (void *)rx->pdu; in ull_sync_iso_estab_done()
743 ll_rx_put_sched(rx->hdr.link, rx); in ull_sync_iso_estab_done()
856 struct node_rx_pdu *rx; in ull_sync_iso_done_terminate() local
953 struct node_rx_pdu *rx; in timeout_cleanup() local
1097 struct node_rx_pdu *rx; in disabled_cb() local
1106 LL_ASSERT(rx->hdr.link); in disabled_cb()
1107 link = rx->hdr.link; in disabled_cb()
1108 rx->hdr.link = NULL; in disabled_cb()
[all …]
/subsys/shell/backends/
A Dshell_rpmsg.c19 struct shell_rpmsg_rx rx; in rpmsg_shell_cb() local
25 rx.data = data; in rpmsg_shell_cb()
26 rx.len = len; in rpmsg_shell_cb()
27 if (k_msgq_put(&sh_rpmsg->rx_q, &rx, K_NO_WAIT) != 0) { in rpmsg_shell_cb()
135 struct shell_rpmsg_rx *rx = &sh_rpmsg->rx_cur; in read() local
144 if (rx->data == NULL) { in read()
148 rx->data = NULL; in read()
152 __ASSERT_NO_MSG(rx->len > 0); in read()
156 __ASSERT_NO_MSG(rx->len > sh_rpmsg->rx_consumed); in read()
157 read_len = rx->len - sh_rpmsg->rx_consumed; in read()
[all …]
/subsys/bluetooth/controller/ll_sw/openisa/lll/
A Dlll_prof.c115 struct node_rx_pdu *rx; in lll_prof_send() local
118 rx = ull_pdu_rx_alloc_peek(3); in lll_prof_send()
119 if (rx) { in lll_prof_send()
125 rx->hdr.type = NODE_RX_TYPE_PROFILE; in lll_prof_send()
126 rx->hdr.handle = 0xFFFF; in lll_prof_send()
128 pdu = (void *)rx->pdu; in lll_prof_send()
137 ull_rx_put_sched(rx->hdr.link, rx); in lll_prof_send()
/subsys/net/lib/shell/
A Dmem.c102 struct k_mem_slab *rx, *tx; in cmd_net_mem() local
105 net_pkt_get_info(&rx, &tx, &rx_data, &tx_data); in cmd_net_mem()
119 PR("%p\t%d\t%u\t%u\tRX\n", rx, rx->info.num_blocks, in cmd_net_mem()
120 k_mem_slab_num_free_get(rx), rx->info.max_used); in cmd_net_mem()
126 rx, rx->info.num_blocks, k_mem_slab_num_free_get(rx)); in cmd_net_mem()
139 PR("%p\t%d\tRX\n", rx, rx->info.num_blocks); in cmd_net_mem()
/subsys/net/lib/mqtt/
A Dmqtt_decoder.c578 &param->prop.rx.has_maximum_qos, in connack_properties_decode()
608 &param->prop.rx.has_user_prop, in connack_properties_decode()
643 &param->prop.rx.has_auth_method, in connack_properties_decode()
648 &param->prop.rx.has_auth_data, in connack_properties_decode()
720 &param->prop.rx.has_topic_alias, in publish_properties_decode()
735 &param->prop.rx.has_user_prop, in publish_properties_decode()
886 &prop->rx.has_reason_string, in common_ack_properties_decode()
891 &prop->rx.has_user_prop, in common_ack_properties_decode()
1102 &param->prop.rx.has_user_prop, in disconnect_properties_decode()
1159 &param->prop.rx.has_auth_data, in auth_properties_decode()
[all …]

Completed in 766 milliseconds

123456