conn_object.c 16.9 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11
/* RxRPC virtual connection handler
 *
 * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved.
 * Written by David Howells (dhowells@redhat.com)
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version
 * 2 of the License, or (at your option) any later version.
 */

12 13
#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt

14
#include <linux/module.h>
15
#include <linux/slab.h>
16 17 18 19 20 21 22
#include <linux/net.h>
#include <linux/skbuff.h>
#include <linux/crypto.h>
#include <net/sock.h>
#include <net/af_rxrpc.h>
#include "ar-internal.h"

23 24 25
/*
 * Time till a connection expires after last use (in seconds).
 */
26
unsigned int rxrpc_connection_expiry = 10 * 60;
27

28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44
static void rxrpc_connection_reaper(struct work_struct *work);

LIST_HEAD(rxrpc_connections);
DEFINE_RWLOCK(rxrpc_connection_lock);
static DECLARE_DELAYED_WORK(rxrpc_connection_reap, rxrpc_connection_reaper);

/*
 * allocate a new connection
 */
static struct rxrpc_connection *rxrpc_alloc_connection(gfp_t gfp)
{
	struct rxrpc_connection *conn;

	_enter("");

	conn = kzalloc(sizeof(struct rxrpc_connection), gfp);
	if (conn) {
45 46
		spin_lock_init(&conn->channel_lock);
		init_waitqueue_head(&conn->channel_wq);
47
		INIT_WORK(&conn->processor, &rxrpc_process_connection);
48
		INIT_LIST_HEAD(&conn->link);
49 50
		conn->calls = RB_ROOT;
		skb_queue_head_init(&conn->rx_queue);
51
		conn->security = &rxrpc_no_security;
52 53 54 55
		rwlock_init(&conn->lock);
		spin_lock_init(&conn->state_lock);
		atomic_set(&conn->usage, 1);
		conn->debug_id = atomic_inc_return(&rxrpc_debug_id);
56
		atomic_set(&conn->avail_chans, RXRPC_MAXCALLS);
57
		conn->size_align = 4;
58
		conn->header_size = sizeof(struct rxrpc_wire_header);
59 60
	}

61
	_leave(" = %p{%d}", conn, conn ? conn->debug_id : 0);
62 63 64 65 66 67 68 69 70 71 72
	return conn;
}

/*
 * add a call to a connection's call-by-ID tree
 */
static void rxrpc_add_call_ID_to_conn(struct rxrpc_connection *conn,
				      struct rxrpc_call *call)
{
	struct rxrpc_call *xcall;
	struct rb_node *parent, **p;
D
David Howells 已提交
73
	u32 call_id;
74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98

	write_lock_bh(&conn->lock);

	call_id = call->call_id;
	p = &conn->calls.rb_node;
	parent = NULL;
	while (*p) {
		parent = *p;
		xcall = rb_entry(parent, struct rxrpc_call, conn_node);

		if (call_id < xcall->call_id)
			p = &(*p)->rb_left;
		else if (call_id > xcall->call_id)
			p = &(*p)->rb_right;
		else
			BUG();
	}

	rb_link_node(&call->conn_node, parent, p);
	rb_insert_color(&call->conn_node, &conn->calls);

	write_unlock_bh(&conn->lock);
}

/*
99 100
 * Allocate a client connection.  The caller must take care to clear any
 * padding bytes in *cp.
101
 */
