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()
85 		INIT_LIST_HEAD(&peer->link);  in rxrpc_alloc_peer()
86 		INIT_LIST_HEAD(&peer->error_targets);  in rxrpc_alloc_peer()
87 		spin_lock_init(&peer->lock);  in rxrpc_alloc_peer()
88 		atomic_set(&peer->usage, 1);  in rxrpc_alloc_peer()
89 		peer->debug_id = atomic_inc_return(&rxrpc_debug_id);  in rxrpc_alloc_peer()
90 		memcpy(&peer->srx, srx, sizeof(*srx));  in rxrpc_alloc_peer()
92 		rxrpc_assess_MTU_size(peer);  in rxrpc_alloc_peer()
93 		peer->mtu = peer->if_mtu;  in rxrpc_alloc_peer()
96 			peer->hdrsize = sizeof(struct iphdr);  in rxrpc_alloc_peer()
99 				peer->hdrsize += sizeof(struct udphdr);  in rxrpc_alloc_peer()
109 		peer->hdrsize += sizeof(struct rxrpc_header);  in rxrpc_alloc_peer()
110 		peer->maxdata = peer->mtu - peer->hdrsize;  in rxrpc_alloc_peer()
113 	_leave(" = %p", peer);  in rxrpc_alloc_peer()
114 	return peer;  in rxrpc_alloc_peer()
122 	struct rxrpc_peer *peer, *candidate;  in rxrpc_get_peer()  local
134 	list_for_each_entry(peer, &rxrpc_peers, link) {  in rxrpc_get_peer()
136 		       peer->debug_id,  in rxrpc_get_peer()
137 		       atomic_read(&peer->usage),  in rxrpc_get_peer()
138 		       peer->srx.transport_type,  in rxrpc_get_peer()
139 		       peer->srx.transport_len);  in rxrpc_get_peer()
141 		if (atomic_read(&peer->usage) > 0 &&  in rxrpc_get_peer()
142 		    peer->srx.transport_type == srx->transport_type &&  in rxrpc_get_peer()
143 		    peer->srx.transport_len == srx->transport_len &&  in rxrpc_get_peer()
144 		    memcmp(&peer->srx.transport,  in rxrpc_get_peer()
161 	list_for_each_entry(peer, &rxrpc_peers, link) {  in rxrpc_get_peer()
162 		if (atomic_read(&peer->usage) > 0 &&  in rxrpc_get_peer()
163 		    peer->srx.transport_type == srx->transport_type &&  in rxrpc_get_peer()
164 		    peer->srx.transport_len == srx->transport_len &&  in rxrpc_get_peer()
165 		    memcmp(&peer->srx.transport,  in rxrpc_get_peer()
172 	peer = candidate;  in rxrpc_get_peer()
175 	list_add_tail(&peer->link, &rxrpc_peers);  in rxrpc_get_peer()
182 	     peer->debug_id,  in rxrpc_get_peer()
183 	     peer->srx.transport_type,  in rxrpc_get_peer()
184 	     peer->srx.transport.family,  in rxrpc_get_peer()
185 	     &peer->srx.transport.sin.sin_addr,  in rxrpc_get_peer()
186 	     ntohs(peer->srx.transport.sin.sin_port));  in rxrpc_get_peer()
188 	_leave(" = %p {u=%d}", peer, atomic_read(&peer->usage));  in rxrpc_get_peer()
189 	return peer;  in rxrpc_get_peer()
193 	usage = atomic_inc_return(&peer->usage);  in rxrpc_get_peer()
199 	usage = atomic_inc_return(&peer->usage);  in rxrpc_get_peer()
211 	struct rxrpc_peer *peer;  in rxrpc_find_peer()  local
221 		list_for_each_entry(peer, &rxrpc_peers, link) {  in rxrpc_find_peer()
222 			if (atomic_read(&peer->usage) > 0 &&  in rxrpc_find_peer()
223 			    peer->srx.transport_type == SOCK_DGRAM &&  in rxrpc_find_peer()
224 			    peer->srx.transport.family == AF_INET &&  in rxrpc_find_peer()
225 			    peer->srx.transport.sin.sin_port == port &&  in rxrpc_find_peer()
226 			    peer->srx.transport.sin.sin_addr.s_addr == addr)  in rxrpc_find_peer()
238 	_net("Rx UDP DGRAM from peer %d", peer->debug_id);  in rxrpc_find_peer()
239 	atomic_inc(&peer->usage);  in rxrpc_find_peer()
241 	_leave(" = %p", peer);  in rxrpc_find_peer()
242 	return peer;  in rxrpc_find_peer()
245 	_net("Rx UDP DGRAM from NEW peer %d", peer->debug_id);  in rxrpc_find_peer()
254 void rxrpc_put_peer(struct rxrpc_peer *peer)  in rxrpc_put_peer()  argument
256 	_enter("%p{u=%d}", peer, atomic_read(&peer->usage));  in rxrpc_put_peer()
258 	ASSERTCMP(atomic_read(&peer->usage), >, 0);  in rxrpc_put_peer()
260 	if (likely(!atomic_dec_and_test(&peer->usage))) {  in rxrpc_put_peer()
265 	rxrpc_queue_work(&peer->destroyer);  in rxrpc_put_peer()
274 	struct rxrpc_peer *peer =  in rxrpc_destroy_peer()  local
277 	_enter("%p{%d}", peer, atomic_read(&peer->usage));  in rxrpc_destroy_peer()
280 	list_del(&peer->link);  in rxrpc_destroy_peer()
283 	_net("DESTROY PEER %d", peer->debug_id);  in rxrpc_destroy_peer()
284 	kfree(peer);  in rxrpc_destroy_peer()