| /net/rxrpc/ |
| D | ar-transport.c | 34 struct rxrpc_transport *trans; in rxrpc_alloc_transport() local
38 trans = kzalloc(sizeof(struct rxrpc_transport), gfp); in rxrpc_alloc_transport()
39 if (trans) { in rxrpc_alloc_transport()
40 trans->local = local; in rxrpc_alloc_transport()
41 trans->peer = peer; in rxrpc_alloc_transport()
42 INIT_LIST_HEAD(&trans->link); in rxrpc_alloc_transport()
43 trans->bundles = RB_ROOT; in rxrpc_alloc_transport()
44 trans->client_conns = RB_ROOT; in rxrpc_alloc_transport()
45 trans->server_conns = RB_ROOT; in rxrpc_alloc_transport()
46 skb_queue_head_init(&trans->error_queue); in rxrpc_alloc_transport()
[all …]
|
| D | ar-connection.c | 66 struct rxrpc_transport *trans, in rxrpc_get_bundle() argument
75 rx, key_serial(key), trans->debug_id, ntohs(service_id)); in rxrpc_get_bundle()
77 if (rx->trans == trans && rx->bundle) { in rxrpc_get_bundle()
84 spin_lock(&trans->client_lock); in rxrpc_get_bundle()
86 p = trans->bundles.rb_node; in rxrpc_get_bundle()
98 spin_unlock(&trans->client_lock); in rxrpc_get_bundle()
111 spin_lock(&trans->client_lock); in rxrpc_get_bundle()
113 pp = &trans->bundles.rb_node; in rxrpc_get_bundle()
132 rb_insert_color(&bundle->node, &trans->bundles); in rxrpc_get_bundle()
133 spin_unlock(&trans->client_lock); in rxrpc_get_bundle()
[all …]
|
| D | af_rxrpc.c | 229 struct rxrpc_transport *trans; in rxrpc_name_to_transport() local
249 trans = rxrpc_get_transport(rx->local, peer, gfp); in rxrpc_name_to_transport()
251 _leave(" = %p", trans); in rxrpc_name_to_transport()
252 return trans; in rxrpc_name_to_transport()
276 struct rxrpc_transport *trans; in rxrpc_kernel_begin_call() local
286 trans = rxrpc_name_to_transport(sock, (struct sockaddr *) srx, in rxrpc_kernel_begin_call()
288 if (IS_ERR(trans)) { in rxrpc_kernel_begin_call()
289 call = ERR_CAST(trans); in rxrpc_kernel_begin_call()
290 trans = NULL; in rxrpc_kernel_begin_call()
294 trans = rx->trans; in rxrpc_kernel_begin_call()
[all …]
|
| D | ar-proc.c | 49 struct rxrpc_transport *trans; in rxrpc_call_seq_show() local
62 trans = call->conn->trans; in rxrpc_call_seq_show()
65 &trans->local->srx.transport.sin.sin_addr, in rxrpc_call_seq_show()
66 ntohs(trans->local->srx.transport.sin.sin_port)); in rxrpc_call_seq_show()
69 &trans->peer->srx.transport.sin.sin_addr, in rxrpc_call_seq_show()
70 ntohs(trans->peer->srx.transport.sin.sin_port)); in rxrpc_call_seq_show()
132 struct rxrpc_transport *trans; in rxrpc_connection_seq_show() local
145 trans = conn->trans; in rxrpc_connection_seq_show()
148 &trans->local->srx.transport.sin.sin_addr, in rxrpc_connection_seq_show()
149 ntohs(trans->local->srx.transport.sin.sin_port)); in rxrpc_connection_seq_show()
[all …]
|
| D | ar-error.c | 31 struct rxrpc_transport *trans; in rxrpc_UDP_error_report() local
62 trans = rxrpc_find_transport(local, peer); in rxrpc_UDP_error_report()
63 if (!trans) { in rxrpc_UDP_error_report()
110 skb_queue_tail(&trans->error_queue, skb); in rxrpc_UDP_error_report()
111 rxrpc_queue_work(&trans->error_handler); in rxrpc_UDP_error_report()
135 struct rxrpc_transport *trans = in rxrpc_UDP_error_handler() local
142 skb = skb_dequeue(&trans->error_queue); in rxrpc_UDP_error_handler()
222 spin_lock_bh(&trans->peer->lock); in rxrpc_UDP_error_handler()
223 trans->peer->net_error = err; in rxrpc_UDP_error_handler()
225 list_for_each_entry_safe(call, _n, &trans->peer->error_targets, in rxrpc_UDP_error_handler()
[all …]
|
| D | ar-output.c | 130 struct rxrpc_transport *trans, struct msghdr *msg, in rxrpc_client_sendmsg() argument
144 ASSERT(trans != NULL); in rxrpc_client_sendmsg()
152 if (trans) { in rxrpc_client_sendmsg()
162 bundle = rxrpc_get_bundle(rx, trans, key, service_id, in rxrpc_client_sendmsg()
168 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID, in rxrpc_client_sendmsg()
170 if (trans) in rxrpc_client_sendmsg()
171 rxrpc_put_bundle(trans, bundle); in rxrpc_client_sendmsg()
335 int rxrpc_send_packet(struct rxrpc_transport *trans, struct sk_buff *skb) in rxrpc_send_packet() argument
346 msg.msg_name = &trans->peer->srx.transport.sin; in rxrpc_send_packet()
347 msg.msg_namelen = sizeof(trans->peer->srx.transport.sin); in rxrpc_send_packet()
[all …]
|
| D | ar-call.c | 104 struct rxrpc_transport *trans, in rxrpc_alloc_client_call() argument
114 ASSERT(trans != NULL); in rxrpc_alloc_client_call()
125 ret = rxrpc_connect_call(rx, trans, bundle, call, gfp); in rxrpc_alloc_client_call()
131 spin_lock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
132 list_add(&call->error_link, &call->conn->trans->peer->error_targets); in rxrpc_alloc_client_call()
133 spin_unlock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
147 struct rxrpc_transport *trans, in rxrpc_get_client_call() argument
157 rx, trans ? trans->debug_id : -1, bundle ? bundle->debug_id : -1, in rxrpc_get_client_call()
178 if (!create || !trans) in rxrpc_get_client_call()
183 candidate = rxrpc_alloc_client_call(rx, trans, bundle, gfp); in rxrpc_get_client_call()
[all …]
|
| D | ar-input.c | 603 skb_queue_tail(&conn->trans->local->accept_queue, skb); in rxrpc_post_packet_to_call()
604 rxrpc_queue_work(&conn->trans->local->acceptor); in rxrpc_post_packet_to_call()
610 rxrpc_reject_packet(conn->trans->local, skb); in rxrpc_post_packet_to_call()
674 struct rxrpc_transport *trans; in rxrpc_data_ready() local
756 trans = rxrpc_find_transport(local, peer); in rxrpc_data_ready()
758 if (!trans) in rxrpc_data_ready()
761 conn = rxrpc_find_connection(trans, &sp->hdr); in rxrpc_data_ready()
762 rxrpc_put_transport(trans); in rxrpc_data_ready()
|
| D | ar-accept.c | 79 struct rxrpc_transport *trans; in rxrpc_accept_incoming_call() local
107 trans = rxrpc_get_transport(local, peer, GFP_NOIO); in rxrpc_accept_incoming_call()
109 if (IS_ERR(trans)) { in rxrpc_accept_incoming_call()
115 conn = rxrpc_incoming_connection(trans, &sp->hdr, GFP_NOIO); in rxrpc_accept_incoming_call()
116 rxrpc_put_transport(trans); in rxrpc_accept_incoming_call()
|
| D | ar-ack.c | 209 if (rxrpc_send_packet(call->conn->trans, txb) < 0) { in rxrpc_resend()
569 peer = call->conn->trans->peer; in rxrpc_extract_ackinfo()
857 msg.msg_name = &call->conn->trans->peer->srx.transport.sin; in rxrpc_process_call()
858 msg.msg_namelen = sizeof(call->conn->trans->peer->srx.transport.sin); in rxrpc_process_call()
891 error = call->conn->trans->peer->net_error; in rxrpc_process_call()
1167 mtu = call->conn->trans->peer->if_mtu; in rxrpc_process_call()
1168 mtu -= call->conn->trans->peer->hdrsize; in rxrpc_process_call()
1220 ret = kernel_sendmsg(call->conn->trans->local->socket, in rxrpc_process_call()
|
| D | ar-connevent.c | 86 msg.msg_name = &conn->trans->peer->srx.transport.sin; in rxrpc_abort_connection()
87 msg.msg_namelen = sizeof(conn->trans->peer->srx.transport.sin); in rxrpc_abort_connection()
115 ret = kernel_sendmsg(conn->trans->local->socket, &msg, iov, 2, len); in rxrpc_abort_connection()
|
| /net/rds/ |
| D | transport.c | 43 int rds_trans_register(struct rds_transport *trans) in rds_trans_register() argument
45 BUG_ON(strlen(trans->t_name) + 1 > TRANSNAMSIZ); in rds_trans_register()
49 if (transports[trans->t_type]) in rds_trans_register()
51 trans->t_type); in rds_trans_register()
53 transports[trans->t_type] = trans; in rds_trans_register()
54 printk(KERN_INFO "Registered RDS/%s transport\n", trans->t_name); in rds_trans_register()
63 void rds_trans_unregister(struct rds_transport *trans) in rds_trans_unregister() argument
67 transports[trans->t_type] = NULL; in rds_trans_unregister()
68 printk(KERN_INFO "Unregistered RDS/%s transport\n", trans->t_name); in rds_trans_unregister()
74 void rds_trans_put(struct rds_transport *trans) in rds_trans_put() argument
[all …]
|
| D | connection.c | 69 struct rds_transport *trans) in rds_conn_lookup() argument
75 conn->c_trans == trans) { in rds_conn_lookup()
115 struct rds_transport *trans, gfp_t gfp, in __rds_conn_create() argument
125 conn = rds_conn_lookup(head, laddr, faddr, trans); in __rds_conn_create()
171 if (is_outgoing && trans->t_prefer_loopback) { in __rds_conn_create()
176 trans = &rds_loop_transport; in __rds_conn_create()
180 conn->c_trans = trans; in __rds_conn_create()
182 ret = trans->conn_alloc(conn, gfp); in __rds_conn_create()
200 trans->t_name ? trans->t_name : "[unknown]", in __rds_conn_create()
214 trans->conn_free(conn->c_transport_data); in __rds_conn_create()
[all …]
|
| D | rdma_transport.c | 73 struct rds_transport *trans; in rds_rdma_cm_event_handler() local
80 trans = &rds_iw_transport; in rds_rdma_cm_event_handler()
82 trans = &rds_ib_transport; in rds_rdma_cm_event_handler()
103 ret = trans->cm_handle_connect(cm_id, event); in rds_rdma_cm_event_handler()
114 ret = trans->cm_initiate_connect(cm_id); in rds_rdma_cm_event_handler()
118 trans->cm_connect_complete(conn, event); in rds_rdma_cm_event_handler()
|
| D | bind.c | 167 struct rds_transport *trans; in rds_bind() local
184 trans = rds_trans_get_preferred(sin->sin_addr.s_addr); in rds_bind()
185 if (!trans) { in rds_bind()
193 rs->rs_transport = trans; in rds_bind()
|
| D | stats.c | 123 goto trans; in rds_stats_info()
137 trans: in rds_stats_info()
|
| D | rds.h | 616 struct rds_transport *trans, gfp_t gfp);
618 struct rds_transport *trans, gfp_t gfp);
803 int rds_trans_register(struct rds_transport *trans);
804 void rds_trans_unregister(struct rds_transport *trans);
806 void rds_trans_put(struct rds_transport *trans);
|
| /net/sctp/ |
| D | socket.c | 604 struct sctp_transport *trans; in sctp_send_asconf_add_ip() local
606 list_for_each_entry(trans, in sctp_send_asconf_add_ip()
609 dst_release(trans->dst); in sctp_send_asconf_add_ip()
610 trans->cwnd = min(4*asoc->pathmtu, max_t(__u32, in sctp_send_asconf_add_ip()
612 trans->ssthresh = asoc->peer.i.a_rwnd; in sctp_send_asconf_add_ip()
613 trans->rto = asoc->rto_initial; in sctp_send_asconf_add_ip()
614 sctp_max_rto(asoc, trans); in sctp_send_asconf_add_ip()
615 trans->rtt = trans->srtt = trans->rttvar = 0; in sctp_send_asconf_add_ip()
616 sctp_transport_route(trans, NULL, in sctp_send_asconf_add_ip()
2323 struct sctp_transport *trans, in sctp_apply_peer_addr_params() argument
[all …]
|
| D | tsnmap.c | 118 struct sctp_transport *trans) in sctp_tsnmap_mark() argument
137 if (trans) in sctp_tsnmap_mark()
138 trans->sack_generation = in sctp_tsnmap_mark()
139 trans->asoc->peer.sack_generation; in sctp_tsnmap_mark()
|
| D | associola.c | 1209 struct sctp_transport *trans; in sctp_assoc_update() local
1222 trans = list_entry(pos, struct sctp_transport, transports); in sctp_assoc_update()
1223 if (!sctp_assoc_lookup_paddr(new, &trans->ipaddr)) { in sctp_assoc_update()
1224 sctp_assoc_rm_peer(asoc, trans); in sctp_assoc_update()
1229 sctp_transport_reset(trans); in sctp_assoc_update()
1261 list_for_each_entry(trans, &new->peer.transport_addr_list, in sctp_assoc_update()
1263 if (!sctp_assoc_lookup_paddr(asoc, &trans->ipaddr)) in sctp_assoc_update()
1264 sctp_assoc_add_peer(asoc, &trans->ipaddr, in sctp_assoc_update()
1265 GFP_ATOMIC, trans->state); in sctp_assoc_update()
|
| /net/llc/ |
| D | llc_sap.c | 145 struct llc_sap_state_trans *trans, in llc_exec_sap_trans_actions() argument
149 llc_sap_action_t *next_action = trans->ev_actions; in llc_exec_sap_trans_actions()
169 struct llc_sap_state_trans *trans; in llc_sap_next_state() local
173 trans = llc_find_sap_trans(sap, skb); in llc_sap_next_state()
174 if (!trans) in llc_sap_next_state()
181 rc = llc_exec_sap_trans_actions(sap, trans, skb); in llc_sap_next_state()
187 sap->state = trans->next_state; in llc_sap_next_state()
|
| D | llc_conn.c | 36 struct llc_conn_state_trans *trans,
379 struct llc_conn_state_trans *trans; in llc_conn_service() local
384 trans = llc_qualify_conn_ev(sk, skb); in llc_conn_service()
385 if (trans) { in llc_conn_service()
386 rc = llc_exec_conn_trans_actions(sk, trans, skb); in llc_conn_service()
387 if (!rc && trans->next_state != NO_STATE_CHANGE) { in llc_conn_service()
388 llc->state = trans->next_state; in llc_conn_service()
453 struct llc_conn_state_trans *trans, in llc_exec_conn_trans_actions() argument
459 for (next_action = trans->ev_actions; in llc_exec_conn_trans_actions()
|
| /net/9p/ |
| D | trans_rdma.c | 228 struct p9_trans_rdma *rdma = c->trans; in p9_cm_event_handler()
329 struct p9_trans_rdma *rdma = client->trans; in cq_comp_handler()
388 struct p9_trans_rdma *rdma = client->trans; in post_recv()
416 struct p9_trans_rdma *rdma = client->trans; in rdma_request()
527 rdma = client->trans; in rdma_close()
598 client->trans = rdma; in rdma_create_trans()
|
| D | trans_fd.c | 235 ts = client->trans; in p9_fd_poll()
274 ts = client->trans; in p9_fd_read()
417 ts = client->trans; in p9_fd_write()
664 struct p9_trans_fd *ts = client->trans; in p9_fd_request()
789 client->trans = ts; in p9_fd_open()
817 client->trans = p; in p9_socket_open()
868 ts = client->trans; in p9_fd_close()
997 p = (struct p9_trans_fd *) client->trans; in p9_fd_create()
|
| D | trans_virtio.c | 122 struct virtio_chan *chan = client->trans; in p9_virtio_close()
269 struct virtio_chan *chan = client->trans; in p9_virtio_request()
372 struct virtio_chan *chan = client->trans; in p9_virtio_zc_request()
632 client->trans = (void *)chan; in p9_virtio_create()
|