102
static struct rxrpc_connection *
103
rxrpc_alloc_client_connection(struct rxrpc_conn_parameters *cp, gfp_t gfp)
104 105
{
	struct rxrpc_connection *conn;
106
	int ret;
107 108 109

	_enter("");

110
	conn = rxrpc_alloc_connection(gfp);
111
	if (!conn) {
112
		_leave(" = -ENOMEM");
113
		return ERR_PTR(-ENOMEM);
114
	}
115

116 117 118 119 120 121 122 123 124
	conn->params		= *cp;
	conn->proto.local	= cp->local;
	conn->proto.epoch	= rxrpc_epoch;
	conn->proto.cid		= 0;
	conn->proto.in_clientflag = 0;
	conn->proto.family	= cp->peer->srx.transport.family;
	conn->out_clientflag	= RXRPC_CLIENT_INITIATED;
	conn->state		= RXRPC_CONN_CLIENT;

125 126 127 128 129 130 131 132
	switch (conn->proto.family) {
	case AF_INET:
		conn->proto.addr_size = sizeof(conn->proto.ipv4_addr);
		conn->proto.ipv4_addr = cp->peer->srx.transport.sin.sin_addr;
		conn->proto.port = cp->peer->srx.transport.sin.sin_port;
		break;
	}

133
	ret = rxrpc_get_client_connection_id(conn, gfp);
134 135
	if (ret < 0)
		goto error_0;
136 137

	ret = rxrpc_init_client_conn_security(conn);
138 139 140
	if (ret < 0)
		goto error_1;

141 142 143
	ret = conn->security->prime_packet_security(conn);
	if (ret < 0)
		goto error_2;
144

145
	write_lock(&rxrpc_connection_lock);
146
	list_add_tail(&conn->link, &rxrpc_connections);
147
	write_unlock(&rxrpc_connection_lock);
148

149 150 151
	/* We steal the caller's peer ref. */
	cp->peer = NULL;
	rxrpc_get_local(conn->params.local);
152 153 154 155 156
	key_get(conn->params.key);

	_leave(" = %p", conn);
	return conn;

157 158
error_2:
	conn->security->clear(conn);
159 160 161 162 163 164 165 166
error_1:
	rxrpc_put_client_connection_id(conn);
error_0:
	kfree(conn);
	_leave(" = %d", ret);
	return ERR_PTR(ret);
}

167 168 169 170
/*
 * find a connection for a call
 * - called in process context with IRQs enabled
 */
