/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() 119 (atomic_read(&conn->sndbuf_space) && in smc_tx_wait() 120 !conn->urg_tx_pend), in smc_tx_wait() [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 …]
|
/linux/fs/smb/server/ |
H A D | connection.c | 33 void ksmbd_conn_free(struct ksmbd_conn *conn) in ksmbd_conn_free() argument 36 list_del(&conn->conns_list); 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 kfree(conn); in ksmbd_conn_free() 53 struct ksmbd_conn *conn; in ksmbd_conn_alloc() local 55 conn = kzalloc(sizeof(struct ksmbd_conn), KSMBD_DEFAULT_GFP); in ksmbd_conn_alloc() 56 if (!conn) in ksmbd_conn_alloc() [all …]
|
H A D | connection.h | 113 int (*process_fn)(struct ksmbd_conn *conn); 114 int (*terminate_fn)(struct ksmbd_conn *conn); 137 struct ksmbd_conn *conn; member 148 bool ksmbd_conn_alive(struct ksmbd_conn *conn); 149 void ksmbd_conn_wait_idle(struct ksmbd_conn *conn); 152 void ksmbd_conn_free(struct ksmbd_conn *conn); 155 int ksmbd_conn_rdma_read(struct ksmbd_conn *conn, 159 int ksmbd_conn_rdma_write(struct ksmbd_conn *conn, 169 void ksmbd_conn_lock(struct ksmbd_conn *conn); 170 void ksmbd_conn_unlock(struct ksmbd_conn *conn); [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/bluetooth/ |
H A D | hci_conn.c | 47 struct hci_conn *conn; member 70 void hci_connect_le_scan_cleanup(struct hci_conn *conn, u8 status) in hci_connect_le_scan_cleanup() argument 73 struct hci_dev *hdev = conn->hdev; in hci_connect_le_scan_cleanup() 78 bdaddr = &conn->dst; in hci_connect_le_scan_cleanup() 79 bdaddr_type = conn->dst_type; in hci_connect_le_scan_cleanup() 93 if (params->conn) { in hci_connect_le_scan_cleanup() 94 hci_conn_drop(params->conn); in hci_connect_le_scan_cleanup() 95 hci_conn_put(params->conn); in hci_connect_le_scan_cleanup() 96 params->conn = NULL; in hci_connect_le_scan_cleanup() 109 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->hcon); in sco_conn_free() 95 disable_delayed_work_sync(&conn->timeout_work); in sco_conn_free() 97 kfree(conn); in sco_conn_free() [all …]
|
/linux/drivers/target/iscsi/ |
H A D | iscsi_target_login.c | 38 static struct iscsi_login *iscsi_login_init_conn(struct iscsit_conn *conn) in iscsi_login_init_conn() argument 47 conn->login = login; in iscsi_login_init_conn() 48 login->conn = conn; in iscsi_login_init_conn() 63 conn->conn_login = login; in iscsi_login_init_conn() 78 int iscsi_login_setup_crypto(struct iscsit_conn *conn) in iscsi_login_setup_crypto() argument 93 conn->conn_rx_hash = ahash_request_alloc(tfm, GFP_KERNEL); in iscsi_login_setup_crypto() 94 if (!conn->conn_rx_hash) { in iscsi_login_setup_crypto() 99 ahash_request_set_callback(conn->conn_rx_hash, 0, NULL, NULL); in iscsi_login_setup_crypto() 101 conn->conn_tx_hash = ahash_request_alloc(tfm, GFP_KERNEL); in iscsi_login_setup_crypto() 102 if (!conn->conn_tx_hash) { in iscsi_login_setup_crypto() [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() 513 iscsit_do_crypto_hash_buf(conn->conn_tx_hash, hdr, in iscsit_xmit_nondatain_pdu() 539 if (conn->conn_ops->DataDigest) { in iscsit_xmit_nondatain_pdu() 540 iscsit_do_crypto_hash_buf(conn->conn_tx_hash, 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/rxrpc/ |
H A D | conn_event.c | 22 static bool rxrpc_set_conn_aborted(struct rxrpc_connection *conn, struct sk_buff *skb, in rxrpc_set_conn_aborted() argument 28 if (conn->state != RXRPC_CONN_ABORTED) { in rxrpc_set_conn_aborted() 29 spin_lock(&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 | rxkad.c | 42 static int rxkad_prime_packet_security(struct rxrpc_connection *conn, 100 static int rxkad_init_connection_security(struct rxrpc_connection *conn, in rxkad_init_connection_security() argument 106 _enter("{%d},{%x}", conn->debug_id, key_serial(conn->key)); in rxkad_init_connection_security() 108 conn->security_ix = token->security_index; in rxkad_init_connection_security() 121 switch (conn->security_level) { in rxkad_init_connection_security() 131 ret = rxkad_prime_packet_security(conn, ci); in rxkad_init_connection_security() 135 conn->rxkad.cipher = ci; in rxkad_init_connection_security() 155 switch (call->conn->security_level) { in rxkad_alloc_txbuf() 183 static int rxkad_prime_packet_security(struct rxrpc_connection *conn, in rxkad_prime_packet_security() argument 195 if (!conn->key) in rxkad_prime_packet_security() [all …]
|
/linux/drivers/gpu/drm/bridge/ |
H A D | display-connector.c | 45 struct display_connector *conn = to_display_connector(bridge); in display_connector_detect() local 47 if (conn->hpd_gpio) { in display_connector_detect() 48 if (gpiod_get_value_cansleep(conn->hpd_gpio)) in display_connector_detect() 54 if (conn->bridge.ddc && drm_probe_ddc(conn->bridge.ddc)) in display_connector_detect() 57 switch (conn->bridge.type) { in display_connector_detect() 87 struct display_connector *conn = to_display_connector(bridge); in display_connector_edid_read() local 89 return drm_edid_read_ddc(connector, conn->bridge.ddc); in display_connector_edid_read() 109 struct drm_connector *conn = conn_state->connector; in display_connector_get_output_bus_fmts() local 117 if (conn->display_info.num_bus_formats && in display_connector_get_output_bus_fmts() 118 conn->display_info.bus_formats) in display_connector_get_output_bus_fmts() [all …]
|
/linux/net/rds/ |
H A D | connection.c | 89 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup() local 91 hlist_for_each_entry_rcu(conn, head, c_hash_node) { in rds_conn_lookup() 92 if (ipv6_addr_equal(&conn->c_faddr, faddr) && in rds_conn_lookup() 93 ipv6_addr_equal(&conn->c_laddr, laddr) && in rds_conn_lookup() 94 conn->c_trans == trans && in rds_conn_lookup() 95 conn->c_tos == tos && in rds_conn_lookup() 96 net == rds_conn_net(conn) && in rds_conn_lookup() 97 conn->c_dev_if == dev_if) { in rds_conn_lookup() 98 ret = conn; in rds_conn_lookup() 115 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 …]
|
H A D | iscsi_tcp.c | 88 struct iscsi_conn *conn = rd_desc->arg.data; in iscsi_sw_tcp_recv() local 92 ISCSI_SW_TCP_DBG(conn, "in %d bytes\n", skb->len - offset); in iscsi_sw_tcp_recv() 96 consumed = iscsi_tcp_recv_skb(conn, skb, offset, 0, &status); in iscsi_sw_tcp_recv() 101 ISCSI_SW_TCP_DBG(conn, "read %d bytes status %d\n", in iscsi_sw_tcp_recv() 118 struct iscsi_conn *conn = sk->sk_user_data; in iscsi_sw_sk_state_check() local 121 (conn->session->state != ISCSI_STATE_LOGGING_OUT) && in iscsi_sw_sk_state_check() 123 ISCSI_SW_TCP_DBG(conn, "TCP_CLOSE|TCP_CLOSE_WAIT\n"); in iscsi_sw_sk_state_check() 124 iscsi_conn_failure(conn, ISCSI_ERR_TCP_CONN_CLOSE); in iscsi_sw_sk_state_check() 130 static void iscsi_sw_tcp_recv_data(struct iscsi_conn *conn) in iscsi_sw_tcp_recv_data() argument 132 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_sw_tcp_recv_data() [all …]
|