| /net/sctp/ |
| D | transport.c | 110 struct sctp_transport *transport; in sctp_transport_new() local
112 transport = kzalloc(sizeof(*transport), gfp); in sctp_transport_new()
113 if (!transport) in sctp_transport_new()
116 if (!sctp_transport_init(net, transport, addr, gfp)) in sctp_transport_new()
119 SCTP_DBG_OBJCNT_INC(transport); in sctp_transport_new()
121 return transport; in sctp_transport_new()
124 kfree(transport); in sctp_transport_new()
133 void sctp_transport_free(struct sctp_transport *transport) in sctp_transport_free() argument
135 transport->dead = 1; in sctp_transport_free()
138 if (del_timer(&transport->hb_timer)) in sctp_transport_free()
[all …]
|
| D | outqueue.c | 58 struct sctp_transport *transport,
65 struct sctp_transport *transport,
110 struct sctp_transport *transport, in sctp_cacc_skip_3_1_d() argument
113 if (count_of_newacks >= 2 && transport != primary) in sctp_cacc_skip_3_1_d()
125 static inline int sctp_cacc_skip_3_1_f(struct sctp_transport *transport, in sctp_cacc_skip_3_1_f() argument
129 (transport && !transport->cacc.cacc_saw_newack)) in sctp_cacc_skip_3_1_f()
142 struct sctp_transport *transport, in sctp_cacc_skip_3_1() argument
146 if (sctp_cacc_skip_3_1_d(primary, transport, count_of_newacks)) in sctp_cacc_skip_3_1()
148 if (sctp_cacc_skip_3_1_f(transport, count_of_newacks)) in sctp_cacc_skip_3_1()
185 struct sctp_transport *transport, in sctp_cacc_skip() argument
[all …]
|
| D | sm_sideeffect.c | 117 struct sctp_transport *transport; in sctp_do_ecn_ecne_work() local
122 transport = sctp_assoc_lookup_tsn(asoc, lowest_tsn); in sctp_do_ecn_ecne_work()
125 if (transport) in sctp_do_ecn_ecne_work()
126 sctp_transport_lower_cwnd(transport, in sctp_do_ecn_ecne_work()
245 struct sctp_transport *transport = (struct sctp_transport *) peer; in sctp_generate_t3_rtx_event() local
246 struct sctp_association *asoc = transport->asoc; in sctp_generate_t3_rtx_event()
256 if (!mod_timer(&transport->T3_rtx_timer, jiffies + (HZ/20))) in sctp_generate_t3_rtx_event()
257 sctp_transport_hold(transport); in sctp_generate_t3_rtx_event()
264 if (transport->dead) in sctp_generate_t3_rtx_event()
272 transport, GFP_ATOMIC); in sctp_generate_t3_rtx_event()
[all …]
|
| D | output.c | 94 chunk = sctp_get_ecne_prepend(packet->transport->asoc); in sctp_packet_config()
108 struct sctp_transport *transport, in sctp_packet_init() argument
111 struct sctp_association *asoc = transport->asoc; in sctp_packet_init()
114 pr_debug("%s: packet:%p transport:%p\n", __func__, packet, transport); in sctp_packet_init()
116 packet->transport = transport; in sctp_packet_init()
192 struct sctp_association *asoc = pkt->transport->asoc; in sctp_packet_bundle_auth()
237 asoc = pkt->transport->asoc; in sctp_packet_bundle_sack()
244 if (pkt->transport->sack_generation != in sctp_packet_bundle_sack()
245 pkt->transport->asoc->peer.sack_generation) in sctp_packet_bundle_sack()
314 chunk->transport = packet->transport; in __sctp_packet_append_chunk()
[all …]
|
| D | associola.c | 327 struct sctp_transport *transport; in sctp_association_free() local
384 transport = list_entry(pos, struct sctp_transport, transports); in sctp_association_free()
386 sctp_transport_free(transport); in sctp_association_free()
431 struct sctp_transport *transport) in sctp_assoc_set_primary() argument
439 asoc->peer.primary_path != transport) in sctp_assoc_set_primary()
442 asoc->peer.primary_path = transport; in sctp_assoc_set_primary()
445 memcpy(&asoc->peer.primary_addr, &transport->ipaddr, in sctp_assoc_set_primary()
451 if ((transport->state == SCTP_ACTIVE) || in sctp_assoc_set_primary()
452 (transport->state == SCTP_UNKNOWN)) in sctp_assoc_set_primary()
453 asoc->peer.active_path = transport; in sctp_assoc_set_primary()
[all …]
|
| D | endpointola.c | 323 struct sctp_transport **transport) in __sctp_endpoint_lookup_assoc() argument
333 *transport = NULL; in __sctp_endpoint_lookup_assoc()
355 *transport = t; in __sctp_endpoint_lookup_assoc()
368 struct sctp_transport **transport) in sctp_endpoint_lookup_assoc() argument
373 asoc = __sctp_endpoint_lookup_assoc(ep, paddr, transport); in sctp_endpoint_lookup_assoc()
412 struct sctp_transport *transport; in sctp_endpoint_bh_rcv() local
463 &transport); in sctp_endpoint_bh_rcv()
465 chunk->transport = transport; in sctp_endpoint_bh_rcv()
476 asoc->peer.last_data_from = chunk->transport; in sctp_endpoint_bh_rcv()
483 if (chunk->transport) in sctp_endpoint_bh_rcv()
[all …]
|
| D | input.c | 113 struct sctp_transport *transport = NULL; in sctp_rcv() local
174 asoc = __sctp_rcv_lookup(net, skb, &src, &dest, &transport); in sctp_rcv()
239 chunk->transport = transport; in sctp_rcv()
481 struct sctp_transport *transport = NULL; in sctp_err_lookup() local
498 asoc = __sctp_lookup_association(net, &saddr, &daddr, &transport); in sctp_err_lookup()
540 *tpp = transport; in sctp_err_lookup()
578 struct sctp_transport *transport; in sctp_v4_err() local
589 sk = sctp_err_lookup(net, AF_INET, skb, sctp_hdr(skb), &asoc, &transport); in sctp_v4_err()
611 sctp_icmp_frag_needed(sk, asoc, transport, info); in sctp_v4_err()
616 transport); in sctp_v4_err()
[all …]
|
| D | sm_make_chunk.c | 481 retval->transport = chunk->transport; in sctp_make_init_ack()
589 retval->transport = chunk->transport; in sctp_make_cookie_echo()
630 retval->transport = chunk->transport; in sctp_make_cookie_ack()
686 retval->transport = chunk->transport; in sctp_make_cwr()
818 retval->transport = asoc->peer.last_data_from; in sctp_make_sack()
872 retval->transport = chunk->transport; in sctp_make_shutdown()
894 retval->transport = chunk->transport; in sctp_make_shutdown_ack()
924 retval->transport = chunk->transport; in sctp_make_shutdown_complete()
962 retval->transport = chunk->transport; in sctp_make_abort()
996 retval->transport = chunk->transport; in sctp_make_abort_no_data()
[all …]
|
| D | objcnt.c | 48 SCTP_DBG_OBJCNT(transport);
65 SCTP_DBG_OBJCNT_ENTRY(transport),
|
| D | sm_statefuns.c | 104 struct sctp_transport *transport);
574 asoc, chunk->transport); in sctp_sf_do_5_1C_ack()
777 auth.transport = chunk->transport; in sctp_sf_do_5_1D_ce()
959 struct sctp_transport *transport = (struct sctp_transport *) arg; in sctp_sf_heartbeat() local
963 reply = sctp_make_heartbeat(asoc, transport); in sctp_sf_heartbeat()
971 SCTP_TRANSPORT(transport)); in sctp_sf_heartbeat()
985 struct sctp_transport *transport = (struct sctp_transport *) arg; in sctp_sf_sendbeat_8_3() local
1005 if (transport->param_flags & SPP_HB_ENABLE) { in sctp_sf_sendbeat_8_3()
1015 SCTP_TRANSPORT(transport)); in sctp_sf_sendbeat_8_3()
1018 SCTP_TRANSPORT(transport)); in sctp_sf_sendbeat_8_3()
[all …]
|
| D | proc.c | 159 struct sctp_transport *transport; in sctp_seq_dump_remote_addrs() local
165 list_for_each_entry_rcu(transport, &assoc->peer.transport_addr_list, in sctp_seq_dump_remote_addrs()
167 addr = &transport->ipaddr; in sctp_seq_dump_remote_addrs()
168 if (transport->dead) in sctp_seq_dump_remote_addrs()
|
| D | ipv6.c | 147 struct sctp_transport *transport; in sctp_v6_err() local
160 sk = sctp_err_lookup(net, AF_INET6, skb, sctp_hdr(skb), &asoc, &transport); in sctp_v6_err()
176 sctp_icmp_frag_needed(sk, asoc, transport, ntohl(info)); in sctp_v6_err()
180 sctp_icmp_proto_unreachable(sk, asoc, transport); in sctp_v6_err()
185 sctp_icmp_redirect(sk, transport, skb); in sctp_v6_err()
207 static int sctp_v6_xmit(struct sk_buff *skb, struct sctp_transport *transport) in sctp_v6_xmit() argument
211 struct flowi6 *fl6 = &transport->fl.u.ip6; in sctp_v6_xmit()
219 if (!(transport->param_flags & SPP_PMTUD_ENABLE)) in sctp_v6_xmit()
|
| /net/sunrpc/ |
| D | xprtsock.c | 499 struct sock_xprt *transport = container_of(task->tk_rqstp->rq_xprt, struct sock_xprt, xprt); in xs_nospace_callback() local
501 transport->inet->sk_write_pending--; in xs_nospace_callback()
502 clear_bit(SOCK_ASYNC_NOSPACE, &transport->sock->flags); in xs_nospace_callback()
514 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_nospace() local
515 struct sock *sk = transport->inet; in xs_nospace()
527 if (test_bit(SOCK_ASYNC_NOSPACE, &transport->sock->flags)) { in xs_nospace()
532 set_bit(SOCK_NOSPACE, &transport->sock->flags); in xs_nospace()
538 clear_bit(SOCK_ASYNC_NOSPACE, &transport->sock->flags); in xs_nospace()
574 struct sock_xprt *transport = in xs_local_send_request() local
585 status = xs_sendpages(transport->sock, NULL, 0, xdr, req->rq_bytes_sent, in xs_local_send_request()
[all …]
|
| D | Kconfig | 54 transport.
56 To compile RPC client RDMA transport support as a module,
67 transport.
69 To compile RPC server RDMA transport support as a module,
|
| /net/rxrpc/ |
| D | ar-local.c | 79 (struct sockaddr *) &local->srx.transport, in rxrpc_create_local()
137 srx->transport.family, in rxrpc_lookup_local()
138 &srx->transport.sin.sin_addr, in rxrpc_lookup_local()
139 ntohs(srx->transport.sin.sin_port)); in rxrpc_lookup_local()
149 local->srx.transport.family, in rxrpc_lookup_local()
150 &local->srx.transport.sin.sin_addr, in rxrpc_lookup_local()
151 ntohs(local->srx.transport.sin.sin_port)); in rxrpc_lookup_local()
154 local->srx.transport.family != srx->transport.family) in rxrpc_lookup_local()
157 switch (srx->transport.family) { in rxrpc_lookup_local()
159 if (local->srx.transport.sin.sin_port != in rxrpc_lookup_local()
[all …]
|
| D | ar-peer.c | 44 peer->srx.transport.sin.sin_addr.s_addr, 0, in rxrpc_assess_MTU_size()
81 if (srx->transport.family == AF_INET) { in rxrpc_alloc_peer()
115 &srx->transport.sin.sin_addr, in rxrpc_get_peer()
116 ntohs(srx->transport.sin.sin_port)); in rxrpc_get_peer()
130 memcmp(&peer->srx.transport, in rxrpc_get_peer()
131 &srx->transport, in rxrpc_get_peer()
151 memcmp(&peer->srx.transport, in rxrpc_get_peer()
152 &srx->transport, in rxrpc_get_peer()
171 peer->srx.transport.family, in rxrpc_get_peer()
172 &peer->srx.transport.sin.sin_addr, in rxrpc_get_peer()
[all …]
|
| D | ar-proc.c | 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()
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()
152 &trans->peer->srx.transport.sin.sin_addr, in rxrpc_connection_seq_show()
153 ntohs(trans->peer->srx.transport.sin.sin_port)); in rxrpc_connection_seq_show()
|
| D | ar-transport.c | 56 if (peer->srx.transport.family == AF_INET) { in rxrpc_alloc_transport()
87 &local->srx.transport.sin.sin_addr, in rxrpc_get_transport()
88 ntohs(local->srx.transport.sin.sin_port), in rxrpc_get_transport()
89 &peer->srx.transport.sin.sin_addr, in rxrpc_get_transport()
90 ntohs(peer->srx.transport.sin.sin_port)); in rxrpc_get_transport()
159 &local->srx.transport.sin.sin_addr, in rxrpc_find_transport()
160 ntohs(local->srx.transport.sin.sin_port), in rxrpc_find_transport()
161 &peer->srx.transport.sin.sin_addr, in rxrpc_find_transport()
162 ntohs(peer->srx.transport.sin.sin_port)); in rxrpc_find_transport()
|
| D | ar-accept.c | 39 msg.msg_name = &srx->transport.sin; in rxrpc_busy()
40 msg.msg_namelen = sizeof(srx->transport.sin); in rxrpc_busy()
246 srx.transport.family = local->srx.transport.family; in rxrpc_accept_incoming_calls()
248 switch (srx.transport.family) { in rxrpc_accept_incoming_calls()
251 srx.transport.sin.sin_port = udp_hdr(skb)->source; in rxrpc_accept_incoming_calls()
252 srx.transport.sin.sin_addr.s_addr = ip_hdr(skb)->saddr; in rxrpc_accept_incoming_calls()
|
| D | af_rxrpc.c | 93 len -= offsetof(struct sockaddr_rxrpc, transport); in rxrpc_validate_address()
98 if (srx->transport.family != rx->proto) in rxrpc_validate_address()
101 switch (srx->transport.family) { in rxrpc_validate_address()
104 ntohs(srx->transport.sin.sin_port), in rxrpc_validate_address()
105 &srx->transport.sin.sin_addr); in rxrpc_validate_address()
107 memset((void *)&srx->transport + 8, 0, in rxrpc_validate_address()
240 if (rx->srx.transport.family != srx->transport.family) in rxrpc_name_to_transport()
401 rx->srx.transport.family = srx->transport.family; in rxrpc_connect()
|
| /net/vmw_vsock/ |
| D | af_vsock.c | 119 static const struct vsock_transport *transport; variable
128 return transport->get_local_cid(); in vm_sockets_get_local_cid()
431 return transport->shutdown(vsock_sk(sk), mode); in vsock_send_shutdown()
539 return transport->dgram_bind(vsk, addr); in __vsock_bind_dgram()
557 cid = transport->get_local_cid(); in __vsock_bind()
633 if (transport->init(vsk, psk) < 0) { in __vsock_create()
661 transport->release(vsk); in __vsock_release()
685 transport->destruct(vsk); in vsock_sk_destruct()
709 return transport->stream_has_data(vsk); in vsock_stream_has_data()
715 return transport->stream_has_space(vsk); in vsock_stream_has_space()
[all …]
|
| D | Kconfig | 19 tristate "VMware VMCI transport for Virtual Sockets"
22 This module implements a VMCI transport for Virtual Sockets.
24 Enable this transport if your Virtual Machine runs on a VMware
|
| /net/rds/ |
| D | Kconfig | 14 Allow RDS to use Infiniband and iWARP as a transport.
15 This transport supports RDMA operations.
21 Allow RDS to use TCP as a transport.
22 This transport does not support RDMA operations.
|
| /net/netrom/ |
| D | nr_out.c | 38 unsigned char transport[NR_TRANSPORT_LEN]; in nr_output() local
43 skb_copy_from_linear_data(skb, transport, NR_TRANSPORT_LEN); in nr_output()
62 skb_copy_to_linear_data(skbn, transport, in nr_output()
|
| /net/iucv/ |
| D | af_iucv.c | 291 if (iucv->transport == AF_IUCV_TRANS_IUCV) in iucv_below_msglim()
487 if (iucv->transport == AF_IUCV_TRANS_HIPER) { in iucv_sock_close()
565 iucv->transport = AF_IUCV_TRANS_IUCV; in iucv_sock_alloc()
567 iucv->transport = AF_IUCV_TRANS_HIPER; in iucv_sock_alloc()
749 iucv->transport = AF_IUCV_TRANS_HIPER; in iucv_sock_bind()
763 iucv->transport = AF_IUCV_TRANS_IUCV; in iucv_sock_bind()
860 iucv->transport == AF_IUCV_TRANS_HIPER) in iucv_sock_connect()
878 if (iucv->transport == AF_IUCV_TRANS_HIPER) in iucv_sock_connect()
893 if (err && iucv->transport == AF_IUCV_TRANS_IUCV) in iucv_sock_connect()
1113 if (iucv->transport == AF_IUCV_TRANS_HIPER) in iucv_sock_sendmsg()
[all …]
|