171
int rxrpc_connect_call(struct rxrpc_call *call,
172
		       struct rxrpc_conn_parameters *cp,
173
		       struct sockaddr_rxrpc *srx,
174 175
		       gfp_t gfp)
{
176 177 178 179
	struct rxrpc_connection *conn, *candidate = NULL;
	struct rxrpc_local *local = cp->local;
	struct rb_node *p, **pp, *parent;
	long diff;
180
	int chan;
181 182 183

	DECLARE_WAITQUEUE(myself, current);

184
	_enter("{%d,%lx},", call->debug_id, call->user_call_ID);
185

186 187 188
	cp->peer = rxrpc_lookup_peer(cp->local, srx, gfp);
	if (!cp->peer)
		return -ENOMEM;
189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209

	if (!cp->exclusive) {
		/* Search for a existing client connection unless this is going
		 * to be a connection that's used exclusively for a single call.
		 */
		_debug("search 1");
		spin_lock(&local->client_conns_lock);
		p = local->client_conns.rb_node;
		while (p) {
			conn = rb_entry(p, struct rxrpc_connection, client_node);

#define cmp(X) ((long)conn->params.X - (long)cp->X)
			diff = (cmp(peer) ?:
				cmp(key) ?:
				cmp(security_level));
			if (diff < 0)
				p = p->rb_left;
			else if (diff > 0)
				p = p->rb_right;
			else
				goto found_extant_conn;
210
		}
211 212
		spin_unlock(&local->client_conns_lock);
	}
213

214 215
	/* We didn't find a connection or we want an exclusive one. */
	_debug("get new conn");
216
	candidate = rxrpc_alloc_client_connection(cp, gfp);
217 218 219 220
	if (!candidate) {
		_leave(" = -ENOMEM");
		return -ENOMEM;
	}
221

222 223 224 225 226 227 228 229 230 231 232 233
	if (cp->exclusive) {
		/* Assign the call on an exclusive connection to channel 0 and
		 * don't add the connection to the endpoint's shareable conn
		 * lookup tree.
		 */
		_debug("exclusive chan 0");
		conn = candidate;
		atomic_set(&conn->avail_chans, RXRPC_MAXCALLS - 1);
		spin_lock(&conn->channel_lock);
		chan = 0;
		goto found_channel;
	}
234

235 236 237 238 239
	/* We need to redo the search before attempting to add a new connection
	 * lest we race with someone else adding a conflicting instance.
	 */
	_debug("search 2");
	spin_lock(&local->client_conns_lock);
240

241 242 243 244 245
	pp = &local->client_conns.rb_node;
	parent = NULL;
	while (*pp) {
		parent = *pp;
		conn = rb_entry(parent, struct rxrpc_connection, client_node);
246

247 248 249 250 251 252 253 254 255 256
		diff = (cmp(peer) ?:
			cmp(key) ?:
			cmp(security_level));
		if (diff < 0)
			pp = &(*pp)->rb_left;
		else if (diff > 0)
			pp = &(*pp)->rb_right;
		else
			goto found_extant_conn;
	}
257

258 259 260 261 262 263 264
	/* The second search also failed; simply add the new connection with
	 * the new call in channel 0.  Note that we need to take the channel
	 * lock before dropping the client conn lock.
	 */
	_debug("new conn");
	conn = candidate;
	candidate = NULL;
265

266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281
	rb_link_node(&conn->client_node, parent, pp);
	rb_insert_color(&conn->client_node, &local->client_conns);

	atomic_set(&conn->avail_chans, RXRPC_MAXCALLS - 1);
	spin_lock(&conn->channel_lock);
	spin_unlock(&local->client_conns_lock);
	chan = 0;

found_channel:
	_debug("found chan");
	call->conn	= conn;
	call->channel	= chan;
	call->epoch	= conn->proto.epoch;
	call->cid	= conn->proto.cid | chan;
	call->call_id	= ++conn->call_counter;
	rcu_assign_pointer(conn->channels[chan], call);
282

283
	_net("CONNECT call %d on conn %d", call->debug_id, conn->debug_id);
284

285 286
	rxrpc_add_call_ID_to_conn(conn, call);
	spin_unlock(&conn->channel_lock);
287 288
	rxrpc_put_peer(cp->peer);
	cp->peer = NULL;
289 290 291 292 293 294 295 296 297 298 299
	_leave(" = %p {u=%d}", conn, atomic_read(&conn->usage));
	return 0;

	/* We found a suitable connection already in existence.  Discard any
	 * candidate we may have allocated, and try to get a channel on this
	 * one.
	 */
found_extant_conn:
	_debug("found conn");
	rxrpc_get_connection(conn);
	spin_unlock(&local->client_conns_lock);
300

301
	rxrpc_put_connection(candidate);
302

303 304 305 306 307 308
	if (!atomic_add_unless(&conn->avail_chans, -1, 0)) {
		if (!gfpflags_allow_blocking(gfp)) {
			rxrpc_put_connection(conn);
			_leave(" = -EAGAIN");
			return -EAGAIN;
		}
309

310 311 312 313 314 315 316 317 318 319 320
		add_wait_queue(&conn->channel_wq, &myself);
		for (;;) {
			set_current_state(TASK_INTERRUPTIBLE);
			if (atomic_add_unless(&conn->avail_chans, -1, 0))
				break;
			if (signal_pending(current))
				goto interrupted;
			schedule();
		}
		remove_wait_queue(&conn->channel_wq, &myself);
		__set_current_state(TASK_RUNNING);
321 322
	}

323 324
	/* The connection allegedly now has a free channel and we can now
	 * attach the call to it.
325
	 */
326 327
	spin_lock(&conn->channel_lock);

328 329 330 331 332 333
	for (chan = 0; chan < RXRPC_MAXCALLS; chan++)
		if (!conn->channels[chan])
			goto found_channel;
	BUG();

interrupted:
334 335 336
	remove_wait_queue(&conn->channel_wq, &myself);
	__set_current_state(TASK_RUNNING);
	rxrpc_put_connection(conn);
337 338
	rxrpc_put_peer(cp->peer);
	cp->peer = NULL;
339 340 341 342 343 344 345
	_leave(" = -ERESTARTSYS");
	return -ERESTARTSYS;
}

/*
 * get a record of an incoming connection
 */
346 347
struct rxrpc_connection *rxrpc_incoming_connection(struct rxrpc_local *local,
						   struct rxrpc_peer *peer,
348
						   struct sk_buff *skb)
