76 static long rxrpc_peer_cmp_key(const struct rxrpc_peer *peer,  in rxrpc_peer_cmp_key()  argument
83 	diff = ((peer->hash_key - hash_key) ?:  in rxrpc_peer_cmp_key()
84 		((unsigned long)peer->local - (unsigned long)local) ?:  in rxrpc_peer_cmp_key()
85 		(peer->srx.transport_type - srx->transport_type) ?:  in rxrpc_peer_cmp_key()
86 		(peer->srx.transport_len - srx->transport_len) ?:  in rxrpc_peer_cmp_key()
87 		(peer->srx.transport.family - srx->transport.family));  in rxrpc_peer_cmp_key()
93 		return ((u16 __force)peer->srx.transport.sin.sin_port -  in rxrpc_peer_cmp_key()
95 			memcmp(&peer->srx.transport.sin.sin_addr,  in rxrpc_peer_cmp_key()
100 		return ((u16 __force)peer->srx.transport.sin6.sin6_port -  in rxrpc_peer_cmp_key()
102 			memcmp(&peer->srx.transport.sin6.sin6_addr,  in rxrpc_peer_cmp_key()
119 	struct rxrpc_peer *peer;  in __rxrpc_lookup_peer_rcu()  local
122 	hash_for_each_possible_rcu(rxnet->peer_hash, peer, hash_link, hash_key) {  in __rxrpc_lookup_peer_rcu()
123 		if (rxrpc_peer_cmp_key(peer, local, srx, hash_key) == 0 &&  in __rxrpc_lookup_peer_rcu()
124 		    refcount_read(&peer->ref) > 0)  in __rxrpc_lookup_peer_rcu()
125 			return peer;  in __rxrpc_lookup_peer_rcu()
137 	struct rxrpc_peer *peer;  in rxrpc_lookup_peer_rcu()  local
140 	peer = __rxrpc_lookup_peer_rcu(local, srx, hash_key);  in rxrpc_lookup_peer_rcu()
141 	if (peer)  in rxrpc_lookup_peer_rcu()
142 		_leave(" = %p {u=%d}", peer, refcount_read(&peer->ref));  in rxrpc_lookup_peer_rcu()
143 	return peer;  in rxrpc_lookup_peer_rcu()
151 				  struct rxrpc_peer *peer)  in rxrpc_assess_MTU_size()  argument
162 	peer->if_mtu = 1500;  in rxrpc_assess_MTU_size()
165 	switch (peer->srx.transport.family) {  in rxrpc_assess_MTU_size()
169 			peer->srx.transport.sin.sin_addr.s_addr, 0,  in rxrpc_assess_MTU_size()
183 		memcpy(&fl6->daddr, &peer->srx.transport.sin6.sin6_addr,  in rxrpc_assess_MTU_size()
199 	peer->if_mtu = dst_mtu(dst);  in rxrpc_assess_MTU_size()
202 	_leave(" [if_mtu %u]", peer->if_mtu);  in rxrpc_assess_MTU_size()
211 	struct rxrpc_peer *peer;  in rxrpc_alloc_peer()  local
215 	peer = kzalloc(sizeof(struct rxrpc_peer), gfp);  in rxrpc_alloc_peer()
216 	if (peer) {  in rxrpc_alloc_peer()
217 		refcount_set(&peer->ref, 1);  in rxrpc_alloc_peer()
218 		peer->local = rxrpc_get_local(local, rxrpc_local_get_peer);  in rxrpc_alloc_peer()
219 		INIT_HLIST_HEAD(&peer->error_targets);  in rxrpc_alloc_peer()
220 		peer->service_conns = RB_ROOT;  in rxrpc_alloc_peer()
221 		seqlock_init(&peer->service_conn_lock);  in rxrpc_alloc_peer()
222 		spin_lock_init(&peer->lock);  in rxrpc_alloc_peer()
223 		spin_lock_init(&peer->rtt_input_lock);  in rxrpc_alloc_peer()
224 		peer->debug_id = atomic_inc_return(&rxrpc_debug_id);  in rxrpc_alloc_peer()
226 		rxrpc_peer_init_rtt(peer);  in rxrpc_alloc_peer()
228 		peer->cong_ssthresh = RXRPC_TX_MAX_WINDOW;  in rxrpc_alloc_peer()
229 		trace_rxrpc_peer(peer->debug_id, 1, why);  in rxrpc_alloc_peer()
232 	_leave(" = %p", peer);  in rxrpc_alloc_peer()
233 	return peer;  in rxrpc_alloc_peer()
239 static void rxrpc_init_peer(struct rxrpc_local *local, struct rxrpc_peer *peer,  in rxrpc_init_peer()  argument
242 	peer->hash_key = hash_key;  in rxrpc_init_peer()
243 	rxrpc_assess_MTU_size(local, peer);  in rxrpc_init_peer()
244 	peer->mtu = peer->if_mtu;  in rxrpc_init_peer()
245 	peer->rtt_last_req = ktime_get_real();  in rxrpc_init_peer()
247 	switch (peer->srx.transport.family) {  in rxrpc_init_peer()
249 		peer->hdrsize = sizeof(struct iphdr);  in rxrpc_init_peer()
253 		peer->hdrsize = sizeof(struct ipv6hdr);  in rxrpc_init_peer()
260 	switch (peer->srx.transport_type) {  in rxrpc_init_peer()
262 		peer->hdrsize += sizeof(struct udphdr);  in rxrpc_init_peer()
268 	peer->hdrsize += sizeof(struct rxrpc_wire_header);  in rxrpc_init_peer()
269 	peer->maxdata = peer->mtu - peer->hdrsize;  in rxrpc_init_peer()
280 	struct rxrpc_peer *peer;  in rxrpc_create_peer()  local
284 	peer = rxrpc_alloc_peer(local, gfp, rxrpc_peer_new_client);  in rxrpc_create_peer()
285 	if (peer) {  in rxrpc_create_peer()
286 		memcpy(&peer->srx, srx, sizeof(*srx));  in rxrpc_create_peer()
287 		rxrpc_init_peer(local, peer, hash_key);  in rxrpc_create_peer()
290 	_leave(" = %p", peer);  in rxrpc_create_peer()
291 	return peer;  in rxrpc_create_peer()
294 static void rxrpc_free_peer(struct rxrpc_peer *peer)  in rxrpc_free_peer()  argument
296 	trace_rxrpc_peer(peer->debug_id, 0, rxrpc_peer_free);  in rxrpc_free_peer()
297 	rxrpc_put_local(peer->local, rxrpc_local_put_peer);  in rxrpc_free_peer()
298 	kfree_rcu(peer, rcu);  in rxrpc_free_peer()
306 void rxrpc_new_incoming_peer(struct rxrpc_local *local, struct rxrpc_peer *peer)  in rxrpc_new_incoming_peer()  argument
311 	hash_key = rxrpc_peer_hash_key(local, &peer->srx);  in rxrpc_new_incoming_peer()
312 	rxrpc_init_peer(local, peer, hash_key);  in rxrpc_new_incoming_peer()
315 	hash_add_rcu(rxnet->peer_hash, &peer->hash_link, hash_key);  in rxrpc_new_incoming_peer()
316 	list_add_tail(&peer->keepalive_link, &rxnet->peer_keepalive_new);  in rxrpc_new_incoming_peer()
326 	struct rxrpc_peer *peer, *candidate;  in rxrpc_lookup_peer()  local
334 	peer = __rxrpc_lookup_peer_rcu(local, srx, hash_key);  in rxrpc_lookup_peer()
335 	if (peer && !rxrpc_get_peer_maybe(peer, rxrpc_peer_get_lookup_client))  in rxrpc_lookup_peer()
336 		peer = NULL;  in rxrpc_lookup_peer()
339 	if (!peer) {  in rxrpc_lookup_peer()
352 		peer = __rxrpc_lookup_peer_rcu(local, srx, hash_key);  in rxrpc_lookup_peer()
353 		if (peer && !rxrpc_get_peer_maybe(peer, rxrpc_peer_get_lookup_client))  in rxrpc_lookup_peer()
354 			peer = NULL;  in rxrpc_lookup_peer()
355 		if (!peer) {  in rxrpc_lookup_peer()
364 		if (peer)  in rxrpc_lookup_peer()
367 			peer = candidate;  in rxrpc_lookup_peer()
370 	_leave(" = %p {u=%d}", peer, refcount_read(&peer->ref));  in rxrpc_lookup_peer()
371 	return peer;  in rxrpc_lookup_peer()
377 struct rxrpc_peer *rxrpc_get_peer(struct rxrpc_peer *peer, enum rxrpc_peer_trace why)  in rxrpc_get_peer()  argument
381 	__refcount_inc(&peer->ref, &r);  in rxrpc_get_peer()
382 	trace_rxrpc_peer(peer->debug_id, r + 1, why);  in rxrpc_get_peer()
383 	return peer;  in rxrpc_get_peer()
389 struct rxrpc_peer *rxrpc_get_peer_maybe(struct rxrpc_peer *peer,  in rxrpc_get_peer_maybe()  argument
394 	if (peer) {  in rxrpc_get_peer_maybe()
395 		if (__refcount_inc_not_zero(&peer->ref, &r))  in rxrpc_get_peer_maybe()
396 			trace_rxrpc_peer(peer->debug_id, r + 1, why);  in rxrpc_get_peer_maybe()
398 			peer = NULL;  in rxrpc_get_peer_maybe()
400 	return peer;  in rxrpc_get_peer_maybe()
406 static void __rxrpc_put_peer(struct rxrpc_peer *peer)  in __rxrpc_put_peer()  argument
408 	struct rxrpc_net *rxnet = peer->local->rxnet;  in __rxrpc_put_peer()
410 	ASSERT(hlist_empty(&peer->error_targets));  in __rxrpc_put_peer()
413 	hash_del_rcu(&peer->hash_link);  in __rxrpc_put_peer()
414 	list_del_init(&peer->keepalive_link);  in __rxrpc_put_peer()
417 	rxrpc_free_peer(peer);  in __rxrpc_put_peer()
423 void rxrpc_put_peer(struct rxrpc_peer *peer, enum rxrpc_peer_trace why)  in rxrpc_put_peer()  argument
429 	if (peer) {  in rxrpc_put_peer()
430 		debug_id = peer->debug_id;  in rxrpc_put_peer()
431 		dead = __refcount_dec_and_test(&peer->ref, &r);  in rxrpc_put_peer()
434 			__rxrpc_put_peer(peer);  in rxrpc_put_peer()
443 	struct rxrpc_peer *peer;  in rxrpc_destroy_all_peers()  local
450 		hlist_for_each_entry(peer, &rxnet->peer_hash[i], hash_link) {  in rxrpc_destroy_all_peers()
452 			       peer->debug_id,  in rxrpc_destroy_all_peers()
453 			       refcount_read(&peer->ref),  in rxrpc_destroy_all_peers()
454 			       &peer->srx.transport);  in rxrpc_destroy_all_peers()
470 	*_srx = call->peer->srx;  in rxrpc_kernel_get_peer()
485 	struct rxrpc_peer *peer = call->peer;  in rxrpc_kernel_get_srtt()  local
487 	if (peer->rtt_count == 0) {  in rxrpc_kernel_get_srtt()
492 	*_srtt = call->peer->srtt_us >> 3;  in rxrpc_kernel_get_srtt()