| /linux-2.6.39/net/rds/ |
| D | threads.c | 73 void rds_connect_complete(struct rds_connection *conn) in rds_connect_complete() argument
75 if (!rds_conn_transition(conn, RDS_CONN_CONNECTING, RDS_CONN_UP)) { in rds_connect_complete()
79 atomic_read(&conn->c_state)); in rds_connect_complete()
80 atomic_set(&conn->c_state, RDS_CONN_ERROR); in rds_connect_complete()
81 queue_work(rds_wq, &conn->c_down_w); in rds_connect_complete()
86 conn, &conn->c_laddr, &conn->c_faddr); in rds_connect_complete()
88 conn->c_reconnect_jiffies = 0; in rds_connect_complete()
89 set_bit(0, &conn->c_map_queued); in rds_connect_complete()
90 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_connect_complete()
91 queue_delayed_work(rds_wq, &conn->c_recv_w, 0); in rds_connect_complete()
[all …]
|
| D | connection.c | 70 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup() local
73 hlist_for_each_entry_rcu(conn, pos, 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 | send.c | 61 void rds_send_reset(struct rds_connection *conn) in rds_send_reset() argument
66 if (conn->c_xmit_rm) { in rds_send_reset()
67 rm = conn->c_xmit_rm; in rds_send_reset()
68 conn->c_xmit_rm = NULL; in rds_send_reset()
77 conn->c_xmit_sg = 0; in rds_send_reset()
78 conn->c_xmit_hdr_off = 0; in rds_send_reset()
79 conn->c_xmit_data_off = 0; in rds_send_reset()
80 conn->c_xmit_atomic_sent = 0; in rds_send_reset()
81 conn->c_xmit_rdma_sent = 0; in rds_send_reset()
82 conn->c_xmit_data_sent = 0; in rds_send_reset()
[all …]
|
| D | ib_cm.c | 74 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol() argument
76 conn->c_version = version; in rds_ib_set_protocol()
82 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control() argument
84 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_set_flow_control()
89 rds_ib_send_add_credits(conn, credits); in rds_ib_set_flow_control()
124 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete() argument
127 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_connect_complete()
131 if (event->param.conn.private_data_len >= sizeof(*dp)) { in rds_ib_cm_connect_complete()
132 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete()
136 rds_ib_set_protocol(conn, in rds_ib_cm_connect_complete()
[all …]
|
| D | iw_cm.c | 44 static void rds_iw_set_protocol(struct rds_connection *conn, unsigned int version) in rds_iw_set_protocol() argument
46 conn->c_version = version; in rds_iw_set_protocol()
52 static void rds_iw_set_flow_control(struct rds_connection *conn, u32 credits) in rds_iw_set_flow_control() argument
54 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_set_flow_control()
59 rds_iw_send_add_credits(conn, credits); in rds_iw_set_flow_control()
69 void rds_iw_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_iw_cm_connect_complete() argument
72 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_cm_connect_complete()
76 if (event->param.conn.private_data_len) { in rds_iw_cm_connect_complete()
77 dp = event->param.conn.private_data; in rds_iw_cm_connect_complete()
79 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_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 …]
|
| /linux-2.6.39/net/bluetooth/ |
| D | hci_conn.c | 48 static void hci_le_connect(struct hci_conn *conn) in hci_le_connect() argument
50 struct hci_dev *hdev = conn->hdev; in hci_le_connect()
53 conn->state = BT_CONNECT; in hci_le_connect()
54 conn->out = 1; in hci_le_connect()
55 conn->link_mode |= HCI_LM_MASTER; in hci_le_connect()
60 bacpy(&cp.peer_addr, &conn->dst); in hci_le_connect()
70 static void hci_le_connect_cancel(struct hci_conn *conn) in hci_le_connect_cancel() argument
72 hci_send_cmd(conn->hdev, HCI_OP_LE_CREATE_CONN_CANCEL, 0, NULL); in hci_le_connect_cancel()
75 void hci_acl_connect(struct hci_conn *conn) in hci_acl_connect() argument
77 struct hci_dev *hdev = conn->hdev; in hci_acl_connect()
[all …]
|
| D | hci_event.c | 88 struct hci_conn *conn; in hci_cc_role_discovery() local
97 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_role_discovery()
98 if (conn) { in hci_cc_role_discovery()
100 conn->link_mode &= ~HCI_LM_MASTER; in hci_cc_role_discovery()
102 conn->link_mode |= HCI_LM_MASTER; in hci_cc_role_discovery()
111 struct hci_conn *conn; in hci_cc_read_link_policy() local
120 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_read_link_policy()
121 if (conn) in hci_cc_read_link_policy()
122 conn->link_policy = __le16_to_cpu(rp->policy); in hci_cc_read_link_policy()
130 struct hci_conn *conn; in hci_cc_write_link_policy() local
[all …]
|
| D | l2cap_core.c | 71 static struct sk_buff *l2cap_build_cmd(struct l2cap_conn *conn,
172 static void __l2cap_chan_add(struct l2cap_conn *conn, struct sock *sk, struct sock *parent) in __l2cap_chan_add() argument
174 struct l2cap_chan_list *l = &conn->chan_list; in __l2cap_chan_add()
176 BT_DBG("conn %p, psm 0x%2.2x, dcid 0x%4.4x", conn, in __l2cap_chan_add()
179 conn->disc_reason = 0x13; in __l2cap_chan_add()
181 l2cap_pi(sk)->conn = conn; in __l2cap_chan_add()
184 if (conn->hcon->type == LE_LINK) { in __l2cap_chan_add()
216 struct l2cap_conn *conn = l2cap_pi(sk)->conn; in l2cap_chan_del() local
221 BT_DBG("sk %p, conn %p, err %d", sk, conn, err); in l2cap_chan_del()
223 if (conn) { in l2cap_chan_del()
[all …]
|
| D | sco.c | 61 static void __sco_chan_add(struct sco_conn *conn, struct sock *sk, struct sock *parent);
64 static int sco_conn_del(struct hci_conn *conn, int err);
101 struct sco_conn *conn = hcon->sco_data; in sco_conn_add() local
103 if (conn || status) in sco_conn_add()
104 return conn; in sco_conn_add()
106 conn = kzalloc(sizeof(struct sco_conn), GFP_ATOMIC); in sco_conn_add()
107 if (!conn) in sco_conn_add()
110 spin_lock_init(&conn->lock); in sco_conn_add()
112 hcon->sco_data = conn; in sco_conn_add()
113 conn->hcon = hcon; in sco_conn_add()
[all …]
|
| /linux-2.6.39/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 | 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 | 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 …]
|
| /linux-2.6.39/drivers/scsi/ |
| D | libiscsi.c | 103 inline void iscsi_conn_queue_work(struct iscsi_conn *conn) in iscsi_conn_queue_work() argument
105 struct Scsi_Host *shost = conn->session->host; in iscsi_conn_queue_work()
109 queue_work(ihost->workq, &conn->xmitwork); in iscsi_conn_queue_work()
162 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() local
176 if (left > conn->max_xmit_dlength) { in iscsi_prep_data_out_pdu()
177 hton24(hdr->dlength, conn->max_xmit_dlength); in iscsi_prep_data_out_pdu()
178 r2t->data_count = conn->max_xmit_dlength; in iscsi_prep_data_out_pdu()
185 conn->dataout_pdus_cnt++; in iscsi_prep_data_out_pdu()
235 ISCSI_DBG_SESSION(task->conn->session, in iscsi_prep_ecdb_ahs()
261 ISCSI_DBG_SESSION(task->conn->session, in iscsi_prep_bidi_ahs()
[all …]
|
| D | libiscsi_tcp.c | 414 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_data_recv_done() local
420 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr, in iscsi_tcp_data_recv_done()
421 conn->data, tcp_conn->in.datalen); in iscsi_tcp_data_recv_done()
432 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_data_recv_prep() local
435 if (conn->datadgst_en && in iscsi_tcp_data_recv_prep()
436 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD)) in iscsi_tcp_data_recv_prep()
440 conn->data, tcp_conn->in.datalen, in iscsi_tcp_data_recv_prep()
463 ISCSI_DBG_TCP(task->conn, "pending r2t dropped\n"); in iscsi_tcp_cleanup_task()
480 static int iscsi_tcp_data_in(struct iscsi_conn *conn, struct iscsi_task *task) in iscsi_tcp_data_in() argument
482 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_tcp_data_in()
[all …]
|
| D | iscsi_tcp.c | 85 struct iscsi_conn *conn = rd_desc->arg.data; in iscsi_sw_tcp_recv() local
89 ISCSI_SW_TCP_DBG(conn, "in %d bytes\n", skb->len - offset); in iscsi_sw_tcp_recv()
93 consumed = iscsi_tcp_recv_skb(conn, skb, offset, 0, &status); in iscsi_sw_tcp_recv()
98 ISCSI_SW_TCP_DBG(conn, "read %d bytes status %d\n", in iscsi_sw_tcp_recv()
113 struct iscsi_conn *conn = (struct iscsi_conn*)sk->sk_user_data; in iscsi_sw_sk_state_check() local
117 ISCSI_SW_TCP_DBG(conn, "TCP_CLOSE|TCP_CLOSE_WAIT\n"); in iscsi_sw_sk_state_check()
118 iscsi_conn_failure(conn, ISCSI_ERR_TCP_CONN_CLOSE); in iscsi_sw_sk_state_check()
126 struct iscsi_conn *conn = sk->sk_user_data; in iscsi_sw_tcp_data_ready() local
127 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_sw_tcp_data_ready()
138 rd_desc.arg.data = conn; in iscsi_sw_tcp_data_ready()
[all …]
|
| /linux-2.6.39/drivers/s390/net/ |
| D | netiucv.c | 242 struct iucv_connection *conn; member
253 struct iucv_connection *conn; member
535 struct iucv_connection *conn = path->private; in netiucv_callback_rx() local
538 ev.conn = conn; in netiucv_callback_rx()
540 fsm_event(conn->fsm, CONN_EVENT_RX, &ev); in netiucv_callback_rx()
546 struct iucv_connection *conn = path->private; in netiucv_callback_txdone() local
549 ev.conn = conn; in netiucv_callback_txdone()
551 fsm_event(conn->fsm, CONN_EVENT_TXDONE, &ev); in netiucv_callback_txdone()
556 struct iucv_connection *conn = path->private; in netiucv_callback_connack() local
558 fsm_event(conn->fsm, CONN_EVENT_CONN_ACK, conn); in netiucv_callback_connack()
[all …]
|
| /linux-2.6.39/include/net/bluetooth/ |
| D | hci_core.h | 252 void (*connect_cfm_cb) (struct hci_conn *conn, u8 status);
253 void (*security_cfm_cb) (struct hci_conn *conn, u8 status);
254 void (*disconn_cfm_cb) (struct hci_conn *conn, u8 reason);
398 void hci_acl_connect(struct hci_conn *conn);
399 void hci_acl_disconn(struct hci_conn *conn, __u8 reason);
400 void hci_add_sco(struct hci_conn *conn, __u16 handle);
401 void hci_setup_sync(struct hci_conn *conn, __u16 handle);
402 void hci_sco_setup(struct hci_conn *conn, __u8 status);
405 int hci_conn_del(struct hci_conn *conn);
410 int hci_conn_check_link_mode(struct hci_conn *conn);
[all …]
|
| /linux-2.6.39/arch/um/drivers/ |
| D | port_kern.c | 47 struct connection *conn = data; in pipe_interrupt() local
50 fd = os_rcv_fd(conn->socket[0], &conn->helper_pid); in pipe_interrupt()
57 os_close_file(conn->fd); in pipe_interrupt()
60 list_del(&conn->list); in pipe_interrupt()
62 conn->fd = fd; in pipe_interrupt()
63 list_add(&conn->list, &conn->port->connections); in pipe_interrupt()
65 complete(&conn->port->done); in pipe_interrupt()
78 struct connection *conn; in port_accept() local
89 conn = kmalloc(sizeof(*conn), GFP_ATOMIC); in port_accept()
90 if (conn == NULL) { in port_accept()
[all …]
|
| D | vde_user.c | 18 VDECONN *conn = NULL; in vde_user_init() local
23 conn = vde_open(pri->vde_switch, pri->descr, pri->args); in vde_user_init()
25 if (conn == NULL) { in vde_user_init()
34 pri->conn = conn; in vde_user_init()
43 if (pri->conn != NULL) in vde_user_open()
44 return vde_datafd(pri->conn); in vde_user_open()
54 if (pri->conn != NULL) { in vde_remove()
56 vde_close(pri->conn); in vde_remove()
57 pri->conn = NULL; in vde_remove()
98 int vde_user_read(void *conn, void *buf, int len) in vde_user_read() argument
[all …]
|
| /linux-2.6.39/net/wireless/ |
| D | sme.c | 90 if (wdev->conn->params.channel) { in cfg80211_conn_scan()
108 if (wdev->conn->params.channel) in cfg80211_conn_scan()
109 request->channels[0] = wdev->conn->params.channel; in cfg80211_conn_scan()
127 memcpy(request->ssids[0].ssid, wdev->conn->params.ssid, in cfg80211_conn_scan()
128 wdev->conn->params.ssid_len); in cfg80211_conn_scan()
129 request->ssids[0].ssid_len = wdev->conn->params.ssid_len; in cfg80211_conn_scan()
138 wdev->conn->state = CFG80211_CONN_SCANNING; in cfg80211_conn_scan()
157 if (!wdev->conn) in cfg80211_conn_do_work()
160 params = &wdev->conn->params; in cfg80211_conn_do_work()
162 switch (wdev->conn->state) { in cfg80211_conn_do_work()
[all …]
|
| /linux-2.6.39/fs/ocfs2/ |
| D | stack_o2cb.c | 199 static int o2cb_dlm_lock(struct ocfs2_cluster_connection *conn, in o2cb_dlm_lock() argument
211 status = dlmlock(conn->cc_lockspace, o2dlm_mode, &lksb->lksb_o2dlm, in o2cb_dlm_lock()
219 static int o2cb_dlm_unlock(struct ocfs2_cluster_connection *conn, in o2cb_dlm_unlock() argument
227 status = dlmunlock(conn->cc_lockspace, &lksb->lksb_o2dlm, in o2cb_dlm_unlock()
264 struct ocfs2_cluster_connection *conn = data; in o2dlm_eviction_cb() local
267 node_num, conn->cc_namelen, conn->cc_name); in o2dlm_eviction_cb()
269 conn->cc_recovery_handler(node_num, conn->cc_recovery_data); in o2dlm_eviction_cb()
272 static int o2cb_cluster_connect(struct ocfs2_cluster_connection *conn) in o2cb_cluster_connect() argument
280 BUG_ON(conn == NULL); in o2cb_cluster_connect()
281 BUG_ON(conn->cc_proto == NULL); in o2cb_cluster_connect()
[all …]
|
| /linux-2.6.39/drivers/infiniband/ulp/iser/ |
| D | iscsi_iser.c | 95 iscsi_iser_recv(struct iscsi_conn *conn, in iscsi_iser_recv() argument
114 rc = iscsi_complete_pdu(conn, hdr, rx_data, rx_data_len); in iscsi_iser_recv()
120 iscsi_conn_failure(conn, rc); in iscsi_iser_recv()
135 struct iscsi_iser_conn *iser_conn = task->conn->dd_data; in iser_initialize_task_headers()
190 iscsi_iser_mtask_xmit(struct iscsi_conn *conn, struct iscsi_task *task) in iscsi_iser_mtask_xmit() argument
194 iser_dbg("mtask xmit [cid %d itt 0x%x]\n", conn->id, task->itt); in iscsi_iser_mtask_xmit()
196 error = iser_send_control(conn, task); in iscsi_iser_mtask_xmit()
208 iscsi_iser_task_xmit_unsol_data(struct iscsi_conn *conn, in iscsi_iser_task_xmit_unsol_data() argument
223 error = iser_send_data_out(conn, task, &hdr); in iscsi_iser_task_xmit_unsol_data()
240 struct iscsi_conn *conn = task->conn; in iscsi_iser_task_xmit() local
[all …]
|