349 350
{
	struct rxrpc_connection *conn, *candidate = NULL;
351
	struct rxrpc_skb_priv *sp = rxrpc_skb(skb);
352 353
	struct rb_node *p, **pp;
	const char *new = "old";
D
David Howells 已提交
354
	u32 epoch, cid;
355 356 357

	_enter("");

358
	ASSERT(sp->hdr.flags & RXRPC_CLIENT_INITIATED);
359

360 361
	epoch = sp->hdr.epoch;
	cid = sp->hdr.cid & RXRPC_CIDMASK;
362 363

	/* search the connection list first */
364
	read_lock_bh(&peer->conn_lock);
365

366
	p = peer->service_conns.rb_node;
367
	while (p) {
368
		conn = rb_entry(p, struct rxrpc_connection, service_node);
369

370
		_debug("maybe %x", conn->proto.cid);
371

372
		if (epoch < conn->proto.epoch)
373
			p = p->rb_left;
374
		else if (epoch > conn->proto.epoch)
375
			p = p->rb_right;
376
		else if (cid < conn->proto.cid)
377
			p = p->rb_left;
378
		else if (cid > conn->proto.cid)
379 380 381 382
			p = p->rb_right;
		else
			goto found_extant_connection;
	}
383
	read_unlock_bh(&peer->conn_lock);
384 385 386

	/* not yet present - create a candidate for a new record and then
	 * redo the search */
387
	candidate = rxrpc_alloc_connection(GFP_NOIO);
388 389 390 391 392
	if (!candidate) {
		_leave(" = -ENOMEM");
		return ERR_PTR(-ENOMEM);
	}

393
	candidate->proto.local		= local;
394 395 396
	candidate->proto.epoch		= sp->hdr.epoch;
	candidate->proto.cid		= sp->hdr.cid & RXRPC_CIDMASK;
	candidate->proto.in_clientflag	= RXRPC_CLIENT_INITIATED;
397 398
	candidate->params.local		= local;
	candidate->params.peer		= peer;
399 400 401
	candidate->params.service_id	= sp->hdr.serviceId;
	candidate->security_ix		= sp->hdr.securityIndex;
	candidate->out_clientflag	= 0;
402
	candidate->state		= RXRPC_CONN_SERVICE;
403
	if (candidate->params.service_id)
404
		candidate->state	= RXRPC_CONN_SERVICE_UNSECURED;
405

406
	write_lock_bh(&peer->conn_lock);
407

408
	pp = &peer->service_conns.rb_node;
409 410 411
	p = NULL;
	while (*pp) {
		p = *pp;
412
		conn = rb_entry(p, struct rxrpc_connection, service_node);
413

414
		if (epoch < conn->proto.epoch)
415
			pp = &(*pp)->rb_left;
416
		else if (epoch > conn->proto.epoch)
417
			pp = &(*pp)->rb_right;
418
		else if (cid < conn->proto.cid)
419
			pp = &(*pp)->rb_left;
420
		else if (cid > conn->proto.cid)
421 422 423 424 425 426 427 428
			pp = &(*pp)->rb_right;
		else
			goto found_extant_second;
	}

	/* we can now add the new candidate to the list */
	conn = candidate;
	candidate = NULL;
429
	rb_link_node(&conn->service_node, p, pp);
430 431 432
	rb_insert_color(&conn->service_node, &peer->service_conns);
	rxrpc_get_peer(peer);
	rxrpc_get_local(local);
433

434
	write_unlock_bh(&peer->conn_lock);
435

436
	write_lock(&rxrpc_connection_lock);
437
	list_add_tail(&conn->link, &rxrpc_connections);
438
	write_unlock(&rxrpc_connection_lock);
439 440 441 442

	new = "new";

success:
443
	_net("CONNECTION %s %d {%x}", new, conn->debug_id, conn->proto.cid);
444 445 446 447 448 449

	_leave(" = %p {u=%d}", conn, atomic_read(&conn->usage));
	return conn;

	/* we found the connection in the list immediately */
found_extant_connection:
450
	if (sp->hdr.securityIndex != conn->security_ix) {
451
		read_unlock_bh(&peer->conn_lock);
452 453
		goto security_mismatch;
	}
454
	rxrpc_get_connection(conn);
455
	read_unlock_bh(&peer->conn_lock);
456 457 458 459
	goto success;

	/* we found the connection on the second time through the list */
found_extant_second:
460
	if (sp->hdr.securityIndex != conn->security_ix) {
461
		write_unlock_bh(&peer->conn_lock);
462 463
		goto security_mismatch;
	}
464
	rxrpc_get_connection(conn);
465
	write_unlock_bh(&peer->conn_lock);
466 467 468 469 470 471 472 473 474 475 476 477 478
	kfree(candidate);
	goto success;

security_mismatch:
	kfree(candidate);
	_leave(" = -EKEYREJECTED");
	return ERR_PTR(-EKEYREJECTED);
}

