Lines Matching refs:peer
26 * Find the peer associated with an ICMP packet.
107 static void rxrpc_adjust_mtu(struct rxrpc_peer *peer, struct sock_exterr_skb *serr)
114 if (mtu > 0 && peer->if_mtu == 65535 && mtu < peer->if_mtu) {
115 peer->if_mtu = mtu;
121 mtu = peer->if_mtu;
128 if (mtu < peer->hdrsize)
129 mtu = peer->hdrsize + 4;
133 if (mtu < peer->mtu) {
134 spin_lock_bh(&peer->lock);
135 peer->mtu = mtu;
136 peer->maxdata = peer->mtu - peer->hdrsize;
137 spin_unlock_bh(&peer->lock);
139 peer->mtu, peer->maxdata);
151 struct rxrpc_peer *peer;
182 peer = rxrpc_lookup_peer_icmp_rcu(local, skb, &srx);
183 if (peer && !rxrpc_get_peer_maybe(peer))
184 peer = NULL;
185 if (!peer) {
188 _leave(" [no peer]");
192 trace_rxrpc_rx_icmp(peer, &serr->ee, &srx);
197 rxrpc_adjust_mtu(peer, serr);
200 rxrpc_put_peer(peer);
205 rxrpc_store_error(peer, serr);
208 rxrpc_put_peer(peer);
214 * Map an error report to error codes on the peer record.
216 static void rxrpc_store_error(struct rxrpc_peer *peer,
282 rxrpc_distribute_error(peer, err, compl);
286 * Distribute an error that occurred on a peer.
288 static void rxrpc_distribute_error(struct rxrpc_peer *peer, int error,
293 hlist_for_each_entry_rcu(call, &peer->error_targets, error_link) {
307 struct rxrpc_peer *peer;
315 peer = list_entry(collector->next,
318 list_del_init(&peer->keepalive_link);
319 if (!rxrpc_get_peer_maybe(peer))
322 if (__rxrpc_use_local(peer->local)) {
325 keepalive_at = peer->last_tx_at + RXRPC_KEEPALIVE_TIME;
327 _debug("%02x peer %u t=%d {%pISp}",
328 cursor, peer->debug_id, slot, &peer->srx.transport);
332 rxrpc_send_keepalive(peer);
336 /* A transmission to this peer occurred since last we
343 list_add_tail(&peer->keepalive_link,
345 rxrpc_unuse_local(peer->local);
347 rxrpc_put_peer_locked(peer);