| /net/rxrpc/ |
| D | ar-transport.c | 33 struct rxrpc_transport *trans; in rxrpc_alloc_transport() local
37 trans = kzalloc(sizeof(struct rxrpc_transport), gfp); in rxrpc_alloc_transport()
38 if (trans) { in rxrpc_alloc_transport()
39 trans->local = local; in rxrpc_alloc_transport()
40 trans->peer = peer; in rxrpc_alloc_transport()
41 INIT_LIST_HEAD(&trans->link); in rxrpc_alloc_transport()
42 trans->bundles = RB_ROOT; in rxrpc_alloc_transport()
43 trans->client_conns = RB_ROOT; in rxrpc_alloc_transport()
44 trans->server_conns = RB_ROOT; in rxrpc_alloc_transport()
45 skb_queue_head_init(&trans->error_queue); in rxrpc_alloc_transport()
[all …]
|
| D | ar-connection.c | 65 struct rxrpc_transport *trans, in rxrpc_get_bundle() argument
74 rx, key_serial(key), trans->debug_id, ntohs(service_id)); in rxrpc_get_bundle()
76 if (rx->trans == trans && rx->bundle) { in rxrpc_get_bundle()
83 spin_lock(&trans->client_lock); in rxrpc_get_bundle()
85 p = trans->bundles.rb_node; in rxrpc_get_bundle()
97 spin_unlock(&trans->client_lock); in rxrpc_get_bundle()
110 spin_lock(&trans->client_lock); in rxrpc_get_bundle()
112 pp = &trans->bundles.rb_node; in rxrpc_get_bundle()
131 rb_insert_color(&bundle->node, &trans->bundles); in rxrpc_get_bundle()
132 spin_unlock(&trans->client_lock); in rxrpc_get_bundle()
[all …]
|
| D | af_rxrpc.c | 225 struct rxrpc_transport *trans; in rxrpc_name_to_transport() local
245 trans = rxrpc_get_transport(rx->local, peer, gfp); in rxrpc_name_to_transport()
247 _leave(" = %p", trans); in rxrpc_name_to_transport()
248 return trans; in rxrpc_name_to_transport()
272 struct rxrpc_transport *trans; in rxrpc_kernel_begin_call() local
282 trans = rxrpc_name_to_transport(sock, (struct sockaddr *) srx, in rxrpc_kernel_begin_call()
284 if (IS_ERR(trans)) { in rxrpc_kernel_begin_call()
285 call = ERR_CAST(trans); in rxrpc_kernel_begin_call()
286 trans = NULL; in rxrpc_kernel_begin_call()
290 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()
114 skb_queue_tail(&trans->error_queue, skb); in rxrpc_UDP_error_report()
115 rxrpc_queue_work(&trans->error_handler); in rxrpc_UDP_error_report()
139 struct rxrpc_transport *trans = in rxrpc_UDP_error_handler() local
146 skb = skb_dequeue(&trans->error_queue); in rxrpc_UDP_error_handler()
229 spin_lock_bh(&trans->peer->lock); in rxrpc_UDP_error_handler()
230 trans->peer->net_error = err; in rxrpc_UDP_error_handler()
232 list_for_each_entry_safe(call, _n, &trans->peer->error_targets, in rxrpc_UDP_error_handler()
[all …]
|
| D | ar-output.c | 128 struct rxrpc_transport *trans, struct msghdr *msg, in rxrpc_client_sendmsg() argument
142 ASSERT(trans != NULL); in rxrpc_client_sendmsg()
150 if (trans) { in rxrpc_client_sendmsg()
160 bundle = rxrpc_get_bundle(rx, trans, key, service_id, in rxrpc_client_sendmsg()
166 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID, in rxrpc_client_sendmsg()
168 if (trans) in rxrpc_client_sendmsg()
169 rxrpc_put_bundle(trans, bundle); in rxrpc_client_sendmsg()
333 int rxrpc_send_packet(struct rxrpc_transport *trans, struct sk_buff *skb) in rxrpc_send_packet() argument
344 msg.msg_name = &trans->peer->srx.transport.sin; in rxrpc_send_packet()
345 msg.msg_namelen = sizeof(trans->peer->srx.transport.sin); in rxrpc_send_packet()
[all …]
|
| D | ar-call.c | 103 struct rxrpc_transport *trans, in rxrpc_alloc_client_call() argument
113 ASSERT(trans != NULL); in rxrpc_alloc_client_call()
124 ret = rxrpc_connect_call(rx, trans, bundle, call, gfp); in rxrpc_alloc_client_call()
130 spin_lock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
131 list_add(&call->error_link, &call->conn->trans->peer->error_targets); in rxrpc_alloc_client_call()
132 spin_unlock(&call->conn->trans->peer->lock); in rxrpc_alloc_client_call()
146 struct rxrpc_transport *trans, in rxrpc_get_client_call() argument
156 rx, trans ? trans->debug_id : -1, bundle ? bundle->debug_id : -1, in rxrpc_get_client_call()
177 if (!create || !trans) in rxrpc_get_client_call()
182 candidate = rxrpc_alloc_client_call(rx, trans, bundle, gfp); in rxrpc_get_client_call()
[all …]
|
| D | ar-input.c | 601 skb_queue_tail(&conn->trans->local->accept_queue, skb); in rxrpc_post_packet_to_call()
602 rxrpc_queue_work(&conn->trans->local->acceptor); in rxrpc_post_packet_to_call()
608 rxrpc_reject_packet(conn->trans->local, skb); in rxrpc_post_packet_to_call()
672 struct rxrpc_transport *trans; in rxrpc_data_ready() local
754 trans = rxrpc_find_transport(local, peer); in rxrpc_data_ready()
756 if (!trans) in rxrpc_data_ready()
759 conn = rxrpc_find_connection(trans, &sp->hdr); in rxrpc_data_ready()
760 rxrpc_put_transport(trans); in rxrpc_data_ready()
|
| D | ar-accept.c | 78 struct rxrpc_transport *trans; in rxrpc_accept_incoming_call() local
101 trans = rxrpc_get_transport(local, peer, GFP_NOIO); in rxrpc_accept_incoming_call()
103 if (IS_ERR(trans)) { in rxrpc_accept_incoming_call()
109 conn = rxrpc_incoming_connection(trans, &sp->hdr, GFP_NOIO); in rxrpc_accept_incoming_call()
110 rxrpc_put_transport(trans); in rxrpc_accept_incoming_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()
|
| D | ar-ack.c | 208 if (rxrpc_send_packet(call->conn->trans, txb) < 0) { in rxrpc_resend()
567 peer = call->conn->trans->peer; in rxrpc_extract_ackinfo()
855 msg.msg_name = &call->conn->trans->peer->srx.transport.sin; in rxrpc_process_call()
856 msg.msg_namelen = sizeof(call->conn->trans->peer->srx.transport.sin); in rxrpc_process_call()
889 error = call->conn->trans->peer->net_error; in rxrpc_process_call()
1165 mtu = call->conn->trans->peer->if_mtu; in rxrpc_process_call()
1166 mtu -= call->conn->trans->peer->hdrsize; in rxrpc_process_call()
1218 ret = kernel_sendmsg(call->conn->trans->local->socket, in rxrpc_process_call()
|
| D | rxkad.c | 587 msg.msg_name = &conn->trans->peer->srx.transport.sin; in rxkad_issue_challenge()
588 msg.msg_namelen = sizeof(conn->trans->peer->srx.transport.sin); in rxkad_issue_challenge()
614 ret = kernel_sendmsg(conn->trans->local->socket, &msg, iov, 2, len); in rxkad_issue_challenge()
639 msg.msg_name = &conn->trans->peer->srx.transport.sin; in rxkad_send_response()
640 msg.msg_namelen = sizeof(conn->trans->peer->srx.transport.sin); in rxkad_send_response()
664 ret = kernel_sendmsg(conn->trans->local->socket, &msg, iov, 3, len); in rxkad_send_response()
|
| D | ar-recvmsg.c | 147 &call->conn->trans->peer->srx, in rxrpc_recvmsg()
148 sizeof(call->conn->trans->peer->srx)); in rxrpc_recvmsg()
|
| D | ar-security.c | 160 struct rxrpc_local *local = conn->trans->local; in rxrpc_init_server_conn_security()
|
| D | ar-internal.h | 57 struct rxrpc_transport *trans; /* transport handler */ member
241 struct rxrpc_transport *trans; /* transport session */ member
|
| /net/llc/ |
| D | llc_sap.c | 148 struct llc_sap_state_trans *trans, in llc_exec_sap_trans_actions() argument
152 llc_sap_action_t *next_action = trans->ev_actions; in llc_exec_sap_trans_actions()
172 struct llc_sap_state_trans *trans; in llc_sap_next_state() local
176 trans = llc_find_sap_trans(sap, skb); in llc_sap_next_state()
177 if (!trans) in llc_sap_next_state()
184 rc = llc_exec_sap_trans_actions(sap, trans, skb); in llc_sap_next_state()
190 sap->state = trans->next_state; in llc_sap_next_state()
|
| D | llc_station.c | 541 static u16 llc_exec_station_trans_actions(struct llc_station_state_trans *trans, in llc_exec_station_trans_actions() argument
545 llc_station_action_t *next_action = trans->ev_actions; in llc_exec_station_trans_actions()
602 struct llc_station_state_trans *trans; in llc_station_next_state() local
606 trans = llc_find_station_trans(skb); in llc_station_next_state()
607 if (trans) { in llc_station_next_state()
612 rc = llc_exec_station_trans_actions(trans, skb); in llc_station_next_state()
617 llc_main_station.state = trans->next_state; in llc_station_next_state()
|
| D | llc_conn.c | 35 struct llc_conn_state_trans *trans,
383 struct llc_conn_state_trans *trans; in llc_conn_service() local
388 trans = llc_qualify_conn_ev(sk, skb); in llc_conn_service()
389 if (trans) { in llc_conn_service()
390 rc = llc_exec_conn_trans_actions(sk, trans, skb); in llc_conn_service()
391 if (!rc && trans->next_state != NO_STATE_CHANGE) { in llc_conn_service()
392 llc->state = trans->next_state; in llc_conn_service()
457 struct llc_conn_state_trans *trans, in llc_exec_conn_trans_actions() argument
463 for (next_action = trans->ev_actions; in llc_exec_conn_trans_actions()
|
| /net/sctp/ |
| D | socket.c | 2140 struct sctp_transport *trans, in sctp_apply_peer_addr_params() argument
2149 if (params->spp_flags & SPP_HB_DEMAND && trans) { in sctp_apply_peer_addr_params()
2150 error = sctp_primitive_REQUESTHEARTBEAT (trans->asoc, trans); in sctp_apply_peer_addr_params()
2170 if (trans) { in sctp_apply_peer_addr_params()
2171 trans->hbinterval = in sctp_apply_peer_addr_params()
2183 if (trans) { in sctp_apply_peer_addr_params()
2184 trans->param_flags = in sctp_apply_peer_addr_params()
2185 (trans->param_flags & ~SPP_HB) | hb_change; in sctp_apply_peer_addr_params()
2201 if (trans) { in sctp_apply_peer_addr_params()
2202 trans->pathmtu = params->spp_pathmtu; in sctp_apply_peer_addr_params()
[all …]
|
| D | associola.c | 1118 struct sctp_transport *trans; in sctp_assoc_update() local
1131 trans = list_entry(pos, struct sctp_transport, transports); in sctp_assoc_update()
1132 if (!sctp_assoc_lookup_paddr(new, &trans->ipaddr)) in sctp_assoc_update()
1133 sctp_assoc_del_peer(asoc, &trans->ipaddr); in sctp_assoc_update()
1136 sctp_transport_reset(trans); in sctp_assoc_update()
1168 list_for_each_entry(trans, &new->peer.transport_addr_list, in sctp_assoc_update()
1170 if (!sctp_assoc_lookup_paddr(asoc, &trans->ipaddr)) in sctp_assoc_update()
1171 sctp_assoc_add_peer(asoc, &trans->ipaddr, in sctp_assoc_update()
1172 GFP_ATOMIC, trans->state); in sctp_assoc_update()
|
| D | sm_sideeffect.c | 160 struct sctp_transport *trans = asoc->peer.last_data_from; in sctp_gen_sack() local
164 (!trans && (asoc->param_flags & SPP_SACKDELAY_DISABLE)) || in sctp_gen_sack()
165 (trans && (trans->param_flags & SPP_SACKDELAY_DISABLE))) in sctp_gen_sack()
200 if (trans) { in sctp_gen_sack()
202 if (asoc->peer.sack_cnt >= trans->sackfreq - 1) in sctp_gen_sack()
206 trans->sackdelay; in sctp_gen_sack()
|
| /net/9p/ |
| D | trans_fd.c | 229 ts = client->trans; in p9_fd_poll()
268 ts = client->trans; in p9_fd_read()
409 ts = client->trans; in p9_fd_write()
655 struct p9_trans_fd *ts = client->trans; in p9_fd_request()
777 client->trans = ts; in p9_fd_open()
801 ((struct p9_trans_fd *)client->trans)->rd->f_flags |= O_NONBLOCK; in p9_socket_open()
840 ts = client->trans; in p9_fd_close()
916 p = (struct p9_trans_fd *) client->trans; in p9_fd_create_tcp()
968 p = (struct p9_trans_fd *) client->trans; in p9_fd_create_unix()
1004 p = (struct p9_trans_fd *) client->trans; in p9_fd_create()
|
| D | trans_virtio.c | 104 struct virtio_chan *chan = client->trans; in p9_virtio_close()
193 struct virtio_chan *chan = client->trans; in p9_virtio_request()
315 client->trans = (void *)chan; in p9_virtio_create()
|
| D | trans_rdma.c | 226 struct p9_trans_rdma *rdma = c->trans; in p9_cm_event_handler()
328 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()
520 rdma = client->trans; in rdma_close()
590 client->trans = rdma; in rdma_create_trans()
|
| D | client.c | 712 clnt->trans = NULL; in p9_client_create()
|