]>
git.proxmox.com Git - mirror_ubuntu-bionic-kernel.git/blob - net/rxrpc/local_object.c
1 /* Local endpoint object management
3 * Copyright (C) 2016 Red Hat, Inc. All Rights Reserved.
4 * Written by David Howells (dhowells@redhat.com)
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public Licence
8 * as published by the Free Software Foundation; either version
9 * 2 of the Licence, or (at your option) any later version.
12 #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
14 #include <linux/module.h>
15 #include <linux/net.h>
16 #include <linux/skbuff.h>
17 #include <linux/slab.h>
18 #include <linux/udp.h>
20 #include <linux/hashtable.h>
22 #include <net/af_rxrpc.h>
23 #include "ar-internal.h"
25 static void rxrpc_local_processor(struct work_struct
*);
26 static void rxrpc_local_rcu(struct rcu_head
*);
29 * Compare a local to an address. Return -ve, 0 or +ve to indicate less than,
30 * same or greater than.
32 * We explicitly don't compare the RxRPC service ID as we want to reject
33 * conflicting uses by differing services. Further, we don't want to share
34 * addresses with different options (IPv6), so we don't compare those bits
37 static long rxrpc_local_cmp_key(const struct rxrpc_local
*local
,
38 const struct sockaddr_rxrpc
*srx
)
42 diff
= ((local
->srx
.transport_type
- srx
->transport_type
) ?:
43 (local
->srx
.transport_len
- srx
->transport_len
) ?:
44 (local
->srx
.transport
.family
- srx
->transport
.family
));
48 switch (srx
->transport
.family
) {
50 /* If the choice of UDP port is left up to the transport, then
51 * the endpoint record doesn't match.
53 return ((u16 __force
)local
->srx
.transport
.sin
.sin_port
-
54 (u16 __force
)srx
->transport
.sin
.sin_port
) ?:
55 memcmp(&local
->srx
.transport
.sin
.sin_addr
,
56 &srx
->transport
.sin
.sin_addr
,
57 sizeof(struct in_addr
));
58 #ifdef CONFIG_AF_RXRPC_IPV6
60 /* If the choice of UDP6 port is left up to the transport, then
61 * the endpoint record doesn't match.
63 return ((u16 __force
)local
->srx
.transport
.sin6
.sin6_port
-
64 (u16 __force
)srx
->transport
.sin6
.sin6_port
) ?:
65 memcmp(&local
->srx
.transport
.sin6
.sin6_addr
,
66 &srx
->transport
.sin6
.sin6_addr
,
67 sizeof(struct in6_addr
));
75 * Allocate a new local endpoint.
77 static struct rxrpc_local
*rxrpc_alloc_local(struct rxrpc_net
*rxnet
,
78 const struct sockaddr_rxrpc
*srx
)
80 struct rxrpc_local
*local
;
82 local
= kzalloc(sizeof(struct rxrpc_local
), GFP_KERNEL
);
84 atomic_set(&local
->usage
, 1);
86 INIT_LIST_HEAD(&local
->link
);
87 INIT_WORK(&local
->processor
, rxrpc_local_processor
);
88 init_rwsem(&local
->defrag_sem
);
89 skb_queue_head_init(&local
->reject_queue
);
90 skb_queue_head_init(&local
->event_queue
);
91 local
->client_conns
= RB_ROOT
;
92 spin_lock_init(&local
->client_conns_lock
);
93 spin_lock_init(&local
->lock
);
94 rwlock_init(&local
->services_lock
);
95 local
->debug_id
= atomic_inc_return(&rxrpc_debug_id
);
96 memcpy(&local
->srx
, srx
, sizeof(*srx
));
97 local
->srx
.srx_service
= 0;
100 _leave(" = %p", local
);
105 * create the local socket
106 * - must be called with rxrpc_local_mutex locked
108 static int rxrpc_open_socket(struct rxrpc_local
*local
, struct net
*net
)
114 local
, local
->srx
.transport_type
, local
->srx
.transport
.family
);
116 /* create a socket to represent the local endpoint */
117 ret
= sock_create_kern(net
, local
->srx
.transport
.family
,
118 local
->srx
.transport_type
, 0, &local
->socket
);
120 _leave(" = %d [socket]", ret
);
124 /* if a local address was supplied then bind it */
125 if (local
->srx
.transport_len
> sizeof(sa_family_t
)) {
127 ret
= kernel_bind(local
->socket
,
128 (struct sockaddr
*)&local
->srx
.transport
,
129 local
->srx
.transport_len
);
131 _debug("bind failed %d", ret
);
136 switch (local
->srx
.transport
.family
) {
138 /* we want to receive ICMPv6 errors */
140 ret
= kernel_setsockopt(local
->socket
, SOL_IPV6
, IPV6_RECVERR
,
141 (char *) &opt
, sizeof(opt
));
143 _debug("setsockopt failed");
147 /* we want to set the don't fragment bit */
148 opt
= IPV6_PMTUDISC_DO
;
149 ret
= kernel_setsockopt(local
->socket
, SOL_IPV6
, IPV6_MTU_DISCOVER
,
150 (char *) &opt
, sizeof(opt
));
152 _debug("setsockopt failed");
156 /* Fall through and set IPv4 options too otherwise we don't get
157 * errors from IPv4 packets sent through the IPv6 socket.
161 /* we want to receive ICMP errors */
163 ret
= kernel_setsockopt(local
->socket
, SOL_IP
, IP_RECVERR
,
164 (char *) &opt
, sizeof(opt
));
166 _debug("setsockopt failed");
170 /* we want to set the don't fragment bit */
171 opt
= IP_PMTUDISC_DO
;
172 ret
= kernel_setsockopt(local
->socket
, SOL_IP
, IP_MTU_DISCOVER
,
173 (char *) &opt
, sizeof(opt
));
175 _debug("setsockopt failed");
184 /* set the socket up */
185 sock
= local
->socket
->sk
;
186 sock
->sk_user_data
= local
;
187 sock
->sk_data_ready
= rxrpc_data_ready
;
188 sock
->sk_error_report
= rxrpc_error_report
;
193 kernel_sock_shutdown(local
->socket
, SHUT_RDWR
);
194 local
->socket
->sk
->sk_user_data
= NULL
;
195 sock_release(local
->socket
);
196 local
->socket
= NULL
;
198 _leave(" = %d", ret
);
203 * Look up or create a new local endpoint using the specified local address.
205 struct rxrpc_local
*rxrpc_lookup_local(struct net
*net
,
206 const struct sockaddr_rxrpc
*srx
)
208 struct rxrpc_local
*local
;
209 struct rxrpc_net
*rxnet
= rxrpc_net(net
);
210 struct list_head
*cursor
;
215 _enter("{%d,%d,%pISp}",
216 srx
->transport_type
, srx
->transport
.family
, &srx
->transport
);
218 mutex_lock(&rxnet
->local_mutex
);
220 for (cursor
= rxnet
->local_endpoints
.next
;
221 cursor
!= &rxnet
->local_endpoints
;
222 cursor
= cursor
->next
) {
223 local
= list_entry(cursor
, struct rxrpc_local
, link
);
225 diff
= rxrpc_local_cmp_key(local
, srx
);
231 /* Services aren't allowed to share transport sockets, so
232 * reject that here. It is possible that the object is dying -
233 * but it may also still have the local transport address that
236 if (srx
->srx_service
) {
241 /* Found a match. We replace a dying object. Attempting to
242 * bind the transport socket may still fail if we're attempting
243 * to use a local address that the dying object is still using.
245 if (!rxrpc_get_local_maybe(local
)) {
246 cursor
= cursor
->next
;
247 list_del_init(&local
->link
);
255 local
= rxrpc_alloc_local(rxnet
, srx
);
259 ret
= rxrpc_open_socket(local
, net
);
263 list_add_tail(&local
->link
, cursor
);
267 mutex_unlock(&rxnet
->local_mutex
);
269 _net("LOCAL %s %d {%pISp}",
270 age
, local
->debug_id
, &local
->srx
.transport
);
272 _leave(" = %p", local
);
278 mutex_unlock(&rxnet
->local_mutex
);
280 _leave(" = %d", ret
);
284 mutex_unlock(&rxnet
->local_mutex
);
285 _leave(" = -EADDRINUSE");
286 return ERR_PTR(-EADDRINUSE
);
290 * A local endpoint reached its end of life.
292 void __rxrpc_put_local(struct rxrpc_local
*local
)
294 _enter("%d", local
->debug_id
);
295 rxrpc_queue_work(&local
->processor
);
299 * Destroy a local endpoint's socket and then hand the record to RCU to dispose
302 * Closing the socket cannot be done from bottom half context or RCU callback
303 * context because it might sleep.
305 static void rxrpc_local_destroyer(struct rxrpc_local
*local
)
307 struct socket
*socket
= local
->socket
;
308 struct rxrpc_net
*rxnet
= local
->rxnet
;
310 _enter("%d", local
->debug_id
);
312 /* We can get a race between an incoming call packet queueing the
313 * processor again and the work processor starting the destruction
314 * process which will shut down the UDP socket.
317 _leave(" [already dead]");
322 mutex_lock(&rxnet
->local_mutex
);
323 list_del_init(&local
->link
);
324 mutex_unlock(&rxnet
->local_mutex
);
326 ASSERT(RB_EMPTY_ROOT(&local
->client_conns
));
327 ASSERT(!local
->service
);
330 local
->socket
= NULL
;
331 kernel_sock_shutdown(socket
, SHUT_RDWR
);
332 socket
->sk
->sk_user_data
= NULL
;
333 sock_release(socket
);
336 /* At this point, there should be no more packets coming in to the
339 rxrpc_purge_queue(&local
->reject_queue
);
340 rxrpc_purge_queue(&local
->event_queue
);
342 _debug("rcu local %d", local
->debug_id
);
343 call_rcu(&local
->rcu
, rxrpc_local_rcu
);
347 * Process events on an endpoint
349 static void rxrpc_local_processor(struct work_struct
*work
)
351 struct rxrpc_local
*local
=
352 container_of(work
, struct rxrpc_local
, processor
);
355 _enter("%d", local
->debug_id
);
359 if (atomic_read(&local
->usage
) == 0)
360 return rxrpc_local_destroyer(local
);
362 if (!skb_queue_empty(&local
->reject_queue
)) {
363 rxrpc_reject_packets(local
);
367 if (!skb_queue_empty(&local
->event_queue
)) {
368 rxrpc_process_local_events(local
);
375 * Destroy a local endpoint after the RCU grace period expires.
377 static void rxrpc_local_rcu(struct rcu_head
*rcu
)
379 struct rxrpc_local
*local
= container_of(rcu
, struct rxrpc_local
, rcu
);
381 _enter("%d", local
->debug_id
);
383 ASSERT(!work_pending(&local
->processor
));
385 _net("DESTROY LOCAL %d", local
->debug_id
);
391 * Verify the local endpoint list is empty by this point.
393 void rxrpc_destroy_all_locals(struct rxrpc_net
*rxnet
)
395 struct rxrpc_local
*local
;
399 flush_workqueue(rxrpc_workqueue
);
401 if (!list_empty(&rxnet
->local_endpoints
)) {
402 mutex_lock(&rxnet
->local_mutex
);
403 list_for_each_entry(local
, &rxnet
->local_endpoints
, link
) {
404 pr_err("AF_RXRPC: Leaked local %p {%d}\n",
405 local
, atomic_read(&local
->usage
));
407 mutex_unlock(&rxnet
->local_mutex
);