sctp: merge the seq_start/next/exits in remaddrs and assocs
[deliverable/linux.git] / net / sctp / proc.c
CommitLineData
60c778b2 1/* SCTP kernel implementation
1da177e4
LT
2 * Copyright (c) 2003 International Business Machines, Corp.
3 *
60c778b2 4 * This file is part of the SCTP kernel implementation
1da177e4 5 *
60c778b2 6 * This SCTP implementation is free software;
1da177e4
LT
7 * you can redistribute it and/or modify it under the terms of
8 * the GNU General Public License as published by
9 * the Free Software Foundation; either version 2, or (at your option)
10 * any later version.
11 *
60c778b2 12 * This SCTP implementation is distributed in the hope that it
1da177e4
LT
13 * will be useful, but WITHOUT ANY WARRANTY; without even the implied
14 * ************************
15 * warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
16 * See the GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License
4b2f13a2
JK
19 * along with GNU CC; see the file COPYING. If not, see
20 * <http://www.gnu.org/licenses/>.
1da177e4
LT
21 *
22 * Please send any bug reports or fixes you make to the
23 * email address(es):
91705c61 24 * lksctp developers <linux-sctp@vger.kernel.org>
1da177e4 25 *
1da177e4
LT
26 * Written or modified by:
27 * Sridhar Samudrala <sri@us.ibm.com>
1da177e4
LT
28 */
29
30#include <linux/types.h>
31#include <linux/seq_file.h>
32#include <linux/init.h>
bc3b2d7f 33#include <linux/export.h>
1da177e4 34#include <net/sctp/sctp.h>
3f5340a6 35#include <net/ip.h> /* for snmp_fold_field */
1da177e4 36
5833929c 37static const struct snmp_mib sctp_snmp_list[] = {
1da177e4
LT
38 SNMP_MIB_ITEM("SctpCurrEstab", SCTP_MIB_CURRESTAB),
39 SNMP_MIB_ITEM("SctpActiveEstabs", SCTP_MIB_ACTIVEESTABS),
40 SNMP_MIB_ITEM("SctpPassiveEstabs", SCTP_MIB_PASSIVEESTABS),
41 SNMP_MIB_ITEM("SctpAborteds", SCTP_MIB_ABORTEDS),
42 SNMP_MIB_ITEM("SctpShutdowns", SCTP_MIB_SHUTDOWNS),
43 SNMP_MIB_ITEM("SctpOutOfBlues", SCTP_MIB_OUTOFBLUES),
44 SNMP_MIB_ITEM("SctpChecksumErrors", SCTP_MIB_CHECKSUMERRORS),
45 SNMP_MIB_ITEM("SctpOutCtrlChunks", SCTP_MIB_OUTCTRLCHUNKS),
46 SNMP_MIB_ITEM("SctpOutOrderChunks", SCTP_MIB_OUTORDERCHUNKS),
47 SNMP_MIB_ITEM("SctpOutUnorderChunks", SCTP_MIB_OUTUNORDERCHUNKS),
48 SNMP_MIB_ITEM("SctpInCtrlChunks", SCTP_MIB_INCTRLCHUNKS),
49 SNMP_MIB_ITEM("SctpInOrderChunks", SCTP_MIB_INORDERCHUNKS),
50 SNMP_MIB_ITEM("SctpInUnorderChunks", SCTP_MIB_INUNORDERCHUNKS),
51 SNMP_MIB_ITEM("SctpFragUsrMsgs", SCTP_MIB_FRAGUSRMSGS),
52 SNMP_MIB_ITEM("SctpReasmUsrMsgs", SCTP_MIB_REASMUSRMSGS),
53 SNMP_MIB_ITEM("SctpOutSCTPPacks", SCTP_MIB_OUTSCTPPACKS),
54 SNMP_MIB_ITEM("SctpInSCTPPacks", SCTP_MIB_INSCTPPACKS),
ac0b0462
SS
55 SNMP_MIB_ITEM("SctpT1InitExpireds", SCTP_MIB_T1_INIT_EXPIREDS),
56 SNMP_MIB_ITEM("SctpT1CookieExpireds", SCTP_MIB_T1_COOKIE_EXPIREDS),
57 SNMP_MIB_ITEM("SctpT2ShutdownExpireds", SCTP_MIB_T2_SHUTDOWN_EXPIREDS),
58 SNMP_MIB_ITEM("SctpT3RtxExpireds", SCTP_MIB_T3_RTX_EXPIREDS),
59 SNMP_MIB_ITEM("SctpT4RtoExpireds", SCTP_MIB_T4_RTO_EXPIREDS),
60 SNMP_MIB_ITEM("SctpT5ShutdownGuardExpireds", SCTP_MIB_T5_SHUTDOWN_GUARD_EXPIREDS),
61 SNMP_MIB_ITEM("SctpDelaySackExpireds", SCTP_MIB_DELAY_SACK_EXPIREDS),
62 SNMP_MIB_ITEM("SctpAutocloseExpireds", SCTP_MIB_AUTOCLOSE_EXPIREDS),
63 SNMP_MIB_ITEM("SctpT3Retransmits", SCTP_MIB_T3_RETRANSMITS),
64 SNMP_MIB_ITEM("SctpPmtudRetransmits", SCTP_MIB_PMTUD_RETRANSMITS),
65 SNMP_MIB_ITEM("SctpFastRetransmits", SCTP_MIB_FAST_RETRANSMITS),
66 SNMP_MIB_ITEM("SctpInPktSoftirq", SCTP_MIB_IN_PKT_SOFTIRQ),
67 SNMP_MIB_ITEM("SctpInPktBacklog", SCTP_MIB_IN_PKT_BACKLOG),
68 SNMP_MIB_ITEM("SctpInPktDiscards", SCTP_MIB_IN_PKT_DISCARDS),
69 SNMP_MIB_ITEM("SctpInDataChunkDiscards", SCTP_MIB_IN_DATA_CHUNK_DISCARDS),
d2287f84 70 SNMP_MIB_SENTINEL
1da177e4
LT
71};
72
1da177e4
LT
73/* Display sctp snmp mib statistics(/proc/net/sctp/snmp). */
74static int sctp_snmp_seq_show(struct seq_file *seq, void *v)
75{
13d782f6 76 struct net *net = seq->private;
1da177e4
LT
77 int i;
78
79 for (i = 0; sctp_snmp_list[i].name != NULL; i++)
80 seq_printf(seq, "%-32s\t%ld\n", sctp_snmp_list[i].name,
c9f2dba6 81 snmp_fold_field(net->sctp.sctp_statistics,
1da177e4
LT
82 sctp_snmp_list[i].entry));
83
84 return 0;
85}
86
87/* Initialize the seq file operations for 'snmp' object. */
88static int sctp_snmp_seq_open(struct inode *inode, struct file *file)
89{
13d782f6 90 return single_open_net(inode, file, sctp_snmp_seq_show);
1da177e4
LT
91}
92
da7071d7 93static const struct file_operations sctp_snmp_seq_fops = {
1da177e4
LT
94 .owner = THIS_MODULE,
95 .open = sctp_snmp_seq_open,
96 .read = seq_read,
97 .llseek = seq_lseek,
0da9a0c2 98 .release = single_release_net,
1da177e4
LT
99};
100
101/* Set up the proc fs entry for 'snmp' object. */
13d782f6 102int __net_init sctp_snmp_proc_init(struct net *net)
1da177e4
LT
103{
104 struct proc_dir_entry *p;
105
13d782f6
EB
106 p = proc_create("snmp", S_IRUGO, net->sctp.proc_net_sctp,
107 &sctp_snmp_seq_fops);
1da177e4
LT
108 if (!p)
109 return -ENOMEM;
110
1da177e4
LT
111 return 0;
112}
113
114/* Cleanup the proc fs entry for 'snmp' object. */
13d782f6 115void sctp_snmp_proc_exit(struct net *net)
1da177e4 116{
13d782f6 117 remove_proc_entry("snmp", net->sctp.proc_net_sctp);
1da177e4
LT
118}
119
120/* Dump local addresses of an association/endpoint. */
121static void sctp_seq_dump_local_addrs(struct seq_file *seq, struct sctp_ep_common *epb)
122{
bca735bd 123 struct sctp_association *asoc;
1da177e4 124 struct sctp_sockaddr_entry *laddr;
bca735bd
VY
125 struct sctp_transport *peer;
126 union sctp_addr *addr, *primary = NULL;
1da177e4
LT
127 struct sctp_af *af;
128
bca735bd 129 if (epb->type == SCTP_EP_TYPE_ASSOCIATION) {
f9e42b85
DB
130 asoc = sctp_assoc(epb);
131
132 peer = asoc->peer.primary_path;
133 if (unlikely(peer == NULL)) {
b527fe69 134 WARN(1, "Association %p with NULL primary path!\n", asoc);
f9e42b85
DB
135 return;
136 }
137
138 primary = &peer->saddr;
bca735bd
VY
139 }
140
0b0fe913
TG
141 rcu_read_lock();
142 list_for_each_entry_rcu(laddr, &epb->bind_addr.address_list, list) {
143 if (!laddr->valid)
144 continue;
145
5f242a13 146 addr = &laddr->a;
1da177e4 147 af = sctp_get_af_specific(addr->sa.sa_family);
bca735bd
VY
148 if (primary && af->cmp_addr(addr, primary)) {
149 seq_printf(seq, "*");
150 }
5f242a13 151 af->seq_dump_addr(seq, addr);
1da177e4 152 }
0b0fe913 153 rcu_read_unlock();
1da177e4
LT
154}
155
156/* Dump remote addresses of an association. */
157static void sctp_seq_dump_remote_addrs(struct seq_file *seq, struct sctp_association *assoc)
158{
1da177e4 159 struct sctp_transport *transport;
bca735bd 160 union sctp_addr *addr, *primary;
1da177e4
LT
161 struct sctp_af *af;
162
acd2bc96 163 primary = &assoc->peer.primary_addr;
45122ca2 164 list_for_each_entry_rcu(transport, &assoc->peer.transport_addr_list,
9dbc15f0 165 transports) {
5f242a13 166 addr = &transport->ipaddr;
45122ca2 167
1da177e4 168 af = sctp_get_af_specific(addr->sa.sa_family);
acd2bc96 169 if (af->cmp_addr(addr, primary)) {
bca735bd
VY
170 seq_printf(seq, "*");
171 }
5f242a13 172 af->seq_dump_addr(seq, addr);
1da177e4
LT
173 }
174}
175
26ac8e5f 176static void *sctp_eps_seq_start(struct seq_file *seq, loff_t *pos)
bca735bd 177{
49392e5e 178 if (*pos >= sctp_ep_hashsize)
bca735bd
VY
179 return NULL;
180
181 if (*pos < 0)
182 *pos = 0;
183
184 if (*pos == 0)
185 seq_printf(seq, " ENDPT SOCK STY SST HBKT LPORT UID INODE LADDRS\n");
186
bca735bd
VY
187 return (void *)pos;
188}
189
190static void sctp_eps_seq_stop(struct seq_file *seq, void *v)
191{
bca735bd
VY
192}
193
194
26ac8e5f 195static void *sctp_eps_seq_next(struct seq_file *seq, void *v, loff_t *pos)
bca735bd 196{
49392e5e 197 if (++*pos >= sctp_ep_hashsize)
bca735bd
VY
198 return NULL;
199
bca735bd
VY
200 return pos;
201}
202
203
1da177e4
LT
204/* Display sctp endpoints (/proc/net/sctp/eps). */
205static int sctp_eps_seq_show(struct seq_file *seq, void *v)
206{
207 struct sctp_hashbucket *head;
208 struct sctp_ep_common *epb;
209 struct sctp_endpoint *ep;
210 struct sock *sk;
38b0e42a 211 int hash = *(loff_t *)v;
bca735bd 212
49392e5e 213 if (hash >= sctp_ep_hashsize)
bca735bd
VY
214 return -ENOMEM;
215
49392e5e 216 head = &sctp_ep_hashtable[hash];
79b91130 217 local_bh_disable();
bca735bd 218 read_lock(&head->lock);
b67bfe0d 219 sctp_for_each_hentry(epb, &head->chain) {
bca735bd
VY
220 ep = sctp_ep(epb);
221 sk = epb->sk;
6932f119 222 if (!net_eq(sock_net(sk), seq_file_net(seq)))
13d782f6 223 continue;
d14c5ab6 224 seq_printf(seq, "%8pK %8pK %-3d %-3d %-4d %-5d %5u %5lu ", ep, sk,
49392e5e 225 sctp_sk(sk)->type, sk->sk_state, hash,
bca735bd 226 epb->bind_addr.port,
a7cb5a49
EB
227 from_kuid_munged(seq_user_ns(seq), sock_i_uid(sk)),
228 sock_i_ino(sk));
bca735bd
VY
229
230 sctp_seq_dump_local_addrs(seq, epb);
231 seq_printf(seq, "\n");
1da177e4 232 }
bca735bd 233 read_unlock(&head->lock);
79b91130 234 local_bh_enable();
1da177e4
LT
235
236 return 0;
237}
238
56b3d975 239static const struct seq_operations sctp_eps_ops = {
bca735bd
VY
240 .start = sctp_eps_seq_start,
241 .next = sctp_eps_seq_next,
242 .stop = sctp_eps_seq_stop,
243 .show = sctp_eps_seq_show,
244};
245
246
1da177e4
LT
247/* Initialize the seq file operations for 'eps' object. */
248static int sctp_eps_seq_open(struct inode *inode, struct file *file)
249{
13d782f6
EB
250 return seq_open_net(inode, file, &sctp_eps_ops,
251 sizeof(struct seq_net_private));
1da177e4
LT
252}
253
da7071d7 254static const struct file_operations sctp_eps_seq_fops = {
1da177e4
LT
255 .open = sctp_eps_seq_open,
256 .read = seq_read,
257 .llseek = seq_lseek,
0da9a0c2 258 .release = seq_release_net,
1da177e4
LT
259};
260
261/* Set up the proc fs entry for 'eps' object. */
13d782f6 262int __net_init sctp_eps_proc_init(struct net *net)
1da177e4
LT
263{
264 struct proc_dir_entry *p;
265
13d782f6
EB
266 p = proc_create("eps", S_IRUGO, net->sctp.proc_net_sctp,
267 &sctp_eps_seq_fops);
1da177e4
LT
268 if (!p)
269 return -ENOMEM;
270
1da177e4
LT
271 return 0;
272}
273
274/* Cleanup the proc fs entry for 'eps' object. */
13d782f6 275void sctp_eps_proc_exit(struct net *net)
1da177e4 276{
13d782f6 277 remove_proc_entry("eps", net->sctp.proc_net_sctp);
1da177e4
LT
278}
279
39f66a7d
XL
280struct sctp_ht_iter {
281 struct seq_net_private p;
282 struct rhashtable_iter hti;
283};
bca735bd 284
b5e2f4e6 285static void *sctp_transport_seq_start(struct seq_file *seq, loff_t *pos)
39f66a7d 286{
626d16f5
XL
287 struct sctp_ht_iter *iter = seq->private;
288 int err = sctp_transport_walk_start(&iter->hti);
39f66a7d
XL
289
290 if (err)
291 return ERR_PTR(err);
292
626d16f5 293 return sctp_transport_get_idx(seq_file_net(seq), &iter->hti, *pos);
39f66a7d
XL
294}
295
b5e2f4e6 296static void sctp_transport_seq_stop(struct seq_file *seq, void *v)
39f66a7d 297{
626d16f5
XL
298 struct sctp_ht_iter *iter = seq->private;
299
300 sctp_transport_walk_stop(&iter->hti);
39f66a7d 301}
bca735bd 302
b5e2f4e6 303static void *sctp_transport_seq_next(struct seq_file *seq, void *v, loff_t *pos)
bca735bd 304{
626d16f5
XL
305 struct sctp_ht_iter *iter = seq->private;
306
39f66a7d 307 ++*pos;
bca735bd 308
626d16f5 309 return sctp_transport_get_next(seq_file_net(seq), &iter->hti);
bca735bd
VY
310}
311
1da177e4
LT
312/* Display sctp associations (/proc/net/sctp/assocs). */
313static int sctp_assocs_seq_show(struct seq_file *seq, void *v)
314{
39f66a7d 315 struct sctp_transport *transport;
1da177e4 316 struct sctp_association *assoc;
39f66a7d 317 struct sctp_ep_common *epb;
1da177e4 318 struct sock *sk;
bca735bd 319
39f66a7d
XL
320 if (v == SEQ_START_TOKEN) {
321 seq_printf(seq, " ASSOC SOCK STY SST ST HBKT "
322 "ASSOC-ID TX_QUEUE RX_QUEUE UID INODE LPORT "
323 "RPORT LADDRS <-> RADDRS "
324 "HBINT INS OUTS MAXRT T1X T2X RTXC "
325 "wmema wmemq sndbuf rcvbuf\n");
326 return 0;
1da177e4 327 }
39f66a7d
XL
328
329 transport = (struct sctp_transport *)v;
fba4c330
XL
330 if (!sctp_transport_hold(transport))
331 return 0;
39f66a7d
XL
332 assoc = transport->asoc;
333 epb = &assoc->base;
334 sk = epb->sk;
335
336 seq_printf(seq,
337 "%8pK %8pK %-3d %-3d %-2d %-4d "
338 "%4d %8d %8d %7u %5lu %-5d %5d ",
339 assoc, sk, sctp_sk(sk)->type, sk->sk_state,
340 assoc->state, 0,
341 assoc->assoc_id,
342 assoc->sndbuf_used,
343 atomic_read(&assoc->rmem_alloc),
344 from_kuid_munged(seq_user_ns(seq), sock_i_uid(sk)),
345 sock_i_ino(sk),
346 epb->bind_addr.port,
347 assoc->peer.port);
348 seq_printf(seq, " ");
349 sctp_seq_dump_local_addrs(seq, epb);
350 seq_printf(seq, "<-> ");
351 sctp_seq_dump_remote_addrs(seq, assoc);
352 seq_printf(seq, "\t%8lu %5d %5d %4d %4d %4d %8d "
353 "%8d %8d %8d %8d",
354 assoc->hbinterval, assoc->c.sinit_max_instreams,
355 assoc->c.sinit_num_ostreams, assoc->max_retrans,
356 assoc->init_retries, assoc->shutdown_retries,
357 assoc->rtx_data_chunks,
358 atomic_read(&sk->sk_wmem_alloc),
359 sk->sk_wmem_queued,
360 sk->sk_sndbuf,
361 sk->sk_rcvbuf);
362 seq_printf(seq, "\n");
1da177e4 363
fba4c330
XL
364 sctp_transport_put(transport);
365
1da177e4
LT
366 return 0;
367}
368
56b3d975 369static const struct seq_operations sctp_assoc_ops = {
b5e2f4e6
XL
370 .start = sctp_transport_seq_start,
371 .next = sctp_transport_seq_next,
372 .stop = sctp_transport_seq_stop,
bca735bd
VY
373 .show = sctp_assocs_seq_show,
374};
375
1da177e4
LT
376/* Initialize the seq file operations for 'assocs' object. */
377static int sctp_assocs_seq_open(struct inode *inode, struct file *file)
378{
13d782f6 379 return seq_open_net(inode, file, &sctp_assoc_ops,
39f66a7d 380 sizeof(struct sctp_ht_iter));
1da177e4
LT
381}
382
da7071d7 383static const struct file_operations sctp_assocs_seq_fops = {
1da177e4
LT
384 .open = sctp_assocs_seq_open,
385 .read = seq_read,
386 .llseek = seq_lseek,
0da9a0c2 387 .release = seq_release_net,
1da177e4
LT
388};
389
390/* Set up the proc fs entry for 'assocs' object. */
13d782f6 391int __net_init sctp_assocs_proc_init(struct net *net)
1da177e4
LT
392{
393 struct proc_dir_entry *p;
394
13d782f6 395 p = proc_create("assocs", S_IRUGO, net->sctp.proc_net_sctp,
459eea74 396 &sctp_assocs_seq_fops);
1da177e4
LT
397 if (!p)
398 return -ENOMEM;
399
1da177e4
LT
400 return 0;
401}
402
403/* Cleanup the proc fs entry for 'assocs' object. */
13d782f6 404void sctp_assocs_proc_exit(struct net *net)
1da177e4 405{
13d782f6 406 remove_proc_entry("assocs", net->sctp.proc_net_sctp);
1da177e4 407}
20c2c1fd 408
20c2c1fd
NH
409static int sctp_remaddr_seq_show(struct seq_file *seq, void *v)
410{
20c2c1fd 411 struct sctp_association *assoc;
3d73e8fa 412 struct sctp_transport *transport, *tsp;
20c2c1fd 413
39f66a7d
XL
414 if (v == SEQ_START_TOKEN) {
415 seq_printf(seq, "ADDR ASSOC_ID HB_ACT RTO MAX_PATH_RTX "
416 "REM_ADDR_RTX START STATE\n");
417 return 0;
418 }
20c2c1fd 419
3d73e8fa
XL
420 transport = (struct sctp_transport *)v;
421 if (!sctp_transport_hold(transport))
fba4c330 422 return 0;
3d73e8fa 423 assoc = transport->asoc;
39f66a7d
XL
424
425 list_for_each_entry_rcu(tsp, &assoc->peer.transport_addr_list,
426 transports) {
39f66a7d
XL
427 /*
428 * The remote address (ADDR)
429 */
430 tsp->af_specific->seq_dump_addr(seq, &tsp->ipaddr);
431 seq_printf(seq, " ");
432 /*
433 * The association ID (ASSOC_ID)
434 */
435 seq_printf(seq, "%d ", tsp->asoc->assoc_id);
436
437 /*
438 * If the Heartbeat is active (HB_ACT)
439 * Note: 1 = Active, 0 = Inactive
440 */
441 seq_printf(seq, "%d ", timer_pending(&tsp->hb_timer));
442
443 /*
444 * Retransmit time out (RTO)
445 */
446 seq_printf(seq, "%lu ", tsp->rto);
447
448 /*
449 * Maximum path retransmit count (PATH_MAX_RTX)
450 */
451 seq_printf(seq, "%d ", tsp->pathmaxrxt);
452
453 /*
454 * remote address retransmit count (REM_ADDR_RTX)
455 * Note: We don't have a way to tally this at the moment
456 * so lets just leave it as zero for the moment
457 */
458 seq_puts(seq, "0 ");
459
460 /*
461 * remote address start time (START). This is also not
462 * currently implemented, but we can record it with a
463 * jiffies marker in a subsequent patch
464 */
465 seq_puts(seq, "0 ");
466
467 /*
468 * The current state of this destination. I.e.
469 * SCTP_ACTIVE, SCTP_INACTIVE, ...
470 */
471 seq_printf(seq, "%d", tsp->state);
45122ca2 472
39f66a7d 473 seq_printf(seq, "\n");
20c2c1fd
NH
474 }
475
3d73e8fa 476 sctp_transport_put(transport);
fba4c330 477
20c2c1fd 478 return 0;
20c2c1fd
NH
479}
480
481static const struct seq_operations sctp_remaddr_ops = {
b5e2f4e6
XL
482 .start = sctp_transport_seq_start,
483 .next = sctp_transport_seq_next,
484 .stop = sctp_transport_seq_stop,
20c2c1fd
NH
485 .show = sctp_remaddr_seq_show,
486};
487
488/* Cleanup the proc fs entry for 'remaddr' object. */
13d782f6 489void sctp_remaddr_proc_exit(struct net *net)
20c2c1fd 490{
13d782f6 491 remove_proc_entry("remaddr", net->sctp.proc_net_sctp);
20c2c1fd
NH
492}
493
494static int sctp_remaddr_seq_open(struct inode *inode, struct file *file)
495{
13d782f6 496 return seq_open_net(inode, file, &sctp_remaddr_ops,
39f66a7d 497 sizeof(struct sctp_ht_iter));
20c2c1fd
NH
498}
499
500static const struct file_operations sctp_remaddr_seq_fops = {
501 .open = sctp_remaddr_seq_open,
502 .read = seq_read,
503 .llseek = seq_lseek,
0da9a0c2 504 .release = seq_release_net,
20c2c1fd
NH
505};
506
13d782f6 507int __net_init sctp_remaddr_proc_init(struct net *net)
20c2c1fd
NH
508{
509 struct proc_dir_entry *p;
510
13d782f6
EB
511 p = proc_create("remaddr", S_IRUGO, net->sctp.proc_net_sctp,
512 &sctp_remaddr_seq_fops);
20c2c1fd
NH
513 if (!p)
514 return -ENOMEM;
20c2c1fd
NH
515 return 0;
516}
This page took 0.771208 seconds and 5 git commands to generate.