Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 200 of 244) sorted by relevance

12

/linux-4.1.27/net/bluetooth/
Dhci_conn.c62 static void hci_le_create_connection_cancel(struct hci_conn *conn) in hci_le_create_connection_cancel() argument
64 hci_send_cmd(conn->hdev, HCI_OP_LE_CREATE_CONN_CANCEL, 0, NULL); in hci_le_create_connection_cancel()
67 static void hci_acl_create_connection(struct hci_conn *conn) in hci_acl_create_connection() argument
69 struct hci_dev *hdev = conn->hdev; in hci_acl_create_connection()
73 BT_DBG("hcon %p", conn); in hci_acl_create_connection()
75 conn->state = BT_CONNECT; in hci_acl_create_connection()
76 conn->out = true; in hci_acl_create_connection()
77 conn->role = HCI_ROLE_MASTER; in hci_acl_create_connection()
79 conn->attempt++; in hci_acl_create_connection()
81 conn->link_policy = hdev->link_policy; in hci_acl_create_connection()
[all …]
Dhci_event.c99 struct hci_conn *conn; in hci_cc_role_discovery() local
108 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_role_discovery()
109 if (conn) in hci_cc_role_discovery()
110 conn->role = rp->role; in hci_cc_role_discovery()
118 struct hci_conn *conn; in hci_cc_read_link_policy() local
127 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_read_link_policy()
128 if (conn) in hci_cc_read_link_policy()
129 conn->link_policy = __le16_to_cpu(rp->policy); in hci_cc_read_link_policy()
137 struct hci_conn *conn; in hci_cc_write_link_policy() local
151 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_write_link_policy()
[all …]
Dhci_sysfs.c29 struct hci_conn *conn = to_hci_conn(dev); in show_link_type() local
30 return sprintf(buf, "%s\n", link_typetostr(conn->type)); in show_link_type()
36 struct hci_conn *conn = to_hci_conn(dev); in show_link_address() local
37 return sprintf(buf, "%pMR\n", &conn->dst); in show_link_address()
56 struct hci_conn *conn = to_hci_conn(dev); in bt_link_release() local
57 kfree(conn); in bt_link_release()
76 void hci_conn_init_sysfs(struct hci_conn *conn) in hci_conn_init_sysfs() argument
78 struct hci_dev *hdev = conn->hdev; in hci_conn_init_sysfs()
80 BT_DBG("conn %p", conn); in hci_conn_init_sysfs()
82 conn->dev.type = &bt_link; in hci_conn_init_sysfs()
[all …]
Dl2cap_core.c56 static struct sk_buff *l2cap_build_cmd(struct l2cap_conn *conn,
58 static void l2cap_send_cmd(struct l2cap_conn *conn, u8 ident, u8 code, u16 len,
90 static struct l2cap_chan *__l2cap_get_chan_by_dcid(struct l2cap_conn *conn, in __l2cap_get_chan_by_dcid() argument
95 list_for_each_entry(c, &conn->chan_l, list) { in __l2cap_get_chan_by_dcid()
102 static struct l2cap_chan *__l2cap_get_chan_by_scid(struct l2cap_conn *conn, in __l2cap_get_chan_by_scid() argument
107 list_for_each_entry(c, &conn->chan_l, list) { in __l2cap_get_chan_by_scid()
116 static struct l2cap_chan *l2cap_get_chan_by_scid(struct l2cap_conn *conn, in l2cap_get_chan_by_scid() argument
121 mutex_lock(&conn->chan_lock); in l2cap_get_chan_by_scid()
122 c = __l2cap_get_chan_by_scid(conn, cid); in l2cap_get_chan_by_scid()
125 mutex_unlock(&conn->chan_lock); in l2cap_get_chan_by_scid()
[all …]
Dsco.c68 struct sco_conn *conn; member
106 struct sco_conn *conn = hcon->sco_data; in sco_conn_add() local
108 if (conn) in sco_conn_add()
109 return conn; in sco_conn_add()
111 conn = kzalloc(sizeof(struct sco_conn), GFP_KERNEL); in sco_conn_add()
112 if (!conn) in sco_conn_add()
115 spin_lock_init(&conn->lock); in sco_conn_add()
117 hcon->sco_data = conn; in sco_conn_add()
118 conn->hcon = hcon; in sco_conn_add()
121 conn->mtu = hdev->sco_mtu; in sco_conn_add()
[all …]
Dsmp.c89 struct l2cap_conn *conn; member
584 static void smp_send_cmd(struct l2cap_conn *conn, u8 code, u16 len, void *data) in smp_send_cmd() argument
586 struct l2cap_chan *chan = conn->smp; in smp_send_cmd()
642 static void build_pairing_cmd(struct l2cap_conn *conn, in build_pairing_cmd() argument
646 struct l2cap_chan *chan = conn->smp; in build_pairing_cmd()
648 struct hci_conn *hcon = conn->hcon; in build_pairing_cmd()
697 req->io_capability = conn->hcon->io_capability; in build_pairing_cmd()
708 rsp->io_capability = conn->hcon->io_capability; in build_pairing_cmd()
718 static u8 check_enc_key_size(struct l2cap_conn *conn, __u8 max_key_size) in check_enc_key_size() argument
720 struct l2cap_chan *chan = conn->smp; in check_enc_key_size()
[all …]
D6lowpan.c154 struct l2cap_conn *conn) in __peer_lookup_conn() argument
159 if (peer->chan->conn == conn) in __peer_lookup_conn()
224 static struct lowpan_peer *lookup_peer(struct l2cap_conn *conn) in lookup_peer() argument
232 peer = __peer_lookup_conn(entry, conn); in lookup_peer()
242 static struct lowpan_dev *lookup_dev(struct l2cap_conn *conn) in lookup_dev() argument
250 if (conn->hcon->hdev == entry->hdev) { in lookup_dev()
399 peer = lookup_peer(chan->conn); in chan_recv_cb()
403 dev = lookup_dev(chan->conn); in chan_recv_cb()
859 SET_NETDEV_DEV(netdev, &chan->conn->hcon->dev); in setup_netdev()
876 (*dev)->hdev = chan->conn->hcon->hdev; in setup_netdev()
[all …]
Damp.c174 int phylink_gen_key(struct hci_conn *conn, u8 *data, u8 *len, u8 *type) in phylink_gen_key() argument
176 struct hci_dev *hdev = conn->hdev; in phylink_gen_key()
182 if (!hci_conn_check_link_mode(conn)) in phylink_gen_key()
185 BT_DBG("conn %p key_type %d", conn, conn->key_type); in phylink_gen_key()
188 if (conn->key_type < 3) { in phylink_gen_key()
189 BT_ERR("Legacy key type %d", conn->key_type); in phylink_gen_key()
193 *type = conn->key_type; in phylink_gen_key()
196 key = hci_find_link_key(hdev, &conn->dst); in phylink_gen_key()
198 BT_DBG("No Link key for conn %p dst %pMR", conn, &conn->dst); in phylink_gen_key()
213 if (conn->key_type == HCI_LK_DEBUG_COMBINATION) { in phylink_gen_key()
[all …]
Dhci_core.c1545 if (p->conn) { in hci_pend_le_actions_clear()
1546 hci_conn_drop(p->conn); in hci_pend_le_actions_clear()
1547 hci_conn_put(p->conn); in hci_pend_le_actions_clear()
1548 p->conn = NULL; in hci_pend_le_actions_clear()
2210 static bool hci_persistent_key(struct hci_dev *hdev, struct hci_conn *conn, in hci_persistent_key() argument
2226 if (!conn) in hci_persistent_key()
2230 if (conn->type == LE_LINK) in hci_persistent_key()
2234 if (conn->auth_type > 0x01 && conn->remote_auth > 0x01) in hci_persistent_key()
2238 if (conn->auth_type == 0x02 || conn->auth_type == 0x03) in hci_persistent_key()
2242 if (conn->remote_auth == 0x02 || conn->remote_auth == 0x03) in hci_persistent_key()
[all …]
Da2mp.c246 struct l2cap_conn *conn = mgr->l2cap_conn; in a2mp_discover_rsp() local
249 mutex_lock(&conn->chan_lock); in a2mp_discover_rsp()
251 list_for_each_entry(chan, &conn->chan_l, list) { in a2mp_discover_rsp()
267 mutex_unlock(&conn->chan_lock); in a2mp_discover_rsp()
743 static struct l2cap_chan *a2mp_chan_open(struct l2cap_conn *conn, bool locked) in a2mp_chan_open() argument
783 __l2cap_chan_add(conn, chan); in a2mp_chan_open()
785 l2cap_chan_add(conn, chan); in a2mp_chan_open()
826 static struct amp_mgr *amp_mgr_create(struct l2cap_conn *conn, bool locked) in amp_mgr_create() argument
835 BT_DBG("conn %p mgr %p", conn, mgr); in amp_mgr_create()
837 mgr->l2cap_conn = conn; in amp_mgr_create()
[all …]
Dmgmt.c1488 struct hci_conn *conn; in clean_up_hci_state() local
1508 list_for_each_entry(conn, &hdev->conn_hash.list, list) { in clean_up_hci_state()
1512 switch (conn->state) { in clean_up_hci_state()
1515 dc.handle = cpu_to_le16(conn->handle); in clean_up_hci_state()
1520 if (conn->type == LE_LINK) in clean_up_hci_state()
1523 else if (conn->type == ACL_LINK) in clean_up_hci_state()
1525 6, &conn->dst); in clean_up_hci_state()
1528 bacpy(&rej.bdaddr, &conn->dst); in clean_up_hci_state()
1530 if (conn->type == ACL_LINK) in clean_up_hci_state()
1533 else if (conn->type == SCO_LINK) in clean_up_hci_state()
[all …]
Dhci_request.c422 struct hci_conn *conn; in disconnected_whitelist_entries() local
424 conn = hci_conn_hash_lookup_ba(hdev, ACL_LINK, &b->bdaddr); in disconnected_whitelist_entries()
425 if (!conn) in disconnected_whitelist_entries()
428 if (conn->state != BT_CONNECTED && conn->state != BT_CONFIG) in disconnected_whitelist_entries()
482 struct hci_conn *conn; in __hci_update_background_scan() local
532 conn = hci_conn_hash_lookup_state(hdev, LE_LINK, BT_CONNECT); in __hci_update_background_scan()
533 if (conn) in __hci_update_background_scan()
Dhci_debugfs.h28 void hci_debugfs_create_conn(struct hci_conn *conn);
44 static inline void hci_debugfs_create_conn(struct hci_conn *conn) in hci_debugfs_create_conn() argument
Dl2cap_sock.c476 cinfo.hci_handle = chan->conn->hcon->handle; in l2cap_sock_getsockopt_old()
477 memcpy(cinfo.dev_class, chan->conn->hcon->dev_class, 3); in l2cap_sock_getsockopt_old()
526 if (chan->conn) { in l2cap_sock_getsockopt()
527 sec.level = chan->conn->hcon->sec_level; in l2cap_sock_getsockopt()
530 sec.key_size = chan->conn->hcon->enc_key_size; in l2cap_sock_getsockopt()
749 struct l2cap_conn *conn; in l2cap_sock_setsockopt() local
788 if (!chan->conn) in l2cap_sock_setsockopt()
791 conn = chan->conn; in l2cap_sock_setsockopt()
795 if (smp_conn_security(conn->hcon, sec.level)) in l2cap_sock_setsockopt()
846 conn = chan->conn; in l2cap_sock_setsockopt()
[all …]
Da2mp.h134 struct l2cap_chan *a2mp_channel_create(struct l2cap_conn *conn,
Dsmp.h186 int smp_user_confirm_reply(struct hci_conn *conn, u16 mgmt_op, __le32 passkey);
Dhci_debugfs.c1132 void hci_debugfs_create_conn(struct hci_conn *conn) in hci_debugfs_create_conn() argument
1134 struct hci_dev *hdev = conn->hdev; in hci_debugfs_create_conn()
1140 snprintf(name, sizeof(name), "%u", conn->handle); in hci_debugfs_create_conn()
1141 conn->debugfs = debugfs_create_dir(name, hdev->debugfs); in hci_debugfs_create_conn()
/linux-4.1.27/net/rds/
Dthreads.c74 void rds_connect_complete(struct rds_connection *conn) in rds_connect_complete() argument
76 if (!rds_conn_transition(conn, RDS_CONN_CONNECTING, RDS_CONN_UP)) { in rds_connect_complete()
80 atomic_read(&conn->c_state)); in rds_connect_complete()
81 rds_conn_drop(conn); 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()
113 void rds_queue_reconnect(struct rds_connection *conn) in rds_queue_reconnect() argument
[all …]
Dconnection.c77 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup() local
79 hlist_for_each_entry_rcu(conn, head, c_hash_node) { in rds_conn_lookup()
80 if (conn->c_faddr == faddr && conn->c_laddr == laddr && in rds_conn_lookup()
81 conn->c_trans == trans) { in rds_conn_lookup()
82 ret = conn; in rds_conn_lookup()
97 static void rds_conn_reset(struct rds_connection *conn) in rds_conn_reset() argument
100 &conn->c_laddr, &conn->c_faddr); in rds_conn_reset()
103 rds_send_reset(conn); in rds_conn_reset()
104 conn->c_flags = 0; in rds_conn_reset()
124 struct rds_connection *conn, *parent = NULL; in __rds_conn_create() local
[all …]
Dsend.c64 void rds_send_reset(struct rds_connection *conn) in rds_send_reset() argument
69 if (conn->c_xmit_rm) { in rds_send_reset()
70 rm = conn->c_xmit_rm; in rds_send_reset()
71 conn->c_xmit_rm = NULL; in rds_send_reset()
80 conn->c_xmit_sg = 0; in rds_send_reset()
81 conn->c_xmit_hdr_off = 0; in rds_send_reset()
82 conn->c_xmit_data_off = 0; in rds_send_reset()
83 conn->c_xmit_atomic_sent = 0; in rds_send_reset()
84 conn->c_xmit_rdma_sent = 0; in rds_send_reset()
85 conn->c_xmit_data_sent = 0; in rds_send_reset()
[all …]
Dib_cm.c75 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol() argument
77 conn->c_version = version; in rds_ib_set_protocol()
83 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control() argument
85 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_set_flow_control()
90 rds_ib_send_add_credits(conn, credits); in rds_ib_set_flow_control()
125 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete() argument
128 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_connect_complete()
132 if (event->param.conn.private_data_len >= sizeof(*dp)) { in rds_ib_cm_connect_complete()
133 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete()
137 rds_ib_set_protocol(conn, in rds_ib_cm_connect_complete()
[all …]
Diw_cm.c45 static void rds_iw_set_protocol(struct rds_connection *conn, unsigned int version) in rds_iw_set_protocol() argument
47 conn->c_version = version; in rds_iw_set_protocol()
53 static void rds_iw_set_flow_control(struct rds_connection *conn, u32 credits) in rds_iw_set_flow_control() argument
55 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_set_flow_control()
60 rds_iw_send_add_credits(conn, credits); in rds_iw_set_flow_control()
70 void rds_iw_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_iw_cm_connect_complete() argument
73 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_cm_connect_complete()
77 if (event->param.conn.private_data_len) { in rds_iw_cm_connect_complete()
78 dp = event->param.conn.private_data; in rds_iw_cm_connect_complete()
80 rds_iw_set_protocol(conn, in rds_iw_cm_connect_complete()
[all …]
Dloop.c60 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 …]
Dtcp_connect.c43 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()
67 rds_conn_drop(conn); in rds_tcp_state_change()
76 int rds_tcp_conn_connect(struct rds_connection *conn) in rds_tcp_conn_connect() argument
89 src.sin_addr.s_addr = (__force u32)conn->c_laddr; in rds_tcp_conn_connect()
95 ret, &conn->c_laddr); in rds_tcp_conn_connect()
100 dest.sin_addr.s_addr = (__force u32)conn->c_faddr; in rds_tcp_conn_connect()
[all …]
Dtcp_recv.c105 static void rds_tcp_cong_recv(struct rds_connection *conn, in rds_tcp_cong_recv() argument
121 map = conn->c_fcong; in rds_tcp_cong_recv()
150 struct rds_connection *conn; member
158 struct rds_connection *conn = arg->conn; in rds_tcp_data_recv() local
159 struct rds_tcp_connection *tc = conn->c_transport_data; in rds_tcp_data_recv()
181 rds_inc_init(&tinc->ti_inc, conn, conn->c_faddr); in rds_tcp_data_recv()
240 rds_tcp_cong_recv(conn, tinc); in rds_tcp_data_recv()
242 rds_recv_incoming(conn, conn->c_faddr, in rds_tcp_data_recv()
243 conn->c_laddr, &tinc->ti_inc, in rds_tcp_data_recv()
261 static int rds_tcp_read_sock(struct rds_connection *conn, gfp_t gfp) in rds_tcp_read_sock() argument
[all …]
Diw_recv.c137 static int rds_iw_recv_refill_one(struct rds_connection *conn, in rds_iw_recv_refill_one() argument
141 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_recv_refill_one()
158 rds_inc_init(&recv->r_iwinc->ii_inc, conn, conn->c_faddr); in rds_iw_recv_refill_one()
224 int rds_iw_recv_refill(struct rds_connection *conn, gfp_t kptr_gfp, in rds_iw_recv_refill() argument
227 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_recv_refill()
234 while ((prefill || rds_conn_up(conn)) && in rds_iw_recv_refill()
244 ret = rds_iw_recv_refill_one(conn, recv, kptr_gfp, page_gfp); in rds_iw_recv_refill()
256 rds_iw_conn_error(conn, "recv post on " in rds_iw_recv_refill()
258 "reconnecting\n", &conn->c_faddr, in rds_iw_recv_refill()
269 rds_iw_advertise_credits(conn, posted); in rds_iw_recv_refill()
[all …]
Dcong.c183 void rds_cong_add_conn(struct rds_connection *conn) in rds_cong_add_conn() argument
187 rdsdebug("conn %p now on map %p\n", conn, conn->c_lcong); in rds_cong_add_conn()
189 list_add_tail(&conn->c_map_item, &conn->c_lcong->m_conn_list); in rds_cong_add_conn()
193 void rds_cong_remove_conn(struct rds_connection *conn) in rds_cong_remove_conn() argument
197 rdsdebug("removing conn %p from map %p\n", conn, conn->c_lcong); in rds_cong_remove_conn()
199 list_del_init(&conn->c_map_item); in rds_cong_remove_conn()
203 int rds_cong_get_maps(struct rds_connection *conn) in rds_cong_get_maps() argument
205 conn->c_lcong = rds_cong_from_addr(conn->c_laddr); in rds_cong_get_maps()
206 conn->c_fcong = rds_cong_from_addr(conn->c_faddr); in rds_cong_get_maps()
208 if (!(conn->c_lcong && conn->c_fcong)) in rds_cong_get_maps()
[all …]
Drds.h424 int (*conn_alloc)(struct rds_connection *conn, gfp_t gfp);
426 int (*conn_connect)(struct rds_connection *conn);
427 void (*conn_shutdown)(struct rds_connection *conn);
428 void (*xmit_prepare)(struct rds_connection *conn);
429 void (*xmit_complete)(struct rds_connection *conn);
430 int (*xmit)(struct rds_connection *conn, struct rds_message *rm,
432 int (*xmit_rdma)(struct rds_connection *conn, struct rm_rdma_op *op);
433 int (*xmit_atomic)(struct rds_connection *conn, struct rm_atomic_op *op);
434 int (*recv)(struct rds_connection *conn);
441 void (*cm_connect_complete)(struct rds_connection *conn,
[all …]
Dtcp_send.c51 void rds_tcp_xmit_prepare(struct rds_connection *conn) in rds_tcp_xmit_prepare() argument
53 struct rds_tcp_connection *tc = conn->c_transport_data; in rds_tcp_xmit_prepare()
58 void rds_tcp_xmit_complete(struct rds_connection *conn) in rds_tcp_xmit_complete() argument
60 struct rds_tcp_connection *tc = conn->c_transport_data; in rds_tcp_xmit_complete()
80 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_tcp_xmit() argument
83 struct rds_tcp_connection *tc = conn->c_transport_data; in rds_tcp_xmit()
148 &conn->c_faddr, ret); in rds_tcp_xmit()
149 rds_conn_drop(conn); in rds_tcp_xmit()
174 struct rds_connection *conn; in rds_tcp_write_space() local
178 conn = sk->sk_user_data; in rds_tcp_write_space()
[all …]
Drdma_transport.c72 struct rds_connection *conn = cm_id->context; in rds_rdma_cm_event_handler() local
76 rdsdebug("conn %p id %p handling event %u (%s)\n", conn, cm_id, in rds_rdma_cm_event_handler()
86 if (conn) { in rds_rdma_cm_event_handler()
87 mutex_lock(&conn->c_cm_lock); in rds_rdma_cm_event_handler()
92 if (rds_conn_state(conn) == RDS_CONN_DISCONNECTING) { in rds_rdma_cm_event_handler()
118 trans->cm_connect_complete(conn, event); in rds_rdma_cm_event_handler()
128 if (conn) in rds_rdma_cm_event_handler()
129 rds_conn_drop(conn); in rds_rdma_cm_event_handler()
134 "%pI4->%pI4\n", &conn->c_laddr, in rds_rdma_cm_event_handler()
135 &conn->c_faddr); in rds_rdma_cm_event_handler()
[all …]
Dib_recv.c265 rds_inc_init(&ibinc->ii_inc, ic->conn, ic->conn->c_faddr); in rds_ib_refill_one_inc()
299 static int rds_ib_recv_refill_one(struct rds_connection *conn, in rds_ib_recv_refill_one() argument
302 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_recv_refill_one()
357 void rds_ib_recv_refill(struct rds_connection *conn, int prefill) in rds_ib_recv_refill() argument
359 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_recv_refill()
366 while ((prefill || rds_conn_up(conn)) && in rds_ib_recv_refill()
375 ret = rds_ib_recv_refill_one(conn, recv, prefill); in rds_ib_recv_refill()
389 rds_ib_conn_error(conn, "recv post on " in rds_ib_recv_refill()
391 "reconnecting\n", &conn->c_faddr, in rds_ib_recv_refill()
401 rds_ib_advertise_credits(conn, posted); in rds_ib_recv_refill()
[all …]
Dib.h98 struct rds_connection *conn; member
279 int rds_ib_conn_alloc(struct rds_connection *conn, gfp_t gfp);
281 int rds_ib_conn_connect(struct rds_connection *conn);
282 void rds_ib_conn_shutdown(struct rds_connection *conn);
286 void __rds_ib_conn_error(struct rds_connection *conn, const char *, ...);
290 void rds_ib_cm_connect_complete(struct rds_connection *conn,
294 #define rds_ib_conn_error(conn, fmt...) \ argument
295 __rds_ib_conn_error(conn, KERN_WARNING "RDS/IB: " fmt)
299 void rds_ib_add_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn);
300 void rds_ib_remove_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn);
[all …]
Dtcp.h14 struct rds_connection *conn; member
48 void rds_tcp_set_callbacks(struct socket *sock, struct rds_connection *conn);
57 int rds_tcp_conn_connect(struct rds_connection *conn);
58 void rds_tcp_conn_shutdown(struct rds_connection *conn);
70 int rds_tcp_recv(struct rds_connection *conn);
75 void rds_tcp_xmit_prepare(struct rds_connection *conn);
76 void rds_tcp_xmit_complete(struct rds_connection *conn);
77 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm,
Diw.h106 struct rds_connection *conn; member
281 int rds_iw_conn_alloc(struct rds_connection *conn, gfp_t gfp);
283 int rds_iw_conn_connect(struct rds_connection *conn);
284 void rds_iw_conn_shutdown(struct rds_connection *conn);
288 void __rds_iw_conn_error(struct rds_connection *conn, const char *, ...);
292 void rds_iw_cm_connect_complete(struct rds_connection *conn,
296 #define rds_iw_conn_error(conn, fmt...) \ argument
297 __rds_iw_conn_error(conn, KERN_WARNING "RDS/IW: " fmt)
301 void rds_iw_add_conn(struct rds_iw_device *rds_iwdev, struct rds_connection *conn);
302 void rds_iw_remove_conn(struct rds_iw_device *rds_iwdev, struct rds_connection *conn);
[all …]
Dtcp_listen.c83 struct rds_connection *conn; in rds_tcp_accept_one() local
111 conn = rds_conn_create(inet->inet_saddr, inet->inet_daddr, in rds_tcp_accept_one()
113 if (IS_ERR(conn)) { in rds_tcp_accept_one()
114 ret = PTR_ERR(conn); in rds_tcp_accept_one()
124 rs_tcp = (struct rds_tcp_connection *)conn->c_transport_data; in rds_tcp_accept_one()
130 if (!rds_conn_transition(conn, RDS_CONN_DOWN, RDS_CONN_CONNECTING)) { in rds_tcp_accept_one()
131 if (rds_conn_state(conn) == RDS_CONN_UP) in rds_tcp_accept_one()
135 rds_conn_drop(conn); in rds_tcp_accept_one()
140 rds_tcp_set_callbacks(new_sock, conn); in rds_tcp_accept_one()
141 rds_connect_complete(conn); in rds_tcp_accept_one()
Diw_send.c198 struct rds_connection *conn = context; in rds_iw_send_cq_comp_handler() local
199 struct rds_iw_connection *ic = conn->c_transport_data; in rds_iw_send_cq_comp_handler()
207 rdsdebug("cq %p conn %p\n", cq, conn); in rds_iw_send_cq_comp_handler()
280 rm = rds_send_get_message(conn, send->s_op); in rds_iw_send_cq_comp_handler()
290 if (test_and_clear_bit(RDS_LL_SEND_FULL, &conn->c_flags) || in rds_iw_send_cq_comp_handler()
291 test_bit(0, &conn->c_map_queued)) in rds_iw_send_cq_comp_handler()
292 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_iw_send_cq_comp_handler()
295 if (wc.status != IB_WC_SUCCESS && rds_conn_up(conn)) { in rds_iw_send_cq_comp_handler()
296 rds_iw_conn_error(conn, in rds_iw_send_cq_comp_handler()
299 &conn->c_faddr, wc.status); in rds_iw_send_cq_comp_handler()
[all …]
Dib_send.c276 struct rds_connection *conn = context; in rds_ib_send_cq_comp_handler() local
277 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_send_cq_comp_handler()
287 rdsdebug("cq %p conn %p\n", cq, conn); in rds_ib_send_cq_comp_handler()
338 if (test_and_clear_bit(RDS_LL_SEND_FULL, &conn->c_flags) || in rds_ib_send_cq_comp_handler()
339 test_bit(0, &conn->c_map_queued)) in rds_ib_send_cq_comp_handler()
340 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_ib_send_cq_comp_handler()
343 if (wc.status != IB_WC_SUCCESS && rds_conn_up(conn)) { in rds_ib_send_cq_comp_handler()
344 rds_ib_conn_error(conn, "send completion on %pI4 had status " in rds_ib_send_cq_comp_handler()
346 &conn->c_faddr, wc.status, in rds_ib_send_cq_comp_handler()
420 struct rds_connection *conn = ic->i_cm_id->context; in rds_ib_send_grab_credits() local
[all …]
Dtcp.c121 void rds_tcp_set_callbacks(struct socket *sock, struct rds_connection *conn) in rds_tcp_set_callbacks() argument
123 struct rds_tcp_connection *tc = conn->c_transport_data; in rds_tcp_set_callbacks()
139 tc->conn = conn; in rds_tcp_set_callbacks()
144 sock->sk->sk_user_data = conn; in rds_tcp_set_callbacks()
199 static int rds_tcp_conn_alloc(struct rds_connection *conn, gfp_t gfp) in rds_tcp_conn_alloc() argument
212 conn->c_transport_data = tc; in rds_tcp_conn_alloc()
218 rdsdebug("alloced tc %p\n", conn->c_transport_data); in rds_tcp_conn_alloc()
247 if (tc->conn->c_passive) in rds_tcp_destroy_conns()
248 rds_conn_destroy(tc->conn->c_passive); in rds_tcp_destroy_conns()
249 rds_conn_destroy(tc->conn); in rds_tcp_destroy_conns()
Dib.c75 rds_conn_connect_if_down(ic->conn); in rds_ib_nodev_connect()
86 rds_conn_drop(ic->conn); in rds_ib_dev_shutdown()
266 static int rds_ib_conn_info_visitor(struct rds_connection *conn, in rds_ib_conn_info_visitor() argument
273 if (conn->c_trans != &rds_ib_transport) in rds_ib_conn_info_visitor()
276 iinfo->src_addr = conn->c_laddr; in rds_ib_conn_info_visitor()
277 iinfo->dst_addr = conn->c_faddr; in rds_ib_conn_info_visitor()
281 if (rds_conn_state(conn) == RDS_CONN_UP) { in rds_ib_conn_info_visitor()
285 ic = conn->c_transport_data; in rds_ib_conn_info_visitor()
Diw.c167 static int rds_iw_conn_info_visitor(struct rds_connection *conn, in rds_iw_conn_info_visitor() argument
174 if (conn->c_trans != &rds_iw_transport) in rds_iw_conn_info_visitor()
177 iinfo->src_addr = conn->c_laddr; in rds_iw_conn_info_visitor()
178 iinfo->dst_addr = conn->c_faddr; in rds_iw_conn_info_visitor()
182 if (rds_conn_state(conn) == RDS_CONN_UP) { in rds_iw_conn_info_visitor()
186 ic = conn->c_transport_data; in rds_iw_conn_info_visitor()
Drecv.c41 void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn, in rds_inc_init() argument
46 inc->i_conn = conn; in rds_inc_init()
157 void rds_recv_incoming(struct rds_connection *conn, __be32 saddr, __be32 daddr, in rds_recv_incoming() argument
164 inc->i_conn = conn; in rds_recv_incoming()
168 "flags 0x%x rx_jiffies %lu\n", conn, in rds_recv_incoming()
169 (unsigned long long)conn->c_next_rx_seq, in rds_recv_incoming()
198 if (be64_to_cpu(inc->i_hdr.h_sequence) < conn->c_next_rx_seq && in rds_recv_incoming()
203 conn->c_next_rx_seq = be64_to_cpu(inc->i_hdr.h_sequence) + 1; in rds_recv_incoming()
207 rds_send_pong(conn, inc->i_hdr.h_sport); in rds_recv_incoming()
Drdma_transport.h10 int rds_rdma_conn_connect(struct rds_connection *conn);
Dib_rdma.c162 void rds_ib_add_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn) in rds_ib_add_conn() argument
164 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_add_conn()
181 void rds_ib_remove_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn) in rds_ib_remove_conn() argument
183 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_remove_conn()
212 rds_conn_destroy(ic->conn); in rds_ib_destroy_nodev_conns()
Diw_rdma.c198 void rds_iw_add_conn(struct rds_iw_device *rds_iwdev, struct rds_connection *conn) argument
200 struct rds_iw_connection *ic = conn->c_transport_data;
216 void rds_iw_remove_conn(struct rds_iw_device *rds_iwdev, struct rds_connection *conn) argument
218 struct rds_iw_connection *ic = conn->c_transport_data;
248 rds_conn_destroy(ic->conn);
/linux-4.1.27/drivers/target/iscsi/
Discsi_target_login.c41 static struct iscsi_login *iscsi_login_init_conn(struct iscsi_conn *conn) in iscsi_login_init_conn() argument
50 conn->login = login; in iscsi_login_init_conn()
51 login->conn = conn; in iscsi_login_init_conn()
66 conn->conn_ops = kzalloc(sizeof(struct iscsi_conn_ops), GFP_KERNEL); in iscsi_login_init_conn()
67 if (!conn->conn_ops) { in iscsi_login_init_conn()
73 init_waitqueue_head(&conn->queues_wq); in iscsi_login_init_conn()
74 INIT_LIST_HEAD(&conn->conn_list); in iscsi_login_init_conn()
75 INIT_LIST_HEAD(&conn->conn_cmd_list); in iscsi_login_init_conn()
76 INIT_LIST_HEAD(&conn->immed_queue_list); in iscsi_login_init_conn()
77 INIT_LIST_HEAD(&conn->response_queue_list); in iscsi_login_init_conn()
[all …]
Discsi_target_util.c85 iscsit_add_cmd_to_immediate_queue(cmd, cmd->conn, ISTATE_SEND_R2T); in iscsit_add_r2t_to_list()
154 struct iscsi_cmd *iscsit_allocate_cmd(struct iscsi_conn *conn, int state) in iscsit_allocate_cmd() argument
157 struct se_session *se_sess = conn->sess->se_sess; in iscsit_allocate_cmd()
164 size = sizeof(struct iscsi_cmd) + conn->conn_transport->priv_size; in iscsit_allocate_cmd()
169 cmd->conn = conn; in iscsit_allocate_cmd()
278 int iscsit_sequence_cmd(struct iscsi_conn *conn, struct iscsi_cmd *cmd, in iscsit_sequence_cmd() argument
285 mutex_lock(&conn->sess->cmdsn_mutex); in iscsit_sequence_cmd()
287 cmdsn_ret = iscsit_check_received_cmdsn(conn->sess, be32_to_cpu(cmdsn)); in iscsit_sequence_cmd()
291 if ((ret >= 0) && !list_empty(&conn->sess->sess_ooo_cmdsn_list)) in iscsit_sequence_cmd()
292 iscsit_execute_ooo_cmdsns(conn->sess); in iscsit_sequence_cmd()
[all …]
Discsi_target_nego.c104 struct iscsi_conn *conn, in iscsi_handle_authentication() argument
111 struct iscsi_session *sess = conn->sess; in iscsi_handle_authentication()
121 se_nacl = conn->sess->se_sess->se_node_acl; in iscsi_handle_authentication()
154 strcpy(conn->sess->auth_type, "CHAP"); in iscsi_handle_authentication()
156 strcpy(conn->sess->auth_type, NONE); in iscsi_handle_authentication()
162 return srp_main_loop(conn, auth, in_buf, out_buf, in iscsi_handle_authentication()
166 return chap_main_loop(conn, auth, in_buf, out_buf, in iscsi_handle_authentication()
178 static void iscsi_remove_failed_auth_entry(struct iscsi_conn *conn) in iscsi_remove_failed_auth_entry() argument
180 kfree(conn->auth_protocol); in iscsi_remove_failed_auth_entry()
184 struct iscsi_conn *conn, in iscsi_target_check_login_request() argument
[all …]
Discsi_target_erl0.c40 struct iscsi_conn *conn = cmd->conn; in iscsit_set_dataout_sequence_values() local
49 conn->sess->sess_ops->FirstBurstLength) ? in iscsit_set_dataout_sequence_values()
50 conn->sess->sess_ops->FirstBurstLength : cmd->se_cmd.data_length)); in iscsit_set_dataout_sequence_values()
54 if (!conn->sess->sess_ops->DataSequenceInOrder) in iscsit_set_dataout_sequence_values()
60 conn->sess->sess_ops->MaxBurstLength) ? in iscsit_set_dataout_sequence_values()
62 conn->sess->sess_ops->MaxBurstLength) : cmd->se_cmd.data_length; in iscsit_set_dataout_sequence_values()
66 conn->sess->sess_ops->MaxBurstLength) >= in iscsit_set_dataout_sequence_values()
69 conn->sess->sess_ops->MaxBurstLength); in iscsit_set_dataout_sequence_values()
77 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_within_command_recovery_check() local
93 if (conn->sess->sess_ops->DataSequenceInOrder) { in iscsit_dataout_within_command_recovery_check()
[all …]
Discsi_target.c492 static int iscsit_queue_rsp(struct iscsi_conn *conn, struct iscsi_cmd *cmd) in iscsit_queue_rsp() argument
494 iscsit_add_cmd_to_response_queue(cmd, cmd->conn, cmd->i_state); in iscsit_queue_rsp()
498 static void iscsit_aborted_task(struct iscsi_conn *conn, struct iscsi_cmd *cmd) in iscsit_aborted_task() argument
502 spin_lock_bh(&conn->cmd_lock); in iscsit_aborted_task()
505 spin_unlock_bh(&conn->cmd_lock); in iscsit_aborted_task()
510 static enum target_prot_op iscsit_get_sup_prot_ops(struct iscsi_conn *conn) in iscsit_get_sup_prot_ops() argument
646 struct iscsi_conn *conn, in iscsit_add_reject() argument
652 cmd = iscsit_allocate_cmd(conn, TASK_INTERRUPTIBLE); in iscsit_add_reject()
666 spin_lock_bh(&conn->cmd_lock); in iscsit_add_reject()
667 list_add_tail(&cmd->i_conn_node, &conn->conn_cmd_list); in iscsit_add_reject()
[all …]
Discsi_target_erl2.c40 struct iscsi_conn *conn = cmd->conn; in iscsit_create_conn_recovery_datain_values() local
47 conn->conn_ops->MaxRecvDataSegmentLength) < in iscsit_create_conn_recovery_datain_values()
48 conn->sess->sess_ops->MaxBurstLength) { in iscsit_create_conn_recovery_datain_values()
50 conn->conn_ops->MaxRecvDataSegmentLength; in iscsit_create_conn_recovery_datain_values()
52 conn->conn_ops->MaxRecvDataSegmentLength; in iscsit_create_conn_recovery_datain_values()
55 (conn->sess->sess_ops->MaxBurstLength - in iscsit_create_conn_recovery_datain_values()
67 struct iscsi_conn *conn = cmd->conn; in iscsit_create_conn_recovery_dataout_values() local
73 if ((write_data_done + conn->sess->sess_ops->MaxBurstLength) <= in iscsit_create_conn_recovery_dataout_values()
75 write_data_done += conn->sess->sess_ops->MaxBurstLength; in iscsit_create_conn_recovery_dataout_values()
142 cmd->conn = NULL; in iscsit_free_connection_recovery_entires()
[all …]
Discsi_target_tmr.c43 struct iscsi_conn *conn = cmd->conn; in iscsit_tmr_abort_task() local
48 ref_cmd = iscsit_find_cmd_from_itt(conn, hdr->rtt); in iscsit_tmr_abort_task()
51 " %hu.\n", hdr->rtt, conn->cid); in iscsit_tmr_abort_task()
52 return (iscsi_sna_gte(be32_to_cpu(hdr->refcmdsn), conn->sess->exp_cmd_sn) && in iscsit_tmr_abort_task()
53 iscsi_sna_lte(be32_to_cpu(hdr->refcmdsn), conn->sess->max_cmd_sn)) ? in iscsit_tmr_abort_task()
74 struct iscsi_conn *conn, in iscsit_tmr_task_warm_reset() argument
78 struct iscsi_session *sess = conn->sess; in iscsit_tmr_task_warm_reset()
94 struct iscsi_conn *conn, in iscsit_tmr_task_cold_reset() argument
98 struct iscsi_session *sess = conn->sess; in iscsit_tmr_task_cold_reset()
118 struct iscsi_conn *conn = cmd->conn; in iscsit_tmr_task_reassign() local
[all …]
Discsi_target_erl1.c46 struct iscsi_conn *conn, in iscsit_dump_data_payload() argument
55 if (conn->sess->sess_ops->RDMAExtensions) in iscsit_dump_data_payload()
75 rx_got = rx_data(conn, &iov, 1, size); in iscsit_dump_data_payload()
92 rx_got = rx_data(conn, &iov, 1, padding); in iscsit_dump_data_payload()
99 if (conn->conn_ops->DataDigest) { in iscsit_dump_data_payload()
105 rx_got = rx_data(conn, &iov, 1, ISCSI_CRC_LEN); in iscsit_dump_data_payload()
137 iscsit_add_cmd_to_immediate_queue(cmd, cmd->conn, ISTATE_SEND_R2T); in iscsit_send_recovery_r2t_for_snack()
208 struct iscsi_conn *conn = cmd->conn; in iscsit_create_recovery_datain_values_datasequenceinorder_yes() local
213 conn->conn_ops->MaxRecvDataSegmentLength) < in iscsit_create_recovery_datain_values_datasequenceinorder_yes()
214 conn->sess->sess_ops->MaxBurstLength) { in iscsit_create_recovery_datain_values_datasequenceinorder_yes()
[all …]
Discsi_target_datain_values.c91 struct iscsi_conn *conn = cmd->conn; in iscsit_set_datain_values_yes_and_yes() local
118 if ((read_data_left <= conn->conn_ops->MaxRecvDataSegmentLength) && in iscsit_set_datain_values_yes_and_yes()
119 (read_data_left <= (conn->sess->sess_ops->MaxBurstLength - in iscsit_set_datain_values_yes_and_yes()
124 if (conn->sess->sess_ops->ErrorRecoveryLevel > 0) in iscsit_set_datain_values_yes_and_yes()
128 conn->conn_ops->MaxRecvDataSegmentLength) < in iscsit_set_datain_values_yes_and_yes()
129 conn->sess->sess_ops->MaxBurstLength) { in iscsit_set_datain_values_yes_and_yes()
131 conn->conn_ops->MaxRecvDataSegmentLength; in iscsit_set_datain_values_yes_and_yes()
134 datain->length = (conn->sess->sess_ops->MaxBurstLength - in iscsit_set_datain_values_yes_and_yes()
139 if (conn->sess->sess_ops->ErrorRecoveryLevel > 0) in iscsit_set_datain_values_yes_and_yes()
189 struct iscsi_conn *conn = cmd->conn; in iscsit_set_datain_values_no_and_yes() local
[all …]
Discsi_target_auth.c51 struct iscsi_conn *conn, in chap_gen_challenge() argument
57 struct iscsi_chap *chap = conn->auth_protocol; in chap_gen_challenge()
110 struct iscsi_conn *conn, in chap_server_open() argument
126 conn->auth_protocol = kzalloc(sizeof(struct iscsi_chap), GFP_KERNEL); in chap_server_open()
127 if (!conn->auth_protocol) in chap_server_open()
130 chap = conn->auth_protocol; in chap_server_open()
152 chap->id = conn->tpg->tpg_chap_id++; in chap_server_open()
159 chap_gen_challenge(conn, 1, aic_str, aic_len); in chap_server_open()
164 static void chap_close(struct iscsi_conn *conn) in chap_close() argument
166 kfree(conn->auth_protocol); in chap_close()
[all …]
Discsi_target_seq_pdu_list.c221 struct iscsi_conn *conn = cmd->conn; in iscsit_determine_counts_for_list() local
224 mdsl = cmd->conn->conn_ops->MaxXmitDataSegmentLength; in iscsit_determine_counts_for_list()
226 mdsl = cmd->conn->conn_ops->MaxRecvDataSegmentLength; in iscsit_determine_counts_for_list()
235 conn->sess->sess_ops->FirstBurstLength); in iscsit_determine_counts_for_list()
257 >= conn->sess->sess_ops->FirstBurstLength) { in iscsit_determine_counts_for_list()
259 (conn->sess->sess_ops->FirstBurstLength - in iscsit_determine_counts_for_list()
261 offset += (conn->sess->sess_ops->FirstBurstLength - in iscsit_determine_counts_for_list()
277 conn->sess->sess_ops->MaxBurstLength) { in iscsit_determine_counts_for_list()
278 offset += (conn->sess->sess_ops->MaxBurstLength - in iscsit_determine_counts_for_list()
302 struct iscsi_conn *conn = cmd->conn; in iscsit_do_build_pdu_and_seq_lists() local
[all …]
Discsi_target_nodeattrib.c108 struct iscsi_conn *conn; in iscsit_na_nopin_timeout() local
139 list_for_each_entry(conn, &sess->sess_conn_list, in iscsit_na_nopin_timeout()
141 if (conn->conn_state != in iscsit_na_nopin_timeout()
145 spin_lock(&conn->nopin_timer_lock); in iscsit_na_nopin_timeout()
146 __iscsit_start_nopin_timer(conn); in iscsit_na_nopin_timeout()
147 spin_unlock(&conn->nopin_timer_lock); in iscsit_na_nopin_timeout()
Discsi_target_configfs.c657 struct iscsi_conn *conn; in lio_target_nacl_show_info() local
717 list_for_each_entry(conn, &sess->sess_conn_list, conn_list) { in lio_target_nacl_show_info()
719 " State: ", conn->cid); in lio_target_nacl_show_info()
720 switch (conn->conn_state) { in lio_target_nacl_show_info()
755 rb += sprintf(page+rb, " Address %s %s", conn->login_ip, in lio_target_nacl_show_info()
756 (conn->network_transport == ISCSI_TCP) ? in lio_target_nacl_show_info()
759 conn->stat_sn); in lio_target_nacl_show_info()
1777 cmd->conn->conn_transport->iscsit_queue_data_in(cmd->conn, cmd); in lio_queue_data_in()
1785 struct iscsi_conn *conn = cmd->conn; in lio_write_pending() local
1788 return conn->conn_transport->iscsit_get_dataout(conn, cmd, false); in lio_write_pending()
[all …]
Discsi_target_parameters.c26 struct iscsi_conn *conn, in iscsi_login_rx_data() argument
42 conn->of_marker += length; in iscsi_login_rx_data()
44 rx_got = rx_data(conn, &iov, 1, length); in iscsi_login_rx_data()
55 struct iscsi_conn *conn, in iscsi_login_tx_data() argument
80 conn->if_marker += length; in iscsi_login_tx_data()
82 tx_sent = tx_data(conn, &iov[0], iov_cnt, length); in iscsi_login_tx_data()
1103 struct iscsi_conn *conn) in iscsi_check_acceptor_state() argument
1187 conn->conn_ops->MaxRecvDataSegmentLength = tmp; in iscsi_check_acceptor_state()
1190 conn->conn_ops->MaxRecvDataSegmentLength); in iscsi_check_acceptor_state()
1194 conn->param_list); in iscsi_check_acceptor_state()
[all …]
Discsi_target_util.h16 extern int iscsit_sequence_cmd(struct iscsi_conn *conn, struct iscsi_cmd *cmd,
/linux-4.1.27/drivers/staging/lustre/lustre/ptlrpc/
Dconnection.c51 struct ptlrpc_connection *conn, *conn2; in ptlrpc_connection_get() local
53 conn = cfs_hash_lookup(conn_hash, &peer); in ptlrpc_connection_get()
54 if (conn) in ptlrpc_connection_get()
57 OBD_ALLOC_PTR(conn); in ptlrpc_connection_get()
58 if (!conn) in ptlrpc_connection_get()
61 conn->c_peer = peer; in ptlrpc_connection_get()
62 conn->c_self = self; in ptlrpc_connection_get()
63 INIT_HLIST_NODE(&conn->c_hash); in ptlrpc_connection_get()
64 atomic_set(&conn->c_refcount, 1); in ptlrpc_connection_get()
66 obd_str2uuid(&conn->c_remote_uuid, uuid->uuid); in ptlrpc_connection_get()
[all …]
Dniobuf.c52 struct ptlrpc_connection *conn, int portal, __u64 xid, in ptl_send_buf() argument
59 LASSERT(conn != NULL); in ptl_send_buf()
60 CDEBUG(D_INFO, "conn=%p id %s\n", conn, libcfs_id2str(conn->c_peer)); in ptl_send_buf()
85 rc = LNetPut(conn->c_self, *mdh, ack, in ptl_send_buf()
86 conn->c_peer, portal, xid, offset, 0); in ptl_send_buf()
93 libcfs_id2str(conn->c_peer), portal, xid, rc); in ptl_send_buf()
356 struct ptlrpc_connection *conn; in ptlrpc_send_reply() local
411 conn = ptlrpc_connection_get(req->rq_peer, req->rq_self, NULL); in ptlrpc_send_reply()
413 conn = ptlrpc_connection_addref(req->rq_export->exp_connection); in ptlrpc_send_reply()
415 if (unlikely(conn == NULL)) { in ptlrpc_send_reply()
[all …]
Dimport.c490 struct obd_import_conn *imp_conn = NULL, *conn; in import_select_connection() local
504 list_for_each_entry(conn, &imp->imp_conn_list, oic_item) { in import_select_connection()
507 libcfs_nid2str(conn->oic_conn->c_peer.nid), in import_select_connection()
508 conn->oic_last_attempt); in import_select_connection()
512 if ((conn->oic_last_attempt == 0) || in import_select_connection()
513 cfs_time_beforeq_64(conn->oic_last_attempt, in import_select_connection()
515 imp_conn = conn; in import_select_connection()
524 imp_conn = conn; in import_select_connection()
525 else if (cfs_time_before_64(conn->oic_last_attempt, in import_select_connection()
527 imp_conn = conn; in import_select_connection()
/linux-4.1.27/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd_cb.c111 ksocknal_send_iov (ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_send_iov() argument
120 rc = ksocknal_lib_send_iov(conn, tx); in ksocknal_send_iov()
148 ksocknal_send_kiov (ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_send_kiov() argument
158 rc = ksocknal_lib_send_kiov(conn, tx); in ksocknal_send_kiov()
186 ksocknal_transmit (ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_transmit() argument
198 rc = ksocknal_connsock_addref(conn); in ksocknal_transmit()
200 LASSERT (conn->ksnc_closing); in ksocknal_transmit()
210 rc = ksocknal_send_iov (conn, tx); in ksocknal_transmit()
212 rc = ksocknal_send_kiov (conn, tx); in ksocknal_transmit()
215 bufnob = conn->ksnc_sock->sk->sk_wmem_queued; in ksocknal_transmit()
[all …]
Dsocklnd_lib-linux.c40 ksocknal_lib_get_conn_addrs(ksock_conn_t *conn) in ksocknal_lib_get_conn_addrs() argument
42 int rc = libcfs_sock_getaddr(conn->ksnc_sock, 1, in ksocknal_lib_get_conn_addrs()
43 &conn->ksnc_ipaddr, in ksocknal_lib_get_conn_addrs()
44 &conn->ksnc_port); in ksocknal_lib_get_conn_addrs()
47 LASSERT(!conn->ksnc_closing); in ksocknal_lib_get_conn_addrs()
54 rc = libcfs_sock_getaddr(conn->ksnc_sock, 0, in ksocknal_lib_get_conn_addrs()
55 &conn->ksnc_myipaddr, NULL); in ksocknal_lib_get_conn_addrs()
65 ksocknal_lib_zc_capable(ksock_conn_t *conn) in ksocknal_lib_zc_capable() argument
67 int caps = conn->ksnc_sock->sk->sk_route_caps; in ksocknal_lib_zc_capable()
69 if (conn->ksnc_proto == &ksocknal_protocol_v1x) in ksocknal_lib_zc_capable()
[all …]
Dsocklnd_proto.c45 ksocknal_queue_tx_msg_v1(ksock_conn_t *conn, ksock_tx_t *tx_msg) in ksocknal_queue_tx_msg_v1() argument
48 list_add_tail(&tx_msg->tx_list, &conn->ksnc_tx_queue); in ksocknal_queue_tx_msg_v1()
53 ksocknal_next_tx_carrier(ksock_conn_t *conn) in ksocknal_next_tx_carrier() argument
55 ksock_tx_t *tx = conn->ksnc_tx_carrier; in ksocknal_next_tx_carrier()
58 LASSERT(!list_empty(&conn->ksnc_tx_queue)); in ksocknal_next_tx_carrier()
62 if (tx->tx_list.next == &conn->ksnc_tx_queue) { in ksocknal_next_tx_carrier()
64 conn->ksnc_tx_carrier = NULL; in ksocknal_next_tx_carrier()
66 conn->ksnc_tx_carrier = list_entry(tx->tx_list.next, in ksocknal_next_tx_carrier()
68 LASSERT(conn->ksnc_tx_carrier->tx_msg.ksm_type == tx->tx_msg.ksm_type); in ksocknal_next_tx_carrier()
73 ksocknal_queue_tx_zcack_v2(ksock_conn_t *conn, in ksocknal_queue_tx_zcack_v2() argument
[all …]
Dsocklnd.c323 ksocknal_associate_route_conn_locked(ksock_route_t *route, ksock_conn_t *conn) in ksocknal_associate_route_conn_locked() argument
326 int type = conn->ksnc_type; in ksocknal_associate_route_conn_locked()
329 conn->ksnc_route = route; in ksocknal_associate_route_conn_locked()
332 if (route->ksnr_myipaddr != conn->ksnc_myipaddr) { in ksocknal_associate_route_conn_locked()
338 &conn->ksnc_myipaddr); in ksocknal_associate_route_conn_locked()
344 &conn->ksnc_myipaddr); in ksocknal_associate_route_conn_locked()
351 route->ksnr_myipaddr = conn->ksnc_myipaddr; in ksocknal_associate_route_conn_locked()
370 ksock_conn_t *conn; in ksocknal_add_route_locked() local
397 conn = list_entry(tmp, ksock_conn_t, ksnc_list); in ksocknal_add_route_locked()
399 if (conn->ksnc_ipaddr != route->ksnr_ipaddr) in ksocknal_add_route_locked()
[all …]
Dsocklnd.h417 ksocknal_conn_addref(ksock_conn_t *conn) in ksocknal_conn_addref() argument
419 LASSERT(atomic_read(&conn->ksnc_conn_refcount) > 0); in ksocknal_conn_addref()
420 atomic_inc(&conn->ksnc_conn_refcount); in ksocknal_conn_addref()
423 extern void ksocknal_queue_zombie_conn(ksock_conn_t *conn);
424 extern void ksocknal_finalize_zcreq(ksock_conn_t *conn);
427 ksocknal_conn_decref(ksock_conn_t *conn) in ksocknal_conn_decref() argument
429 LASSERT(atomic_read(&conn->ksnc_conn_refcount) > 0); in ksocknal_conn_decref()
430 if (atomic_dec_and_test(&conn->ksnc_conn_refcount)) in ksocknal_conn_decref()
431 ksocknal_queue_zombie_conn(conn); in ksocknal_conn_decref()
435 ksocknal_connsock_addref(ksock_conn_t *conn) in ksocknal_connsock_addref() argument
[all …]
/linux-4.1.27/net/rxrpc/
Dar-connection.c200 struct rxrpc_connection *conn; in rxrpc_alloc_connection() local
204 conn = kzalloc(sizeof(struct rxrpc_connection), gfp); in rxrpc_alloc_connection()
205 if (conn) { in rxrpc_alloc_connection()
206 INIT_WORK(&conn->processor, &rxrpc_process_connection); in rxrpc_alloc_connection()
207 INIT_LIST_HEAD(&conn->bundle_link); in rxrpc_alloc_connection()
208 conn->calls = RB_ROOT; in rxrpc_alloc_connection()
209 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
210 rwlock_init(&conn->lock); in rxrpc_alloc_connection()
211 spin_lock_init(&conn->state_lock); in rxrpc_alloc_connection()
212 atomic_set(&conn->usage, 1); in rxrpc_alloc_connection()
[all …]
Dar-connevent.c28 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 …]
Dar-security.c124 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 …]
Drxkad.c62 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 …]
Dar-call.c124 call->conn->trans->local, addr_size, in rxrpc_call_hash_add()
294 call->epoch = call->conn->epoch; in rxrpc_alloc_client_call()
295 call->service_id = call->conn->service_id; in rxrpc_alloc_client_call()
296 call->in_clientflag = call->conn->in_clientflag; in rxrpc_alloc_client_call()
300 spin_lock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
301 list_add(&call->error_link, &call->conn->trans->peer->error_targets); in rxrpc_alloc_client_call()
302 spin_unlock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
390 _net("CALL new %d on CONN %d", call->debug_id, call->conn->debug_id); in rxrpc_get_client_call()
416 struct rxrpc_connection *conn, in rxrpc_incoming_call() argument
424 _enter(",%d,,%x", conn->debug_id, gfp); in rxrpc_incoming_call()
[all …]
Dar-proc.c62 trans = call->conn->trans; in rxrpc_call_seq_show()
77 ntohs(call->conn->service_id), in rxrpc_call_seq_show()
78 ntohl(call->conn->cid), in rxrpc_call_seq_show()
80 call->conn->in_clientflag ? "Svc" : "Clt", in rxrpc_call_seq_show()
131 struct rxrpc_connection *conn; in rxrpc_connection_seq_show() local
144 conn = list_entry(v, struct rxrpc_connection, link); in rxrpc_connection_seq_show()
145 trans = conn->trans; in rxrpc_connection_seq_show()
160 ntohs(conn->service_id), in rxrpc_connection_seq_show()
161 ntohl(conn->cid), in rxrpc_connection_seq_show()
162 conn->call_counter, in rxrpc_connection_seq_show()
[all …]
Dar-output.c179 call->debug_id, call->user_call_ID, call->state, call->conn); in rxrpc_client_sendmsg()
224 call->debug_id, call->user_call_ID, call->state, call->conn); in rxrpc_kernel_send_data()
257 call->debug_id, call->user_call_ID, call->state, call->conn); in rxrpc_kernel_abort_call()
500 ret = rxrpc_send_packet(call->conn->trans, skb); in rxrpc_queue_packet()
562 max = call->conn->trans->peer->maxdata; in rxrpc_send_data()
563 max -= call->conn->security_size; in rxrpc_send_data()
564 max &= ~(call->conn->size_align - 1UL); in rxrpc_send_data()
570 space = chunk + call->conn->size_align; in rxrpc_send_data()
571 space &= ~(call->conn->size_align - 1UL); in rxrpc_send_data()
573 size = space + call->conn->header_size; in rxrpc_send_data()
[all …]
Dar-accept.c78 struct rxrpc_connection *conn; in rxrpc_accept_incoming_call() local
115 conn = rxrpc_incoming_connection(trans, &sp->hdr, GFP_NOIO); in rxrpc_accept_incoming_call()
117 if (IS_ERR(conn)) { in rxrpc_accept_incoming_call()
119 ret = PTR_ERR(conn); in rxrpc_accept_incoming_call()
123 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO); in rxrpc_accept_incoming_call()
124 rxrpc_put_connection(conn); in rxrpc_accept_incoming_call()
140 spin_lock(&call->conn->state_lock); in rxrpc_accept_incoming_call()
142 call->conn->state == RXRPC_CONN_SERVER_UNSECURED) { in rxrpc_accept_incoming_call()
145 call->conn->state = RXRPC_CONN_SERVER_CHALLENGING; in rxrpc_accept_incoming_call()
146 atomic_inc(&call->conn->usage); in rxrpc_accept_incoming_call()
[all …]
Dar-input.c202 if (call->conn->security) in rxrpc_fast_process_data()
334 hi_serial = atomic_read(&call->conn->hi_serial); in rxrpc_fast_process_packet()
336 hi_serial = atomic_cmpxchg(&call->conn->hi_serial, hi_serial, in rxrpc_fast_process_packet()
369 if (call->conn->out_clientflag) in rxrpc_fast_process_packet()
544 if (call->conn->in_clientflag) in rxrpc_post_packet_to_call()
571 rxrpc_reject_packet(call->conn->trans->local, skb); in rxrpc_post_packet_to_call()
586 static void rxrpc_post_packet_to_conn(struct rxrpc_connection *conn, in rxrpc_post_packet_to_conn() argument
589 _enter("%p,%p", conn, skb); in rxrpc_post_packet_to_conn()
591 atomic_inc(&conn->usage); in rxrpc_post_packet_to_conn()
592 skb_queue_tail(&conn->rx_queue, skb); in rxrpc_post_packet_to_conn()
[all …]
Dar-ack.c251 htonl(atomic_inc_return(&call->conn->serial)); in rxrpc_resend()
258 if (rxrpc_send_packet(call->conn->trans, txb) < 0) { in rxrpc_resend()
618 peer = call->conn->trans->peer; in rxrpc_extract_ackinfo()
906 msg.msg_name = &call->conn->trans->peer->srx.transport.sin; in rxrpc_process_call()
907 msg.msg_namelen = sizeof(call->conn->trans->peer->srx.transport.sin); in rxrpc_process_call()
912 hdr.epoch = call->conn->epoch; in rxrpc_process_call()
917 hdr.flags = call->conn->out_clientflag; in rxrpc_process_call()
919 hdr.securityIndex = call->conn->security_ix; in rxrpc_process_call()
921 hdr.serviceId = call->conn->service_id; in rxrpc_process_call()
940 error = call->conn->trans->peer->net_error; in rxrpc_process_call()
[all …]
Dar-recvmsg.c148 sizeof(call->conn->trans->peer->srx); in rxrpc_recvmsg()
150 &call->conn->trans->peer->srx, len); in rxrpc_recvmsg()
206 if (call->conn->out_clientflag) { in rxrpc_recvmsg()
Daf_rxrpc.c708 if (rx->conn) { in rxrpc_release_sock()
709 rxrpc_put_connection(rx->conn); in rxrpc_release_sock()
710 rx->conn = NULL; in rxrpc_release_sock()
/linux-4.1.27/drivers/scsi/
Dlibiscsi.c88 inline void iscsi_conn_queue_work(struct iscsi_conn *conn) in iscsi_conn_queue_work() argument
90 struct Scsi_Host *shost = conn->session->host; in iscsi_conn_queue_work()
94 queue_work(ihost->workq, &conn->xmitwork); in iscsi_conn_queue_work()
139 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() local
153 if (left > conn->max_xmit_dlength) { in iscsi_prep_data_out_pdu()
154 hton24(hdr->dlength, conn->max_xmit_dlength); in iscsi_prep_data_out_pdu()
155 r2t->data_count = conn->max_xmit_dlength; in iscsi_prep_data_out_pdu()
162 conn->dataout_pdus_cnt++; in iscsi_prep_data_out_pdu()
212 ISCSI_DBG_SESSION(task->conn->session, in iscsi_prep_ecdb_ahs()
238 ISCSI_DBG_SESSION(task->conn->session, in iscsi_prep_bidi_ahs()
[all …]
Discsi_tcp.c86 struct iscsi_conn *conn = rd_desc->arg.data; in iscsi_sw_tcp_recv() local
90 ISCSI_SW_TCP_DBG(conn, "in %d bytes\n", skb->len - offset); in iscsi_sw_tcp_recv()
94 consumed = iscsi_tcp_recv_skb(conn, skb, offset, 0, &status); in iscsi_sw_tcp_recv()
99 ISCSI_SW_TCP_DBG(conn, "read %d bytes status %d\n", in iscsi_sw_tcp_recv()
116 struct iscsi_conn *conn = sk->sk_user_data; in iscsi_sw_sk_state_check() local
119 (conn->session->state != ISCSI_STATE_LOGGING_OUT) && in iscsi_sw_sk_state_check()
121 ISCSI_SW_TCP_DBG(conn, "TCP_CLOSE|TCP_CLOSE_WAIT\n"); in iscsi_sw_sk_state_check()
122 iscsi_conn_failure(conn, ISCSI_ERR_TCP_CONN_CLOSE); in iscsi_sw_sk_state_check()
130 struct iscsi_conn *conn; in iscsi_sw_tcp_data_ready() local
135 conn = sk->sk_user_data; in iscsi_sw_tcp_data_ready()
[all …]
Dlibiscsi_tcp.c415 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_data_recv_done() local
421 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr, in iscsi_tcp_data_recv_done()
422 conn->data, tcp_conn->in.datalen); in iscsi_tcp_data_recv_done()
433 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_data_recv_prep() local
436 if (conn->datadgst_en && in iscsi_tcp_data_recv_prep()
437 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD)) in iscsi_tcp_data_recv_prep()
441 conn->data, tcp_conn->in.datalen, in iscsi_tcp_data_recv_prep()
465 ISCSI_DBG_TCP(task->conn, "pending r2t dropped\n"); in iscsi_tcp_cleanup_task()
483 static int iscsi_tcp_data_in(struct iscsi_conn *conn, struct iscsi_task *task) in iscsi_tcp_data_in() argument
485 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_tcp_data_in()
[all …]
Dscsi_transport_iscsi.c1617 static uint32_t iscsi_conn_get_sid(struct iscsi_cls_conn *conn) in iscsi_conn_get_sid() argument
1619 struct iscsi_cls_session *sess = iscsi_dev_to_session(conn->dev.parent); in iscsi_conn_get_sid()
1648 struct iscsi_cls_conn *conn; in iscsi_conn_lookup() local
1651 list_for_each_entry(conn, &connlist, conn_list) { in iscsi_conn_lookup()
1652 if ((conn->cid == cid) && (iscsi_conn_get_sid(conn) == sid)) { in iscsi_conn_lookup()
1654 return conn; in iscsi_conn_lookup()
2143 struct iscsi_cls_conn *conn = iscsi_dev_to_conn(dev); in iscsi_conn_release() local
2144 struct device *parent = conn->dev.parent; in iscsi_conn_release()
2146 ISCSI_DBG_TRANS_CONN(conn, "Releasing conn\n"); in iscsi_conn_release()
2147 kfree(conn); in iscsi_conn_release()
[all …]
/linux-4.1.27/drivers/staging/lustre/lnet/klnds/o2iblnd/
Do2iblnd_cb.c133 kib_conn_t *conn = rx->rx_conn; in kiblnd_drop_rx() local
134 struct kib_sched_info *sched = conn->ibc_sched; in kiblnd_drop_rx()
138 LASSERT(conn->ibc_nrx > 0); in kiblnd_drop_rx()
139 conn->ibc_nrx--; in kiblnd_drop_rx()
142 kiblnd_conn_decref(conn); in kiblnd_drop_rx()
148 kib_conn_t *conn = rx->rx_conn; in kiblnd_post_rx() local
149 kib_net_t *net = conn->ibc_peer->ibp_ni->ni_data; in kiblnd_post_rx()
160 mr = kiblnd_find_dma_mr(conn->ibc_hdev, rx->rx_msgaddr, IBLND_MSG_SIZE); in kiblnd_post_rx()
172 LASSERT(conn->ibc_state >= IBLND_CONN_INIT); in kiblnd_post_rx()
175 if (conn->ibc_state > IBLND_CONN_ESTABLISHED) { in kiblnd_post_rx()
[all …]
Do2iblnd.h660 #define kiblnd_conn_addref(conn) \ argument
663 (conn), atomic_read(&(conn)->ibc_refcount)); \
664 atomic_inc(&(conn)->ibc_refcount); \
667 #define kiblnd_conn_decref(conn) \ argument
672 (conn), atomic_read(&(conn)->ibc_refcount)); \
673 LASSERT_ATOMIC_POS(&(conn)->ibc_refcount); \
674 if (atomic_dec_and_test(&(conn)->ibc_refcount)) { \
676 list_add_tail(&(conn)->ibc_list, \
727 kiblnd_send_keepalive(kib_conn_t *conn) in kiblnd_send_keepalive() argument
730 cfs_time_after(jiffies, conn->ibc_last_send + in kiblnd_send_keepalive()
[all …]
Do2iblnd.c464 kib_conn_t *conn; in kiblnd_del_peer_locked() local
470 conn = list_entry(ctmp, kib_conn_t, ibc_list); in kiblnd_del_peer_locked()
472 kiblnd_close_conn_locked(conn, 0); in kiblnd_del_peer_locked()
537 kib_conn_t *conn; in kiblnd_get_conn_by_idx() local
559 conn = list_entry(ctmp, kib_conn_t, in kiblnd_get_conn_by_idx()
561 kiblnd_conn_addref(conn); in kiblnd_get_conn_by_idx()
565 return conn; in kiblnd_get_conn_by_idx()
608 static int kiblnd_get_completion_vector(kib_conn_t *conn, int cpt) in kiblnd_get_completion_vector() argument
614 lnet_nid_t nid = conn->ibc_peer->ibp_nid; in kiblnd_get_completion_vector()
616 vectors = conn->ibc_cmid->device->num_comp_vectors; in kiblnd_get_completion_vector()
[all …]
/linux-4.1.27/drivers/s390/net/
Dnetiucv.c218 struct iucv_connection *conn; member
229 struct iucv_connection *conn; member
297 static char *netiucv_printuser(struct iucv_connection *conn) in netiucv_printuser() argument
303 if (memcmp(conn->userdata, iucvMagic_ebcdic, 16)) { in netiucv_printuser()
306 memcpy(tmp_uid, conn->userid, 8); in netiucv_printuser()
308 memcpy(tmp_udat, conn->userdata, 16); in netiucv_printuser()
314 return netiucv_printname(conn->userid, 8); in netiucv_printuser()
533 struct iucv_connection *conn = path->private; in netiucv_callback_rx() local
536 ev.conn = conn; in netiucv_callback_rx()
538 fsm_event(conn->fsm, CONN_EVENT_RX, &ev); in netiucv_callback_rx()
[all …]
/linux-4.1.27/drivers/gpu/drm/armada/
Darmada_output.c16 struct drm_connector conn; member
20 #define drm_to_armada_conn(c) container_of(c, struct armada_connector, conn)
22 struct drm_encoder *armada_drm_connector_encoder(struct drm_connector *conn) in armada_drm_connector_encoder() argument
24 struct drm_encoder *enc = conn->encoder; in armada_drm_connector_encoder()
26 return enc ? enc : drm_encoder_find(conn->dev, conn->encoder_ids[0]); in armada_drm_connector_encoder()
30 struct drm_connector *conn, bool force) in armada_drm_connector_detect() argument
32 struct armada_connector *dconn = drm_to_armada_conn(conn); in armada_drm_connector_detect()
36 status = dconn->type->detect(conn, force); in armada_drm_connector_detect()
38 struct drm_encoder *enc = armada_drm_connector_encoder(conn); in armada_drm_connector_detect()
41 status = encoder_helper_funcs(enc)->detect(enc, conn); in armada_drm_connector_detect()
[all …]
Darmada_slave.c17 static int armada_drm_slave_get_modes(struct drm_connector *conn) in armada_drm_slave_get_modes() argument
19 struct drm_encoder *enc = armada_drm_connector_encoder(conn); in armada_drm_slave_get_modes()
25 count = slave->slave_funcs->get_modes(enc, conn); in armada_drm_slave_get_modes()
67 armada_drm_conn_slave_create(struct drm_connector *conn, const void *data) in armada_drm_conn_slave_create() argument
74 conn->interlace_allowed = config->interlace_allowed; in armada_drm_conn_slave_create()
75 conn->doublescan_allowed = config->doublescan_allowed; in armada_drm_conn_slave_create()
76 conn->polled = config->polled; in armada_drm_conn_slave_create()
78 drm_connector_helper_add(conn, &armada_drm_slave_helper_funcs); in armada_drm_conn_slave_create()
92 ret = drm_encoder_init(conn->dev, &slave->base, in armada_drm_conn_slave_create()
102 ret = drm_i2c_encoder_init(conn->dev, slave, adap, &config->info); in armada_drm_conn_slave_create()
[all …]
Darmada_output.h22 struct drm_encoder *armada_drm_connector_encoder(struct drm_connector *conn);
30 int armada_drm_slave_encoder_mode_valid(struct drm_connector *conn,
33 int armada_drm_slave_encoder_set_property(struct drm_connector *conn,
/linux-4.1.27/drivers/gpu/drm/nouveau/nvkm/engine/disp/
Dconn.c35 struct nvkm_connector *conn = container_of(notify, typeof(*conn), hpd); in nvkm_connector_hpd() local
36 struct nvkm_disp *disp = nvkm_disp(conn); in nvkm_connector_hpd()
37 struct nvkm_gpio *gpio = nvkm_gpio(conn); in nvkm_connector_hpd()
40 int index = conn->index; in nvkm_connector_hpd()
44 if (!gpio->get(gpio, 0, DCB_GPIO_UNUSED, conn->hpd.index)) in nvkm_connector_hpd()
57 struct nvkm_connector *conn = (void *)object; in _nvkm_connector_fini() local
58 nvkm_notify_put(&conn->hpd); in _nvkm_connector_fini()
59 return nvkm_object_fini(&conn->base, suspend); in _nvkm_connector_fini()
65 struct nvkm_connector *conn = (void *)object; in _nvkm_connector_init() local
66 int ret = nvkm_object_init(&conn->base); in _nvkm_connector_init()
[all …]
Doutp.c36 nv_ofuncs(outp->conn)->fini(nv_object(outp->conn), suspend); in _nvkm_output_fini()
46 nv_ofuncs(outp->conn)->init(nv_object(outp->conn)); in _nvkm_output_init()
55 nvkm_object_ref(NULL, (void *)&outp->conn); in _nvkm_output_dtor()
104 (struct nvkm_object **)&outp->conn); in nvkm_output_create_()
Doutpdp.c141 struct nvkm_connector *conn = container_of(notify, typeof(*conn), hpd); in nvkm_output_dp_hpd() local
143 struct nvkm_disp *disp = nvkm_disp(conn); in nvkm_output_dp_hpd()
148 if (outp->base.conn == conn && in nvkm_output_dp_hpd()
158 nvkm_event_send(&disp->hpd, rep.mask, conn->index, in nvkm_output_dp_hpd()
231 nvkm_notify_fini(&outp->base.conn->hpd); in nvkm_output_dp_create_()
277 &outp->base.conn->hpd); in nvkm_output_dp_create_()
Dbase.c81 if (ret = -ENXIO, outp->conn->index == req->v0.conn) { in nvkm_disp_hpd_ctor()
82 if (ret = -ENODEV, outp->conn->hpd.event) { in nvkm_disp_hpd_ctor()
84 notify->index = req->v0.conn; in nvkm_disp_hpd_ctor()
Dpriv.h8 struct nvkm_oclass **conn; member
Dconn.h51 struct nvkm_connector *_conn = (void *)conn; \
Doutp.h19 struct nvkm_connector *conn; member
DKbuild2 nvkm-y += nvkm/engine/disp/conn.o
/linux-4.1.27/arch/um/drivers/
Dport_kern.c47 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 …]
Dvde_user.c16 VDECONN *conn = NULL; in vde_user_init() local
21 conn = vde_open(pri->vde_switch, pri->descr, pri->args); in vde_user_init()
23 if (conn == NULL) { in vde_user_init()
32 pri->conn = conn; in vde_user_init()
41 if (pri->conn != NULL) in vde_user_open()
42 return vde_datafd(pri->conn); in vde_user_open()
52 if (pri->conn != NULL) { in vde_remove()
54 vde_close(pri->conn); in vde_remove()
55 pri->conn = NULL; in vde_remove()
96 int vde_user_read(void *conn, void *buf, int len) in vde_user_read() argument
[all …]
Dvde.h13 void *conn; member
29 extern int vde_user_read(void *conn, void *buf, int len);
30 extern int vde_user_write(void *conn, void *buf, int len);
Dvde_kern.c28 vpri->conn = NULL; in vde_init()
43 if (pri->conn != NULL) in vde_read()
44 return vde_user_read(pri->conn, skb_mac_header(skb), in vde_read()
55 if (pri->conn != NULL) in vde_write()
56 return vde_user_write((void *)pri->conn, skb->data, in vde_write()
Dnet_kern.c291 struct connection *conn = (struct connection *)_conn; in uml_net_user_timer_expire() local
293 dprintk(KERN_INFO "uml_net_user_timer_expire [%p]\n", conn); in uml_net_user_timer_expire()
294 do_connect(conn); in uml_net_user_timer_expire()
/linux-4.1.27/drivers/block/drbd/
Ddrbd_state.c75 device->state.conn != C_STANDALONE || in conn_all_vols_unconf()
187 enum drbd_conns conn = C_MASK; in conn_lowest_conn() local
194 conn = min_t(enum drbd_conns, conn, device->state.conn); in conn_lowest_conn()
198 return conn; in conn_lowest_conn()
209 if (peer_device->device->state.conn == C_WF_REPORT_PARAMS) { in no_peer_wf_report_params()
240 return (os.conn >= C_CONNECTED && ns.conn >= C_CONNECTED && in cl_wide_st_chg()
242 (os.conn != C_STARTING_SYNC_T && ns.conn == C_STARTING_SYNC_T) || in cl_wide_st_chg()
243 (os.conn != C_STARTING_SYNC_S && ns.conn == C_STARTING_SYNC_S) || in cl_wide_st_chg()
245 (os.conn >= C_CONNECTED && ns.conn == C_DISCONNECTING) || in cl_wide_st_chg()
246 (os.conn == C_CONNECTED && ns.conn == C_VERIFY_S) || in cl_wide_st_chg()
[all …]
Ddrbd_proc.c76 if (state.conn == C_VERIFY_S || state.conn == C_VERIFY_T) in drbd_get_syncer_progress()
133 if (state.conn == C_VERIFY_S || state.conn == C_VERIFY_T) in drbd_syncer_progress()
205 if (state.conn == C_SYNC_TARGET || in drbd_syncer_progress()
206 state.conn == C_VERIFY_S) { in drbd_syncer_progress()
218 if (state.conn == C_VERIFY_S || in drbd_syncer_progress()
219 state.conn == C_VERIFY_T) { in drbd_syncer_progress()
283 sn = drbd_conn_str(state.conn); in drbd_seq_show()
285 if (state.conn == C_STANDALONE && in drbd_seq_show()
329 if (state.conn == C_SYNC_SOURCE || in drbd_seq_show()
330 state.conn == C_SYNC_TARGET || in drbd_seq_show()
[all …]
Ddrbd_worker.c434 switch (device->state.conn) { in w_resync_timer()
838 test_bit(GOT_PING_ACK, &connection->flags) || device->state.conn < C_CONNECTED); in ping_peer()
877 if (device->state.conn == C_VERIFY_S || device->state.conn == C_VERIFY_T) in drbd_resync_finished()
891 verify_done = (os.conn == C_VERIFY_S || os.conn == C_VERIFY_T); in drbd_resync_finished()
895 if (os.conn <= C_CONNECTED) in drbd_resync_finished()
899 ns.conn = C_CONNECTED; in drbd_resync_finished()
907 if (os.conn == C_VERIFY_S || os.conn == C_VERIFY_T) { in drbd_resync_finished()
916 if (os.conn == C_SYNC_TARGET || os.conn == C_PAUSED_SYNC_T) in drbd_resync_finished()
937 if (os.conn == C_SYNC_TARGET || os.conn == C_PAUSED_SYNC_T) { in drbd_resync_finished()
948 if (os.conn == C_SYNC_TARGET || os.conn == C_PAUSED_SYNC_T) { in drbd_resync_finished()
[all …]
Ddrbd_req.h338 s.conn >= C_WF_BITMAP_T && in drbd_should_do_remote()
339 s.conn < C_AHEAD); in drbd_should_do_remote()
346 return s.conn == C_AHEAD || s.conn == C_WF_BITMAP_S; in drbd_should_send_out_of_sync()
Ddrbd_receiver.c519 conn_request_state(connection, NS(conn, C_BROKEN_PIPE), CS_HARD); in drbd_recv()
649 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_try_connect()
730 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in prepare_listen_socket()
772 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_wait_for_connect()
916 if (conn_request_state(connection, NS(conn, C_WF_CONNECTION), CS_VERBOSE) < SS_SUCCESS) in conn_connect()
1095 rv = conn_request_state(connection, NS(conn, C_WF_REPORT_PARAMS), CS_VERBOSE); in conn_connect()
1941 pcmd = (device->state.conn >= C_SYNC_SOURCE && in e_end_block()
1942 device->state.conn <= C_PAUSED_SYNC_T && in e_end_block()
2248 _conn_request_state(connection, NS(conn, C_TIMEOUT), CS_HARD); in handle_write_conflicts()
2398 if (device->state.conn == C_SYNC_TARGET) in receive_Data()
[all …]
Ddrbd_nl.c678 if (((device->state.conn < C_CONNECTED || in drbd_set_role()
691 if (device->state.conn >= C_WF_REPORT_PARAMS) { in drbd_set_role()
1036 if (device->state.conn < C_CONNECTED && assume_peer_has_space) { in drbd_new_dev_size()
1199 if (device->state.conn >= C_WF_REPORT_PARAMS) { in drbd_reconsider_max_bio_size()
1263 if (device->state.conn < C_CONNECTED) in drbd_suspend_al()
1425 if (device->state.conn >= C_CONNECTED) { in drbd_adm_disk_opts()
1687 if (device->state.conn < C_CONNECTED && in drbd_adm_attach()
1835 if (device->state.conn == C_CONNECTED) { in drbd_adm_attach()
1967 if (device->state.conn == C_SYNC_SOURCE || in conn_resync_running()
1968 device->state.conn == C_SYNC_TARGET || in conn_resync_running()
[all …]
Ddrbd_state.h84 unsigned conn:5 ; /* 17/32 cstates */ member
100 unsigned conn:5 ; /* 17/32 cstates */
/linux-4.1.27/net/wireless/
Dsme.c52 if (!wdev->conn) in cfg80211_sme_free()
55 kfree(wdev->conn->ie); in cfg80211_sme_free()
56 kfree(wdev->conn); in cfg80211_sme_free()
57 wdev->conn = NULL; in cfg80211_sme_free()
72 if (wdev->conn->params.channel) in cfg80211_conn_scan()
83 if (wdev->conn->params.channel) { in cfg80211_conn_scan()
84 enum ieee80211_band band = wdev->conn->params.channel->band; in cfg80211_conn_scan()
92 request->channels[0] = wdev->conn->params.channel; in cfg80211_conn_scan()
118 memcpy(request->ssids[0].ssid, wdev->conn->params.ssid, in cfg80211_conn_scan()
119 wdev->conn->params.ssid_len); in cfg80211_conn_scan()
[all …]
Dwext-sme.c92 if (wdev->conn) { in cfg80211_mgd_wext_siwfreq()
191 if (wdev->conn) { in cfg80211_mgd_wext_siwessid()
280 if (wdev->conn) { in cfg80211_mgd_wext_siwap()
367 if (wdev->conn) { in cfg80211_wext_siwgenie()
/linux-4.1.27/fs/ocfs2/
Dstack_o2cb.c200 static int o2cb_dlm_lock(struct ocfs2_cluster_connection *conn, in o2cb_dlm_lock() argument
212 status = dlmlock(conn->cc_lockspace, o2dlm_mode, &lksb->lksb_o2dlm, in o2cb_dlm_lock()
220 static int o2cb_dlm_unlock(struct ocfs2_cluster_connection *conn, in o2cb_dlm_unlock() argument
228 status = dlmunlock(conn->cc_lockspace, &lksb->lksb_o2dlm, in o2cb_dlm_unlock()
320 struct ocfs2_cluster_connection *conn = data; in o2dlm_eviction_cb() local
323 node_num, conn->cc_namelen, conn->cc_name); in o2dlm_eviction_cb()
325 conn->cc_recovery_handler(node_num, conn->cc_recovery_data); in o2dlm_eviction_cb()
328 static int o2cb_cluster_connect(struct ocfs2_cluster_connection *conn) in o2cb_cluster_connect() argument
336 BUG_ON(conn == NULL); in o2cb_cluster_connect()
337 BUG_ON(conn->cc_proto == NULL); in o2cb_cluster_connect()
[all …]
Dstack_user.c215 static int ocfs2_live_connection_attach(struct ocfs2_cluster_connection *conn, in ocfs2_live_connection_attach() argument
221 c->oc_conn = conn; in ocfs2_live_connection_attach()
696 static int user_dlm_lock(struct ocfs2_cluster_connection *conn, in user_dlm_lock() argument
709 ret = dlm_lock(conn->cc_lockspace, mode, &lksb->lksb_fsdlm, in user_dlm_lock()
716 static int user_dlm_unlock(struct ocfs2_cluster_connection *conn, in user_dlm_unlock() argument
722 ret = dlm_unlock(conn->cc_lockspace, lksb->lksb_fsdlm.sb_lkid, in user_dlm_unlock()
751 static int user_plock(struct ocfs2_cluster_connection *conn, in user_plock() argument
775 return dlm_posix_get(conn->cc_lockspace, ino, file, fl); in user_plock()
777 return dlm_posix_unlock(conn->cc_lockspace, ino, file, fl); in user_plock()
779 return dlm_posix_lock(conn->cc_lockspace, ino, file, cmd, fl); in user_plock()
[all …]
Dstackglue.h138 int (*connect)(struct ocfs2_cluster_connection *conn);
154 int (*disconnect)(struct ocfs2_cluster_connection *conn);
160 int (*this_node)(struct ocfs2_cluster_connection *conn,
173 int (*dlm_lock)(struct ocfs2_cluster_connection *conn,
189 int (*dlm_unlock)(struct ocfs2_cluster_connection *conn,
216 int (*plock)(struct ocfs2_cluster_connection *conn,
256 struct ocfs2_cluster_connection **conn);
267 struct ocfs2_cluster_connection **conn);
268 int ocfs2_cluster_disconnect(struct ocfs2_cluster_connection *conn,
271 int ocfs2_cluster_this_node(struct ocfs2_cluster_connection *conn,
[all …]
Dstackglue.c241 int ocfs2_dlm_lock(struct ocfs2_cluster_connection *conn, in ocfs2_dlm_lock() argument
249 lksb->lksb_conn = conn; in ocfs2_dlm_lock()
251 BUG_ON(lksb->lksb_conn != conn); in ocfs2_dlm_lock()
252 return active_stack->sp_ops->dlm_lock(conn, mode, lksb, flags, in ocfs2_dlm_lock()
257 int ocfs2_dlm_unlock(struct ocfs2_cluster_connection *conn, in ocfs2_dlm_unlock() argument
263 return active_stack->sp_ops->dlm_unlock(conn, lksb, flags); in ocfs2_dlm_unlock()
301 int ocfs2_plock(struct ocfs2_cluster_connection *conn, u64 ino, in ocfs2_plock() argument
306 return active_stack->sp_ops->plock(conn, ino, file, cmd, fl); in ocfs2_plock()
320 struct ocfs2_cluster_connection **conn) in ocfs2_cluster_connect() argument
326 BUG_ON(conn == NULL); in ocfs2_cluster_connect()
[all …]
/linux-4.1.27/include/net/bluetooth/
Dhci_core.h473 void (*connect_cfm_cb) (struct hci_conn *conn, u8 status);
474 void (*security_cfm_cb) (struct hci_conn *conn, u8 status);
475 void (*disconn_cfm_cb) (struct hci_conn *conn, u8 reason);
481 struct hci_conn *conn; member
507 struct hci_conn *conn; member
627 static inline bool hci_conn_ssp_enabled(struct hci_conn *conn) in hci_conn_ssp_enabled() argument
629 struct hci_dev *hdev = conn->hdev; in hci_conn_ssp_enabled()
631 test_bit(HCI_CONN_SSP_ENABLED, &conn->flags); in hci_conn_ssp_enabled()
634 static inline bool hci_conn_sc_enabled(struct hci_conn *conn) in hci_conn_sc_enabled() argument
636 struct hci_dev *hdev = conn->hdev; in hci_conn_sc_enabled()
[all …]
Dl2cap.h484 struct l2cap_conn *conn; member
651 int (*probe) (struct l2cap_conn *conn, struct l2cap_user *user);
652 void (*remove) (struct l2cap_conn *conn, struct l2cap_user *user);
926 void l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan);
927 void __l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan);
935 struct l2cap_conn *l2cap_conn_get(struct l2cap_conn *conn);
936 void l2cap_conn_put(struct l2cap_conn *conn);
938 int l2cap_register_user(struct l2cap_conn *conn, struct l2cap_user *user);
939 void l2cap_unregister_user(struct l2cap_conn *conn, struct l2cap_user *user);
/linux-4.1.27/net/netfilter/
Dxt_connlimit.c89 static inline bool already_closed(const struct nf_conn *conn) in already_closed() argument
91 if (nf_ct_protonum(conn) == IPPROTO_TCP) in already_closed()
92 return conn->proto.tcp.state == TCP_CONNTRACK_TIME_WAIT || in already_closed()
93 conn->proto.tcp.state == TCP_CONNTRACK_CLOSE; in already_closed()
123 struct xt_connlimit_conn *conn; in add_hlist() local
125 conn = kmem_cache_alloc(connlimit_conn_cachep, GFP_ATOMIC); in add_hlist()
126 if (conn == NULL) in add_hlist()
128 conn->tuple = *tuple; in add_hlist()
129 conn->addr = *addr; in add_hlist()
130 hlist_add_head(&conn->node, head); in add_hlist()
[all …]
/linux-4.1.27/drivers/infiniband/ulp/iser/
Discsi_iser.c116 iscsi_iser_recv(struct iscsi_conn *conn, struct iscsi_hdr *hdr, in iscsi_iser_recv() argument
139 rc = iscsi_complete_pdu(conn, hdr, rx_data, rx_data_len); in iscsi_iser_recv()
145 iscsi_conn_failure(conn, rc); in iscsi_iser_recv()
182 struct iser_conn *iser_conn = task->conn->dd_data; in iser_initialize_task_headers()
263 iscsi_iser_mtask_xmit(struct iscsi_conn *conn, struct iscsi_task *task) in iscsi_iser_mtask_xmit() argument
267 iser_dbg("mtask xmit [cid %d itt 0x%x]\n", conn->id, task->itt); in iscsi_iser_mtask_xmit()
269 error = iser_send_control(conn, task); in iscsi_iser_mtask_xmit()
281 iscsi_iser_task_xmit_unsol_data(struct iscsi_conn *conn, in iscsi_iser_task_xmit_unsol_data() argument
296 error = iser_send_data_out(conn, task, &hdr); in iscsi_iser_task_xmit_unsol_data()
319 struct iscsi_conn *conn = task->conn; in iscsi_iser_task_xmit() local
[all …]
Diser_initiator.c337 static int iser_post_rx_bufs(struct iscsi_conn *conn, struct iscsi_hdr *req) in iser_post_rx_bufs() argument
339 struct iser_conn *iser_conn = conn->dd_data; in iser_post_rx_bufs()
341 struct iscsi_session *session = conn->session; in iser_post_rx_bufs()
376 int iser_send_command(struct iscsi_conn *conn, in iser_send_command() argument
379 struct iser_conn *iser_conn = conn->dd_data; in iser_send_command()
439 iser_err("conn %p failed task->itt %d err %d\n",conn, task->itt, err); in iser_send_command()
446 int iser_send_data_out(struct iscsi_conn *conn, in iser_send_data_out() argument
450 struct iser_conn *iser_conn = conn->dd_data; in iser_send_data_out()
507 iser_err("conn %p failed err %d\n", conn, err); in iser_send_data_out()
511 int iser_send_control(struct iscsi_conn *conn, in iser_send_control() argument
[all …]
Discsi_iser.h562 int iser_send_control(struct iscsi_conn *conn,
565 int iser_send_command(struct iscsi_conn *conn,
568 int iser_send_data_out(struct iscsi_conn *conn,
572 void iscsi_iser_recv(struct iscsi_conn *conn,
/linux-4.1.27/sound/firewire/fireworks/
Dfireworks_stream.c15 struct cmp_connection *conn; in init_stream() local
21 conn = &efw->out_conn; in init_stream()
25 conn = &efw->in_conn; in init_stream()
30 err = cmp_connection_init(conn, efw->unit, c_dir, 0); in init_stream()
37 cmp_connection_destroy(conn); in init_stream()
59 struct cmp_connection *conn; in start_stream() local
67 conn = &efw->out_conn; in start_stream()
71 conn = &efw->in_conn; in start_stream()
80 err = cmp_connection_establish(conn, in start_stream()
87 conn->resources.channel, in start_stream()
[all …]
/linux-4.1.27/drivers/net/wireless/ath/ath6kl/
Dtxrx.c102 static bool ath6kl_process_uapsdq(struct ath6kl_sta *conn, in ath6kl_process_uapsdq() argument
114 if (conn->sta_flags & STA_PS_APSD_TRIGGER) { in ath6kl_process_uapsdq()
120 spin_lock_bh(&conn->psq_lock); in ath6kl_process_uapsdq()
121 if (!skb_queue_empty(&conn->apsdq)) in ath6kl_process_uapsdq()
123 else if (conn->sta_flags & STA_PS_APSD_EOSP) in ath6kl_process_uapsdq()
126 spin_unlock_bh(&conn->psq_lock); in ath6kl_process_uapsdq()
128 } else if (!conn->apsd_info) { in ath6kl_process_uapsdq()
152 if ((conn->apsd_info & (1 << traffic_class)) == 0) in ath6kl_process_uapsdq()
156 spin_lock_bh(&conn->psq_lock); in ath6kl_process_uapsdq()
157 is_apsdq_empty = skb_queue_empty(&conn->apsdq); in ath6kl_process_uapsdq()
[all …]
Dmain.c29 struct ath6kl_sta *conn = NULL; in ath6kl_find_sta() local
39 conn = &ar->sta_list[i]; in ath6kl_find_sta()
44 return conn; in ath6kl_find_sta()
49 struct ath6kl_sta *conn = NULL; in ath6kl_find_sta_by_aid() local
54 conn = &ar->sta_list[ctr]; in ath6kl_find_sta_by_aid()
58 return conn; in ath6kl_find_sta_by_aid()
864 struct ath6kl_sta *conn; in ath6kl_pspoll_event() local
870 conn = ath6kl_find_sta_by_aid(ar, aid); in ath6kl_pspoll_event()
872 if (!conn) in ath6kl_pspoll_event()
878 spin_lock_bh(&conn->psq_lock); in ath6kl_pspoll_event()
[all …]
Dcfg80211.c3099 struct ath6kl_sta *conn; in ath6kl_mgmt_powersave_ap() local
3109 conn = ath6kl_find_sta(vif, mgmt->da); in ath6kl_mgmt_powersave_ap()
3110 if (!conn) in ath6kl_mgmt_powersave_ap()
3113 if (conn->sta_flags & STA_PS_SLEEP) { in ath6kl_mgmt_powersave_ap()
3114 if (!(conn->sta_flags & STA_PS_POLLED)) { in ath6kl_mgmt_powersave_ap()
3128 spin_lock_bh(&conn->psq_lock); in ath6kl_mgmt_powersave_ap()
3129 is_psq_empty = skb_queue_empty(&conn->psq) && in ath6kl_mgmt_powersave_ap()
3130 (conn->mgmt_psq_len == 0); in ath6kl_mgmt_powersave_ap()
3131 list_add_tail(&mgmt_buf->list, &conn->mgmt_psq); in ath6kl_mgmt_powersave_ap()
3132 conn->mgmt_psq_len++; in ath6kl_mgmt_powersave_ap()
[all …]
/linux-4.1.27/sound/firewire/oxfw/
Doxfw-stream.c119 struct cmp_connection *conn; in start_stream() local
126 conn = &oxfw->in_conn; in start_stream()
129 conn = &oxfw->out_conn; in start_stream()
160 err = cmp_connection_establish(conn, in start_stream()
166 conn->resources.channel, in start_stream()
167 conn->speed); in start_stream()
169 cmp_connection_break(conn); in start_stream()
185 struct cmp_connection *conn; in check_connection_used_by_others() local
190 conn = &oxfw->out_conn; in check_connection_used_by_others()
192 conn = &oxfw->in_conn; in check_connection_used_by_others()
[all …]
/linux-4.1.27/drivers/infiniband/ulp/isert/
Dib_isert.c53 isert_map_rdma(struct iscsi_conn *conn, struct iscsi_cmd *cmd,
58 isert_reg_rdma(struct iscsi_conn *conn, struct iscsi_cmd *cmd,
61 isert_put_response(struct iscsi_conn *conn, struct iscsi_cmd *cmd);
71 isert_prot_cmd(struct isert_conn *conn, struct se_cmd *cmd) in isert_prot_cmd() argument
73 return (conn->pi_support && in isert_prot_cmd()
599 struct se_session *se_sess = isert_conn->conn->sess->se_sess; in isert_conn_create_fastreg_pool()
762 event->param.conn.initiator_depth, in isert_connect_request()
1160 isert_put_login_tx(struct iscsi_conn *conn, struct iscsi_login *login, in isert_put_login_tx() argument
1163 struct isert_conn *isert_conn = conn->context; in isert_put_login_tx()
1194 if (!conn->sess->sess_ops->SessionType && in isert_put_login_tx()
[all …]
Dib_isert.h141 struct isert_conn *conn; member
166 struct iscsi_conn *conn; member
218 int (*reg_rdma_mem)(struct iscsi_conn *conn,
/linux-4.1.27/drivers/scsi/cxgbi/
Dlibcxgbi.c1687 struct iscsi_tcp_conn *tcp_conn = task->conn->dd_data; in task_release_itt()
1704 struct iscsi_conn *conn = task->conn; in task_reserve_itt() local
1705 struct iscsi_session *sess = conn->session; in task_reserve_itt()
1706 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in task_reserve_itt()
1739 void cxgbi_parse_pdu_itt(struct iscsi_conn *conn, itt_t itt, int *idx, int *age) in cxgbi_parse_pdu_itt() argument
1741 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in cxgbi_parse_pdu_itt()
1762 struct iscsi_conn *conn = csk->user_data; in cxgbi_conn_tx_open() local
1764 if (conn) { in cxgbi_conn_tx_open()
1766 "csk 0x%p, cid %d.\n", csk, conn->id); in cxgbi_conn_tx_open()
1767 iscsi_conn_queue_work(conn); in cxgbi_conn_tx_open()
[all …]
/linux-4.1.27/drivers/scsi/be2iscsi/
Dbe_iscsi.c134 struct iscsi_conn *conn; in beiscsi_conn_create() local
149 conn = cls_conn->dd_data; in beiscsi_conn_create()
150 beiscsi_conn = conn->dd_data; in beiscsi_conn_create()
153 beiscsi_conn->conn = conn; in beiscsi_conn_create()
199 struct iscsi_conn *conn = cls_conn->dd_data; in beiscsi_conn_bind() local
200 struct beiscsi_conn *beiscsi_conn = conn->dd_data; in beiscsi_conn_bind()
230 beiscsi_ep->conn = beiscsi_conn; in beiscsi_conn_bind()
235 beiscsi_conn, conn, beiscsi_ep->ep_cid); in beiscsi_conn_bind()
671 struct iscsi_conn *conn = cls_conn->dd_data; in beiscsi_set_param() local
672 struct iscsi_session *session = conn->session; in beiscsi_set_param()
[all …]
Dbe_main.c223 struct iscsi_conn *conn; in beiscsi_eh_abort() local
254 conn = aborted_task->conn; in beiscsi_eh_abort()
255 beiscsi_conn = conn->dd_data; in beiscsi_eh_abort()
300 struct iscsi_conn *conn; in beiscsi_eh_device_reset() local
318 conn = session->leadconn; in beiscsi_eh_device_reset()
319 beiscsi_conn = conn->dd_data; in beiscsi_eh_device_reset()
325 for (i = 0; i < conn->session->cmds_max; i++) { in beiscsi_eh_device_reset()
326 abrt_task = conn->session->cmds[i]; in beiscsi_eh_device_reset()
1090 struct iscsi_conn *conn = beiscsi_conn->conn; in beiscsi_process_async_pdu() local
1091 struct iscsi_session *session = conn->session; in beiscsi_process_async_pdu()
[all …]
Dbe_iscsi.h49 void beiscsi_offload_iscsi(struct beiscsi_hba *phba, struct iscsi_conn *conn,
/linux-4.1.27/drivers/gpu/drm/nouveau/nvkm/subdev/bios/
Dmxm.c74 mxm_sor_map(struct nvkm_bios *bios, u8 conn) in mxm_sor_map() argument
83 if (conn < nv_ro08(bios, map + 3)) { in mxm_sor_map()
85 map += conn; in mxm_sor_map()
97 return g84_sor_map[conn]; in mxm_sor_map()
99 return g92_sor_map[conn]; in mxm_sor_map()
101 return g94_sor_map[conn]; in mxm_sor_map()
103 return g98_sor_map[conn]; in mxm_sor_map()
Ddcb.c129 u32 conn = nv_ro32(bios, dcb + 0x00); in dcb_outp_parse() local
130 outp->or = (conn & 0x0f000000) >> 24; in dcb_outp_parse()
131 outp->location = (conn & 0x00300000) >> 20; in dcb_outp_parse()
132 outp->bus = (conn & 0x000f0000) >> 16; in dcb_outp_parse()
133 outp->connector = (conn & 0x0000f000) >> 12; in dcb_outp_parse()
134 outp->heads = (conn & 0x00000f00) >> 8; in dcb_outp_parse()
135 outp->i2c_index = (conn & 0x000000f0) >> 4; in dcb_outp_parse()
136 outp->type = (conn & 0x0000000f); in dcb_outp_parse()
DKbuild4 nvkm-y += nvkm/subdev/bios/conn.o
/linux-4.1.27/drivers/hwtracing/coresight/
Dcoresight.c75 struct coresight_connection *conn; in coresight_find_link_inport() local
81 conn = &parent->conns[i]; in coresight_find_link_inport()
82 if (conn->child_dev == csdev) in coresight_find_link_inport()
83 return conn->child_port; in coresight_find_link_inport()
96 struct coresight_connection *conn; in coresight_find_link_outport() local
102 conn = &csdev->conns[i]; in coresight_find_link_outport()
103 if (conn->child_dev == child) in coresight_find_link_outport()
104 return conn->outport; in coresight_find_link_outport()
304 struct coresight_connection *conn; in coresight_build_paths() local
317 conn = &csdev->conns[i]; in coresight_build_paths()
[all …]
/linux-4.1.27/drivers/scsi/bnx2i/
Dbnx2i_iscsi.c114 if ((start_bd_offset > task->conn->session->first_burst) || in bnx2i_setup_write_cmd_bd_info()
118 iscsi_conn_printk(KERN_ALERT, task->conn, in bnx2i_setup_write_cmd_bd_info()
124 iscsi_conn_printk(KERN_ALERT, task->conn, in bnx2i_setup_write_cmd_bd_info()
190 bd_count = bnx2i_map_scsi_sg(cmd->conn->hba, cmd); in bnx2i_iscsi_map_sg_list()
427 if (bnx2i_ep->conn) { in bnx2i_free_ep()
428 bnx2i_ep->conn->ep = NULL; in bnx2i_free_ep()
429 bnx2i_ep->conn = NULL; in bnx2i_free_ep()
1084 struct bnx2i_conn *bnx2i_conn = cmd->conn; in bnx2i_iscsi_send_generic_request()
1160 struct iscsi_conn *conn = task->conn; in bnx2i_cleanup_task() local
1161 struct bnx2i_conn *bnx2i_conn = conn->dd_data; in bnx2i_cleanup_task()
[all …]
Dbnx2i.h259 struct bnx2i_conn *conn; member
751 struct bnx2i_conn *conn; member
828 void bnx2i_get_rq_buf(struct bnx2i_conn *conn, char *ptr, int len);
829 void bnx2i_put_rq_buf(struct bnx2i_conn *conn, int count);
836 extern int bnx2i_send_iscsi_login(struct bnx2i_conn *conn,
838 extern int bnx2i_send_iscsi_tmf(struct bnx2i_conn *conn,
840 extern int bnx2i_send_iscsi_text(struct bnx2i_conn *conn,
842 extern int bnx2i_send_iscsi_scsicmd(struct bnx2i_conn *conn,
844 extern int bnx2i_send_iscsi_nopout(struct bnx2i_conn *conn,
847 extern int bnx2i_send_iscsi_logout(struct bnx2i_conn *conn,
[all …]
Dbnx2i_hwi.c210 static void bnx2i_ring_577xx_doorbell(struct bnx2i_conn *conn) in bnx2i_ring_577xx_doorbell() argument
220 writel(cpu_to_le32(msg), conn->ep->qp.ctx_base); in bnx2i_ring_577xx_doorbell()
390 struct iscsi_conn *conn = bnx2i_conn->cls_conn->dd_data; in bnx2i_send_iscsi_tmf() local
414 ctask = iscsi_itt_to_task(conn, tmfabort_hdr->rtt); in bnx2i_send_iscsi_tmf()
645 void bnx2i_update_iscsi_conn(struct iscsi_conn *conn) in bnx2i_update_iscsi_conn() argument
647 struct bnx2i_conn *bnx2i_conn = conn->dd_data; in bnx2i_update_iscsi_conn()
665 if (conn->hdrdgst_en) in bnx2i_update_iscsi_conn()
667 if (conn->datadgst_en) in bnx2i_update_iscsi_conn()
669 if (conn->session->initial_r2t_en) in bnx2i_update_iscsi_conn()
671 if (conn->session->imm_data_en) in bnx2i_update_iscsi_conn()
[all …]
/linux-4.1.27/net/tipc/
Dnode.c170 struct tipc_sock_conn *conn; in tipc_node_add_conn() local
181 conn = kmalloc(sizeof(*conn), GFP_ATOMIC); in tipc_node_add_conn()
182 if (!conn) { in tipc_node_add_conn()
186 conn->peer_node = dnode; in tipc_node_add_conn()
187 conn->port = port; in tipc_node_add_conn()
188 conn->peer_port = peer_port; in tipc_node_add_conn()
191 list_add_tail(&conn->list, &node->conn_sks); in tipc_node_add_conn()
201 struct tipc_sock_conn *conn, *safe; in tipc_node_remove_conn() local
211 list_for_each_entry_safe(conn, safe, &node->conn_sks, list) { in tipc_node_remove_conn()
212 if (port != conn->port) in tipc_node_remove_conn()
[all …]
/linux-4.1.27/drivers/gpu/drm/nouveau/
Dnouveau_bios.c1397 uint32_t conn, uint32_t conf, struct dcb_output *entry) in parse_dcb20_entry() argument
1402 entry->type = conn & 0xf; in parse_dcb20_entry()
1403 entry->i2c_index = (conn >> 4) & 0xf; in parse_dcb20_entry()
1404 entry->heads = (conn >> 8) & 0xf; in parse_dcb20_entry()
1405 entry->connector = (conn >> 12) & 0xf; in parse_dcb20_entry()
1406 entry->bus = (conn >> 16) & 0xf; in parse_dcb20_entry()
1407 entry->location = (conn >> 20) & 0x3; in parse_dcb20_entry()
1408 entry->or = (conn >> 24) & 0xf; in parse_dcb20_entry()
1541 uint32_t conn, uint32_t conf, struct dcb_output *entry) in parse_dcb15_entry() argument
1545 switch (conn & 0x0000000f) { in parse_dcb15_entry()
[all …]
Dnouveau_display.c373 struct nouveau_connector *conn = nouveau_connector(connector); in nouveau_display_init() local
374 nvif_notify_get(&conn->hpd); in nouveau_display_init()
393 struct nouveau_connector *conn = nouveau_connector(connector); in nouveau_display_fini() local
394 nvif_notify_put(&conn->hpd); in nouveau_display_fini()
/linux-4.1.27/include/scsi/
Dscsi_transport_iscsi.h101 int (*start_conn) (struct iscsi_cls_conn *conn);
102 void (*stop_conn) (struct iscsi_cls_conn *conn, int flag);
103 void (*destroy_conn) (struct iscsi_cls_conn *conn);
104 int (*set_param) (struct iscsi_cls_conn *conn, enum iscsi_param param,
108 int (*get_conn_param) (struct iscsi_cls_conn *conn,
117 int (*send_pdu) (struct iscsi_cls_conn *conn, struct iscsi_hdr *hdr,
119 void (*get_stats) (struct iscsi_cls_conn *conn,
130 void (*parse_pdu_itt) (struct iscsi_conn *conn, itt_t itt,
182 extern void iscsi_conn_error_event(struct iscsi_cls_conn *conn,
184 extern void iscsi_conn_login_event(struct iscsi_cls_conn *conn,
[all …]
Dlibiscsi.h130 struct iscsi_conn *conn; /* used connection */ member
432 extern void iscsi_conn_failure(struct iscsi_conn *conn, enum iscsi_err err);
439 extern void iscsi_suspend_tx(struct iscsi_conn *conn);
440 extern void iscsi_suspend_queue(struct iscsi_conn *conn);
441 extern void iscsi_conn_queue_work(struct iscsi_conn *conn);
Dlibiscsi_tcp.h98 extern int iscsi_tcp_recv_skb(struct iscsi_conn *conn, struct sk_buff *skb,
133 extern int iscsi_tcp_set_max_r2t(struct iscsi_conn *conn, char *buf);
/linux-4.1.27/drivers/video/fbdev/nvidia/
Dnv_of.c28 int nvidia_probe_of_connector(struct fb_info *info, int conn, u8 **out_edid) in nvidia_probe_of_connector() argument
51 if ((pname[len-1] == 'A' && conn == 1) || in nvidia_probe_of_connector()
52 (pname[len-1] == 'B' && conn == 2)) { in nvidia_probe_of_connector()
75 printk(KERN_DEBUG "nvidiafb: Found OF EDID for head %d\n", conn); in nvidia_probe_of_connector()
Dnv_i2c.c152 int nvidia_probe_i2c_connector(struct fb_info *info, int conn, u8 **out_edid) in nvidia_probe_i2c_connector() argument
157 if (par->chan[conn - 1].par) in nvidia_probe_i2c_connector()
158 edid = fb_ddc_read(&par->chan[conn - 1].adapter); in nvidia_probe_i2c_connector()
160 if (!edid && conn == 1) { in nvidia_probe_i2c_connector()
Dnv_proto.h37 int nvidia_probe_i2c_connector(struct fb_info *info, int conn,
45 int nvidia_probe_of_connector(struct fb_info *info, int conn,
/linux-4.1.27/drivers/video/fbdev/aty/
Dradeon_i2c.c140 int radeon_probe_i2c_connector(struct radeonfb_info *rinfo, int conn, in radeon_probe_i2c_connector() argument
145 edid = fb_ddc_read(&rinfo->i2c[conn-1].adapter); in radeon_probe_i2c_connector()
150 pr_debug("radeonfb: I2C (port %d) ... not found\n", conn); in radeon_probe_i2c_connector()
157 pr_debug("radeonfb: I2C (port %d) ... found LVDS panel\n", conn); in radeon_probe_i2c_connector()
160 pr_debug("radeonfb: I2C (port %d) ... found TMDS panel\n", conn); in radeon_probe_i2c_connector()
164 pr_debug("radeonfb: I2C (port %d) ... found CRT display\n", conn); in radeon_probe_i2c_connector()
Dradeon_monitor.c256 int offset, chips, connectors, tmp, i, conn, type; in radeon_parse_connector_info() local
282 for (conn = 0; ; conn++) { in radeon_parse_connector_info()
289 conn, type, __conn_type_table[type], tmp); in radeon_parse_connector_info()
/linux-4.1.27/drivers/gpio/
Dgpiolib-acpi.c554 struct acpi_gpio_connection *conn; in acpi_gpio_adr_space_handler() local
567 list_for_each_entry(conn, &achip->conns, node) { in acpi_gpio_adr_space_handler()
568 if (conn->pin == pin) { in acpi_gpio_adr_space_handler()
570 desc = conn->desc; in acpi_gpio_adr_space_handler()
606 conn = kzalloc(sizeof(*conn), GFP_KERNEL); in acpi_gpio_adr_space_handler()
607 if (!conn) { in acpi_gpio_adr_space_handler()
614 conn->pin = pin; in acpi_gpio_adr_space_handler()
615 conn->desc = desc; in acpi_gpio_adr_space_handler()
616 list_add_tail(&conn->node, &achip->conns); in acpi_gpio_adr_space_handler()
652 struct acpi_gpio_connection *conn, *tmp; in acpi_gpiochip_free_regions() local
[all …]
/linux-4.1.27/fs/ocfs2/dlmfs/
Duserdlm.c303 struct ocfs2_cluster_connection *conn = in user_dlm_unblock_lock() local
348 status = ocfs2_dlm_unlock(conn, &lockres->l_lksb, in user_dlm_unblock_lock()
385 status = ocfs2_dlm_lock(conn, new_level, &lockres->l_lksb, in user_dlm_unblock_lock()
430 struct ocfs2_cluster_connection *conn = in user_dlm_cluster_lock() local
488 status = ocfs2_dlm_lock(conn, level, &lockres->l_lksb, in user_dlm_cluster_lock()
609 struct ocfs2_cluster_connection *conn = in user_dlm_destroy_lock() local
645 status = ocfs2_dlm_unlock(conn, &lockres->l_lksb, DLM_LKF_VALBLK); in user_dlm_destroy_lock()
673 struct ocfs2_cluster_connection *conn; in user_dlm_register() local
678 NULL, &conn); in user_dlm_register()
682 return rc ? ERR_PTR(rc) : conn; in user_dlm_register()
[all …]
Ddlmfs.c474 struct ocfs2_cluster_connection *conn; in dlmfs_mkdir() local
494 conn = user_dlm_register(domain); in dlmfs_mkdir()
495 if (IS_ERR(conn)) { in dlmfs_mkdir()
496 status = PTR_ERR(conn); in dlmfs_mkdir()
501 ip->ip_conn = conn; in dlmfs_mkdir()
Duserdlm.h87 void user_dlm_unregister(struct ocfs2_cluster_connection *conn);
/linux-4.1.27/drivers/net/wireless/ti/wlcore/
Ddebugfs.c265 wl->conf.conn.dynamic_ps_timeout); in dynamic_ps_timeout_read()
290 wl->conf.conn.dynamic_ps_timeout = value; in dynamic_ps_timeout_write()
329 wl->conf.conn.forced_ps); in forced_ps_read()
354 if (wl->conf.conn.forced_ps == value) in forced_ps_write()
357 wl->conf.conn.forced_ps = value; in forced_ps_write()
648 if (wl->conf.conn.wake_up_event == CONF_WAKE_UP_EVENT_DTIM || in dtim_interval_read()
649 wl->conf.conn.wake_up_event == CONF_WAKE_UP_EVENT_N_DTIM) in dtim_interval_read()
650 value = wl->conf.conn.listen_interval; in dtim_interval_read()
678 wl->conf.conn.listen_interval = value; in dtim_interval_write()
681 wl->conf.conn.wake_up_event = CONF_WAKE_UP_EVENT_DTIM; in dtim_interval_write()
[all …]
Dps.c100 timeout = wl->conf.conn.forced_ps ? in wl1271_ps_elp_sleep()
179 u16 timeout = wl->conf.conn.dynamic_ps_timeout; in wl1271_ps_set_mode()
188 wl->conf.conn.wake_up_event, in wl1271_ps_set_mode()
189 wl->conf.conn.listen_interval); in wl1271_ps_set_mode()
Dacx.c365 wl->conf.conn.bcn_filt_mode == CONF_BCN_FILT_MODE_DISABLED) in wl1271_acx_beacon_filter_opt()
414 for (i = 0; i < wl->conf.conn.bcn_filt_ie_count; i++) { in wl1271_acx_beacon_filter_table()
415 struct conf_bcn_filt_rule *r = &(wl->conf.conn.bcn_filt_ie[i]); in wl1271_acx_beacon_filter_table()
471 threshold = wl->conf.conn.synch_fail_thold; in wl1271_acx_conn_monit_params()
472 timeout = wl->conf.conn.bss_lose_timeout; in wl1271_acx_conn_monit_params()
592 bb->beacon_rx_timeout = cpu_to_le16(wl->conf.conn.beacon_rx_timeout); in wl1271_acx_bcn_dtim_options()
593 bb->broadcast_timeout = cpu_to_le16(wl->conf.conn.broadcast_timeout); in wl1271_acx_bcn_dtim_options()
594 bb->rx_broadcast_in_ps = wl->conf.conn.rx_broadcast_in_ps; in wl1271_acx_bcn_dtim_options()
595 bb->ps_poll_threshold = wl->conf.conn.ps_poll_threshold; in wl1271_acx_bcn_dtim_options()
1081 if (enable && wl->conf.conn.bet_enable == CONF_BET_MODE_DISABLE) in wl1271_acx_bet_enable()
[all …]
Devent.c240 int delay = wl->conf.conn.synch_fail_thold * in wlcore_event_beacon_loss()
241 wl->conf.conn.bss_lose_timeout; in wlcore_event_beacon_loss()
/linux-4.1.27/drivers/gpu/drm/nouveau/nvkm/subdev/mxm/
Dnv50.c104 u8 *conn; in mxm_dcb_sanitise_entry() local
150 conn = bios->data; in mxm_dcb_sanitise_entry()
151 conn += nvbios_connEe(bios, (ctx.outp[0] & 0x0000f000) >> 12, &ver, &len); in mxm_dcb_sanitise_entry()
152 type = conn[0]; in mxm_dcb_sanitise_entry()
175 conn[0] = type; in mxm_dcb_sanitise_entry()
/linux-4.1.27/drivers/net/wireless/ath/wil6210/
Dcfg80211.c385 struct wmi_connect_cmd conn; in wil_cfg80211_connect() local
447 memset(&conn, 0, sizeof(conn)); in wil_cfg80211_connect()
450 conn.network_type = WMI_NETTYPE_INFRA; in wil_cfg80211_connect()
453 conn.network_type = WMI_NETTYPE_P2P; in wil_cfg80211_connect()
461 conn.dot11_auth_mode = WMI_AUTH11_SHARED; in wil_cfg80211_connect()
462 conn.auth_mode = WMI_AUTH_WPA2_PSK; in wil_cfg80211_connect()
463 conn.pairwise_crypto_type = WMI_CRYPT_AES_GCMP; in wil_cfg80211_connect()
464 conn.pairwise_crypto_len = 16; in wil_cfg80211_connect()
466 conn.dot11_auth_mode = WMI_AUTH11_OPEN; in wil_cfg80211_connect()
467 conn.auth_mode = WMI_AUTH_NONE; in wil_cfg80211_connect()
[all …]
/linux-4.1.27/fs/nfsd/
Dnfs4callback.c729 static int setup_callback_client(struct nfs4_client *clp, struct nfs4_cb_conn *conn, struct nfsd4_s… in setup_callback_client() argument
739 .address = (struct sockaddr *) &conn->cb_addr, in setup_callback_client()
740 .addrsize = conn->cb_addrlen, in setup_callback_client()
741 .saddress = (struct sockaddr *) &conn->cb_saddr, in setup_callback_client()
755 args.prognumber = conn->cb_prog; in setup_callback_client()
758 clp->cl_cb_ident = conn->cb_ident; in setup_callback_client()
760 if (!conn->cb_xprt) in setup_callback_client()
762 clp->cl_cb_conn.cb_xprt = conn->cb_xprt; in setup_callback_client()
764 args.bc_xprt = conn->cb_xprt; in setup_callback_client()
766 args.protocol = conn->cb_xprt->xpt_class->xcl_ident | in setup_callback_client()
[all …]
Dnfs4state.c1473 struct nfsd4_conn *conn; in alloc_conn() local
1475 conn = kmalloc(sizeof(struct nfsd4_conn), GFP_KERNEL); in alloc_conn()
1476 if (!conn) in alloc_conn()
1479 conn->cn_xprt = rqstp->rq_xprt; in alloc_conn()
1480 conn->cn_flags = flags; in alloc_conn()
1481 INIT_LIST_HEAD(&conn->cn_xpt_user.list); in alloc_conn()
1482 return conn; in alloc_conn()
1485 static void __nfsd4_hash_conn(struct nfsd4_conn *conn, struct nfsd4_session *ses) in __nfsd4_hash_conn() argument
1487 conn->cn_session = ses; in __nfsd4_hash_conn()
1488 list_add(&conn->cn_persession, &ses->se_conns); in __nfsd4_hash_conn()
[all …]
/linux-4.1.27/net/bluetooth/hidp/
Dcore.c64 static int hidp_session_probe(struct l2cap_conn *conn,
66 static void hidp_session_remove(struct l2cap_conn *conn,
697 input->dev.parent = &session->conn->hcon->dev; in hidp_setup_input()
787 hid->dev.parent = &session->conn->hcon->dev; in hidp_setup_hid()
908 struct l2cap_conn *conn) in hidp_session_new() argument
929 session->conn = l2cap_conn_get(conn); in hidp_session_new()
961 l2cap_conn_put(session->conn); in hidp_session_new()
983 l2cap_conn_put(session->conn); in session_free()
1087 static int hidp_session_probe(struct l2cap_conn *conn, in hidp_session_probe() argument
1148 static void hidp_session_remove(struct l2cap_conn *conn, in hidp_session_remove() argument
[all …]
Dhidp.h150 struct l2cap_conn *conn; member
/linux-4.1.27/drivers/scsi/qla4xxx/
Dql4_os.c111 static int qla4xxx_conn_get_param(struct iscsi_cls_conn *conn,
128 static int qla4xxx_conn_start(struct iscsi_cls_conn *conn);
134 static void qla4xxx_conn_destroy(struct iscsi_cls_conn *conn);
2809 struct iscsi_cls_conn *cls_conn = ddb_entry->conn; in qla4xxx_session_get_param()
2876 struct iscsi_conn *conn; in qla4xxx_conn_get_param() local
2880 conn = cls_conn->dd_data; in qla4xxx_conn_get_param()
2881 qla_conn = conn->dd_data; in qla4xxx_conn_get_param()
2973 struct iscsi_conn *conn, *existing_conn; in qla4xxx_match_fwdb_session() local
2977 conn = cls_conn->dd_data; in qla4xxx_match_fwdb_session()
2980 conn->persistent_address == NULL || in qla4xxx_match_fwdb_session()
[all …]
Dql4_isr.c371 struct iscsi_conn *conn; in qla4xxx_passthru_status_entry() local
386 cls_conn = ddb_entry->conn; in qla4xxx_passthru_status_entry()
387 conn = cls_conn->dd_data; in qla4xxx_passthru_status_entry()
388 spin_lock(&conn->session->back_lock); in qla4xxx_passthru_status_entry()
389 task = iscsi_itt_to_task(conn, itt); in qla4xxx_passthru_status_entry()
390 spin_unlock(&conn->session->back_lock); in qla4xxx_passthru_status_entry()
/linux-4.1.27/sound/firewire/bebob/
Dbebob_stream.c342 struct cmp_connection *conn; in check_connection_used_by_others() local
347 conn = &bebob->out_conn; in check_connection_used_by_others()
349 conn = &bebob->in_conn; in check_connection_used_by_others()
351 err = cmp_connection_check_used(conn, &used); in check_connection_used_by_others()
355 (conn->direction == CMP_OUTPUT) ? 'o' : 'i', in check_connection_used_by_others()
356 conn->pcr_index); in check_connection_used_by_others()
433 struct cmp_connection *conn; in start_stream() local
437 conn = &bebob->in_conn; in start_stream()
439 conn = &bebob->out_conn; in start_stream()
450 conn->resources.channel, in start_stream()
[all …]
/linux-4.1.27/drivers/video/fbdev/i810/
Di810-i2c.c155 int i810_probe_i2c_connector(struct fb_info *info, u8 **out_edid, int conn) in i810_probe_i2c_connector() argument
160 DPRINTK("i810-i2c: Probe DDC%i Bus\n", conn+1); in i810_probe_i2c_connector()
161 if (conn < par->ddc_num) { in i810_probe_i2c_connector()
162 edid = fb_ddc_read(&par->chan[conn].adapter); in i810_probe_i2c_connector()
Di810_main.h40 int conn);
45 int conn) in i810_probe_i2c_connector() argument
/linux-4.1.27/sound/pci/hda/
Dhda_proc.c144 hda_nid_t conn; in is_stereo_amps() local
155 if (snd_hda_get_raw_connections(codec, nid, &conn, 1) < 0) in is_stereo_amps()
158 wcaps = snd_hda_param_read(codec, conn, AC_PAR_AUDIO_WIDGET_CAP); in is_stereo_amps()
559 unsigned int wid_type, hda_nid_t *conn, in print_conn_list() argument
576 snd_iprintf(buffer, " 0x%02x", conn[c]); in print_conn_list()
586 memcmp(list, conn, conn_len) != 0)) { in print_conn_list()
733 hda_nid_t *conn = NULL; in print_codec_info() local
773 conn = kmalloc(sizeof(hda_nid_t) * conn_len, in print_codec_info()
775 if (!conn) in print_codec_info()
777 if (snd_hda_get_raw_connections(codec, nid, conn, in print_codec_info()
[all …]
Dhda_auto_parser.c196 short assoc, loc, conn, dev; in snd_hda_parse_pin_defcfg() local
206 conn = get_defcfg_connect(def_conf); in snd_hda_parse_pin_defcfg()
207 if (conn == AC_JACK_PORT_NONE) in snd_hda_parse_pin_defcfg()
214 if (conn == AC_JACK_PORT_FIXED || in snd_hda_parse_pin_defcfg()
215 conn == AC_JACK_PORT_BOTH) in snd_hda_parse_pin_defcfg()
453 unsigned int conn = get_defcfg_connect(def_conf); in snd_hda_get_input_pin_attr() local
454 if (conn == AC_JACK_PORT_NONE) in snd_hda_get_input_pin_attr()
457 if (conn == AC_JACK_PORT_FIXED || conn == AC_JACK_PORT_BOTH) in snd_hda_get_input_pin_attr()
Dhda_jack.c471 unsigned int def_conf, conn; in add_jack_kctl() local
479 conn = get_defcfg_connect(def_conf); in add_jack_kctl()
480 if (conn == AC_JACK_PORT_NONE) in add_jack_kctl()
482 phantom_jack = (conn != AC_JACK_PORT_COMPLEX) || in add_jack_kctl()
Dpatch_via.c879 hda_nid_t conn[8]; in add_secret_dac_path() local
884 nums = snd_hda_get_connections(codec, spec->gen.mixer_nid, conn, in add_secret_dac_path()
885 ARRAY_SIZE(conn) - 1); in add_secret_dac_path()
887 if (get_wcaps_type(get_wcaps(codec, conn[i])) == AC_WID_AUD_OUT) in add_secret_dac_path()
896 conn[nums++] = nid; in add_secret_dac_path()
899 nums, conn); in add_secret_dac_path()
/linux-4.1.27/tools/perf/scripts/python/
Dexport-to-postgresql.py242 conn = PQconnectdb("dbname = " + dbname)
243 if (PQstatus(conn)):
248 res = PQexec(conn, sql)
253 ret = PQputCopyData(conn, data, len(data))
257 ret = PQputCopyEnd(conn, None)
260 PQfinish(conn)
/linux-4.1.27/drivers/isdn/hardware/mISDN/
Dhfcpci.c100 unsigned char conn; member
281 hc->hw.conn = 0x09; in reset_hfcpci()
283 hc->hw.conn = 0x36; /* set data flow directions */ in reset_hfcpci()
296 Write_hfc(hc, HFCPCI_CONNECT, hc->hw.conn); in reset_hfcpci()
1352 hc->hw.conn &= ~0x18; in mode_hfcpci()
1359 hc->hw.conn &= ~0x03; in mode_hfcpci()
1381 hc->hw.conn &= ~0x18; in mode_hfcpci()
1388 hc->hw.conn &= ~0x03; in mode_hfcpci()
1411 hc->hw.conn &= 0xc7; in mode_hfcpci()
1412 hc->hw.conn |= 0x08; in mode_hfcpci()
[all …]
/linux-4.1.27/drivers/video/fbdev/riva/
Drivafb-i2c.c152 int riva_probe_i2c_connector(struct riva_par *par, int conn, u8 **out_edid) in riva_probe_i2c_connector() argument
156 if (par->chan[conn].par) in riva_probe_i2c_connector()
157 edid = fb_ddc_read(&par->chan[conn].adapter); in riva_probe_i2c_connector()
Drivafb.h75 int riva_probe_i2c_connector(struct riva_par *par, int conn, u8 **out_edid);
/linux-4.1.27/drivers/staging/lustre/lustre/ldlm/
Dldlm_lib.c203 struct obd_import_conn *conn; in client_import_find_conn() local
207 list_for_each_entry(conn, &imp->imp_conn_list, oic_item) { in client_import_find_conn()
209 if (class_check_uuid(&conn->oic_uuid, peer)) { in client_import_find_conn()
210 *uuid = conn->oic_uuid; in client_import_find_conn()
498 struct lustre_handle conn = { 0 }; in client_connect_import() local
508 rc = class_connect(&conn, obd, cluuid); in client_connect_import()
513 *exp = class_conn2export(&conn); in client_connect_import()
517 imp->imp_dlm_handle = conn; in client_connect_import()
/linux-4.1.27/drivers/staging/lustre/lustre/obdclass/
Dclass_obd.c158 static inline void obd_data2conn(struct lustre_handle *conn, in obd_data2conn() argument
161 memset(conn, 0, sizeof(*conn)); in obd_data2conn()
162 conn->cookie = data->ioc_cookie; in obd_data2conn()
166 struct lustre_handle *conn) in obd_conn2data() argument
168 data->ioc_cookie = conn->cookie; in obd_conn2data()
Dgenops.c689 struct obd_export *class_conn2export(struct lustre_handle *conn) in class_conn2export() argument
693 if (!conn) { in class_conn2export()
698 if (conn->cookie == -1) { /* this means assign a new connection */ in class_conn2export()
703 CDEBUG(D_INFO, "looking for export cookie %#llx\n", conn->cookie); in class_conn2export()
704 export = class_handle2object(conn->cookie); in class_conn2export()
717 struct obd_device *class_conn2obd(struct lustre_handle *conn) in class_conn2obd() argument
720 export = class_conn2export(conn); in class_conn2obd()
739 struct obd_import *class_conn2cliimp(struct lustre_handle *conn) in class_conn2cliimp() argument
741 struct obd_device *obd = class_conn2obd(conn); in class_conn2cliimp()
1107 int class_connect(struct lustre_handle *conn, struct obd_device *obd, in class_connect() argument
[all …]
/linux-4.1.27/net/9p/
Dtrans_fd.c97 struct p9_conn *conn; member
159 struct p9_conn conn; member
525 struct p9_conn *m = pwait->conn; in p9_pollwake()
565 pwait->conn = m; in p9_pollwait()
582 struct p9_conn *m = &ts->conn; in p9_conn_create()
664 struct p9_conn *m = &ts->conn; in p9_fd_request()
879 p9_conn_destroy(&ts->conn); in p9_fd_close()
1087 struct p9_conn *conn = list_first_entry(&p9_poll_pending_list, in p9_poll_workfn() local
1090 list_del_init(&conn->poll_pending_link); in p9_poll_workfn()
1093 p9_poll_mux(conn); in p9_poll_workfn()
/linux-4.1.27/drivers/isdn/hisax/
Dhfc_sx.c404 cs->hw.hfcsx.conn = 0x36; /* set data flow directions */ in reset_hfcsx()
405 Write_hfc(cs, HFCSX_CONNECT, cs->hw.hfcsx.conn); in reset_hfcsx()
635 cs->hw.hfcsx.conn |= 0x10; /* B2-IOM -> B2-ST */ in hfcsx_auxcmd()
641 Write_hfc(cs, HFCSX_CONNECT, cs->hw.hfcsx.conn); in hfcsx_auxcmd()
977 cs->hw.hfcsx.conn = (cs->hw.hfcsx.conn & ~7) | 1; in HFCSX_l1hw()
978 Write_hfc(cs, HFCSX_CONNECT, cs->hw.hfcsx.conn); in HFCSX_l1hw()
983 cs->hw.hfcsx.conn = (cs->hw.hfcsx.conn & ~0x38) | 0x08; in HFCSX_l1hw()
984 Write_hfc(cs, HFCSX_CONNECT, cs->hw.hfcsx.conn); in HFCSX_l1hw()
1086 cs->hw.hfcsx.conn &= ~0x18; in mode_hfcsx()
1090 cs->hw.hfcsx.conn &= ~0x03; in mode_hfcsx()
[all …]
Dhfc_pci.c151 cs->hw.hfcpci.conn = 0x36; /* set data flow directions */ in reset_hfcpci()
152 Write_hfc(cs, HFCPCI_CONNECT, cs->hw.hfcpci.conn); in reset_hfcpci()
812 cs->hw.hfcpci.conn |= 0x10; /* B2-IOM -> B2-ST */ in hfcpci_auxcmd()
817 Write_hfc(cs, HFCPCI_CONNECT, cs->hw.hfcpci.conn); in hfcpci_auxcmd()
1212 cs->hw.hfcpci.conn = (cs->hw.hfcpci.conn & ~7) | 1; in HFCPCI_l1hw()
1213 Write_hfc(cs, HFCPCI_CONNECT, cs->hw.hfcpci.conn); in HFCPCI_l1hw()
1219 cs->hw.hfcpci.conn = (cs->hw.hfcpci.conn & ~0x38) | 0x08; in HFCPCI_l1hw()
1220 Write_hfc(cs, HFCPCI_CONNECT, cs->hw.hfcpci.conn); in HFCPCI_l1hw()
1328 cs->hw.hfcpci.conn &= ~0x18; in mode_hfcpci()
1333 cs->hw.hfcpci.conn &= ~0x03; in mode_hfcpci()
[all …]
Dhfc_2bds0.c417 cs->hw.hfcD.conn |= 0x18; in mode_2bs0()
420 cs->hw.hfcD.conn |= 0x3; in mode_2bs0()
427 cs->hw.hfcD.conn &= ~0x18; in mode_2bs0()
431 cs->hw.hfcD.conn &= ~0x3; in mode_2bs0()
438 cs->hw.hfcD.conn &= ~0x18; in mode_2bs0()
442 cs->hw.hfcD.conn &= ~0x3; in mode_2bs0()
449 WriteReg(cs, HFCD_DATA, HFCD_CONN, cs->hw.hfcD.conn); in mode_2bs0()
/linux-4.1.27/drivers/gpu/drm/nouveau/include/nvkm/subdev/bios/
Dmxm.h4 u8 mxm_sor_map(struct nvkm_bios *, u8 conn);
/linux-4.1.27/include/linux/
Ddrbd.h271 unsigned conn:5 ; /* 17/32 cstates */ member
291 unsigned conn:5 ; /* 17/32 cstates */
/linux-4.1.27/drivers/infiniband/core/
Dcma.c1113 event->param.conn.private_data = private_data; in cma_set_rep_event_data()
1114 event->param.conn.private_data_len = IB_CM_REP_PRIVATE_DATA_SIZE; in cma_set_rep_event_data()
1115 event->param.conn.responder_resources = rep_data->responder_resources; in cma_set_rep_event_data()
1116 event->param.conn.initiator_depth = rep_data->initiator_depth; in cma_set_rep_event_data()
1117 event->param.conn.flow_control = rep_data->flow_control; in cma_set_rep_event_data()
1118 event->param.conn.rnr_retry_count = rep_data->rnr_retry_count; in cma_set_rep_event_data()
1119 event->param.conn.srq = rep_data->srq; in cma_set_rep_event_data()
1120 event->param.conn.qp_num = rep_data->remote_qpn; in cma_set_rep_event_data()
1176 event.param.conn.private_data = ib_event->private_data; in cma_ib_handler()
1177 event.param.conn.private_data_len = IB_CM_REJ_PRIVATE_DATA_SIZE; in cma_ib_handler()
[all …]
/linux-4.1.27/net/bluetooth/bnep/
Dcore.c547 struct l2cap_conn *conn = l2cap_pi(session->sock->sk)->chan->conn; in bnep_get_device() local
549 if (!conn || !conn->hcon) in bnep_get_device()
552 return &conn->hcon->dev; in bnep_get_device()
/linux-4.1.27/drivers/gpu/drm/nouveau/include/nvif/
Devent.h43 __u8 conn; member
/linux-4.1.27/drivers/staging/lustre/lustre/include/
Dlustre_export.h400 extern struct obd_export *class_conn2export(struct lustre_handle *conn);
401 extern struct obd_device *class_conn2obd(struct lustre_handle *conn);
/linux-4.1.27/Documentation/blockdev/drbd/
DREADME.txt15 conn-states-8.dot, disk-states-8.dot, node-states-8.dot
/linux-4.1.27/drivers/video/fbdev/matrox/
Dmatroxfb_base.c1042 u_int32_t conn = 0; in matroxfb_ioctl() local
1047 conn |= 1 << i; in matroxfb_ioctl()
1050 if (put_user(conn, (u_int32_t __user *)arg)) in matroxfb_ioctl()
1056 u_int32_t conn = 0; in matroxfb_ioctl() local
1064 conn |= 1 << i; in matroxfb_ioctl()
1070 if (conn & MATROXFB_OUTPUT_CONN_DFP) in matroxfb_ioctl()
1071 conn &= ~MATROXFB_OUTPUT_CONN_SECONDARY; in matroxfb_ioctl()
1072 if (conn & MATROXFB_OUTPUT_CONN_SECONDARY) in matroxfb_ioctl()
1073 conn &= ~MATROXFB_OUTPUT_CONN_DFP; in matroxfb_ioctl()
1075 if (put_user(conn, (u_int32_t __user *)arg)) in matroxfb_ioctl()
[all …]
Dmatroxfb_crtc2.c509 u_int32_t conn = 0; in matroxfb_dh_ioctl() local
514 conn |= 1 << out; in matroxfb_dh_ioctl()
517 if (put_user(conn, (u_int32_t __user *)arg)) in matroxfb_dh_ioctl()
/linux-4.1.27/net/bluetooth/rfcomm/
Dsock.c756 struct l2cap_conn *conn; in rfcomm_sock_getsockopt_old() local
806 conn = l2cap_pi(l2cap_sk)->chan->conn; in rfcomm_sock_getsockopt_old()
809 cinfo.hci_handle = conn->hcon->handle; in rfcomm_sock_getsockopt_old()
810 memcpy(cinfo.dev_class, conn->hcon->dev_class, 3); in rfcomm_sock_getsockopt_old()
Dcore.c215 struct l2cap_conn *conn = l2cap_pi(sk)->chan->conn; in rfcomm_check_security() local
232 return hci_conn_security(conn->hcon, d->sec_level, auth_type, in rfcomm_check_security()
1289 struct l2cap_conn *conn = l2cap_pi(sk)->chan->conn; in rfcomm_dlc_accept() local
1303 hci_conn_switch_role(conn->hcon, 0x00); in rfcomm_dlc_accept()
2113 static void rfcomm_security_cfm(struct hci_conn *conn, u8 status, u8 encrypt) in rfcomm_security_cfm() argument
2119 BT_DBG("conn %p status 0x%02x encrypt 0x%02x", conn, status, encrypt); in rfcomm_security_cfm()
2121 s = rfcomm_session_get(&conn->hdev->bdaddr, &conn->dst); in rfcomm_security_cfm()
2151 if (!status && hci_conn_check_secure(conn, d->sec_level)) in rfcomm_security_cfm()
Dtty.c179 struct hci_conn *conn; in rfcomm_reparent_device() local
189 conn = hci_conn_hash_lookup_ba(hdev, ACL_LINK, &dev->dst); in rfcomm_reparent_device()
194 if (conn && device_is_registered(&conn->dev)) in rfcomm_reparent_device()
195 device_move(dev->tty_dev, &conn->dev, DPM_ORDER_DEV_AFTER_PARENT); in rfcomm_reparent_device()
/linux-4.1.27/include/net/
Dllc_conn.h110 int llc_conn_remove_acked_pdus(struct sock *conn, u8 nr, u16 *how_many_unacked);
/linux-4.1.27/include/rdma/
Drdma_cm.h116 struct rdma_conn_param conn; member
/linux-4.1.27/include/uapi/rdma/
Drdma_user_cm.h266 struct rdma_ucm_conn_param conn; member

12