| /linux/fs/smb/server/ |
| H A D | connection.c | 34 static const char *ksmbd_conn_state_string(struct ksmbd_conn *conn) in ksmbd_conn_state_string() argument
36 switch (READ_ONCE(conn->status)) { in ksmbd_conn_state_string()
56 static const char *ksmbd_conn_transport_string(struct ksmbd_conn *conn) in ksmbd_conn_transport_string() argument
58 if (conn->transport->ops->rdma_read || conn->transport->ops->rdma_write) in ksmbd_conn_transport_string()
73 struct ksmbd_conn *conn) in proc_show_conn_features() argument
78 conn->sign || conn->signing_negotiated, "sign"); in proc_show_conn_features()
79 proc_show_conn_feature(m, &separator, conn->cipher_type, "encrypt"); in proc_show_conn_features()
81 conn->compress_algorithm != SMB3_COMPRESS_NONE, in proc_show_conn_features()
83 proc_show_conn_feature(m, &separator, conn->rdma_transform_ids, in proc_show_conn_features()
85 proc_show_conn_feature(m, &separator, conn->posix_ext_supported, "posix"); in proc_show_conn_features()
[all …]
|
| H A D | connection.h | 158 int (*process_fn)(struct ksmbd_conn *conn);
159 int (*terminate_fn)(struct ksmbd_conn *conn);
190 struct ksmbd_conn *conn; member
204 bool ksmbd_conn_alive(struct ksmbd_conn *conn);
205 void ksmbd_conn_wait_idle(struct ksmbd_conn *conn);
209 void ksmbd_conn_free(struct ksmbd_conn *conn);
210 struct ksmbd_conn *ksmbd_conn_get(struct ksmbd_conn *conn);
211 void ksmbd_conn_put(struct ksmbd_conn *conn);
212 void ksmbd_conn_abort(struct ksmbd_conn *conn);
218 int ksmbd_conn_rdma_read(struct ksmbd_conn *conn,
[all …]
|
| H A D | server.c | 101 if (ksmbd_conn_exiting(work->conn) || in check_conn_state()
102 ksmbd_conn_need_reconnect(work->conn)) { in check_conn_state()
113 static int __process_request(struct ksmbd_work *work, struct ksmbd_conn *conn, in __process_request() argument
125 conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER); in __process_request()
129 command = conn->ops->get_cmd_val(work); in __process_request()
133 if (command >= conn->max_cmds) { in __process_request()
134 conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER); in __process_request()
138 cmds = &conn->cmds[command]; in __process_request()
141 conn->ops->set_rsp_status(work, STATUS_NOT_IMPLEMENTED); in __process_request()
145 signed_req = conn->ops->is_sign_req && conn->ops->is_sign_req(work, command); in __process_request()
[all …]
|
| /linux/net/smc/ |
| H A D | smc_cdc.c | 31 struct smc_connection *conn = cdcpend->conn; in smc_cdc_tx_handler() local
36 sndbuf_desc = conn->sndbuf_desc; in smc_cdc_tx_handler()
37 smc = container_of(conn, struct smc_sock, conn); in smc_cdc_tx_handler()
41 &cdcpend->conn->tx_curs_fin, in smc_cdc_tx_handler()
45 atomic_add(diff, &cdcpend->conn->sndbuf_space); in smc_cdc_tx_handler()
48 smc_curs_copy(&conn->tx_curs_fin, &cdcpend->cursor, conn); in smc_cdc_tx_handler()
49 smc_curs_copy(&conn->local_tx_ctrl_fin, &cdcpend->p_cursor, in smc_cdc_tx_handler()
50 conn); in smc_cdc_tx_handler()
51 conn->tx_cdc_seq_fin = cdcpend->ctrl_seq; in smc_cdc_tx_handler()
54 if (atomic_dec_and_test(&conn->cdc_pend_tx_wr)) { in smc_cdc_tx_handler()
[all …]
|
| H A D | smc_rx.c | 62 struct smc_connection *conn = &smc->conn; in smc_rx_update_consumer() local
67 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
70 if (conn->urg_state == SMC_URG_VALID || conn->urg_rx_skip_pend) { in smc_rx_update_consumer()
71 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
72 &conn->urg_curs); in smc_rx_update_consumer()
77 conn->urg_state = SMC_URG_READ; in smc_rx_update_consumer()
83 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
84 conn->urg_rx_skip_pend = false; in smc_rx_update_consumer()
87 conn->urg_state = SMC_URG_READ; in smc_rx_update_consumer()
91 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
[all …]
|
| H A D | smc_close.c | 57 if (!smc_tx_prepared_sends(&smc->conn)) in smc_close_stream_wait()
61 smc_tx_pending(&smc->conn); in smc_close_stream_wait()
69 !smc_tx_prepared_sends(&smc->conn) || in smc_close_stream_wait()
72 smc->conn.killed, in smc_close_stream_wait()
88 static int smc_close_wr(struct smc_connection *conn) in smc_close_wr() argument
90 conn->local_tx_ctrl.conn_state_flags.peer_done_writing = 1; in smc_close_wr()
92 return smc_cdc_get_slot_and_msg_send(conn); in smc_close_wr()
95 static int smc_close_final(struct smc_connection *conn) in smc_close_final() argument
97 if (atomic_read(&conn->bytes_to_rcv)) in smc_close_final()
98 conn->local_tx_ctrl.conn_state_flags.peer_conn_abort = 1; in smc_close_final()
[all …]
|
| H A D | smc_cdc.h | 77 static inline bool smc_cdc_rxed_any_close(struct smc_connection *conn) in smc_cdc_rxed_any_close() argument
79 return conn->local_rx_ctrl.conn_state_flags.peer_conn_abort || in smc_cdc_rxed_any_close()
80 conn->local_rx_ctrl.conn_state_flags.peer_conn_closed; in smc_cdc_rxed_any_close()
84 struct smc_connection *conn) in smc_cdc_rxed_any_close_or_senddone() argument
86 return smc_cdc_rxed_any_close(conn) || in smc_cdc_rxed_any_close_or_senddone()
87 conn->local_rx_ctrl.conn_state_flags.peer_done_writing; in smc_cdc_rxed_any_close_or_senddone()
103 struct smc_connection *conn) in smc_curs_copy() argument
108 spin_lock_irqsave(&conn->acurs_lock, flags); in smc_curs_copy()
110 spin_unlock_irqrestore(&conn->acurs_lock, flags); in smc_curs_copy()
118 struct smc_connection *conn) in smc_curs_copy_net() argument
[all …]
|
| /linux/net/rxrpc/ |
| H A D | conn_object.c | 26 void rxrpc_poke_conn(struct rxrpc_connection *conn, enum rxrpc_conn_trace why) in rxrpc_poke_conn() argument
28 struct rxrpc_local *local = conn->local; in rxrpc_poke_conn()
35 busy = !list_empty(&conn->attend_link); in rxrpc_poke_conn()
37 rxrpc_get_connection(conn, why); in rxrpc_poke_conn()
38 list_add_tail(&conn->attend_link, &local->conn_attend_q); in rxrpc_poke_conn()
46 struct rxrpc_connection *conn = in rxrpc_connection_timer() local
49 rxrpc_poke_conn(conn, rxrpc_conn_get_poke_timer); in rxrpc_connection_timer()
58 struct rxrpc_connection *conn; in rxrpc_alloc_connection() local
62 conn = kzalloc_obj(struct rxrpc_connection, gfp); in rxrpc_alloc_connection()
63 if (conn) { in rxrpc_alloc_connection()
[all …]
|
| H A D | conn_event.c | 22 static bool rxrpc_set_conn_aborted(struct rxrpc_connection *conn, in rxrpc_set_conn_aborted() argument
28 if (conn->state != RXRPC_CONN_ABORTED) { in rxrpc_set_conn_aborted()
29 spin_lock_irq(&conn->state_lock); in rxrpc_set_conn_aborted()
30 if (conn->state != RXRPC_CONN_ABORTED) { in rxrpc_set_conn_aborted()
31 conn->abort_code = abort_code; in rxrpc_set_conn_aborted()
32 conn->error = err; in rxrpc_set_conn_aborted()
33 conn->completion = compl; in rxrpc_set_conn_aborted()
35 smp_store_release(&conn->state, RXRPC_CONN_ABORTED); in rxrpc_set_conn_aborted()
36 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); in rxrpc_set_conn_aborted()
37 set_bit(RXRPC_CONN_EV_ABORT_CALLS, &conn->events); in rxrpc_set_conn_aborted()
[all …]
|
| H A D | conn_client.c | 46 struct rxrpc_connection *conn) in rxrpc_put_client_connection_id() argument
48 idr_remove(&local->conn_ids, conn->proto.cid >> RXRPC_CIDSHIFT); in rxrpc_put_client_connection_id()
56 struct rxrpc_connection *conn; in rxrpc_destroy_client_conn_ids() local
60 idr_for_each_entry(&local->conn_ids, conn, id) { in rxrpc_destroy_client_conn_ids()
62 conn, refcount_read(&conn->ref)); in rxrpc_destroy_client_conn_ids()
154 struct rxrpc_connection *conn; in rxrpc_alloc_client_connection() local
161 conn = rxrpc_alloc_connection(rxnet, GFP_ATOMIC | __GFP_NOWARN); in rxrpc_alloc_client_connection()
162 if (!conn) in rxrpc_alloc_client_connection()
165 id = idr_alloc_cyclic(&local->conn_ids, conn, 1, 0x40000000, in rxrpc_alloc_client_connection()
168 kfree(conn); in rxrpc_alloc_client_connection()
[all …]
|
| H A D | conn_service.c | 24 struct rxrpc_connection *conn = NULL; in rxrpc_find_service_conn_rcu() local
43 conn = rb_entry(p, struct rxrpc_connection, service_node); in rxrpc_find_service_conn_rcu()
45 if (conn->proto.index_key < k.index_key) in rxrpc_find_service_conn_rcu()
47 else if (conn->proto.index_key > k.index_key) in rxrpc_find_service_conn_rcu()
51 conn = NULL; in rxrpc_find_service_conn_rcu()
56 _leave(" = %d", conn ? conn->debug_id : -1); in rxrpc_find_service_conn_rcu()
57 return conn; in rxrpc_find_service_conn_rcu()
65 struct rxrpc_connection *conn) in rxrpc_publish_service_conn() argument
68 struct rxrpc_conn_proto k = conn->proto; in rxrpc_publish_service_conn()
88 rb_link_node_rcu(&conn->service_node, parent, pp); in rxrpc_publish_service_conn()
[all …]
|
| H A D | rxgk.c | 86 static struct rxgk_context *rxgk_rekey(struct rxrpc_connection *conn, in rxgk_rekey() argument
90 unsigned int key_number, current_key, mask = ARRAY_SIZE(conn->rxgk.keys) - 1; in rxgk_rekey()
95 mutex_lock(&conn->security_lock); in rxgk_rekey()
97 current_key = conn->rxgk.key_number; in rxgk_rekey()
111 gk = conn->rxgk.keys[key_number & mask]; in rxgk_rekey()
120 mutex_unlock(&conn->security_lock); in rxgk_rekey()
125 trace_rxrpc_rxgk_rekey(conn, current_key, in rxgk_rekey()
130 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); in rxgk_rekey()
133 if (WARN_ON(conn->rxgk.keys[key_number & mask])) in rxgk_rekey()
138 gk = conn in rxgk_rekey()
167 rxgk_get_key(struct rxrpc_connection * conn,const u16 * specific_key_number) rxgk_get_key() argument
233 rxgk_init_connection_security(struct rxrpc_connection * conn,struct rxrpc_key_token * token) rxgk_init_connection_security() argument
640 rxgk_issue_challenge(struct rxrpc_connection * conn) rxgk_issue_challenge() argument
707 rxgk_validate_challenge(struct rxrpc_connection * conn,struct sk_buff * skb) rxgk_validate_challenge() argument
754 rxgk_challenge_to_recvmsg(struct rxrpc_connection * conn,struct sk_buff * challenge,struct msghdr * msg) rxgk_challenge_to_recvmsg() argument
788 rxgk_insert_response_header(struct rxrpc_connection * conn,struct rxgk_context * gk,struct sk_buff * response,size_t offset) rxgk_insert_response_header() argument
837 rxgk_construct_authenticator(struct rxrpc_connection * conn,struct sk_buff * challenge,const struct krb5_buffer * appdata,struct sk_buff * response,size_t offset) rxgk_construct_authenticator() argument
895 rxgk_encrypt_authenticator(struct rxrpc_connection * conn,struct rxgk_context * gk,struct sk_buff * response,size_t offset,size_t alloc_len,size_t auth_offset,size_t auth_len) rxgk_encrypt_authenticator() argument
923 rxgk_construct_response(struct rxrpc_connection * conn,struct sk_buff * challenge,struct krb5_buffer * appdata) rxgk_construct_response() argument
1012 rxgk_respond_to_challenge(struct rxrpc_connection * conn,struct sk_buff * challenge,struct krb5_buffer * appdata) rxgk_respond_to_challenge() argument
1025 rxgk_respond_to_challenge_no_appdata(struct rxrpc_connection * conn,struct sk_buff * challenge) rxgk_respond_to_challenge_no_appdata() argument
1087 rxgk_verify_authenticator(struct rxrpc_connection * conn,const struct krb5_enctype * krb5,struct sk_buff * skb,void * auth,unsigned int auth_len) rxgk_verify_authenticator() argument
1164 rxgk_verify_response(struct rxrpc_connection * conn,struct sk_buff * skb,void * buffer,unsigned int len) rxgk_verify_response() argument
1305 rxgk_clear(struct rxrpc_connection * conn) rxgk_clear() argument
[all...] |
| /linux/net/bluetooth/ |
| H A D | hci_conn.c | 45 struct hci_conn *conn; member
68 void hci_connect_le_scan_cleanup(struct hci_conn *conn, u8 status) in hci_connect_le_scan_cleanup() argument
71 struct hci_dev *hdev = conn->hdev; in hci_connect_le_scan_cleanup()
76 bdaddr = &conn->dst; in hci_connect_le_scan_cleanup()
77 bdaddr_type = conn->dst_type; in hci_connect_le_scan_cleanup()
91 if (params->conn) { in hci_connect_le_scan_cleanup()
92 hci_conn_drop(params->conn); in hci_connect_le_scan_cleanup()
93 hci_conn_put(params->conn); in hci_connect_le_scan_cleanup()
94 params->conn = NULL; in hci_connect_le_scan_cleanup()
107 mgmt_connect_failed(hdev, conn, statu in hci_connect_le_scan_cleanup()
137 hci_conn_cleanup(struct hci_conn * conn) hci_conn_cleanup() argument
175 hci_disconnect(struct hci_conn * conn,__u8 reason) hci_disconnect() argument
197 hci_add_sco(struct hci_conn * conn,__u16 handle) hci_add_sco() argument
215 find_next_esco_param(struct hci_conn * conn,const struct sco_param * esco_param,int size) find_next_esco_param() argument
281 struct hci_conn *conn = conn_handle->conn; hci_enhanced_setup_sync() local
402 hci_setup_sync_conn(struct hci_conn * conn,__u16 handle) hci_setup_sync_conn() argument
463 hci_setup_sync(struct hci_conn * conn,__u16 handle) hci_setup_sync() argument
491 struct hci_conn *conn; global() member
501 struct hci_conn *conn = d->conn; le_conn_update_sync() local
570 hci_le_conn_update(struct hci_conn * conn,u16 min,u16 max,u16 latency,u16 to_multiplier) hci_le_conn_update() argument
593 hci_le_start_enc(struct hci_conn * conn,__le16 ediv,__le64 rand,__u8 ltk[16],__u8 key_size) hci_le_start_enc() argument
612 hci_sco_setup(struct hci_conn * conn,__u8 status) hci_sco_setup() argument
635 struct hci_conn *conn = container_of(work, struct hci_conn, hci_conn_timeout() local
659 struct hci_conn *conn = container_of(work, struct hci_conn, hci_conn_idle() local
693 struct hci_conn *conn = container_of(work, struct hci_conn, hci_conn_auto_accept() local
719 struct hci_conn *conn = container_of(work, struct hci_conn, le_conn_timeout() local
758 bis_list(struct hci_conn * conn,void * data) bis_list() argument
795 hci_le_terminate_big(struct hci_dev * hdev,struct hci_conn * conn) hci_le_terminate_big() argument
835 find_bis(struct hci_conn * conn,void * data) find_bis() argument
846 hci_le_big_terminate(struct hci_dev * hdev,struct hci_conn * conn) hci_le_big_terminate() argument
899 bis_cleanup(struct hci_conn * conn) bis_cleanup() argument
955 find_cis(struct hci_conn * conn,void * data) find_cis() argument
970 cis_cleanup(struct hci_conn * conn) cis_cleanup() argument
1005 struct hci_conn *conn; __hci_conn_add() local
1193 hci_conn_cleanup_child(struct hci_conn * conn,u8 reason) hci_conn_cleanup_child() argument
1219 hci_conn_unlink(struct hci_conn * conn) hci_conn_unlink() argument
1261 hci_conn_del(struct hci_conn * conn) hci_conn_del() argument
1398 hci_le_conn_failed(struct hci_conn * conn,u8 status) hci_le_conn_failed() argument
1412 hci_conn_failed(struct hci_conn * conn,u8 status) hci_conn_failed() argument
1439 hci_conn_set_handle(struct hci_conn * conn,u16 handle) hci_conn_set_handle() argument
1472 struct hci_conn *conn; hci_connect_le() local
1554 struct hci_conn *conn; is_connected() local
1606 struct hci_conn *conn; qos_set_big() local
1630 struct hci_conn *conn; qos_set_bis() local
1673 struct hci_conn *conn; hci_add_bis() local
1725 struct hci_conn *conn; hci_connect_le_scan() local
1829 hci_conn_link(struct hci_conn * parent,struct hci_conn * conn) hci_conn_link() argument
1905 hci_le_create_big(struct hci_conn * conn,struct bt_iso_qos * qos) hci_le_create_big() argument
1941 struct hci_conn *conn; set_cig_params_sync() local
2001 hci_le_set_cig_params(struct hci_conn * conn,struct bt_iso_qos * qos) hci_le_set_cig_params() argument
2130 hci_iso_setup_path(struct hci_conn * conn) hci_iso_setup_path() argument
2162 hci_conn_check_create_cis(struct hci_conn * conn) hci_conn_check_create_cis() argument
2181 struct hci_conn *conn; hci_le_create_cis_pending() local
2205 hci_iso_qos_setup(struct hci_dev * hdev,struct hci_conn * conn,struct bt_iso_io_qos * qos,__u8 phys) hci_iso_qos_setup() argument
2228 struct hci_conn *conn = data; create_big_sync() local
2260 struct hci_conn *conn; hci_pa_create_sync() local
2307 struct hci_conn *conn = data; create_big_complete() local
2335 struct hci_conn *conn; hci_bind_bis() local
2390 hci_past_bis(struct hci_conn * conn,bdaddr_t * dst,__u8 dst_type) hci_past_bis() argument
2402 bis_mark_per_adv(struct hci_conn * conn,void * data) bis_mark_per_adv() argument
2423 struct hci_conn *conn; hci_connect_bis() local
2525 hci_conn_check_link_mode(struct hci_conn * conn) hci_conn_check_link_mode() argument
2565 hci_conn_auth(struct hci_conn * conn,__u8 sec_level,__u8 auth_type) hci_conn_auth() argument
2600 hci_conn_encrypt(struct hci_conn * conn) hci_conn_encrypt() argument
2614 hci_conn_security(struct hci_conn * conn,__u8 sec_level,__u8 auth_type,bool initiator) hci_conn_security() argument
2699 hci_conn_check_secure(struct hci_conn * conn,__u8 sec_level) hci_conn_check_secure() argument
2718 hci_conn_switch_role(struct hci_conn * conn,__u8 role) hci_conn_switch_role() argument
2737 hci_conn_enter_active_mode(struct hci_conn * conn,__u8 force_active) hci_conn_enter_active_mode() argument
2765 struct hci_conn *conn; hci_conn_hash_flush() local
2782 get_link_mode(struct hci_conn * conn) get_link_mode() argument
2861 struct hci_conn *conn; hci_get_conn_info() local
2888 struct hci_conn *conn; hci_get_auth_info() local
2905 hci_chan_create(struct hci_conn * conn) hci_chan_create() argument
2932 struct hci_conn *conn = chan->conn; hci_chan_del() local
2950 hci_chan_list_flush(struct hci_conn * conn) hci_chan_list_flush() argument
2992 hci_conn_get_phy(struct hci_conn * conn) hci_conn_get_phy() argument
3095 bt_phy_pkt_type(struct hci_conn * conn,u32 phys) bt_phy_pkt_type() argument
3171 hci_conn_set_phy(struct hci_conn * conn,u32 phys) hci_conn_set_phy() argument
3202 struct hci_conn *conn = data; abort_conn_sync() local
3212 struct hci_conn *conn = data; abort_conn_destroy() local
3217 hci_abort_conn(struct hci_conn * conn,u8 reason) hci_abort_conn() argument
3284 hci_conn_tx_queue(struct hci_conn * conn,struct sk_buff * skb) hci_conn_tx_queue() argument
3347 hci_conn_tx_dequeue(struct hci_conn * conn) hci_conn_tx_dequeue() argument
3374 hci_conn_key_enc_size(struct hci_conn * conn) hci_conn_key_enc_size() argument
[all...] |
| H A D | hci_event.c | 166 struct hci_conn *conn; in hci_cc_role_discovery() local
175 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_role_discovery()
176 if (conn) in hci_cc_role_discovery()
177 conn->role = rp->role; in hci_cc_role_discovery()
188 struct hci_conn *conn; in hci_cc_read_link_policy() local
197 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_read_link_policy()
198 if (conn) in hci_cc_read_link_policy()
199 conn->link_policy = __le16_to_cpu(rp->policy); in hci_cc_read_link_policy()
210 struct hci_conn *conn; in hci_cc_write_link_policy() local
224 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_write_link_policy()
[all …]
|
| H A D | sco.c | 71 struct sco_conn *conn; member
80 struct sco_conn *conn = container_of(ref, struct sco_conn, ref); in sco_conn_free() local
82 BT_DBG("conn %p", conn); in sco_conn_free()
84 if (conn->sk) in sco_conn_free()
85 sco_pi(conn->sk)->conn = NULL; in sco_conn_free()
95 disable_delayed_work_sync(&conn->timeout_work); in sco_conn_free()
97 kfree(conn);
100 static void sco_conn_put(struct sco_conn *conn) in sco_conn_put()
98 sco_conn_put(struct sco_conn * conn) sco_conn_put() argument
108 sco_conn_hold(struct sco_conn * conn) sco_conn_hold() argument
116 sco_conn_hold_unless_zero(struct sco_conn * conn) sco_conn_hold_unless_zero() argument
129 sco_sock_hold(struct sco_conn * conn) sco_sock_hold() argument
141 struct sco_conn *conn = container_of(work, struct sco_conn, sco_sock_timeout() local
196 struct sco_conn *conn = hcon->sco_data; sco_conn_add() local
237 struct sco_conn *conn; sco_chan_del() local
260 struct sco_conn *conn = hcon->sco_data; sco_conn_del() local
285 __sco_chan_add(struct sco_conn * conn,struct sock * sk,struct sock * parent) __sco_chan_add() argument
297 sco_chan_add(struct sco_conn * conn,struct sock * sk,struct sock * parent) sco_chan_add() argument
314 struct sco_conn *conn; sco_connect() local
407 struct sco_conn *conn = sco_pi(sk)->conn; sco_send_frame() local
422 sco_recv_frame(struct sco_conn * conn,struct sk_buff * skb) sco_recv_frame() argument
577 struct sco_conn *conn; sco_sock_close() local
893 sco_conn_defer_accept(struct hci_conn * conn,u16 setting) sco_conn_defer_accept() argument
1406 sco_conn_ready(struct sco_conn * conn) sco_conn_ready() argument
1512 struct sco_conn *conn; sco_connect_cfm() local
1538 struct sco_conn *conn; sco_recv_scodata() local
[all...] |
| /linux/drivers/target/iscsi/ |
| H A D | iscsi_target_login.c | 37 static struct iscsi_login *iscsi_login_init_conn(struct iscsit_conn *conn) in iscsi_login_init_conn() argument
46 conn->login = login; in iscsi_login_init_conn()
47 login->conn = conn; in iscsi_login_init_conn()
62 conn->conn_login = login; in iscsi_login_init_conn()
74 struct iscsit_conn *conn, in iscsi_login_check_initiator_version() argument
82 iscsit_tx_login_rsp(conn, ISCSI_STATUS_CLS_INITIATOR_ERR, in iscsi_login_check_initiator_version()
90 int iscsi_check_for_session_reinstatement(struct iscsit_conn *conn) in iscsi_check_for_session_reinstatement() argument
94 struct iscsi_portal_group *tpg = conn->tpg; in iscsi_check_for_session_reinstatement()
100 INITIATORNAME, conn->param_list); in iscsi_check_for_session_reinstatement()
102 SESSIONTYPE, conn->param_list); in iscsi_check_for_session_reinstatement()
[all …]
|
| H A D | iscsi_target_util.c | 61 iscsit_add_cmd_to_immediate_queue(cmd, cmd->conn, ISTATE_SEND_R2T); in iscsit_add_r2t_to_list()
155 struct iscsit_cmd *iscsit_allocate_cmd(struct iscsit_conn *conn, int state) in iscsit_allocate_cmd() argument
158 struct se_session *se_sess = conn->sess->se_sess; in iscsit_allocate_cmd()
167 size = sizeof(struct iscsit_cmd) + conn->conn_transport->priv_size; in iscsit_allocate_cmd()
173 cmd->conn = conn; in iscsit_allocate_cmd()
285 int iscsit_sequence_cmd(struct iscsit_conn *conn, struct iscsit_cmd *cmd, in iscsit_sequence_cmd() argument
292 mutex_lock(&conn->sess->cmdsn_mutex); in iscsit_sequence_cmd()
294 cmdsn_ret = iscsit_check_received_cmdsn(conn->sess, be32_to_cpu(cmdsn)); in iscsit_sequence_cmd()
298 if ((ret >= 0) && !list_empty(&conn->sess->sess_ooo_cmdsn_list)) in iscsit_sequence_cmd()
299 iscsit_execute_ooo_cmdsns(conn->sess); in iscsit_sequence_cmd()
[all …]
|
| H A D | iscsi_target_nego.c | 101 static struct iscsi_node_auth *iscsi_get_node_auth(struct iscsit_conn *conn) in iscsi_get_node_auth() argument
107 if (conn->sess->sess_ops->SessionType) in iscsi_get_node_auth()
110 se_nacl = conn->sess->se_sess->se_node_acl; in iscsi_get_node_auth()
127 struct iscsit_conn *conn, in iscsi_handle_authentication() argument
136 auth = iscsi_get_node_auth(conn); in iscsi_handle_authentication()
141 strcpy(conn->sess->auth_type, "CHAP"); in iscsi_handle_authentication()
143 strcpy(conn->sess->auth_type, NONE); in iscsi_handle_authentication()
148 return chap_main_loop(conn, auth, in_buf, out_buf, in iscsi_handle_authentication()
154 static void iscsi_remove_failed_auth_entry(struct iscsit_conn *conn) in iscsi_remove_failed_auth_entry() argument
156 kfree(conn->auth_protocol); in iscsi_remove_failed_auth_entry()
[all …]
|
| H A D | iscsi_target_erl0.c | 34 struct iscsit_conn *conn = cmd->conn; in iscsit_set_dataout_sequence_values() local
42 conn->sess->sess_ops->FirstBurstLength); in iscsit_set_dataout_sequence_values()
46 if (!conn->sess->sess_ops->DataSequenceInOrder) in iscsit_set_dataout_sequence_values()
52 conn->sess->sess_ops->MaxBurstLength) ? in iscsit_set_dataout_sequence_values()
54 conn->sess->sess_ops->MaxBurstLength) : cmd->se_cmd.data_length; in iscsit_set_dataout_sequence_values()
58 conn->sess->sess_ops->MaxBurstLength) >= in iscsit_set_dataout_sequence_values()
61 conn->sess->sess_ops->MaxBurstLength); in iscsit_set_dataout_sequence_values()
69 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_within_command_recovery_check() local
85 if (conn->sess->sess_ops->DataSequenceInOrder) { in iscsit_dataout_within_command_recovery_check()
103 if (conn->sess->sess_ops->DataPDUInOrder) { in iscsit_dataout_within_command_recovery_check()
[all …]
|
| H A D | iscsi_target.c | 476 int iscsit_queue_rsp(struct iscsit_conn *conn, struct iscsit_cmd *cmd) in iscsit_queue_rsp() argument
478 return iscsit_add_cmd_to_response_queue(cmd, cmd->conn, cmd->i_state); in iscsit_queue_rsp()
482 void iscsit_aborted_task(struct iscsit_conn *conn, struct iscsit_cmd *cmd) in iscsit_aborted_task() argument
484 spin_lock_bh(&conn->cmd_lock); in iscsit_aborted_task()
487 spin_unlock_bh(&conn->cmd_lock); in iscsit_aborted_task()
498 iscsit_xmit_nondatain_pdu(struct iscsit_conn *conn, struct iscsit_cmd *cmd, in iscsit_xmit_nondatain_pdu() argument
510 if (conn->conn_ops->HeaderDigest) { in iscsit_xmit_nondatain_pdu()
537 if (conn->conn_ops->DataDigest) { in iscsit_xmit_nondatain_pdu()
553 ret = iscsit_send_tx_data(cmd, conn, 1); in iscsit_xmit_nondatain_pdu()
555 iscsit_tx_thread_wait_for_tcp(conn); in iscsit_xmit_nondatain_pdu()
[all …]
|
| /linux/drivers/net/ethernet/mellanox/mlx5/core/fpga/ |
| H A D | conn.c | 48 static int mlx5_fpga_conn_map_buf(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_map_buf() argument
57 dma_device = mlx5_core_dma_dev(conn->fdev->mdev); in mlx5_fpga_conn_map_buf()
62 mlx5_fpga_warn(conn->fdev, "DMA error on sg 0: %d\n", err); in mlx5_fpga_conn_map_buf()
74 mlx5_fpga_warn(conn->fdev, "DMA error on sg 1: %d\n", err); in mlx5_fpga_conn_map_buf()
84 static void mlx5_fpga_conn_unmap_buf(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_unmap_buf() argument
89 dma_device = mlx5_core_dma_dev(conn->fdev->mdev); in mlx5_fpga_conn_unmap_buf()
99 static int mlx5_fpga_conn_post_recv(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_post_recv() argument
106 err = mlx5_fpga_conn_map_buf(conn, buf); in mlx5_fpga_conn_post_recv()
110 if (unlikely(conn->qp.rq.pc - conn->qp.rq.cc >= conn->qp.rq.size)) { in mlx5_fpga_conn_post_recv()
111 mlx5_fpga_conn_unmap_buf(conn, buf); in mlx5_fpga_conn_post_recv()
[all …]
|
| /linux/net/rds/ |
| H A D | connection.c | 90 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup() local
92 hlist_for_each_entry_rcu(conn, head, c_hash_node) { in rds_conn_lookup()
93 if (ipv6_addr_equal(&conn->c_faddr, faddr) && in rds_conn_lookup()
94 ipv6_addr_equal(&conn->c_laddr, laddr) && in rds_conn_lookup()
95 conn->c_trans == trans && in rds_conn_lookup()
96 conn->c_tos == tos && in rds_conn_lookup()
97 net == rds_conn_net(conn) && in rds_conn_lookup()
98 conn->c_dev_if == dev_if) { in rds_conn_lookup()
99 ret = conn; in rds_conn_lookup()
118 struct rds_connection *conn = cp->cp_conn; in rds_conn_path_reset() local
[all …]
|
| H A D | ib_cm.c | 49 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol() argument
51 conn->c_version = version; in rds_ib_set_protocol()
57 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control() argument
59 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_set_flow_control()
64 rds_ib_send_add_credits(conn, credits); in rds_ib_set_flow_control()
74 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete() argument
76 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_connect_complete()
84 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete()
85 if (conn->c_isv6) { in rds_ib_cm_connect_complete()
86 if (event->param.conn.private_data_len >= in rds_ib_cm_connect_complete()
[all …]
|
| /linux/drivers/scsi/ |
| H A D | libiscsi.c | 88 inline void iscsi_conn_queue_xmit(struct iscsi_conn *conn) in iscsi_conn_queue_xmit() argument
90 struct Scsi_Host *shost = conn->session->host; in iscsi_conn_queue_xmit()
94 queue_work(ihost->workq, &conn->xmitwork); in iscsi_conn_queue_xmit()
98 inline void iscsi_conn_queue_recv(struct iscsi_conn *conn) in iscsi_conn_queue_recv() argument
100 struct Scsi_Host *shost = conn->session->host; in iscsi_conn_queue_recv()
103 if (ihost->workq && !test_bit(ISCSI_CONN_FLAG_SUSPEND_RX, &conn->flags)) in iscsi_conn_queue_recv()
104 queue_work(ihost->workq, &conn->recvwork); in iscsi_conn_queue_recv()
149 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() local
163 if (left > conn->max_xmit_dlength) { in iscsi_prep_data_out_pdu()
164 hton24(hdr->dlength, conn->max_xmit_dlength); in iscsi_prep_data_out_pdu()
[all …]
|
| /linux/drivers/net/ethernet/sfc/ |
| H A D | tc_conntrack.c | 45 struct efx_tc_ct_entry *conn = ptr; in efx_tc_ct_free() local
50 conn->cookie); in efx_tc_ct_free()
55 efx_tc_flower_release_counter(efx, conn->cnt); in efx_tc_ct_free()
56 kfree(conn); in efx_tc_ct_free()
94 struct efx_tc_ct_entry *conn) in efx_tc_ct_parse_match() argument
147 conn->eth_proto = fm.key->n_proto; in efx_tc_ct_parse_match()
148 if (conn->eth_proto != (ipv == 4 ? htons(ETH_P_IP) in efx_tc_ct_parse_match()
152 ipv, ntohs(conn->eth_proto)); in efx_tc_ct_parse_match()
161 conn->ip_proto = fm.key->ip_proto; in efx_tc_ct_parse_match()
162 switch (conn->ip_proto) { in efx_tc_ct_parse_match()
[all …]
|