/*
 * find a connection based on transport and RxRPC connection ID for an incoming
 * packet
 */
479 480
struct rxrpc_connection *rxrpc_find_connection(struct rxrpc_local *local,
					       struct rxrpc_peer *peer,
481
					       struct sk_buff *skb)
482 483
{
	struct rxrpc_connection *conn;
484
	struct rxrpc_skb_priv *sp = rxrpc_skb(skb);
485
	struct rb_node *p;
486
	u32 epoch, cid;
487

488
	_enter(",{%x,%x}", sp->hdr.cid, sp->hdr.flags);
489

490
	read_lock_bh(&peer->conn_lock);
491

492 493
	cid	= sp->hdr.cid & RXRPC_CIDMASK;
	epoch	= sp->hdr.epoch;
494

495
	if (sp->hdr.flags & RXRPC_CLIENT_INITIATED) {
496
		p = peer->service_conns.rb_node;
497
		while (p) {
498
			conn = rb_entry(p, struct rxrpc_connection, service_node);
499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514

			_debug("maybe %x", conn->proto.cid);

			if (epoch < conn->proto.epoch)
				p = p->rb_left;
			else if (epoch > conn->proto.epoch)
				p = p->rb_right;
			else if (cid < conn->proto.cid)
				p = p->rb_left;
			else if (cid > conn->proto.cid)
				p = p->rb_right;
			else
				goto found;
		}
	} else {
		conn = idr_find(&rxrpc_client_conn_ids, cid >> RXRPC_CIDSHIFT);
515 516 517
		if (conn &&
		    conn->proto.epoch == epoch &&
		    conn->params.peer == peer)
518 519 520
			goto found;
	}

521
	read_unlock_bh(&peer->conn_lock);
522 523 524 525
	_leave(" = NULL");
	return NULL;

found:
526
	rxrpc_get_connection(conn);
527
	read_unlock_bh(&peer->conn_lock);
528 529 530 531
	_leave(" = %p", conn);
	return conn;
}

532 533 534 535 536 537 538 539 540 541 542
/*
 * Disconnect a call and clear any channel it occupies when that call
 * terminates.
 */
void rxrpc_disconnect_call(struct rxrpc_call *call)
{
	struct rxrpc_connection *conn = call->conn;
	unsigned chan = call->channel;

	_enter("%d,%d", conn->debug_id, call->channel);

543 544
	spin_lock(&conn->channel_lock);

545 546 547 548 549
	if (conn->channels[chan] == call) {
		rcu_assign_pointer(conn->channels[chan], NULL);
		atomic_inc(&conn->avail_chans);
		wake_up(&conn->channel_wq);
	}
550 551 552 553 554 555

	spin_unlock(&conn->channel_lock);

	call->conn = NULL;
	rxrpc_put_connection(conn);
	_leave("");
556 557
}

558 559 560 561 562
/*
 * release a virtual connection
 */
void rxrpc_put_connection(struct rxrpc_connection *conn)
{
563 564 565
	if (!conn)
		return;

566 567 568 569 570
	_enter("%p{u=%d,d=%d}",
	       conn, atomic_read(&conn->usage), conn->debug_id);

	ASSERTCMP(atomic_read(&conn->usage), >, 0);

571
	conn->put_time = ktime_get_seconds();
572 573
	if (atomic_dec_and_test(&conn->usage)) {
		_debug("zombie");
574
		rxrpc_queue_delayed_work(&rxrpc_connection_reap, 0);
575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593
	}

	_leave("");
}

