Lines Matching defs:peer
33 * assess the MTU size for the network interface through which this peer is
36 static void rxrpc_assess_MTU_size(struct rxrpc_peer *peer)
42 peer->if_mtu = 1500;
46 switch (peer->srx.transport.family) {
51 fl.nl_u.ip4_u.daddr = peer->srx.transport.sin.sin_addr.s_addr;
67 peer->if_mtu = dst_mtu(&rt->dst);
70 _leave(" [if_mtu %u]", peer->if_mtu);
74 * allocate a new peer
79 struct rxrpc_peer *peer;
83 peer = kzalloc(sizeof(struct rxrpc_peer), gfp);
84 if (peer) {
85 INIT_WORK(&peer->destroyer, &rxrpc_destroy_peer);
86 INIT_LIST_HEAD(&peer->link);
87 INIT_LIST_HEAD(&peer->error_targets);
88 spin_lock_init(&peer->lock);
89 atomic_set(&peer->usage, 1);
90 peer->debug_id = atomic_inc_return(&rxrpc_debug_id);
91 memcpy(&peer->srx, srx, sizeof(*srx));
93 rxrpc_assess_MTU_size(peer);
94 peer->mtu = peer->if_mtu;
97 peer->hdrsize = sizeof(struct iphdr);
100 peer->hdrsize += sizeof(struct udphdr);
110 peer->hdrsize += sizeof(struct rxrpc_header);
111 peer->maxdata = peer->mtu - peer->hdrsize;
114 _leave(" = %p", peer);
115 return peer;
123 struct rxrpc_peer *peer, *candidate;
133 /* search the peer list first */
135 list_for_each_entry(peer, &rxrpc_peers, link) {
137 peer->debug_id,
138 atomic_read(&peer->usage),
139 peer->srx.transport_type,
140 peer->srx.transport_len);
142 if (atomic_read(&peer->usage) > 0 &&
143 peer->srx.transport_type == srx->transport_type &&
144 peer->srx.transport_len == srx->transport_len &&
145 memcmp(&peer->srx.transport,
162 list_for_each_entry(peer, &rxrpc_peers, link) {
163 if (atomic_read(&peer->usage) > 0 &&
164 peer->srx.transport_type == srx->transport_type &&
165 peer->srx.transport_len == srx->transport_len &&
166 memcmp(&peer->srx.transport,
173 peer = candidate;
176 list_add_tail(&peer->link, &rxrpc_peers);
183 peer->debug_id,
184 peer->srx.transport_type,
185 peer->srx.transport.family,
186 &peer->srx.transport.sin.sin_addr,
187 ntohs(peer->srx.transport.sin.sin_port));
189 _leave(" = %p {u=%d}", peer, atomic_read(&peer->usage));
190 return peer;
192 /* we found the peer in the list immediately */
194 usage = atomic_inc_return(&peer->usage);
198 /* we found the peer on the second time through the list */
200 usage = atomic_inc_return(&peer->usage);
207 * find the peer associated with a packet
212 struct rxrpc_peer *peer;
216 /* search the peer list */
222 list_for_each_entry(peer, &rxrpc_peers, link) {
223 if (atomic_read(&peer->usage) > 0 &&
224 peer->srx.transport_type == SOCK_DGRAM &&
225 peer->srx.transport.family == AF_INET &&
226 peer->srx.transport.sin.sin_port == port &&
227 peer->srx.transport.sin.sin_addr.s_addr == addr)
239 _net("Rx UDP DGRAM from peer %d", peer->debug_id);
240 atomic_inc(&peer->usage);
242 _leave(" = %p", peer);
243 return peer;
246 _net("Rx UDP DGRAM from NEW peer %d", peer->debug_id);
255 void rxrpc_put_peer(struct rxrpc_peer *peer)
257 _enter("%p{u=%d}", peer, atomic_read(&peer->usage));
259 ASSERTCMP(atomic_read(&peer->usage), >, 0);
261 if (likely(!atomic_dec_and_test(&peer->usage))) {
266 rxrpc_queue_work(&peer->destroyer);
275 struct rxrpc_peer *peer =
278 _enter("%p{%d}", peer, atomic_read(&peer->usage));
281 list_del(&peer->link);
284 _net("DESTROY PEER %d", peer->debug_id);
285 kfree(peer);
293 * preemptively destroy all the peer records from a transport endpoint rather