Searched defs:conn (Results 1 - 25 of 57) sorted by relevance

123

/net/rds/
H A Dtcp_connect.c43 struct rds_connection *conn; local
47 conn = sk->sk_user_data;
48 if (!conn) {
52 tc = conn->c_transport_data;
63 rds_connect_complete(conn);
66 rds_conn_drop(conn);
75 int rds_tcp_conn_connect(struct rds_connection *conn) argument
88 src.sin_addr.s_addr = (__force u32)conn->c_laddr;
94 ret, &conn->c_laddr);
99 dest.sin_addr.s_addr = (__force u32)conn
130 rds_tcp_conn_shutdown(struct rds_connection *conn) argument
[all...]
H A Drdma_transport.c72 struct rds_connection *conn = cm_id->context; local
76 rdsdebug("conn %p id %p handling event %u (%s)\n", conn, cm_id,
86 if (conn) {
87 mutex_lock(&conn->c_cm_lock);
92 if (rds_conn_state(conn) == RDS_CONN_DISCONNECTING) {
118 trans->cm_connect_complete(conn, event);
128 if (conn)
129 rds_conn_drop(conn);
134 "%pI4->%pI4\n", &conn
[all...]
H A Dtcp_listen.c51 struct rds_connection *conn; local
74 conn = rds_conn_create(inet->inet_saddr, inet->inet_daddr,
76 if (IS_ERR(conn)) {
77 ret = PTR_ERR(conn);
84 if (!rds_conn_transition(conn, RDS_CONN_DOWN, RDS_CONN_CONNECTING)) {
85 if (rds_conn_state(conn) == RDS_CONN_UP)
89 rds_conn_drop(conn);
94 rds_tcp_set_callbacks(new_sock, conn);
95 rds_connect_complete(conn);
H A Dthreads.c74 void rds_connect_complete(struct rds_connection *conn) argument
76 if (!rds_conn_transition(conn, RDS_CONN_CONNECTING, RDS_CONN_UP)) {
80 atomic_read(&conn->c_state));
81 atomic_set(&conn->c_state, RDS_CONN_ERROR);
82 queue_work(rds_wq, &conn->c_down_w);
86 rdsdebug("conn %p for %pI4 to %pI4 complete\n",
87 conn, &conn->c_laddr, &conn->c_faddr);
89 conn
114 rds_queue_reconnect(struct rds_connection *conn) argument
142 struct rds_connection *conn = container_of(work, struct rds_connection, c_conn_w.work); local
162 struct rds_connection *conn = container_of(work, struct rds_connection, c_send_w.work); local
184 struct rds_connection *conn = container_of(work, struct rds_connection, c_recv_w.work); local
206 struct rds_connection *conn = container_of(work, struct rds_connection, c_down_w); local
[all...]
H A Dloop.c58 * is handed the sending conn so the sense of the addresses is reversed.
60 static int rds_loop_xmit(struct rds_connection *conn, struct rds_message *rm, argument
70 rds_cong_map_updated(conn->c_fcong, ~(u64) 0);
71 ret = min_t(int, ret, sgp->length - conn->c_xmit_data_off);
77 rds_inc_init(&rm->m_inc, conn, conn->c_laddr);
81 rds_recv_incoming(conn, conn->c_laddr, conn->c_faddr, &rm->m_inc,
84 rds_send_drop_acked(conn, be64_to_cp
103 rds_loop_recv(struct rds_connection *conn) argument
110 struct rds_connection *conn; member in struct:rds_loop_connection
119 rds_loop_conn_alloc(struct rds_connection *conn, gfp_t gfp) argument
151 rds_loop_conn_connect(struct rds_connection *conn) argument
157 rds_loop_conn_shutdown(struct rds_connection *conn) argument
[all...]
H A Dtcp_send.c51 void rds_tcp_xmit_prepare(struct rds_connection *conn) argument
53 struct rds_tcp_connection *tc = conn->c_transport_data;
58 void rds_tcp_xmit_complete(struct rds_connection *conn) argument
60 struct rds_tcp_connection *tc = conn->c_transport_data;
80 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, argument
83 struct rds_tcp_connection *tc = conn->c_transport_data;
148 &conn->c_faddr, ret);
149 rds_conn_drop(conn);
174 struct rds_connection *conn; local
178 conn
[all...]
H A Dcong.c94 * - on connection buildup to associate a conn with its maps
180 * Put the conn on its local map's list. This is called when the conn is
183 void rds_cong_add_conn(struct rds_connection *conn) argument
187 rdsdebug("conn %p now on map %p\n", conn, conn->c_lcong);
189 list_add_tail(&conn->c_map_item, &conn->c_lcong->m_conn_list);
193 void rds_cong_remove_conn(struct rds_connection *conn) argument
203 rds_cong_get_maps(struct rds_connection *conn) argument
216 struct rds_connection *conn; local
396 rds_cong_update_alloc(struct rds_connection *conn) argument
[all...]
H A Diw.c167 static int rds_iw_conn_info_visitor(struct rds_connection *conn, argument
174 if (conn->c_trans != &rds_iw_transport)
177 iinfo->src_addr = conn->c_laddr;
178 iinfo->dst_addr = conn->c_faddr;
182 if (rds_conn_state(conn) == RDS_CONN_UP) {
186 ic = conn->c_transport_data;
H A Dtcp.c121 void rds_tcp_set_callbacks(struct socket *sock, struct rds_connection *conn) argument
123 struct rds_tcp_connection *tc = conn->c_transport_data;
139 tc->conn = conn;
144 sock->sk->sk_user_data = conn;
199 static int rds_tcp_conn_alloc(struct rds_connection *conn, gfp_t gfp) argument
212 conn->c_transport_data = tc;
218 rdsdebug("alloced tc %p\n", conn->c_transport_data);
247 if (tc->conn->c_passive)
248 rds_conn_destroy(tc->conn
[all...]
H A Dtcp.h14 struct rds_connection *conn; member in struct:rds_tcp_connection
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);
76 void rds_tcp_xmit_prepare(struct rds_connection *conn);
77 void rds_tcp_xmit_complete(struct rds_connection *conn);
78 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm,
H A Dtcp_recv.c125 static void rds_tcp_cong_recv(struct rds_connection *conn, argument
141 map = conn->c_fcong;
170 struct rds_connection *conn; member in struct:rds_tcp_desc_arg
178 struct rds_connection *conn = arg->conn; local
179 struct rds_tcp_connection *tc = conn->c_transport_data;
201 rds_inc_init(&tinc->ti_inc, conn, conn->c_faddr);
253 rds_tcp_cong_recv(conn, tinc);
255 rds_recv_incoming(conn, con
274 rds_tcp_read_sock(struct rds_connection *conn, gfp_t gfp) argument
302 rds_tcp_recv(struct rds_connection *conn) argument
320 struct rds_connection *conn; local
[all...]
H A Dconnection.c71 struct rds_connection *conn, *ret = NULL; local
73 hlist_for_each_entry_rcu(conn, head, c_hash_node) {
74 if (conn->c_faddr == faddr && conn->c_laddr == laddr &&
75 conn->c_trans == trans) {
76 ret = conn;
80 rdsdebug("returning conn %p for %pI4 -> %pI4\n", ret,
91 static void rds_conn_reset(struct rds_connection *conn) argument
94 &conn->c_laddr, &conn
118 struct rds_connection *conn, *parent = NULL; local
257 rds_conn_shutdown(struct rds_connection *conn) argument
320 rds_conn_destroy(struct rds_connection *conn) argument
379 struct rds_connection *conn; local
440 struct rds_connection *conn; local
470 rds_conn_info_visitor(struct rds_connection *conn, void *buffer) argument
539 rds_conn_drop(struct rds_connection *conn) argument
550 rds_conn_connect_if_down(struct rds_connection *conn) argument
562 __rds_conn_error(struct rds_connection *conn, const char *fmt, ...) argument
[all...]
H A Dib.c75 rds_conn_connect_if_down(ic->conn);
86 rds_conn_drop(ic->conn);
266 static int rds_ib_conn_info_visitor(struct rds_connection *conn, argument
273 if (conn->c_trans != &rds_ib_transport)
276 iinfo->src_addr = conn->c_laddr;
277 iinfo->dst_addr = conn->c_faddr;
281 if (rds_conn_state(conn) == RDS_CONN_UP) {
285 ic = conn->c_transport_data;
H A Dib_cm.c75 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) argument
77 conn->c_version = version;
83 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) argument
85 struct rds_ib_connection *ic = conn->c_transport_data;
90 rds_ib_send_add_credits(conn, credits);
125 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) argument
128 struct rds_ib_connection *ic = conn->c_transport_data;
132 if (event->param.conn.private_data_len >= sizeof(*dp)) {
133 dp = event->param.conn.private_data;
137 rds_ib_set_protocol(conn,
192 rds_ib_cm_fill_conn_param(struct rds_connection *conn, struct rdma_conn_param *conn_param, struct rds_ib_connect_private *dp, u32 protocol_version, u32 max_responder_resources, u32 max_initiator_depth) argument
242 struct rds_connection *conn = data; local
266 rds_ib_setup_qp(struct rds_connection *conn) argument
452 struct rds_connection *conn = NULL; local
544 struct rds_connection *conn = cm_id->context; local
578 rds_ib_conn_connect(struct rds_connection *conn) argument
624 rds_ib_conn_shutdown(struct rds_connection *conn) argument
744 rds_ib_conn_alloc(struct rds_connection *conn, gfp_t gfp) argument
820 __rds_ib_conn_error(struct rds_connection *conn, const char *fmt, ...) argument
[all...]
H A Diw_cm.c45 static void rds_iw_set_protocol(struct rds_connection *conn, unsigned int version) argument
47 conn->c_version = version;
53 static void rds_iw_set_flow_control(struct rds_connection *conn, u32 credits) argument
55 struct rds_iw_connection *ic = conn->c_transport_data;
60 rds_iw_send_add_credits(conn, credits);
70 void rds_iw_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) argument
73 struct rds_iw_connection *ic = conn->c_transport_data;
77 if (event->param.conn.private_data_len) {
78 dp = event->param.conn.private_data;
80 rds_iw_set_protocol(conn,
107 rds_iw_cm_fill_conn_param(struct rds_connection *conn, struct rdma_conn_param *conn_param, struct rds_iw_connect_private *dp, u32 protocol_version) argument
149 struct rds_connection *conn = data; local
247 rds_iw_setup_qp(struct rds_connection *conn) argument
382 struct rds_connection *conn = NULL; local
478 struct rds_connection *conn = cm_id->context; local
514 rds_iw_conn_connect(struct rds_connection *conn) argument
574 rds_iw_conn_shutdown(struct rds_connection *conn) argument
691 rds_iw_conn_alloc(struct rds_connection *conn, gfp_t gfp) argument
756 __rds_iw_conn_error(struct rds_connection *conn, const char *fmt, ...) argument
[all...]
H A Drecv.c41 void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn, argument
46 inc->i_conn = conn;
143 * rx and conn reset on this specific conn.
146 * down a connection at a time. This lets us reassemble in the conn
148 * flows to tear down partial reassembly progress on conn failure and
154 * conn. This lets loopback, who only has one conn for both directions,
155 * tell us which roles the addrs in the conn are playing for this message.
157 void rds_recv_incoming(struct rds_connection *conn, __be3 argument
[all...]
H A Dsend.c64 void rds_send_reset(struct rds_connection *conn) argument
69 if (conn->c_xmit_rm) {
70 rm = conn->c_xmit_rm;
71 conn->c_xmit_rm = NULL;
80 conn->c_xmit_sg = 0;
81 conn->c_xmit_hdr_off = 0;
82 conn->c_xmit_data_off = 0;
83 conn->c_xmit_atomic_sent = 0;
84 conn->c_xmit_rdma_sent = 0;
85 conn
102 acquire_in_xmit(struct rds_connection *conn) argument
107 release_in_xmit(struct rds_connection *conn) argument
135 rds_send_xmit(struct rds_connection *conn) argument
524 rds_send_get_message(struct rds_connection *conn, struct rm_rdma_op *op) argument
645 rds_send_drop_acked(struct rds_connection *conn, u64 ack, is_acked_func is_acked) argument
676 struct rds_connection *conn; local
751 rds_send_queue_rm(struct rds_sock *rs, struct rds_connection *conn, struct rds_message *rm, __be16 sport, __be16 dport, int *queued) argument
929 struct rds_connection *conn; local
1089 rds_send_pong(struct rds_connection *conn, __be16 dport) argument
[all...]
/net/rxrpc/
H A Dar-proc.c62 trans = call->conn->trans;
77 ntohs(call->conn->service_id),
78 ntohl(call->conn->cid),
80 call->conn->in_clientflag ? "Svc" : "Clt",
131 struct rxrpc_connection *conn; local
144 conn = list_entry(v, struct rxrpc_connection, link);
145 trans = conn->trans;
160 ntohs(conn->service_id),
161 ntohl(conn->cid),
162 conn
[all...]
H A Dar-security.c124 int rxrpc_init_client_conn_security(struct rxrpc_connection *conn) argument
128 struct key *key = conn->key;
131 _enter("{%d},{%x}", conn->debug_id, key_serial(key));
147 conn->security = sec;
149 ret = conn->security->init_connection_security(conn);
151 rxrpc_security_put(conn->security);
152 conn->security = NULL;
163 int rxrpc_init_server_conn_security(struct rxrpc_connection *conn) argument
166 struct rxrpc_local *local = conn
252 rxrpc_clear_conn_security(struct rxrpc_connection *conn) argument
[all...]
H A Dar-accept.c78 struct rxrpc_connection *conn; local
115 conn = rxrpc_incoming_connection(trans, &sp->hdr, GFP_NOIO);
117 if (IS_ERR(conn)) {
118 _debug("no conn");
119 ret = PTR_ERR(conn);
123 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO);
124 rxrpc_put_connection(conn);
140 spin_lock(&call->conn->state_lock);
142 call->conn->state == RXRPC_CONN_SERVER_UNSECURED) {
143 _debug("await conn se
[all...]
H A Dar-connevent.c28 static void rxrpc_abort_calls(struct rxrpc_connection *conn, int state, argument
34 _enter("{%d},%x", conn->debug_id, abort_code);
36 read_lock_bh(&conn->lock);
38 for (p = rb_first(&conn->calls); p; p = rb_next(p)) {
53 read_unlock_bh(&conn->lock);
60 static int rxrpc_abort_connection(struct rxrpc_connection *conn, argument
70 _enter("%d,,%u,%u", conn->debug_id, error, abort_code);
73 spin_lock_bh(&conn->state_lock);
74 if (conn->state < RXRPC_CONN_REMOTELY_ABORTED) {
75 conn
144 rxrpc_process_event(struct rxrpc_connection *conn, struct sk_buff *skb, u32 *_abort_code) argument
214 rxrpc_secure_connection(struct rxrpc_connection *conn) argument
260 struct rxrpc_connection *conn = local
[all...]
H A Dar-input.c211 if (call->conn->security)
343 hi_serial = atomic_read(&call->conn->hi_serial);
345 hi_serial = atomic_cmpxchg(&call->conn->hi_serial, hi_serial,
379 if (call->conn->out_clientflag)
529 static void rxrpc_post_packet_to_call(struct rxrpc_connection *conn, argument
537 _enter("%p,%p", conn, skb);
539 read_lock_bh(&conn->lock);
544 call = conn->channels[ntohl(sp->hdr.cid) & RXRPC_CHANNELMASK];
549 ASSERTCMP(call->conn, ==, conn);
657 rxrpc_post_packet_to_conn(struct rxrpc_connection *conn, struct sk_buff *skb) argument
673 struct rxrpc_connection *conn; local
[all...]
/net/bluetooth/
H A Damp.c167 int phylink_gen_key(struct hci_conn *conn, u8 *data, u8 *len, u8 *type) argument
169 struct hci_dev *hdev = conn->hdev;
175 if (!hci_conn_check_link_mode(conn))
178 BT_DBG("conn %p key_type %d", conn, conn->key_type);
181 if (conn->key_type < 3) {
182 BT_ERR("Legacy key type %d", conn->key_type);
186 *type = conn->key_type;
189 key = hci_find_link_key(hdev, &conn
[all...]
/net/bluetooth/bnep/
H A Dcore.c516 struct hci_conn *conn; local
522 conn = hci_conn_hash_lookup_ba(hdev, ACL_LINK, dst);
526 return conn ? &conn->dev : NULL;
/net/netfilter/
H A Dxt_connlimit.c66 static inline bool already_closed(const struct nf_conn *conn) argument
68 if (nf_ct_protonum(conn) == IPPROTO_TCP)
69 return conn->proto.tcp.state == TCP_CONNTRACK_TIME_WAIT ||
70 conn->proto.tcp.state == TCP_CONNTRACK_CLOSE;
103 struct xt_connlimit_conn *conn; local
118 hlist_for_each_entry_safe(conn, n, hash, node) {
120 &conn->tuple);
127 nf_ct_tuple_equal(&conn->tuple, tuple) &&
138 hlist_del(&conn->node);
139 kfree(conn);
260 struct xt_connlimit_conn *conn; local
[all...]

Completed in 208 milliseconds

123