Skip to content
Navigation Menu
Toggle navigation
Sign in
In this repository
All GitHub Enterprise
↵
Jump to
↵
No suggested jump to results
In this repository
All GitHub Enterprise
↵
Jump to
↵
In this organization
All GitHub Enterprise
↵
Jump to
↵
In this repository
All GitHub Enterprise
↵
Jump to
↵
Sign in
Reseting focus
You signed in with another tab or window.
Reload
to refresh your session.
You signed out in another tab or window.
Reload
to refresh your session.
You switched accounts on another tab or window.
Reload
to refresh your session.
Dismiss alert
{{ message }}
mariux64
/
linux
Public
Notifications
You must be signed in to change notification settings
Fork
0
Star
0
Code
Issues
2
Pull requests
0
Actions
Projects
0
Wiki
Security
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Projects
Wiki
Security
Insights
Files
02a1935
Documentation
LICENSES
arch
block
certs
crypto
drivers
fs
include
init
io_uring
ipc
kernel
lib
mm
net
6lowpan
802
8021q
9p
appletalk
atm
ax25
batman-adv
bluetooth
bpf
bpfilter
bridge
caif
can
ceph
core
dcb
dccp
dns_resolver
dsa
ethernet
ethtool
hsr
ieee802154
ife
ipv4
ipv6
iucv
kcm
key
l2tp
l3mdev
lapb
llc
mac80211
mac802154
mctp
mpls
mptcp
ncsi
netfilter
netlabel
netlink
netrom
nfc
nsh
openvswitch
packet
phonet
psample
qrtr
rds
rfkill
rose
rxrpc
Kconfig
Makefile
af_rxrpc.c
ar-internal.h
call_accept.c
call_event.c
call_object.c
conn_client.c
conn_event.c
conn_object.c
conn_service.c
input.c
insecure.c
key.c
local_event.c
local_object.c
misc.c
net_ns.c
output.c
peer_event.c
peer_object.c
proc.c
protocol.h
recvmsg.c
rtt.c
rxkad.c
security.c
sendmsg.c
server_key.c
skbuff.c
sysctl.c
txbuf.c
utils.c
sched
sctp
smc
strparser
sunrpc
switchdev
tipc
tls
unix
vmw_vsock
wireless
x25
xdp
xfrm
Kconfig
Kconfig.debug
Makefile
compat.c
devres.c
socket.c
sysctl_net.c
rust
samples
scripts
security
sound
tools
usr
virt
.clang-format
.cocciconfig
.get_maintainer.ignore
.gitattributes
.gitignore
.mailmap
.rustfmt.toml
COPYING
CREDITS
Kbuild
Kconfig
MAINTAINERS
Makefile
README
Breadcrumbs
linux
/
net
/
rxrpc
/
proc.c
Blame
Blame
Latest commit
History
History
495 lines (421 loc) · 13.2 KB
Breadcrumbs
linux
/
net
/
rxrpc
/
proc.c
Top
File metadata and controls
Code
Blame
495 lines (421 loc) · 13.2 KB
Raw
// SPDX-License-Identifier: GPL-2.0-or-later /* /proc/net/ support for AF_RXRPC * * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved. * Written by David Howells (dhowells@redhat.com) */ #include <linux/module.h> #include <net/sock.h> #include <net/af_rxrpc.h> #include "ar-internal.h" static const char *const rxrpc_conn_states[RXRPC_CONN__NR_STATES] = { [RXRPC_CONN_UNUSED] = "Unused ", [RXRPC_CONN_CLIENT] = "Client ", [RXRPC_CONN_SERVICE_PREALLOC] = "SvPrealc", [RXRPC_CONN_SERVICE_UNSECURED] = "SvUnsec ", [RXRPC_CONN_SERVICE_CHALLENGING] = "SvChall ", [RXRPC_CONN_SERVICE] = "SvSecure", [RXRPC_CONN_REMOTELY_ABORTED] = "RmtAbort", [RXRPC_CONN_LOCALLY_ABORTED] = "LocAbort", }; /* * generate a list of extant and dead calls in /proc/net/rxrpc_calls */ static void *rxrpc_call_seq_start(struct seq_file *seq, loff_t *_pos) __acquires(rcu) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); rcu_read_lock(); return seq_list_start_head_rcu(&rxnet->calls, *_pos); } static void *rxrpc_call_seq_next(struct seq_file *seq, void *v, loff_t *pos) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); return seq_list_next_rcu(v, &rxnet->calls, pos); } static void rxrpc_call_seq_stop(struct seq_file *seq, void *v) __releases(rcu) { rcu_read_unlock(); } static int rxrpc_call_seq_show(struct seq_file *seq, void *v) { struct rxrpc_local *local; struct rxrpc_sock *rx; struct rxrpc_peer *peer; struct rxrpc_call *call; struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); unsigned long timeout = 0; rxrpc_seq_t tx_hard_ack, rx_hard_ack; char lbuff[50], rbuff[50]; if (v == &rxnet->calls) { seq_puts(seq, "Proto Local " " Remote " " SvID ConnID CallID End Use State Abort " " DebugId TxSeq TW RxSeq RW RxSerial RxTimo\n"); return 0; } call = list_entry(v, struct rxrpc_call, link); rx = rcu_dereference(call->socket); if (rx) { local = READ_ONCE(rx->local); if (local) sprintf(lbuff, "%pISpc", &local->srx.transport); else strcpy(lbuff, "no_local"); } else { strcpy(lbuff, "no_socket"); } peer = call->peer; if (peer) sprintf(rbuff, "%pISpc", &peer->srx.transport); else strcpy(rbuff, "no_connection"); if (call->state != RXRPC_CALL_SERVER_PREALLOC) { timeout = READ_ONCE(call->expect_rx_by); timeout -= jiffies; } tx_hard_ack = READ_ONCE(call->tx_hard_ack); rx_hard_ack = READ_ONCE(call->rx_hard_ack); seq_printf(seq, "UDP %-47.47s %-47.47s %4x %08x %08x %s %3u" " %-8.8s %08x %08x %08x %02x %08x %02x %08x %06lx\n", lbuff, rbuff, call->service_id, call->cid, call->call_id, rxrpc_is_service_call(call) ? "Svc" : "Clt", refcount_read(&call->ref), rxrpc_call_states[call->state], call->abort_code, call->debug_id, tx_hard_ack, READ_ONCE(call->tx_top) - tx_hard_ack, rx_hard_ack, READ_ONCE(call->rx_top) - rx_hard_ack, call->rx_serial, timeout); return 0; } const struct seq_operations rxrpc_call_seq_ops = { .start = rxrpc_call_seq_start, .next = rxrpc_call_seq_next, .stop = rxrpc_call_seq_stop, .show = rxrpc_call_seq_show, }; /* * generate a list of extant virtual connections in /proc/net/rxrpc_conns */ static void *rxrpc_connection_seq_start(struct seq_file *seq, loff_t *_pos) __acquires(rxnet->conn_lock) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); read_lock(&rxnet->conn_lock); return seq_list_start_head(&rxnet->conn_proc_list, *_pos); } static void *rxrpc_connection_seq_next(struct seq_file *seq, void *v, loff_t *pos) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); return seq_list_next(v, &rxnet->conn_proc_list, pos); } static void rxrpc_connection_seq_stop(struct seq_file *seq, void *v) __releases(rxnet->conn_lock) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); read_unlock(&rxnet->conn_lock); } static int rxrpc_connection_seq_show(struct seq_file *seq, void *v) { struct rxrpc_connection *conn; struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); char lbuff[50], rbuff[50]; if (v == &rxnet->conn_proc_list) { seq_puts(seq, "Proto Local " " Remote " " SvID ConnID End Use State Key " " Serial ISerial CallId0 CallId1 CallId2 CallId3\n" ); return 0; } conn = list_entry(v, struct rxrpc_connection, proc_link); if (conn->state == RXRPC_CONN_SERVICE_PREALLOC) { strcpy(lbuff, "no_local"); strcpy(rbuff, "no_connection"); goto print; } sprintf(lbuff, "%pISpc", &conn->params.local->srx.transport); sprintf(rbuff, "%pISpc", &conn->params.peer->srx.transport); print: seq_printf(seq, "UDP %-47.47s %-47.47s %4x %08x %s %3u" " %s %08x %08x %08x %08x %08x %08x %08x\n", lbuff, rbuff, conn->service_id, conn->proto.cid, rxrpc_conn_is_service(conn) ? "Svc" : "Clt", refcount_read(&conn->ref), rxrpc_conn_states[conn->state], key_serial(conn->params.key), atomic_read(&conn->serial), conn->hi_serial, conn->channels[0].call_id, conn->channels[1].call_id, conn->channels[2].call_id, conn->channels[3].call_id); return 0; } const struct seq_operations rxrpc_connection_seq_ops = { .start = rxrpc_connection_seq_start, .next = rxrpc_connection_seq_next, .stop = rxrpc_connection_seq_stop, .show = rxrpc_connection_seq_show, }; /* * generate a list of extant virtual peers in /proc/net/rxrpc/peers */ static int rxrpc_peer_seq_show(struct seq_file *seq, void *v) { struct rxrpc_peer *peer; time64_t now; char lbuff[50], rbuff[50]; if (v == SEQ_START_TOKEN) { seq_puts(seq, "Proto Local " " Remote " " Use CW MTU LastUse RTT RTO\n" ); return 0; } peer = list_entry(v, struct rxrpc_peer, hash_link); sprintf(lbuff, "%pISpc", &peer->local->srx.transport); sprintf(rbuff, "%pISpc", &peer->srx.transport); now = ktime_get_seconds(); seq_printf(seq, "UDP %-47.47s %-47.47s %3u" " %3u %5u %6llus %8u %8u\n", lbuff, rbuff, refcount_read(&peer->ref), peer->cong_cwnd, peer->mtu, now - peer->last_tx_at, peer->srtt_us >> 3, jiffies_to_usecs(peer->rto_j)); return 0; } static void *rxrpc_peer_seq_start(struct seq_file *seq, loff_t *_pos) __acquires(rcu) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); unsigned int bucket, n; unsigned int shift = 32 - HASH_BITS(rxnet->peer_hash); void *p; rcu_read_lock(); if (*_pos >= UINT_MAX) return NULL; n = *_pos & ((1U << shift) - 1); bucket = *_pos >> shift; for (;;) { if (bucket >= HASH_SIZE(rxnet->peer_hash)) { *_pos = UINT_MAX; return NULL; } if (n == 0) { if (bucket == 0) return SEQ_START_TOKEN; *_pos += 1; n++; } p = seq_hlist_start_rcu(&rxnet->peer_hash[bucket], n - 1); if (p) return p; bucket++; n = 1; *_pos = (bucket << shift) | n; } } static void *rxrpc_peer_seq_next(struct seq_file *seq, void *v, loff_t *_pos) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); unsigned int bucket, n; unsigned int shift = 32 - HASH_BITS(rxnet->peer_hash); void *p; if (*_pos >= UINT_MAX) return NULL; bucket = *_pos >> shift; p = seq_hlist_next_rcu(v, &rxnet->peer_hash[bucket], _pos); if (p) return p; for (;;) { bucket++; n = 1; *_pos = (bucket << shift) | n; if (bucket >= HASH_SIZE(rxnet->peer_hash)) { *_pos = UINT_MAX; return NULL; } if (n == 0) { *_pos += 1; n++; } p = seq_hlist_start_rcu(&rxnet->peer_hash[bucket], n - 1); if (p) return p; } } static void rxrpc_peer_seq_stop(struct seq_file *seq, void *v) __releases(rcu) { rcu_read_unlock(); } const struct seq_operations rxrpc_peer_seq_ops = { .start = rxrpc_peer_seq_start, .next = rxrpc_peer_seq_next, .stop = rxrpc_peer_seq_stop, .show = rxrpc_peer_seq_show, }; /* * Generate a list of extant virtual local endpoints in /proc/net/rxrpc/locals */ static int rxrpc_local_seq_show(struct seq_file *seq, void *v) { struct rxrpc_local *local; char lbuff[50]; if (v == SEQ_START_TOKEN) { seq_puts(seq, "Proto Local " " Use Act\n"); return 0; } local = hlist_entry(v, struct rxrpc_local, link); sprintf(lbuff, "%pISpc", &local->srx.transport); seq_printf(seq, "UDP %-47.47s %3u %3u\n", lbuff, refcount_read(&local->ref), atomic_read(&local->active_users)); return 0; } static void *rxrpc_local_seq_start(struct seq_file *seq, loff_t *_pos) __acquires(rcu) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); unsigned int n; rcu_read_lock(); if (*_pos >= UINT_MAX) return NULL; n = *_pos; if (n == 0) return SEQ_START_TOKEN; return seq_hlist_start_rcu(&rxnet->local_endpoints, n - 1); } static void *rxrpc_local_seq_next(struct seq_file *seq, void *v, loff_t *_pos) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); if (*_pos >= UINT_MAX) return NULL; return seq_hlist_next_rcu(v, &rxnet->local_endpoints, _pos); } static void rxrpc_local_seq_stop(struct seq_file *seq, void *v) __releases(rcu) { rcu_read_unlock(); } const struct seq_operations rxrpc_local_seq_ops = { .start = rxrpc_local_seq_start, .next = rxrpc_local_seq_next, .stop = rxrpc_local_seq_stop, .show = rxrpc_local_seq_show, }; /* * Display stats in /proc/net/rxrpc/stats */ int rxrpc_stats_show(struct seq_file *seq, void *v) { struct rxrpc_net *rxnet = rxrpc_net(seq_file_single_net(seq)); seq_printf(seq, "Data : send=%u sendf=%u\n", atomic_read(&rxnet->stat_tx_data_send), atomic_read(&rxnet->stat_tx_data_send_frag)); seq_printf(seq, "Data-Tx : nr=%u retrans=%u\n", atomic_read(&rxnet->stat_tx_data), atomic_read(&rxnet->stat_tx_data_retrans)); seq_printf(seq, "Data-Rx : nr=%u reqack=%u jumbo=%u\n", atomic_read(&rxnet->stat_rx_data), atomic_read(&rxnet->stat_rx_data_reqack), atomic_read(&rxnet->stat_rx_data_jumbo)); seq_printf(seq, "Ack : fill=%u send=%u skip=%u\n", atomic_read(&rxnet->stat_tx_ack_fill), atomic_read(&rxnet->stat_tx_ack_send), atomic_read(&rxnet->stat_tx_ack_skip)); seq_printf(seq, "Ack-Tx : req=%u dup=%u oos=%u exw=%u nos=%u png=%u prs=%u dly=%u idl=%u\n", atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_REQUESTED]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_DUPLICATE]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_OUT_OF_SEQUENCE]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_EXCEEDS_WINDOW]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_NOSPACE]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_PING]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_PING_RESPONSE]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_DELAY]), atomic_read(&rxnet->stat_tx_acks[RXRPC_ACK_IDLE])); seq_printf(seq, "Ack-Rx : req=%u dup=%u oos=%u exw=%u nos=%u png=%u prs=%u dly=%u idl=%u\n", atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_REQUESTED]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_DUPLICATE]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_OUT_OF_SEQUENCE]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_EXCEEDS_WINDOW]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_NOSPACE]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_PING]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_PING_RESPONSE]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_DELAY]), atomic_read(&rxnet->stat_rx_acks[RXRPC_ACK_IDLE])); seq_printf(seq, "Why-Req-A: acklost=%u already=%u mrtt=%u ortt=%u\n", atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_ack_lost]), atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_already_on]), atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_more_rtt]), atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_old_rtt])); seq_printf(seq, "Why-Req-A: nolast=%u retx=%u slows=%u smtxw=%u\n", atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_no_srv_last]), atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_retrans]), atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_slow_start]), atomic_read(&rxnet->stat_why_req_ack[rxrpc_reqack_small_txwin])); seq_printf(seq, "Buffers : txb=%u,%u rxb=%u\n", atomic_read(&rxrpc_nr_txbuf), atomic_read(&rxrpc_n_tx_skbs), atomic_read(&rxrpc_n_rx_skbs)); return 0; } /* * Clear stats if /proc/net/rxrpc/stats is written to. */ int rxrpc_stats_clear(struct file *file, char *buf, size_t size) { struct seq_file *m = file->private_data; struct rxrpc_net *rxnet = rxrpc_net(seq_file_single_net(m)); if (size > 1 || (size == 1 && buf[0] != '\n')) return -EINVAL; atomic_set(&rxnet->stat_tx_data, 0); atomic_set(&rxnet->stat_tx_data_retrans, 0); atomic_set(&rxnet->stat_tx_data_send, 0); atomic_set(&rxnet->stat_tx_data_send_frag, 0); atomic_set(&rxnet->stat_rx_data, 0); atomic_set(&rxnet->stat_rx_data_reqack, 0); atomic_set(&rxnet->stat_rx_data_jumbo, 0); atomic_set(&rxnet->stat_tx_ack_fill, 0); atomic_set(&rxnet->stat_tx_ack_send, 0); atomic_set(&rxnet->stat_tx_ack_skip, 0); memset(&rxnet->stat_tx_acks, 0, sizeof(rxnet->stat_tx_acks)); memset(&rxnet->stat_rx_acks, 0, sizeof(rxnet->stat_rx_acks)); memset(&rxnet->stat_why_req_ack, 0, sizeof(rxnet->stat_why_req_ack)); return size; }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
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
99
100
101
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
You can’t perform that action at this time.