| /net/rds/ |
| D | connection.c | 71 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup() local
73 hlist_for_each_entry_rcu(conn, head, c_hash_node) { in rds_conn_lookup()
74 if (conn->c_faddr == faddr && conn->c_laddr == laddr && in rds_conn_lookup()
75 conn->c_trans == trans) { in rds_conn_lookup()
76 ret = conn; in rds_conn_lookup()
91 static void rds_conn_reset(struct rds_connection *conn) in rds_conn_reset() argument
94 &conn->c_laddr, &conn->c_faddr); in rds_conn_reset()
97 rds_send_reset(conn); in rds_conn_reset()
98 conn->c_flags = 0; in rds_conn_reset()
118 struct rds_connection *conn, *parent = NULL; in __rds_conn_create() local
[all …]
|
| D | threads.c | 74 void rds_connect_complete(struct rds_connection *conn) in rds_connect_complete() argument
76 if (!rds_conn_transition(conn, RDS_CONN_CONNECTING, RDS_CONN_UP)) { in rds_connect_complete()
80 atomic_read(&conn->c_state)); in rds_connect_complete()
81 atomic_set(&conn->c_state, RDS_CONN_ERROR); in rds_connect_complete()
82 queue_work(rds_wq, &conn->c_down_w); in rds_connect_complete()
87 conn, &conn->c_laddr, &conn->c_faddr); in rds_connect_complete()
89 conn->c_reconnect_jiffies = 0; in rds_connect_complete()
90 set_bit(0, &conn->c_map_queued); in rds_connect_complete()
91 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_connect_complete()
92 queue_delayed_work(rds_wq, &conn->c_recv_w, 0); in rds_connect_complete()
[all …]
|
| D | send.c | 64 void rds_send_reset(struct rds_connection *conn) in rds_send_reset() argument
69 if (conn->c_xmit_rm) { in rds_send_reset()
70 rm = conn->c_xmit_rm; in rds_send_reset()
71 conn->c_xmit_rm = NULL; in rds_send_reset()
80 conn->c_xmit_sg = 0; in rds_send_reset()
81 conn->c_xmit_hdr_off = 0; in rds_send_reset()
82 conn->c_xmit_data_off = 0; in rds_send_reset()
83 conn->c_xmit_atomic_sent = 0; in rds_send_reset()
84 conn->c_xmit_rdma_sent = 0; in rds_send_reset()
85 conn->c_xmit_data_sent = 0; in rds_send_reset()
[all …]
|
| D | ib_cm.c | 75 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol() argument
77 conn->c_version = version; in rds_ib_set_protocol()
83 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control() argument
85 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_set_flow_control()
90 rds_ib_send_add_credits(conn, credits); in rds_ib_set_flow_control()
125 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete() argument
128 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_connect_complete()
132 if (event->param.conn.private_data_len >= sizeof(*dp)) { in rds_ib_cm_connect_complete()
133 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete()
137 rds_ib_set_protocol(conn, in rds_ib_cm_connect_complete()
[all …]
|
| D | iw_cm.c | 45 static void rds_iw_set_protocol(struct rds_connection *conn, unsigned int version) in rds_iw_set_protocol() argument
47 conn->c_version = version; in rds_iw_set_protocol()
53 static void rds_iw_set_flow_control(struct rds_connection *conn, u32 credits) in rds_iw_set_flow_control() argument
55 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_set_flow_control()
60 rds_iw_send_add_credits(conn, credits); in rds_iw_set_flow_control()
70 void rds_iw_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_iw_cm_connect_complete() argument
73 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_cm_connect_complete()
77 if (event->param.conn.private_data_len) { in rds_iw_cm_connect_complete()
78 dp = event->param.conn.private_data; in rds_iw_cm_connect_complete()
80 rds_iw_set_protocol(conn, in rds_iw_cm_connect_complete()
[all …]
|
| D | loop.c | 60 static int rds_loop_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_loop_xmit() argument
70 rds_cong_map_updated(conn->c_fcong, ~(u64) 0); in rds_loop_xmit()
71 ret = min_t(int, ret, sgp->length - conn->c_xmit_data_off); in rds_loop_xmit()
77 rds_inc_init(&rm->m_inc, conn, conn->c_laddr); in rds_loop_xmit()
81 rds_recv_incoming(conn, conn->c_laddr, conn->c_faddr, &rm->m_inc, in rds_loop_xmit()
84 rds_send_drop_acked(conn, be64_to_cpu(rm->m_inc.i_hdr.h_sequence), in rds_loop_xmit()
103 static int rds_loop_recv(struct rds_connection *conn) in rds_loop_recv() argument
110 struct rds_connection *conn; member
119 static int rds_loop_conn_alloc(struct rds_connection *conn, gfp_t gfp) in rds_loop_conn_alloc() argument
129 lc->conn = conn; in rds_loop_conn_alloc()
[all …]
|
| D | tcp_recv.c | 125 static void rds_tcp_cong_recv(struct rds_connection *conn, in rds_tcp_cong_recv() argument
141 map = conn->c_fcong; in rds_tcp_cong_recv()
170 struct rds_connection *conn; member
178 struct rds_connection *conn = arg->conn; in rds_tcp_data_recv() local
179 struct rds_tcp_connection *tc = conn->c_transport_data; in rds_tcp_data_recv()
201 rds_inc_init(&tinc->ti_inc, conn, conn->c_faddr); in rds_tcp_data_recv()
253 rds_tcp_cong_recv(conn, tinc); in rds_tcp_data_recv()
255 rds_recv_incoming(conn, conn->c_faddr, in rds_tcp_data_recv()
256 conn->c_laddr, &tinc->ti_inc, in rds_tcp_data_recv()
274 static int rds_tcp_read_sock(struct rds_connection *conn, gfp_t gfp) in rds_tcp_read_sock() argument
[all …]
|
| D | tcp_connect.c | 43 struct rds_connection *conn; in rds_tcp_state_change() local
47 conn = sk->sk_user_data; in rds_tcp_state_change()
48 if (!conn) { in rds_tcp_state_change()
52 tc = conn->c_transport_data; in rds_tcp_state_change()
63 rds_connect_complete(conn); in rds_tcp_state_change()
66 rds_conn_drop(conn); in rds_tcp_state_change()
75 int rds_tcp_conn_connect(struct rds_connection *conn) in rds_tcp_conn_connect() argument
88 src.sin_addr.s_addr = (__force u32)conn->c_laddr; in rds_tcp_conn_connect()
94 ret, &conn->c_laddr); in rds_tcp_conn_connect()
99 dest.sin_addr.s_addr = (__force u32)conn->c_faddr; in rds_tcp_conn_connect()
[all …]
|
| D | iw_recv.c | 137 static int rds_iw_recv_refill_one(struct rds_connection *conn, in rds_iw_recv_refill_one() argument
141 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_recv_refill_one()
158 rds_inc_init(&recv->r_iwinc->ii_inc, conn, conn->c_faddr); in rds_iw_recv_refill_one()
224 int rds_iw_recv_refill(struct rds_connection *conn, gfp_t kptr_gfp, in rds_iw_recv_refill() argument
227 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_recv_refill()
234 while ((prefill || rds_conn_up(conn)) && in rds_iw_recv_refill()
244 ret = rds_iw_recv_refill_one(conn, recv, kptr_gfp, page_gfp); in rds_iw_recv_refill()
256 rds_iw_conn_error(conn, "recv post on " in rds_iw_recv_refill()
258 "reconnecting\n", &conn->c_faddr, in rds_iw_recv_refill()
269 rds_iw_advertise_credits(conn, posted); in rds_iw_recv_refill()
[all …]
|
| D | cong.c | 183 void rds_cong_add_conn(struct rds_connection *conn) in rds_cong_add_conn() argument
187 rdsdebug("conn %p now on map %p\n", conn, conn->c_lcong); in rds_cong_add_conn()
189 list_add_tail(&conn->c_map_item, &conn->c_lcong->m_conn_list); in rds_cong_add_conn()
193 void rds_cong_remove_conn(struct rds_connection *conn) in rds_cong_remove_conn() argument
197 rdsdebug("removing conn %p from map %p\n", conn, conn->c_lcong); in rds_cong_remove_conn()
199 list_del_init(&conn->c_map_item); in rds_cong_remove_conn()
203 int rds_cong_get_maps(struct rds_connection *conn) in rds_cong_get_maps() argument
205 conn->c_lcong = rds_cong_from_addr(conn->c_laddr); in rds_cong_get_maps()
206 conn->c_fcong = rds_cong_from_addr(conn->c_faddr); in rds_cong_get_maps()
208 if (!(conn->c_lcong && conn->c_fcong)) in rds_cong_get_maps()
[all …]
|
| D | rds.h | 423 int (*conn_alloc)(struct rds_connection *conn, gfp_t gfp);
425 int (*conn_connect)(struct rds_connection *conn);
426 void (*conn_shutdown)(struct rds_connection *conn);
427 void (*xmit_prepare)(struct rds_connection *conn);
428 void (*xmit_complete)(struct rds_connection *conn);
429 int (*xmit)(struct rds_connection *conn, struct rds_message *rm,
431 int (*xmit_rdma)(struct rds_connection *conn, struct rm_rdma_op *op);
432 int (*xmit_atomic)(struct rds_connection *conn, struct rm_atomic_op *op);
433 int (*recv)(struct rds_connection *conn);
441 void (*cm_connect_complete)(struct rds_connection *conn,
[all …]
|
| /net/bluetooth/ |
| D | hci_conn.c | 34 static void hci_le_create_connection(struct hci_conn *conn) in hci_le_create_connection() argument
36 struct hci_dev *hdev = conn->hdev; in hci_le_create_connection()
39 conn->state = BT_CONNECT; in hci_le_create_connection()
40 conn->out = true; in hci_le_create_connection()
41 conn->link_mode |= HCI_LM_MASTER; in hci_le_create_connection()
42 conn->sec_level = BT_SECURITY_LOW; in hci_le_create_connection()
47 bacpy(&cp.peer_addr, &conn->dst); in hci_le_create_connection()
48 cp.peer_addr_type = conn->dst_type; in hci_le_create_connection()
58 static void hci_le_create_connection_cancel(struct hci_conn *conn) in hci_le_create_connection_cancel() argument
60 hci_send_cmd(conn->hdev, HCI_OP_LE_CREATE_CONN_CANCEL, 0, NULL); in hci_le_create_connection_cancel()
[all …]
|
| D | smp.c | 152 static struct sk_buff *smp_build_cmd(struct l2cap_conn *conn, u8 code, in smp_build_cmd() argument
161 if (len > conn->mtu) in smp_build_cmd()
179 static void smp_send_cmd(struct l2cap_conn *conn, u8 code, u16 len, void *data) in smp_send_cmd() argument
181 struct sk_buff *skb = smp_build_cmd(conn, code, len, data); in smp_send_cmd()
189 hci_send_acl(conn->hchan, skb, 0); in smp_send_cmd()
191 cancel_delayed_work_sync(&conn->security_timer); in smp_send_cmd()
192 schedule_delayed_work(&conn->security_timer, SMP_TIMEOUT); in smp_send_cmd()
215 static void build_pairing_cmd(struct l2cap_conn *conn, in build_pairing_cmd() argument
222 if (test_bit(HCI_PAIRABLE, &conn->hcon->hdev->dev_flags)) { in build_pairing_cmd()
230 req->io_capability = conn->hcon->io_capability; in build_pairing_cmd()
[all …]
|
| D | hci_event.c | 96 struct hci_conn *conn; in hci_cc_role_discovery() local
105 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_role_discovery()
106 if (conn) { in hci_cc_role_discovery()
108 conn->link_mode &= ~HCI_LM_MASTER; in hci_cc_role_discovery()
110 conn->link_mode |= HCI_LM_MASTER; in hci_cc_role_discovery()
119 struct hci_conn *conn; in hci_cc_read_link_policy() local
128 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_read_link_policy()
129 if (conn) in hci_cc_read_link_policy()
130 conn->link_policy = __le16_to_cpu(rp->policy); in hci_cc_read_link_policy()
138 struct hci_conn *conn; in hci_cc_write_link_policy() local
[all …]
|
| D | sco.c | 43 static void __sco_chan_add(struct sco_conn *conn, struct sock *sk, struct sock *parent);
81 struct sco_conn *conn = hcon->sco_data; in sco_conn_add() local
83 if (conn) in sco_conn_add()
84 return conn; in sco_conn_add()
86 conn = kzalloc(sizeof(struct sco_conn), GFP_KERNEL); in sco_conn_add()
87 if (!conn) in sco_conn_add()
90 spin_lock_init(&conn->lock); in sco_conn_add()
92 hcon->sco_data = conn; in sco_conn_add()
93 conn->hcon = hcon; in sco_conn_add()
95 conn->src = &hdev->bdaddr; in sco_conn_add()
[all …]
|
| D | l2cap_core.c | 51 static struct sk_buff *l2cap_build_cmd(struct l2cap_conn *conn,
53 static void l2cap_send_cmd(struct l2cap_conn *conn, u8 ident, u8 code, u16 len,
63 static struct l2cap_chan *__l2cap_get_chan_by_dcid(struct l2cap_conn *conn, in __l2cap_get_chan_by_dcid() argument
68 list_for_each_entry(c, &conn->chan_l, list) { in __l2cap_get_chan_by_dcid()
75 static struct l2cap_chan *__l2cap_get_chan_by_scid(struct l2cap_conn *conn, in __l2cap_get_chan_by_scid() argument
80 list_for_each_entry(c, &conn->chan_l, list) { in __l2cap_get_chan_by_scid()
89 static struct l2cap_chan *l2cap_get_chan_by_scid(struct l2cap_conn *conn, in l2cap_get_chan_by_scid() argument
94 mutex_lock(&conn->chan_lock); in l2cap_get_chan_by_scid()
95 c = __l2cap_get_chan_by_scid(conn, cid); in l2cap_get_chan_by_scid()
98 mutex_unlock(&conn->chan_lock); in l2cap_get_chan_by_scid()
[all …]
|
| D | hci_sysfs.c | 34 struct hci_conn *conn = to_hci_conn(dev); in show_link_type() local
35 return sprintf(buf, "%s\n", link_typetostr(conn->type)); in show_link_type()
41 struct hci_conn *conn = to_hci_conn(dev); in show_link_address() local
42 return sprintf(buf, "%pMR\n", &conn->dst); in show_link_address()
48 struct hci_conn *conn = to_hci_conn(dev); in show_link_features() local
51 conn->features[0][0], conn->features[0][1], in show_link_features()
52 conn->features[0][2], conn->features[0][3], in show_link_features()
53 conn->features[0][4], conn->features[0][5], in show_link_features()
54 conn->features[0][6], conn->features[0][7]); in show_link_features()
82 struct hci_conn *conn = to_hci_conn(dev); in bt_link_release() local
[all …]
|
| /net/rxrpc/ |
| D | ar-connection.c | 196 struct rxrpc_connection *conn; in rxrpc_alloc_connection() local
200 conn = kzalloc(sizeof(struct rxrpc_connection), gfp); in rxrpc_alloc_connection()
201 if (conn) { in rxrpc_alloc_connection()
202 INIT_WORK(&conn->processor, &rxrpc_process_connection); in rxrpc_alloc_connection()
203 INIT_LIST_HEAD(&conn->bundle_link); in rxrpc_alloc_connection()
204 conn->calls = RB_ROOT; in rxrpc_alloc_connection()
205 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
206 rwlock_init(&conn->lock); in rxrpc_alloc_connection()
207 spin_lock_init(&conn->state_lock); in rxrpc_alloc_connection()
208 atomic_set(&conn->usage, 1); in rxrpc_alloc_connection()
[all …]
|
| D | ar-connevent.c | 28 static void rxrpc_abort_calls(struct rxrpc_connection *conn, int state, in rxrpc_abort_calls() argument
34 _enter("{%d},%x", conn->debug_id, abort_code); in rxrpc_abort_calls()
36 read_lock_bh(&conn->lock); in rxrpc_abort_calls()
38 for (p = rb_first(&conn->calls); p; p = rb_next(p)) { in rxrpc_abort_calls()
53 read_unlock_bh(&conn->lock); in rxrpc_abort_calls()
60 static int rxrpc_abort_connection(struct rxrpc_connection *conn, in rxrpc_abort_connection() argument
70 _enter("%d,,%u,%u", conn->debug_id, error, abort_code); in rxrpc_abort_connection()
73 spin_lock_bh(&conn->state_lock); in rxrpc_abort_connection()
74 if (conn->state < RXRPC_CONN_REMOTELY_ABORTED) { in rxrpc_abort_connection()
75 conn->state = RXRPC_CONN_LOCALLY_ABORTED; in rxrpc_abort_connection()
[all …]
|
| D | rxkad.c | 62 static int rxkad_init_connection_security(struct rxrpc_connection *conn) in rxkad_init_connection_security() argument
68 _enter("{%d},{%x}", conn->debug_id, key_serial(conn->key)); in rxkad_init_connection_security()
70 token = conn->key->payload.data; in rxkad_init_connection_security()
71 conn->security_ix = token->security_index; in rxkad_init_connection_security()
84 switch (conn->security_level) { in rxkad_init_connection_security()
88 conn->size_align = 8; in rxkad_init_connection_security()
89 conn->security_size = sizeof(struct rxkad_level1_hdr); in rxkad_init_connection_security()
90 conn->header_size += sizeof(struct rxkad_level1_hdr); in rxkad_init_connection_security()
93 conn->size_align = 8; in rxkad_init_connection_security()
94 conn->security_size = sizeof(struct rxkad_level2_hdr); in rxkad_init_connection_security()
[all …]
|
| D | ar-security.c | 124 int rxrpc_init_client_conn_security(struct rxrpc_connection *conn) in rxrpc_init_client_conn_security() argument
128 struct key *key = conn->key; in rxrpc_init_client_conn_security()
131 _enter("{%d},{%x}", conn->debug_id, key_serial(key)); in rxrpc_init_client_conn_security()
147 conn->security = sec; in rxrpc_init_client_conn_security()
149 ret = conn->security->init_connection_security(conn); in rxrpc_init_client_conn_security()
151 rxrpc_security_put(conn->security); in rxrpc_init_client_conn_security()
152 conn->security = NULL; in rxrpc_init_client_conn_security()
163 int rxrpc_init_server_conn_security(struct rxrpc_connection *conn) in rxrpc_init_server_conn_security() argument
166 struct rxrpc_local *local = conn->trans->local; in rxrpc_init_server_conn_security()
174 sprintf(kdesc, "%u:%u", ntohs(conn->service_id), conn->security_ix); in rxrpc_init_server_conn_security()
[all …]
|
| D | ar-call.c | 131 spin_lock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
132 list_add(&call->error_link, &call->conn->trans->peer->error_targets); in rxrpc_alloc_client_call()
133 spin_unlock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
221 _net("CALL new %d on CONN %d", call->debug_id, call->conn->debug_id); in rxrpc_get_client_call()
247 struct rxrpc_connection *conn, in rxrpc_incoming_call() argument
255 _enter(",%d,,%x", conn->debug_id, gfp); in rxrpc_incoming_call()
264 candidate->conn = conn; in rxrpc_incoming_call()
270 if (conn->security_ix > 0) in rxrpc_incoming_call()
273 write_lock_bh(&conn->lock); in rxrpc_incoming_call()
276 call = conn->channels[candidate->channel]; in rxrpc_incoming_call()
[all …]
|
| D | ar-proc.c | 62 trans = call->conn->trans; in rxrpc_call_seq_show()
77 ntohs(call->conn->service_id), in rxrpc_call_seq_show()
78 ntohl(call->conn->cid), in rxrpc_call_seq_show()
80 call->conn->in_clientflag ? "Svc" : "Clt", in rxrpc_call_seq_show()
131 struct rxrpc_connection *conn; in rxrpc_connection_seq_show() local
144 conn = list_entry(v, struct rxrpc_connection, link); in rxrpc_connection_seq_show()
145 trans = conn->trans; in rxrpc_connection_seq_show()
160 ntohs(conn->service_id), in rxrpc_connection_seq_show()
161 ntohl(conn->cid), in rxrpc_connection_seq_show()
162 conn->call_counter, in rxrpc_connection_seq_show()
[all …]
|
| /net/wireless/ |
| D | sme.c | 93 if (wdev->conn->params.channel) { in cfg80211_conn_scan()
111 if (wdev->conn->params.channel) in cfg80211_conn_scan()
112 request->channels[0] = wdev->conn->params.channel; in cfg80211_conn_scan()
137 memcpy(request->ssids[0].ssid, wdev->conn->params.ssid, in cfg80211_conn_scan()
138 wdev->conn->params.ssid_len); in cfg80211_conn_scan()
139 request->ssids[0].ssid_len = wdev->conn->params.ssid_len; in cfg80211_conn_scan()
149 wdev->conn->state = CFG80211_CONN_SCANNING; in cfg80211_conn_scan()
168 if (!wdev->conn) in cfg80211_conn_do_work()
171 params = &wdev->conn->params; in cfg80211_conn_do_work()
173 switch (wdev->conn->state) { in cfg80211_conn_do_work()
[all …]
|
| /net/netfilter/ |
| D | xt_connlimit.c | 66 static inline bool already_closed(const struct nf_conn *conn) in already_closed() argument
68 if (nf_ct_protonum(conn) == IPPROTO_TCP) in already_closed()
69 return conn->proto.tcp.state == TCP_CONNTRACK_TIME_WAIT || in already_closed()
70 conn->proto.tcp.state == TCP_CONNTRACK_CLOSE; in already_closed()
103 struct xt_connlimit_conn *conn; in count_them() local
118 hlist_for_each_entry_safe(conn, n, hash, node) { in count_them()
120 &conn->tuple); in count_them()
127 nf_ct_tuple_equal(&conn->tuple, tuple) && in count_them()
138 hlist_del(&conn->node); in count_them()
139 kfree(conn); in count_them()
[all …]
|