| /linux/fs/smb/server/ |
| H A D | connection.c | 28 * @conn: connection instance to be cleaned up
30 * During the thread termination, the corresponding conn instance
31 * resources(sock/memory) are released and finally the conn object is freed.
33 void ksmbd_conn_free(struct ksmbd_conn *conn) in ksmbd_conn_free() argument
36 hash_del(&conn->hlist); in ksmbd_conn_free()
39 xa_destroy(&conn->sessions); in ksmbd_conn_free()
40 kvfree(conn->request_buf); in ksmbd_conn_free()
41 kfree(conn->preauth_info); in ksmbd_conn_free()
42 if (atomic_dec_and_test(&conn->refcnt)) { in ksmbd_conn_free()
43 conn->transport->ops->free_transport(conn->transport); in ksmbd_conn_free()
[all …]
|
| H A D | connection.h | 124 int (*process_fn)(struct ksmbd_conn *conn);
125 int (*terminate_fn)(struct ksmbd_conn *conn);
149 struct ksmbd_conn *conn; member
161 bool ksmbd_conn_alive(struct ksmbd_conn *conn);
162 void ksmbd_conn_wait_idle(struct ksmbd_conn *conn);
165 void ksmbd_conn_free(struct ksmbd_conn *conn);
168 int ksmbd_conn_rdma_read(struct ksmbd_conn *conn,
172 int ksmbd_conn_rdma_write(struct ksmbd_conn *conn,
182 void ksmbd_conn_lock(struct ksmbd_conn *conn);
183 void ksmbd_conn_unlock(struct ksmbd_conn *conn);
[all …]
|
| H A D | smb2ops.c | 196 * @conn: connection instance
198 void init_smb2_1_server(struct ksmbd_conn *conn) in init_smb2_1_server() argument
200 conn->vals = &smb21_server_values; in init_smb2_1_server()
201 conn->ops = &smb2_0_server_ops; in init_smb2_1_server()
202 conn->cmds = smb2_0_server_cmds; in init_smb2_1_server()
203 conn->max_cmds = ARRAY_SIZE(smb2_0_server_cmds); in init_smb2_1_server()
204 conn->signing_algorithm = SIGNING_ALG_HMAC_SHA256_LE; in init_smb2_1_server()
207 conn->vals->capabilities |= SMB2_GLOBAL_CAP_LEASING; in init_smb2_1_server()
213 * @conn: connection instance
215 void init_smb3_0_server(struct ksmbd_conn *conn) in init_smb3_0_server() argument
[all …]
|
| H A D | server.c | 96 if (ksmbd_conn_exiting(work->conn) || in check_conn_state()
97 ksmbd_conn_need_reconnect(work->conn)) { in check_conn_state()
108 static int __process_request(struct ksmbd_work *work, struct ksmbd_conn *conn, in __process_request() argument
119 conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER); in __process_request()
123 command = conn->ops->get_cmd_val(work); in __process_request()
127 if (command >= conn->max_cmds) { in __process_request()
128 conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER); in __process_request()
132 cmds = &conn->cmds[command]; in __process_request()
135 conn->ops->set_rsp_status(work, STATUS_NOT_IMPLEMENTED); in __process_request()
139 if (work->sess && 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_tx.c | 48 if (atomic_read(&smc->conn.sndbuf_space) && sock) { in smc_tx_write_space()
50 SMC_STAT_RMB_TX_FULL(smc, !smc->conn.lnk); in smc_tx_write_space()
80 struct smc_connection *conn = &smc->conn; in smc_tx_wait() local
92 conn->killed || in smc_tx_wait()
93 conn->local_tx_ctrl.conn_state_flags.peer_done_writing) { in smc_tx_wait()
97 if (smc_cdc_rxed_any_close(conn)) { in smc_tx_wait()
112 if (atomic_read(&conn->sndbuf_space) && !conn->urg_tx_pend) in smc_tx_wait()
118 smc_cdc_rxed_any_close(conn) || in smc_tx_wait()
147 struct smc_connection *conn = &smc->conn; smc_should_autocork() local
161 struct smc_connection *conn = &smc->conn; smc_tx_should_cork() local
185 struct smc_connection *conn = &smc->conn; smc_tx_sendmsg() local
303 smcd_tx_ism_write(struct smc_connection * conn,void * data,size_t len,u32 offset,int signal) smcd_tx_ism_write() argument
317 smc_tx_rdma_write(struct smc_connection * conn,int peer_rmbe_offset,int num_sges,struct ib_rdma_wr * rdma_wr) smc_tx_rdma_write() argument
340 smc_tx_advance_cursors(struct smc_connection * conn,union smc_host_cursor * prod,union smc_host_cursor * sent,size_t len) smc_tx_advance_cursors() argument
356 smcr_tx_rdma_writes(struct smc_connection * conn,size_t len,size_t src_off,size_t src_len,size_t dst_off,size_t dst_len,struct smc_rdma_wr * wr_rdma_buf) smcr_tx_rdma_writes() argument
421 smcd_tx_rdma_writes(struct smc_connection * conn,size_t len,size_t src_off,size_t src_len,size_t dst_off,size_t dst_len) smcd_tx_rdma_writes() argument
463 smc_tx_rdma_writes(struct smc_connection * conn,struct smc_rdma_wr * wr_rdma_buf) smc_tx_rdma_writes() argument
547 smcr_tx_sndbuf_nonempty(struct smc_connection * conn) smcr_tx_sndbuf_nonempty() argument
605 smcd_tx_sndbuf_nonempty(struct smc_connection * conn) smcd_tx_sndbuf_nonempty() argument
624 smc_tx_sndbuf_nonempty(struct smc_connection * conn) smc_tx_sndbuf_nonempty() argument
662 smc_tx_pending(struct smc_connection * conn) smc_tx_pending() argument
682 struct smc_connection *conn = container_of(to_delayed_work(work), smc_tx_work() local
692 smc_tx_consumer_update(struct smc_connection * conn,bool force) smc_tx_consumer_update() argument
[all...] |
| H A D | smc_diag.c | 93 else if (smc_conn_lgr_valid(&smc->conn) && smc->conn.lgr->is_smcd) in __smc_diag_dump()
107 smc->conn.alert_token_local) { in __smc_diag_dump()
108 struct smc_connection *conn = &smc->conn; in __smc_diag_dump() local
110 .token = conn->alert_token_local, in __smc_diag_dump()
111 .sndbuf_size = conn->sndbuf_desc ? in __smc_diag_dump()
112 conn->sndbuf_desc->len : 0, in __smc_diag_dump()
113 .rmbe_size = conn->rmb_desc ? conn in __smc_diag_dump()
168 struct smc_connection *conn = &smc->conn; __smc_diag_dump() local
[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(sizeof(struct rxrpc_connection), gfp); in rxrpc_alloc_connection()
63 if (conn) { in rxrpc_alloc_connection()
100 struct rxrpc_connection *conn; rxrpc_find_client_connection_rcu() local
150 __rxrpc_disconnect_call(struct rxrpc_connection * conn,struct rxrpc_call * call) __rxrpc_disconnect_call() argument
192 struct rxrpc_connection *conn = call->conn; rxrpc_disconnect_call() local
222 rxrpc_queue_conn(struct rxrpc_connection * conn,enum rxrpc_conn_trace why) rxrpc_queue_conn() argument
232 rxrpc_see_connection(struct rxrpc_connection * conn,enum rxrpc_conn_trace why) rxrpc_see_connection() argument
245 rxrpc_get_connection(struct rxrpc_connection * conn,enum rxrpc_conn_trace why) rxrpc_get_connection() argument
259 rxrpc_get_connection_maybe(struct rxrpc_connection * conn,enum rxrpc_conn_trace why) rxrpc_get_connection_maybe() argument
288 struct rxrpc_connection *conn = rxrpc_rcu_free_connection() local
307 struct rxrpc_connection *conn = rxrpc_clean_up_connection() local
354 rxrpc_put_connection(struct rxrpc_connection * conn,enum rxrpc_conn_trace why) rxrpc_put_connection() argument
387 struct rxrpc_connection *conn, *_p; rxrpc_service_connection_reaper() local
466 struct rxrpc_connection *conn, *_p; rxrpc_destroy_all_connections() local
[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 in rxrpc_set_conn_aborted()
49 rxrpc_abort_conn(struct rxrpc_connection * conn,struct sk_buff * skb,s32 abort_code,int err,enum rxrpc_abort_reason why) rxrpc_abort_conn() argument
66 rxrpc_input_conn_abort(struct rxrpc_connection * conn,struct sk_buff * skb) rxrpc_input_conn_abort() argument
77 rxrpc_conn_retransmit_call(struct rxrpc_connection * conn,struct sk_buff * skb,unsigned int channel) rxrpc_conn_retransmit_call() argument
203 rxrpc_abort_calls(struct rxrpc_connection * conn) rxrpc_abort_calls() argument
238 rxrpc_process_event(struct rxrpc_connection * conn,struct sk_buff * skb) rxrpc_process_event() argument
290 rxrpc_secure_connection(struct rxrpc_connection * conn) rxrpc_secure_connection() argument
300 rxrpc_process_delayed_final_acks(struct rxrpc_connection * conn,bool force) rxrpc_process_delayed_final_acks() argument
340 rxrpc_do_process_connection(struct rxrpc_connection * conn) rxrpc_do_process_connection() argument
368 struct rxrpc_connection *conn = rxrpc_process_connection() local
384 rxrpc_post_packet_to_conn(struct rxrpc_connection * conn,struct sk_buff * skb) rxrpc_post_packet_to_conn() argument
397 rxrpc_input_conn_packet(struct rxrpc_connection * conn,struct sk_buff * skb) rxrpc_input_conn_packet() argument
432 rxrpc_input_conn_event(struct rxrpc_connection * conn,struct sk_buff * skb) rxrpc_input_conn_event() argument
[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()
61 pr_err("AF_RXRPC: Leaked client conn %p {%d}\n", 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()
[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->rxgk.keys[current_key & mask]; in rxgk_rekey()
[all …]
|
| /linux/net/bluetooth/ |
| H A D | hci_conn.c | 48 struct hci_conn *conn; member
71 void hci_connect_le_scan_cleanup(struct hci_conn *conn, u8 status) in hci_connect_le_scan_cleanup() argument
74 struct hci_dev *hdev = conn->hdev; in hci_connect_le_scan_cleanup()
79 bdaddr = &conn->dst; in hci_connect_le_scan_cleanup()
80 bdaddr_type = conn->dst_type; in hci_connect_le_scan_cleanup()
94 if (params->conn) { in hci_connect_le_scan_cleanup()
95 hci_conn_drop(params->conn); in hci_connect_le_scan_cleanup()
96 hci_conn_put(params->conn); in hci_connect_le_scan_cleanup()
97 params->conn = NULL; in hci_connect_le_scan_cleanup()
110 mgmt_connect_failed(hdev, conn, status); in hci_connect_le_scan_cleanup()
[all …]
|
| H A D | hci_event.c | 165 struct hci_conn *conn; in hci_cc_role_discovery() local
174 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_role_discovery()
175 if (conn) in hci_cc_role_discovery()
176 conn->role = rp->role; in hci_cc_role_discovery()
187 struct hci_conn *conn; in hci_cc_read_link_policy() local
196 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_read_link_policy()
197 if (conn) in hci_cc_read_link_policy()
198 conn->link_policy = __le16_to_cpu(rp->policy); in hci_cc_read_link_policy()
209 struct hci_conn *conn; in hci_cc_write_link_policy() local
223 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_write_link_policy()
[all …]
|
| H A D | sco.c | 73 struct sco_conn *conn; member
82 struct sco_conn *conn = container_of(ref, struct sco_conn, ref); in sco_conn_free() local
84 BT_DBG("conn %p", conn); in sco_conn_free()
86 if (conn->sk) in sco_conn_free()
87 sco_pi(conn->sk)->conn = NULL; in sco_conn_free()
89 if (conn->hcon) { in sco_conn_free()
90 conn->hcon->sco_data = NULL; in sco_conn_free()
91 hci_conn_drop(conn in sco_conn_free()
100 sco_conn_put(struct sco_conn * conn) sco_conn_put() argument
110 sco_conn_hold(struct sco_conn * conn) sco_conn_hold() argument
118 sco_conn_hold_unless_zero(struct sco_conn * conn) sco_conn_hold_unless_zero() argument
131 sco_sock_hold(struct sco_conn * conn) sco_sock_hold() argument
143 struct sco_conn *conn = container_of(work, struct sco_conn, sco_sock_timeout() local
195 struct sco_conn *conn = hcon->sco_data; sco_conn_add() local
233 struct sco_conn *conn; sco_chan_del() local
256 struct sco_conn *conn = hcon->sco_data; sco_conn_del() local
283 __sco_chan_add(struct sco_conn * conn,struct sock * sk,struct sock * parent) __sco_chan_add() argument
295 sco_chan_add(struct sco_conn * conn,struct sock * sk,struct sock * parent) sco_chan_add() argument
312 struct sco_conn *conn; sco_connect() local
384 struct sco_conn *conn = sco_pi(sk)->conn; sco_send_frame() local
399 sco_recv_frame(struct sco_conn * conn,struct sk_buff * skb) sco_recv_frame() argument
827 sco_conn_defer_accept(struct hci_conn * conn,u16 setting) sco_conn_defer_accept() argument
1337 sco_conn_ready(struct sco_conn * conn) sco_conn_ready() argument
1433 struct sco_conn *conn; sco_connect_cfm() local
1456 struct sco_conn *conn = hcon->sco_data; sco_recv_scodata() local
[all...] |
| /linux/drivers/target/iscsi/ |
| 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_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_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.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 …]
|
| 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 …]
|
| /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 …]
|
| H A D | iscsi_tcp.c | 87 struct iscsi_conn *conn = rd_desc->arg.data; in iscsi_sw_tcp_recv() local
91 ISCSI_SW_TCP_DBG(conn, "in %d bytes\n", skb->len - offset); in iscsi_sw_tcp_recv()
95 consumed = iscsi_tcp_recv_skb(conn, skb, offset, 0, &status); in iscsi_sw_tcp_recv()
100 ISCSI_SW_TCP_DBG(conn, "read %d bytes status %d\n", in iscsi_sw_tcp_recv()
117 struct iscsi_conn *conn = sk->sk_user_data; in iscsi_sw_sk_state_check() local
120 (conn->session->state != ISCSI_STATE_LOGGING_OUT) && in iscsi_sw_sk_state_check()
122 ISCSI_SW_TCP_DBG(conn, "TCP_CLOSE|TCP_CLOSE_WAIT\n"); in iscsi_sw_sk_state_check()
123 iscsi_conn_failure(conn, ISCSI_ERR_TCP_CONN_CLOSE); in iscsi_sw_sk_state_check()
129 static void iscsi_sw_tcp_recv_data(struct iscsi_conn *conn) in iscsi_sw_tcp_recv_data() argument
131 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_sw_tcp_recv_data()
[all …]
|
| /linux/net/rds/ |
| H A D | connection.c | 90 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup()
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()
103 rdsdebug("returning conn in rds_conn_lookup()
89 struct rds_connection *conn, *ret = NULL; rds_conn_lookup() local
115 struct rds_connection *conn = cp->cp_conn; rds_conn_path_reset() local
130 __rds_conn_path_init(struct rds_connection * conn,struct rds_conn_path * cp,bool is_outgoing) __rds_conn_path_init() argument
168 struct rds_connection *conn, *parent = NULL; __rds_conn_create() local
369 struct rds_connection *conn = cp->cp_conn; rds_conn_shutdown() local
481 rds_conn_destroy(struct rds_connection * conn) rds_conn_destroy() argument
541 struct rds_connection *conn; rds_conn_message_info_cmn() local
660 struct rds_connection *conn; rds_for_each_conn_info() local
698 struct rds_connection *conn; rds_walk_conn_path_info() local
742 struct rds_connection *conn = cp->cp_conn; rds_conn_info_visitor() local
772 struct rds_connection *conn = cp->cp_conn; rds6_conn_info_visitor() local
893 rds_conn_drop(struct rds_connection * conn) rds_conn_drop() argument
920 rds_check_all_paths(struct rds_connection * conn) rds_check_all_paths() argument
929 rds_conn_connect_if_down(struct rds_connection * conn) rds_conn_connect_if_down() argument
[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/fs/notify/ |
| H A D | mark.c | 117 static __u32 *fsnotify_conn_mask_p(struct fsnotify_mark_connector *conn) in fsnotify_conn_mask_p() argument
119 if (conn->type == FSNOTIFY_OBJ_TYPE_INODE) in fsnotify_conn_mask_p()
120 return &fsnotify_conn_inode(conn)->i_fsnotify_mask; in fsnotify_conn_mask_p()
121 else if (conn->type == FSNOTIFY_OBJ_TYPE_VFSMOUNT) in fsnotify_conn_mask_p()
122 return &fsnotify_conn_mount(conn)->mnt_fsnotify_mask; in fsnotify_conn_mask_p()
123 else if (conn->type == FSNOTIFY_OBJ_TYPE_SB) in fsnotify_conn_mask_p()
124 return &fsnotify_conn_sb(conn)->s_fsnotify_mask; in fsnotify_conn_mask_p()
125 else if (conn->type == FSNOTIFY_OBJ_TYPE_MNTNS) in fsnotify_conn_mask_p()
126 return &fsnotify_conn_mntns(conn)->n_fsnotify_mask; in fsnotify_conn_mask_p()
130 __u32 fsnotify_conn_mask(struct fsnotify_mark_connector *conn) in fsnotify_conn_mask() argument
[all …]
|