/net/rds/ |
H A D | tcp_connect.c | 43 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 D | rdma_transport.c | 72 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 D | tcp_listen.c | 51 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 D | threads.c | 74 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 D | loop.c | 58 * 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 D | tcp_send.c | 51 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 D | cong.c | 94 * - 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 D | iw.c | 167 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 D | tcp.c | 121 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 D | tcp.h | 14 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 D | tcp_recv.c | 125 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 D | connection.c | 71 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 D | ib.c | 75 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 D | ib_cm.c | 75 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 D | iw_cm.c | 45 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 D | recv.c | 41 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 D | send.c | 64 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 D | ar-proc.c | 62 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 D | ar-security.c | 124 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 D | ar-accept.c | 78 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 D | ar-connevent.c | 28 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 D | ar-input.c | 211 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 D | amp.c | 167 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 D | core.c | 516 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 D | xt_connlimit.c | 66 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...] |