/*
 * destroy a virtual connection
 */
static void rxrpc_destroy_connection(struct rxrpc_connection *conn)
{
	_enter("%p{%d}", conn, atomic_read(&conn->usage));

	ASSERTCMP(atomic_read(&conn->usage), ==, 0);

	_net("DESTROY CONN %d", conn->debug_id);

	ASSERT(RB_EMPTY_ROOT(&conn->calls));
	rxrpc_purge_queue(&conn->rx_queue);

594
	conn->security->clear(conn);
595
	key_put(conn->params.key);
596
	key_put(conn->server_key);
597 598
	rxrpc_put_peer(conn->params.peer);
	rxrpc_put_local(conn->params.local);
599

600 601 602 603 604 605 606
	kfree(conn);
	_leave("");
}

/*
 * reap dead connections
 */
R
Roel Kluin 已提交
607
static void rxrpc_connection_reaper(struct work_struct *work)
608 609
{
	struct rxrpc_connection *conn, *_p;
610
	struct rxrpc_peer *peer;
611 612 613 614 615 616
	unsigned long now, earliest, reap_time;

	LIST_HEAD(graveyard);

	_enter("");

617
	now = ktime_get_seconds();
618 619
	earliest = ULONG_MAX;

620
	write_lock(&rxrpc_connection_lock);
621 622 623 624 625 626 627 628
	list_for_each_entry_safe(conn, _p, &rxrpc_connections, link) {
		_debug("reap CONN %d { u=%d,t=%ld }",
		       conn->debug_id, atomic_read(&conn->usage),
		       (long) now - (long) conn->put_time);

		if (likely(atomic_read(&conn->usage) > 0))
			continue;

629 630 631 632
		if (rxrpc_conn_is_client(conn)) {
			struct rxrpc_local *local = conn->params.local;
			spin_lock(&local->client_conns_lock);
			reap_time = conn->put_time + rxrpc_connection_expiry;
633

634 635 636 637
			if (atomic_read(&conn->usage) > 0) {
				;
			} else if (reap_time <= now) {
				list_move_tail(&conn->link, &graveyard);
638
				rxrpc_put_client_connection_id(conn);
639 640 641 642 643 644 645 646
				rb_erase(&conn->client_node,
					 &local->client_conns);
			} else if (reap_time < earliest) {
				earliest = reap_time;
			}

			spin_unlock(&local->client_conns_lock);
		} else {
647 648
			peer = conn->params.peer;
			write_lock_bh(&peer->conn_lock);
649 650 651 652 653 654 655
			reap_time = conn->put_time + rxrpc_connection_expiry;

			if (atomic_read(&conn->usage) > 0) {
				;
			} else if (reap_time <= now) {
				list_move_tail(&conn->link, &graveyard);
				rb_erase(&conn->service_node,
656
					 &peer->service_conns);
657 658
			} else if (reap_time < earliest) {
				earliest = reap_time;
659 660
			}

661
			write_unlock_bh(&peer->conn_lock);
662 663
		}
	}
664
	write_unlock(&rxrpc_connection_lock);
665 666 667 668

	if (earliest != ULONG_MAX) {
		_debug("reschedule reaper %ld", (long) earliest - now);
		ASSERTCMP(earliest, >, now);
669 670
		rxrpc_queue_delayed_work(&rxrpc_connection_reap,
					 (earliest - now) * HZ);
671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693
	}

	/* then destroy all those pulled out */
	while (!list_empty(&graveyard)) {
		conn = list_entry(graveyard.next, struct rxrpc_connection,
				  link);
		list_del_init(&conn->link);

		ASSERTCMP(atomic_read(&conn->usage), ==, 0);
		rxrpc_destroy_connection(conn);
	}

	_leave("");
}

/*
 * preemptively destroy all the connection records rather than waiting for them
 * to time out
 */
void __exit rxrpc_destroy_all_connections(void)
{
	_enter("");

694
	rxrpc_connection_expiry = 0;
695
	cancel_delayed_work(&rxrpc_connection_reap);
696
	rxrpc_queue_delayed_work(&rxrpc_connection_reap, 0);
697 698 699

	_leave("");
}