| /net/rxrpc/ |
| D | ar-peer.c | 35 static void rxrpc_assess_MTU_size(struct rxrpc_peer *peer) in rxrpc_assess_MTU_size() argument
41 peer->if_mtu = 1500; in rxrpc_assess_MTU_size()
45 switch (peer->srx.transport.family) { in rxrpc_assess_MTU_size()
50 fl.nl_u.ip4_u.daddr = peer->srx.transport.sin.sin_addr.s_addr; in rxrpc_assess_MTU_size()
66 peer->if_mtu = dst_mtu(&rt->u.dst); in rxrpc_assess_MTU_size()
69 _leave(" [if_mtu %u]", peer->if_mtu); in rxrpc_assess_MTU_size()
78 struct rxrpc_peer *peer; in rxrpc_alloc_peer() local
82 peer = kzalloc(sizeof(struct rxrpc_peer), gfp); in rxrpc_alloc_peer()
83 if (peer) { in rxrpc_alloc_peer()
84 INIT_WORK(&peer->destroyer, &rxrpc_destroy_peer); in rxrpc_alloc_peer()
[all …]
|
| D | ar-error.c | 33 struct rxrpc_peer *peer; in rxrpc_UDP_error_report() local
55 peer = rxrpc_find_peer(local, addr, port); in rxrpc_UDP_error_report()
56 if (IS_ERR(peer)) { in rxrpc_UDP_error_report()
62 trans = rxrpc_find_transport(local, peer); in rxrpc_UDP_error_report()
64 rxrpc_put_peer(peer); in rxrpc_UDP_error_report()
79 if (mtu > 0 && peer->if_mtu == 65535 && mtu < peer->if_mtu) { in rxrpc_UDP_error_report()
80 peer->if_mtu = mtu; in rxrpc_UDP_error_report()
96 if (mtu < peer->hdrsize) in rxrpc_UDP_error_report()
97 mtu = peer->hdrsize + 4; in rxrpc_UDP_error_report()
101 if (mtu < peer->mtu) { in rxrpc_UDP_error_report()
[all …]
|
| D | ar-transport.c | 30 struct rxrpc_peer *peer, in rxrpc_alloc_transport() argument
40 trans->peer = peer; in rxrpc_alloc_transport()
51 if (peer->srx.transport.family == AF_INET) { in rxrpc_alloc_transport()
52 switch (peer->srx.transport_type) { in rxrpc_alloc_transport()
74 struct rxrpc_peer *peer, in rxrpc_get_transport() argument
84 &peer->srx.transport.sin.sin_addr, in rxrpc_get_transport()
85 ntohs(peer->srx.transport.sin.sin_port)); in rxrpc_get_transport()
90 if (trans->local == local && trans->peer == peer) in rxrpc_get_transport()
97 candidate = rxrpc_alloc_transport(local, peer, gfp); in rxrpc_get_transport()
106 if (trans->local == local && trans->peer == peer) in rxrpc_get_transport()
[all …]
|
| D | ar-proc.c | 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()
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-ack.c | 552 struct rxrpc_peer *peer; in rxrpc_extract_ackinfo() local
567 peer = call->conn->trans->peer; in rxrpc_extract_ackinfo()
568 if (mtu < peer->maxdata) { in rxrpc_extract_ackinfo()
569 spin_lock_bh(&peer->lock); in rxrpc_extract_ackinfo()
570 peer->maxdata = mtu; in rxrpc_extract_ackinfo()
571 peer->mtu = mtu + peer->hdrsize; in rxrpc_extract_ackinfo()
572 spin_unlock_bh(&peer->lock); in rxrpc_extract_ackinfo()
573 _net("Net MTU %u (maxdata %u)", peer->mtu, peer->maxdata); 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()
[all …]
|
| D | ar-accept.c | 80 struct rxrpc_peer *peer; in rxrpc_accept_incoming_call() local
94 peer = rxrpc_get_peer(srx, GFP_NOIO); in rxrpc_accept_incoming_call()
95 if (IS_ERR(peer)) { in rxrpc_accept_incoming_call()
101 trans = rxrpc_get_transport(local, peer, GFP_NOIO); in rxrpc_accept_incoming_call()
102 rxrpc_put_peer(peer); in rxrpc_accept_incoming_call()
|
| D | ar-output.c | 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()
352 if (skb->len - sizeof(struct rxrpc_header) < trans->peer->maxdata) { in rxrpc_send_packet()
367 _leave(" = %d [%u]", ret, trans->peer->maxdata); in rxrpc_send_packet()
389 _leave(" = %d [frag %u]", ret, trans->peer->maxdata); in rxrpc_send_packet()
580 max = call->conn->trans->peer->maxdata; in rxrpc_send_data()
723 ret = call->conn->trans->peer->net_error; in rxrpc_send_data()
|
| D | ar-call.c | 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()
341 spin_lock(&conn->trans->peer->lock); in rxrpc_incoming_call()
342 list_add(&call->error_link, &conn->trans->peer->error_targets); in rxrpc_incoming_call()
343 spin_unlock(&conn->trans->peer->lock); in rxrpc_incoming_call()
657 spin_lock(&call->conn->trans->peer->lock); in rxrpc_cleanup_call()
659 spin_unlock(&call->conn->trans->peer->lock); in rxrpc_cleanup_call()
|
| D | af_rxrpc.c | 227 struct rxrpc_peer *peer; in rxrpc_name_to_transport() local
240 peer = rxrpc_get_peer(srx, gfp); in rxrpc_name_to_transport()
241 if (IS_ERR(peer)) in rxrpc_name_to_transport()
242 return ERR_CAST(peer); in rxrpc_name_to_transport()
245 trans = rxrpc_get_transport(rx->local, peer, gfp); in rxrpc_name_to_transport()
246 rxrpc_put_peer(peer); in rxrpc_name_to_transport()
|
| /net/sctp/ |
| D | associola.c | 207 asoc->peer.rwnd = SCTP_DEFAULT_MAXWINDOW; in sctp_association_init()
218 asoc->peer.i.init_tag = 0; /* INIT needs a vtag of 0. */ in sctp_association_init()
250 INIT_LIST_HEAD(&asoc->peer.transport_addr_list); in sctp_association_init()
251 asoc->peer.transport_count = 0; in sctp_association_init()
264 asoc->peer.sack_needed = 1; in sctp_association_init()
265 asoc->peer.sack_cnt = 0; in sctp_association_init()
272 asoc->peer.asconf_capable = 0; in sctp_association_init()
274 asoc->peer.asconf_capable = 1; in sctp_association_init()
286 memset(&asoc->peer.tsn_map, 0, sizeof(struct sctp_tsnmap)); in sctp_association_init()
295 asoc->peer.ipv4_address = 1; in sctp_association_init()
[all …]
|
| D | transport.c | 59 static struct sctp_transport *sctp_transport_init(struct sctp_transport *peer, in sctp_transport_init() argument
64 peer->ipaddr = *addr; in sctp_transport_init()
65 peer->af_specific = sctp_get_af_specific(addr->sa.sa_family); in sctp_transport_init()
66 peer->asoc = NULL; in sctp_transport_init()
68 peer->dst = NULL; in sctp_transport_init()
69 memset(&peer->saddr, 0, sizeof(union sctp_addr)); in sctp_transport_init()
77 peer->last_rto = peer->rto = msecs_to_jiffies(sctp_rto_initial); in sctp_transport_init()
78 peer->rtt = 0; in sctp_transport_init()
79 peer->rttvar = 0; in sctp_transport_init()
80 peer->srtt = 0; in sctp_transport_init()
[all …]
|
| D | sm_make_chunk.c | 372 if (asoc->peer.ecn_capable) in sctp_make_init_ack()
386 if (asoc->peer.auth_capable) { in sctp_make_init_ack()
422 if (asoc->peer.ecn_capable) in sctp_make_init_ack()
432 if (asoc->peer.prsctp_capable) in sctp_make_init_ack()
440 if (asoc->peer.auth_capable) { in sctp_make_init_ack()
514 cookie = asoc->peer.cookie; in sctp_make_cookie_echo()
515 cookie_len = asoc->peer.cookie_len; in sctp_make_cookie_echo()
704 struct sctp_tsnmap *map = (struct sctp_tsnmap *)&asoc->peer.tsn_map; in sctp_make_sack()
760 retval->transport = asoc->peer.last_data_from; in sctp_make_sack()
787 ctsn = sctp_tsnmap_get_ctsn(&asoc->peer.tsn_map); in sctp_make_shutdown()
[all …]
|
| D | sm_sideeffect.c | 160 struct sctp_transport *trans = asoc->peer.last_data_from; in sctp_gen_sack()
166 asoc->peer.sack_needed = 1; in sctp_gen_sack()
168 ctsn = sctp_tsnmap_get_ctsn(&asoc->peer.tsn_map); in sctp_gen_sack()
169 max_tsn_seen = sctp_tsnmap_get_max_tsn_seen(&asoc->peer.tsn_map); in sctp_gen_sack()
182 asoc->peer.sack_needed = 1; in sctp_gen_sack()
192 if (!asoc->peer.sack_needed) { in sctp_gen_sack()
193 asoc->peer.sack_cnt++; in sctp_gen_sack()
202 if (asoc->peer.sack_cnt >= trans->sackfreq - 1) in sctp_gen_sack()
203 asoc->peer.sack_needed = 1; in sctp_gen_sack()
209 if (asoc->peer.sack_cnt >= asoc->sackfreq - 1) in sctp_gen_sack()
[all …]
|
| D | outqueue.c | 231 list_for_each_entry(transport, &q->asoc->peer.transport_addr_list, in sctp_outq_teardown()
412 q->asoc->peer.rwnd += (sctp_data_size(chunk) + in sctp_retransmit_mark()
442 q->asoc->peer.rwnd += (sctp_data_size(chunk) + in sctp_retransmit_mark()
498 if (transport == transport->asoc->peer.retran_path) in sctp_retransmit()
723 __u16 dport = asoc->peer.port; in sctp_outq_flush()
724 __u32 vtag = asoc->peer.i.init_tag; in sctp_outq_flush()
779 new_transport = asoc->peer.active_path; in sctp_outq_flush()
798 new_transport = asoc->peer.active_path; in sctp_outq_flush()
812 asoc->peer.ecn_capable); in sctp_outq_flush()
895 if (transport == asoc->peer.retran_path) in sctp_outq_flush()
[all …]
|
| D | proc.c | 129 struct sctp_transport *peer; in sctp_seq_dump_local_addrs() local
135 peer = asoc->peer.primary_path; in sctp_seq_dump_local_addrs()
136 primary = &peer->saddr; in sctp_seq_dump_local_addrs()
156 primary = &assoc->peer.primary_addr; in sctp_seq_dump_remote_addrs()
157 list_for_each_entry(transport, &assoc->peer.transport_addr_list, in sctp_seq_dump_remote_addrs()
330 assoc->peer.port); in sctp_assocs_seq_show()
432 list_for_each_entry(tsp, &assoc->peer.transport_addr_list, in sctp_remaddr_seq_show()
|
| D | output.c | 249 asoc->peer.sack_needed = 0; in sctp_packet_bundle_sack()
565 if (asoc && asoc->peer.last_sent_to != tp) { in sctp_packet_transmit()
569 asoc->peer.last_sent_to = tp; in sctp_packet_transmit()
654 rwnd = asoc->peer.rwnd; in sctp_packet_append_data()
746 asoc->peer.rwnd = rwnd; in sctp_packet_append_data()
748 if (!asoc->peer.prsctp_capable) in sctp_packet_append_data()
|
| D | auth.c | 245 return sctp_auth_make_key_vector(asoc->peer.peer_random, in sctp_auth_make_peer_vector()
246 asoc->peer.peer_chunks, in sctp_auth_make_peer_vector()
247 asoc->peer.peer_hmacs, in sctp_auth_make_peer_vector()
400 if (!sctp_auth_enable || !asoc->peer.auth_capable) in sctp_auth_asoc_init_active_key()
536 hmacs = asoc->peer.peer_hmacs; in sctp_auth_asoc_get_hmac()
672 if (!sctp_auth_enable || !asoc || !asoc->peer.auth_capable) in sctp_auth_send_cid()
675 return __sctp_auth_cid(chunk, asoc->peer.peer_chunks); in sctp_auth_send_cid()
|
| D | input.c | 75 const union sctp_addr *peer,
781 epb->hashent = sctp_assoc_hashfn(epb->bind_addr.port, asoc->peer.port); in __sctp_hash_established()
810 asoc->peer.port); in __sctp_unhash_established()
833 const union sctp_addr *peer, in __sctp_lookup_association() argument
846 hash = sctp_assoc_hashfn(ntohs(local->v4.sin_port), ntohs(peer->v4.sin_port)); in __sctp_lookup_association()
851 transport = sctp_assoc_is_match(asoc, local, peer); in __sctp_lookup_association()
|
| /net/x25/ |
| D | x25_forward.c | 97 struct net_device *peer = NULL; in x25_forward_data() local
108 peer = frwd->dev2; in x25_forward_data()
110 peer = frwd->dev1; in x25_forward_data()
117 if ( (nb = x25_get_neigh(peer)) == NULL) in x25_forward_data()
|
| /net/ipv4/ |
| D | xfrm4_policy.c | 108 xdst->u.rt.peer = rt->peer; in xfrm4_fill_dst()
109 if (rt->peer) in xfrm4_fill_dst()
110 atomic_inc(&rt->peer->refcnt); in xfrm4_fill_dst()
210 if (likely(xdst->u.rt.peer)) in xfrm4_dst_destroy()
211 inet_putpeer(xdst->u.rt.peer); in xfrm4_dst_destroy()
|
| D | tcp_ipv4.c | 199 struct inet_peer *peer = rt_get_peer(rt); in tcp_v4_connect() local
206 if (peer != NULL && in tcp_v4_connect()
207 peer->tcp_ts_stamp + TCP_PAWS_MSL >= get_seconds()) { in tcp_v4_connect()
208 tp->rx_opt.ts_recent_stamp = peer->tcp_ts_stamp; in tcp_v4_connect()
209 tp->rx_opt.ts_recent = peer->tcp_ts; in tcp_v4_connect()
1260 struct inet_peer *peer = NULL; in tcp_v4_conn_request() local
1274 (peer = rt_get_peer((struct rtable *)dst)) != NULL && in tcp_v4_conn_request()
1275 peer->v4daddr == saddr) { in tcp_v4_conn_request()
1276 if (get_seconds() < peer->tcp_ts_stamp + TCP_PAWS_MSL && in tcp_v4_conn_request()
1277 (s32)(peer->tcp_ts - req->ts_recent) > in tcp_v4_conn_request()
[all …]
|
| D | ip_fragment.c | 72 struct inet_peer *peer; member
143 qp->peer = sysctl_ipfrag_max_dist ? in ip4_frag_init()
152 if (qp->peer) in ip4_frag_free()
153 inet_putpeer(qp->peer); in ip4_frag_free()
248 struct inet_peer *peer = qp->peer; in ip_frag_too_far() local
254 if (!peer || !max) in ip_frag_too_far()
258 end = atomic_inc_return(&peer->rid); in ip_frag_too_far()
|
| D | route.c | 1240 struct inet_peer *peer; in rt_bind_peer() local
1242 peer = inet_getpeer(rt->rt_dst, create); in rt_bind_peer()
1245 if (rt->peer == NULL) { in rt_bind_peer()
1246 rt->peer = peer; in rt_bind_peer()
1247 peer = NULL; in rt_bind_peer()
1250 if (peer) in rt_bind_peer()
1251 inet_putpeer(peer); in rt_bind_peer()
1279 if (rt->peer == NULL) in __ip_select_ident()
1285 if (rt->peer) { in __ip_select_ident()
1286 iph->id = htons(inet_getid(rt->peer, more)); in __ip_select_ident()
[all …]
|
| /net/decnet/ |
| D | dn_nsp_out.c | 96 fl.fld_dst = dn_saddr2dn(&scp->peer); in dn_nsp_send()
680 if (scp->peer.sdn_objnum) in dn_nsp_send_conninit()
683 skb_put(skb, dn_sockaddr2username(&scp->peer, in dn_nsp_send_conninit()
689 if (scp->peer.sdn_flags & SDF_PROXY) in dn_nsp_send_conninit()
691 if (scp->peer.sdn_flags & SDF_UICPROXY) in dn_nsp_send_conninit()
|
| D | af_decnet.c | 424 if (cb->src != dn_saddr2dn(&scp->peer)) in dn_find_by_skb()
519 scp->peer.sdn_family = AF_DECnet; in dn_alloc_sock()
946 memcpy(&scp->peer, addr, sizeof(struct sockaddr_dn)); in __dn_connect()
951 fl.fld_dst = dn_saddr2dn(&scp->peer); in __dn_connect()
1131 skb_pull(skb, dn_username2sockaddr(skb->data, skb->len, &(DN_SK(newsk)->peer), &type)); in dn_accept()
1132 *(__le16 *)(DN_SK(newsk)->peer.sdn_add.a_addr) = cb->src; in dn_accept()
1145 DN_SK(newsk)->peer.sdn_flags |= SDF_PROXY; in dn_accept()
1148 DN_SK(newsk)->peer.sdn_flags |= SDF_UICPROXY; in dn_accept()
1176 static int dn_getname(struct socket *sock, struct sockaddr *uaddr,int *uaddr_len,int peer) in dn_getname() argument
1186 if (peer) { in dn_getname()
[all …]
|