Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 25 of 207) sorted by relevance

123456789

/subsys/bluetooth/host/
A Dconn.c439 bt_l2cap_recv(conn, conn->rx, false); in bt_acl_recv()
851 if (!conn->has_data(conn)) { in should_stop_tx()
985 if (conn->has_data(conn) && (conn->state == BT_CONN_CONNECTED)) { in get_conn_ready()
1061 buf = conn->tx_data_pull(conn, conn_mtu(conn), &buf_len); in bt_conn_tx_processor()
1079 conn->get_and_clear_cb(conn, buf, &cb, &ud); in bt_conn_tx_processor()
1908 callback->connected(conn, conn->err); in notify_connected()
1914 cb->connected(conn, conn->err); in notify_connected()
1923 callback->disconnected(conn, conn->err); in notify_disconnected()
1929 cb->disconnected(conn, conn->err); in notify_disconnected()
2018 cb->le_phy_updated(conn, &conn->le.phy); in notify_le_phy_updated()
[all …]
/subsys/net/ip/
A Dtcp.c451 conn, step, conn->ca.cwnd, conn->ca.ssthresh, in tcp_new_reno_log()
468 conn->ca.cwnd = conn_mss(conn) * 3 + conn->ca.ssthresh; in tcp_new_reno_fast_retransmit()
476 conn->ca.ssthresh = MAX(conn_mss(conn) * 2, conn->unacked_len / 2); in tcp_new_reno_timeout()
477 conn->ca.cwnd = conn_mss(conn); in tcp_new_reno_timeout()
566 conn->keep_idle, conn->keep_intvl, conn->keep_cnt); in keep_alive_timer_init()
762 conn->test_closed_cb(conn, conn->test_user_data); in tcp_conn_release()
976 conn->seq, conn->ack); in tcp_conn_state()
2080 memset(conn, 0, sizeof(*conn)); in tcp_conn_alloc()
3400 conn, conn->seq, conn->ack); in tcp_in()
3496 conn, conn->seq, conn->ack); in tcp_in()
[all …]
A Dconnection.c105 conn, conn->proto, conn->family, conn->flags, in conn_register_debug()
108 src, local_port, conn->cb, conn->user_data); in conn_register_debug()
146 (void)memset(conn, 0, sizeof(*conn)); in conn_set_unused()
261 return conn; in conn_find_handler()
272 conn - conns, conn); in net_conn_change_callback()
283 conn - conns, conn); in net_conn_change_remote()
330 conn - conns, conn); in net_conn_change_local()
622 conn->cb, conn->user_data); in conn_raw_socket_deliver()
630 if (conn->cb(conn, raw_pkt, NULL, NULL, conn->user_data) == NET_DROP) { in conn_raw_socket_deliver()
949 !conn->v6only && conn->type != SOCK_RAW)) { in net_conn_input()
[all …]
/subsys/bluetooth/controller/ll_sw/
A Dull_llcp_local.c90 lr_dequeue(conn); in llcp_lr_check_done()
217 conn->llcp.local.prt_expire = conn->llcp.prt_reload; in llcp_lr_prt_restart()
235 ctx = lr_dequeue(conn); in llcp_lr_flush_procedures()
239 ctx = lr_dequeue(conn); in llcp_lr_flush_procedures()
493 llcp_lr_prt_stop(conn); in lr_act_complete()
513 lr_act_connect(conn); in lr_st_disconnect()
535 lr_act_run(conn); in lr_st_idle()
551 lr_act_complete(conn); in lr_st_idle()
564 lr_act_run(conn); in lr_st_active()
568 lr_act_complete(conn); in lr_st_active()
[all …]
A Dull_llcp_remote.c128 rr_dequeue(conn); in llcp_rr_check_done()
216 conn->llcp.remote.prt_expire = conn->llcp.prt_reload; in llcp_rr_prt_restart()
494 if (conn->llcp.fex.valid && feature_ext_rej_ind(conn)) { in rr_tx()
520 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rr_act_reject()
536 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rr_act_unsupported()
608 rr_act_run(conn); in rr_st_idle()
633 rr_act_run(conn); in rr_st_idle()
657 rr_act_run(conn); in rr_st_idle()
705 rr_act_reject(conn); in rr_st_reject()
718 rr_act_run(conn); in rr_st_active()
[all …]
A Dull_llcp_common.c288 llcp_lr_complete(conn); in lp_comm_complete_cte_req_finalize()
314 lp_comm_ntf(conn, ctx); in lp_comm_ntf_cte_req_tx()
446 llcp_lr_complete(conn); in lp_comm_terminate_invalid_pdu()
601 if (extra_cond || llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_comm_tx_proxy()
656 lp_comm_tx_proxy(conn, ctx, !lp_cis_terminated(conn));
661 if (feature_dle(conn) && !ull_cp_remote_dle_pending(conn)) {
662 if (llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) {
804 ull_dle_max_time_get(conn, &conn->lll.dle.local.max_rx_time,
984 ull_dle_max_time_get(conn, &conn->lll.dle.local.max_rx_time,
1173 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) {
[all …]
A Dull_llcp_features.h9 conn->llcp.fex.features_used &= ~ll_feat_mask; in feature_unmask_features()
14 conn->llcp.fex.features_peer &= ~ll_feat_mask; in feature_unmask_peer_features()
17 static inline bool feature_le_encryption(struct ll_conn *conn) in feature_le_encryption() argument
35 static inline bool feature_ext_rej_ind(struct ll_conn *conn) in feature_ext_rej_ind() argument
53 static inline bool feature_le_ping(struct ll_conn *conn) in feature_le_ping() argument
62 static inline bool feature_dle(struct ll_conn *conn) in feature_dle() argument
71 static inline bool feature_privacy(struct ll_conn *conn) in feature_privacy() argument
80 static inline bool feature_ext_scan(struct ll_conn *conn) in feature_ext_scan() argument
107 static inline bool feature_phy_2m(struct ll_conn *conn) in feature_phy_2m() argument
125 static inline bool feature_cte_req(struct ll_conn *conn) in feature_cte_req() argument
[all …]
A Dull_llcp.h21 void ull_llcp_init(struct ll_conn *conn);
28 void ull_cp_release_nodes(struct ll_conn *conn);
33 void ull_cp_update_tx_buffer_queue(struct ll_conn *conn);
53 void ull_cp_run(struct ll_conn *conn);
63 void ull_cp_tx_ntf(struct ll_conn *conn);
74 uint8_t ull_cp_le_ping(struct ll_conn *conn);
80 uint8_t ull_cp_version_exchange(struct ll_conn *conn);
205 bool ull_cp_cc_cancel(struct ll_conn *conn);
231 bool ull_lp_cc_is_active(struct ll_conn *conn);
236 bool ull_lp_cc_is_enqueued(struct ll_conn *conn);
[all …]
A Dull_llcp_enc.c156 memcpy(&conn->lll.ccm_tx.key[0], &conn->lll.ccm_rx.key[0], sizeof(conn->lll.ccm_tx.key)); in enc_setup_lll()
159 memcpy(&conn->lll.ccm_tx.iv[0], &conn->lll.ccm_rx.iv[0], sizeof(conn->lll.ccm_tx.iv)); in enc_setup_lll()
256 lp_enc_ntf(conn, ctx); in lp_enc_complete()
257 llcp_lr_complete(conn); in lp_enc_complete()
287 llcp_rr_pause(conn); in lp_enc_send_enc_req()
318 conn->lll.enc_tx = 0U; in lp_enc_send_pause_enc_rsp()
430 llcp_rr_resume(conn); in lp_enc_st_wait_rx_enc_rsp()
460 llcp_rr_resume(conn); in lp_enc_st_wait_rx_start_enc_req()
498 llcp_rr_resume(conn); in lp_enc_st_wait_rx_start_enc_rsp()
727 if (conn->llcp.fex.valid && feature_ext_rej_ind(conn)) { in llcp_rp_enc_tx()
[all …]
A Dull_llcp_conn_upd.c349 !(conn->lll.role && ull_cp_remote_cpr_pending(conn))) { in lp_cu_complete()
360 cu_ntf(conn, ctx); in lp_cu_ntf_complete()
368 if (llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_cu_send_reject_ext_ind()
380 if (cpr_active_is_set(conn) || llcp_lr_ispaused(conn) || in lp_cu_send_conn_param_req()
381 llcp_rr_get_collision(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_cu_send_conn_param_req()
441 if (llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_cu_send_conn_update_ind()
918 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rp_cu_send_conn_update_ind()
952 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rp_cu_send_reject_ext_ind()
963 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rp_cu_send_conn_param_rsp()
987 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rp_cu_send_unknown_rsp()
[all …]
A Dull_llcp_phy.c189 pu_set_timing_restrict(conn, conn->lll.phy_tx); in pu_reset_timing_restrict()
365 ctx->data.pu.instant = ull_conn_event_counter(conn) + conn->lll.latency + in pu_prepare_instant()
505 pu_ntf(conn, ctx); in lp_pu_tx_ntf()
526 if (llcp_lr_ispaused(conn) || llcp_rr_get_collision(conn) || in lp_pu_send_phy_req()
545 if (llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_pu_send_phy_update_ind()
642 conn, pu_select_phy_timing_restrict(conn, ctx->data.pu.tx)); in lp_pu_st_wait_tx_ack_phy_req()
1001 pu_ntf(conn, ctx); in rp_pu_tx_ntf()
1012 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx) || in rp_pu_send_phy_update_ind()
1029 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx) || in rp_pu_send_phy_rsp()
1058 pu_combine_phys(conn, ctx, conn->phy_pref_tx, conn->phy_pref_rx); in rp_pu_st_wait_rx_phy_req()
[all …]
A Dull_conn.c198 if ((conn == NULL) || (conn->lll.handle != handle)) { in ll_connected_get()
202 return conn; in ll_connected_get()
232 if (!conn) { in ll_tx_mem_enqueue()
726 *apto = conn->apto_reload * conn->lll.interval * in ll_apto_get()
1050 conn->appto_expire = conn->appto_reload; in ull_conn_done()
1051 conn->apto_expire = conn->apto_reload; in ull_conn_done()
1059 conn->appto_expire = conn->apto_expire = 0U; in ull_conn_done()
1865 conn, &conn->lll); in disable()
2193 return conn->lll.event_counter + conn->lll.latency_prepare + conn->llcp.prep.lazy; in ull_conn_event_counter_at_prepare()
2265 conn, ticker_start_conn_op_cb, (void *)conn); in ull_conn_update_ticker()
[all …]
A Dull_llcp_chmu.c91 tx = llcp_tx_alloc(conn, ctx); in lp_chmu_tx()
102 llcp_tx_enqueue(conn, tx); in lp_chmu_tx()
108 llcp_lr_complete(conn); in lp_chmu_complete()
115 if (llcp_lr_ispaused(conn) || llcp_rr_get_collision(conn) || in lp_chmu_send_channel_map_update_ind()
116 !llcp_tx_alloc_peek(conn, ctx)) { in lp_chmu_send_channel_map_update_ind()
121 ctx->data.chmu.instant = ull_conn_event_counter(conn) + conn->lll.latency + in lp_chmu_send_channel_map_update_ind()
124 lp_chmu_tx(conn, ctx); in lp_chmu_send_channel_map_update_ind()
196 llcp_lr_complete(conn); in llcp_lp_chmu_rx()
220 llcp_rr_complete(conn); in rp_chmu_complete()
248 llcp_rr_complete(conn); in rp_chmu_st_wait_rx_channel_map_update_ind()
[all …]
A Dull_llcp_cc.c194 llcp_tx_enqueue(conn, tx); in llcp_rp_cc_tx_rsp()
214 llcp_tx_enqueue(conn, tx); in llcp_rp_cc_tx_reject()
240 llcp_rr_complete(conn); in rp_cc_complete()
247 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rp_cc_send_cis_rsp()
261 if (llcp_rr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in rp_cc_send_reject_ind()
287 llcp_rr_complete(conn); in rp_cc_send_reject_ind()
682 llcp_rr_complete(conn); in llcp_rp_cc_rx()
824 if (llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_cc_offset_calc_req()
883 if (llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_cc_send_cis_req()
909 llcp_lr_complete(conn); in lp_cc_complete()
[all …]
A Dull_llcp_past.c104 llcp_rr_complete(conn); in rp_past_complete()
131 ctx = llcp_rr_peek(conn); in rp_past_resolve_cb()
173 rp_past_resolve_conn = conn; in rp_past_addr_resolve()
213 rp_past_complete(conn, ctx); in rp_past_st_wait_rx()
261 rp_past_complete(conn, ctx); in rp_past_st_wait_rx()
298 rp_past_complete(conn, ctx); in rp_past_st_wait_next_evt()
379 llcp_lr_complete(conn); in lp_past_complete()
411 llcp_tx_enqueue(conn, tx); in lp_past_tx()
426 if (llcp_lr_ispaused(conn) || !llcp_tx_alloc_peek(conn, ctx)) { in lp_past_offset_calc_req()
458 lp_past_tx(conn, ctx); in lp_past_st_wait_offset_calc()
[all …]
A Dull_llcp_internal.h448 bool llcp_ntf_pending(struct ll_conn *conn);
568 void llcp_lr_pause(struct ll_conn *conn);
569 void llcp_lr_resume(struct ll_conn *conn);
575 void llcp_lr_init(struct ll_conn *conn);
576 void llcp_lr_run(struct ll_conn *conn);
578 void llcp_lr_connect(struct ll_conn *conn);
592 void llcp_rr_pause(struct ll_conn *conn);
593 void llcp_rr_resume(struct ll_conn *conn);
598 void llcp_rr_init(struct ll_conn *conn);
600 void llcp_rr_run(struct ll_conn *conn);
[all …]
A Dull_llcp.c222 ARG_UNUSED(conn); in llcp_tx_alloc_peek()
237 ARG_UNUSED(conn); in llcp_tx_alloc()
412 llcp_lr_init(conn); in ull_llcp_init()
432 memset(&conn->llcp.vex, 0, sizeof(conn->llcp.vex)); in ull_llcp_init()
436 memset(&conn->llcp.muc, 0, sizeof(conn->llcp.muc)); in ull_llcp_init()
440 memset(&conn->llcp.fex, 0, sizeof(conn->llcp.fex)); in ull_llcp_init()
474 if (conn) { in ull_cp_release_tx()
482 ARG_UNUSED(conn); in ull_cp_release_tx()
547 llcp_rr_run(conn); in ull_cp_run()
548 llcp_lr_run(conn); in ull_cp_run()
[all …]
A Dull_conn_internal.h8 void ll_conn_release(struct ll_conn *conn);
9 uint16_t ll_conn_handle_get(struct ll_conn *conn);
42 uint8_t ull_conn_llcp_req(void *conn);
56 conn_upd_curr = conn; in cpr_active_check_and_set()
62 conn_upd_curr = conn; in cpr_active_set()
67 return conn_upd_curr && (conn_upd_curr != conn); in cpr_active_is_set()
72 if (conn == conn_upd_curr) { in cpr_active_check_and_reset()
95 void ull_conn_update_peer_sca(struct ll_conn *conn);
108 uint8_t ull_dle_update_eff(struct ll_conn *conn);
131 void ull_conn_pause_rx_data(struct ll_conn *conn);
[all …]
/subsys/bluetooth/host/classic/
A Dssp.c255 conn->br.pairing_method = ssp_pair_method(conn); in ssp_auth()
443 if (!conn) { in bt_hci_pin_code_req()
458 if (!conn) { in bt_hci_link_key_notify()
580 if (!conn) { in bt_hci_link_key_req()
651 if (!conn) { in bt_hci_io_capa_resp()
698 if (!conn) { in bt_hci_io_capa_req()
795 if (!conn) { in bt_hci_ssp_complete()
819 if (!conn) { in bt_hci_user_confirm_req()
836 if (!conn) { in bt_hci_user_passkey_notify()
851 if (!conn) { in bt_hci_user_passkey_req()
[all …]
A Dconn_br.c56 struct bt_conn *conn; in bt_conn_create_br() local
60 if (conn) { in bt_conn_create_br()
64 return conn; in bt_conn_create_br()
72 if (!conn) { in bt_conn_create_br()
78 bt_conn_unref(conn); in bt_conn_create_br()
93 bt_conn_unref(conn); in bt_conn_create_br()
100 return conn; in bt_conn_create_br()
134 if (conn == NULL) { in bt_conn_get_dst_br()
140 LOG_DBG("Invalid connection type: %u for %p", conn->type, conn); in bt_conn_get_dst_br()
185 LOG_DBG("Invalid connection type: %u for %p", conn->type, conn); in bt_conn_br_switch_role()
[all …]
/subsys/sensing/
A Dsensor_mgmt.c57 sensor->dev->name, conn, conn->interval); in arbitrate_interval()
273 conn->sink = sink; in init_connection()
277 memset(conn->sensitivity, 0x00, sizeof(conn->sensitivity)); in init_connection()
279 sys_slist_append(&conn->source->client_list, &conn->snode); in init_connection()
309 conn->source->dev->name, sensor->dev->name, i, conn); in init_sensor()
363 *conn = tmp_conn; in open_sensor()
385 free(*conn); in close_sensor()
386 *conn = NULL; in close_sensor()
426 conn->source->dev->name, conn, interval); in set_interval()
485 if (conn->sensitivity[i] != conn->sensitivity[0]) { in get_sensitivity()
[all …]
/subsys/net/lib/shell/
A Dconn.c96 conn->local_addr.sa_family); in conn_handler_cb()
100 (*count) + 1, conn, conn->cb, in conn_handler_cb()
101 net_proto2str(conn->local_addr.sa_family, conn->proto), in conn_handler_cb()
125 conn, conn->context, in tcp_cb()
128 conn->seq, conn->ack, recv_mss, in tcp_cb()
143 if (conn->state != TCP_LISTEN) { in tcp_sent_list_cb()
151 atomic_get(&conn->ref_count), conn->recv_win, conn->send_win, in tcp_sent_list_cb()
152 conn->send_data_total, conn->unacked_len, in tcp_sent_list_cb()
153 conn->data_mode == TCP_DATA_MODE_RESEND ? 1 : 0, conn->in_connect, in tcp_sent_list_cb()
154 conn->in_close, sys_slist_is_empty(&conn->send_queue) ? "empty" : "data"); in tcp_sent_list_cb()
[all …]
/subsys/bluetooth/audio/
A Dtbs_client.c125 __ASSERT_NO_MSG(conn); in tbs_index()
291 current_calls_changed(conn, 0, tbs_index(conn, inst), cnt, calls); in bearer_list_current_calls()
393 provider_name_changed(conn, 0, tbs_index(conn, tbs_inst), name); in provider_name_notify_handler()
422 technology_changed(conn, 0, tbs_index(conn, tbs_inst), technology); in technology_notify_handler()
499 status_flags_changed(conn, 0, tbs_index(conn, tbs_inst), status_flags); in status_flags_notify_handler()
526 call_uri_changed(conn, 0, tbs_index(conn, tbs_inst), uri); in incoming_uri_notify_handler()
577 call_state_changed(conn, 0, tbs_index(conn, tbs_inst), cnt, call_states); in call_state_notify_handler()
627 terminate_reason_changed(conn, 0, tbs_index(conn, tbs_inst), reason); in termination_reason_notify_handler()
653 remote_uri_changed(conn, 0, tbs_index(conn, tbs_inst), uri); in in_call_notify_handler()
679 friendly_name_changed(conn, 0, tbs_index(conn, tbs_inst), name); in friendly_name_notify_handler()
[all …]
/subsys/bluetooth/mesh/
A Dpb_gatt.c31 struct bt_conn *conn; member
42 if (link.conn) { in reset_state()
44 link.conn = NULL; in reset_state()
70 if (link.conn) { in protocol_timeout()
87 if (link.conn != conn || !link.cb) { in bt_mesh_pb_gatt_recv()
108 if (link.conn) { in bt_mesh_pb_gatt_start()
112 link.conn = bt_conn_ref(conn); in bt_mesh_pb_gatt_start()
124 if (link.conn != conn) { in bt_mesh_pb_gatt_close()
139 if (link.conn) { in bt_mesh_pb_gatt_cli_start()
143 link.conn = bt_conn_ref(conn); in bt_mesh_pb_gatt_cli_start()
[all …]
/subsys/mgmt/mcumgr/transport/src/
A Dsmp_bt.c132 conn_data[i].conn = conn; in conn_param_data_alloc()
169 if (conn_data[i].conn == conn) { in conn_param_data_get()
283 ud->conn = NULL; in smp_bt_chr_write()
302 ud->conn = conn; in smp_bt_chr_write()
338 ud->conn = conn; in smp_bt_chr_write()
357 ud->conn = NULL; in smp_bt_ccc_changed()
395 if (!ud->conn) { in smp_bt_conn_from_pkt()
399 return ud->conn; in smp_bt_conn_from_pkt()
438 dst_ud->conn = src_ud->conn; in smp_bt_ud_copy()
607 cpd->conn = NULL; in disconnected()
[all …]

Completed in 161 milliseconds

123456789