Linux Audio

Check our new training course

Loading...
v4.6
 
  1#include <linux/in.h>
  2#include <linux/inet.h>
  3#include <linux/list.h>
  4#include <linux/module.h>
  5#include <linux/net.h>
  6#include <linux/proc_fs.h>
  7#include <linux/rculist.h>
  8#include <linux/seq_file.h>
  9#include <linux/socket.h>
 10#include <net/inet_sock.h>
 11#include <net/kcm.h>
 12#include <net/net_namespace.h>
 13#include <net/netns/generic.h>
 14#include <net/tcp.h>
 15
 16#ifdef CONFIG_PROC_FS
 17struct kcm_seq_muxinfo {
 18	char				*name;
 19	const struct file_operations	*seq_fops;
 20	const struct seq_operations	seq_ops;
 21};
 22
 23static struct kcm_mux *kcm_get_first(struct seq_file *seq)
 24{
 25	struct net *net = seq_file_net(seq);
 26	struct kcm_net *knet = net_generic(net, kcm_net_id);
 27
 28	return list_first_or_null_rcu(&knet->mux_list,
 29				      struct kcm_mux, kcm_mux_list);
 30}
 31
 32static struct kcm_mux *kcm_get_next(struct kcm_mux *mux)
 33{
 34	struct kcm_net *knet = mux->knet;
 35
 36	return list_next_or_null_rcu(&knet->mux_list, &mux->kcm_mux_list,
 37				     struct kcm_mux, kcm_mux_list);
 38}
 39
 40static struct kcm_mux *kcm_get_idx(struct seq_file *seq, loff_t pos)
 41{
 42	struct net *net = seq_file_net(seq);
 43	struct kcm_net *knet = net_generic(net, kcm_net_id);
 44	struct kcm_mux *m;
 45
 46	list_for_each_entry_rcu(m, &knet->mux_list, kcm_mux_list) {
 47		if (!pos)
 48			return m;
 49		--pos;
 50	}
 51	return NULL;
 52}
 53
 54static void *kcm_seq_next(struct seq_file *seq, void *v, loff_t *pos)
 55{
 56	void *p;
 57
 58	if (v == SEQ_START_TOKEN)
 59		p = kcm_get_first(seq);
 60	else
 61		p = kcm_get_next(v);
 62	++*pos;
 63	return p;
 64}
 65
 66static void *kcm_seq_start(struct seq_file *seq, loff_t *pos)
 67	__acquires(rcu)
 68{
 69	rcu_read_lock();
 70
 71	if (!*pos)
 72		return SEQ_START_TOKEN;
 73	else
 74		return kcm_get_idx(seq, *pos - 1);
 75}
 76
 77static void kcm_seq_stop(struct seq_file *seq, void *v)
 78	__releases(rcu)
 79{
 80	rcu_read_unlock();
 81}
 82
 83struct kcm_proc_mux_state {
 84	struct seq_net_private p;
 85	int idx;
 86};
 87
 88static int kcm_seq_open(struct inode *inode, struct file *file)
 89{
 90	struct kcm_seq_muxinfo *muxinfo = PDE_DATA(inode);
 91	int err;
 92
 93	err = seq_open_net(inode, file, &muxinfo->seq_ops,
 94			   sizeof(struct kcm_proc_mux_state));
 95	if (err < 0)
 96		return err;
 97	return err;
 98}
 99
100static void kcm_format_mux_header(struct seq_file *seq)
101{
102	struct net *net = seq_file_net(seq);
103	struct kcm_net *knet = net_generic(net, kcm_net_id);
104
105	seq_printf(seq,
106		   "*** KCM statistics (%d MUX) ****\n",
107		   knet->count);
108
109	seq_printf(seq,
110		   "%-14s %-10s %-16s %-10s %-16s %-8s %-8s %-8s %-8s %s",
111		   "Object",
112		   "RX-Msgs",
113		   "RX-Bytes",
114		   "TX-Msgs",
115		   "TX-Bytes",
116		   "Recv-Q",
117		   "Rmem",
118		   "Send-Q",
119		   "Smem",
120		   "Status");
121
122	/* XXX: pdsts header stuff here */
123	seq_puts(seq, "\n");
124}
125
126static void kcm_format_sock(struct kcm_sock *kcm, struct seq_file *seq,
127			    int i, int *len)
128{
129	seq_printf(seq,
130		   "   kcm-%-7u %-10llu %-16llu %-10llu %-16llu %-8d %-8d %-8d %-8s ",
131		   kcm->index,
132		   kcm->stats.rx_msgs,
133		   kcm->stats.rx_bytes,
134		   kcm->stats.tx_msgs,
135		   kcm->stats.tx_bytes,
136		   kcm->sk.sk_receive_queue.qlen,
137		   sk_rmem_alloc_get(&kcm->sk),
138		   kcm->sk.sk_write_queue.qlen,
139		   "-");
140
141	if (kcm->tx_psock)
142		seq_printf(seq, "Psck-%u ", kcm->tx_psock->index);
143
144	if (kcm->tx_wait)
145		seq_puts(seq, "TxWait ");
146
147	if (kcm->tx_wait_more)
148		seq_puts(seq, "WMore ");
149
150	if (kcm->rx_wait)
151		seq_puts(seq, "RxWait ");
152
153	seq_puts(seq, "\n");
154}
155
156static void kcm_format_psock(struct kcm_psock *psock, struct seq_file *seq,
157			     int i, int *len)
158{
159	seq_printf(seq,
160		   "   psock-%-5u %-10llu %-16llu %-10llu %-16llu %-8d %-8d %-8d %-8d ",
161		   psock->index,
162		   psock->stats.rx_msgs,
163		   psock->stats.rx_bytes,
164		   psock->stats.tx_msgs,
165		   psock->stats.tx_bytes,
166		   psock->sk->sk_receive_queue.qlen,
167		   atomic_read(&psock->sk->sk_rmem_alloc),
168		   psock->sk->sk_write_queue.qlen,
169		   atomic_read(&psock->sk->sk_wmem_alloc));
170
171	if (psock->done)
172		seq_puts(seq, "Done ");
173
174	if (psock->tx_stopped)
175		seq_puts(seq, "TxStop ");
176
177	if (psock->rx_stopped)
178		seq_puts(seq, "RxStop ");
179
180	if (psock->tx_kcm)
181		seq_printf(seq, "Rsvd-%d ", psock->tx_kcm->index);
182
183	if (psock->ready_rx_msg)
184		seq_puts(seq, "RdyRx ");
 
 
 
 
 
 
 
 
 
 
 
 
 
185
186	seq_puts(seq, "\n");
187}
188
189static void
190kcm_format_mux(struct kcm_mux *mux, loff_t idx, struct seq_file *seq)
191{
192	int i, len;
193	struct kcm_sock *kcm;
194	struct kcm_psock *psock;
195
196	/* mux information */
197	seq_printf(seq,
198		   "%-6s%-8s %-10llu %-16llu %-10llu %-16llu %-8s %-8s %-8s %-8s ",
199		   "mux", "",
200		   mux->stats.rx_msgs,
201		   mux->stats.rx_bytes,
202		   mux->stats.tx_msgs,
203		   mux->stats.tx_bytes,
204		   "-", "-", "-", "-");
205
206	seq_printf(seq, "KCMs: %d, Psocks %d\n",
207		   mux->kcm_socks_cnt, mux->psocks_cnt);
208
209	/* kcm sock information */
210	i = 0;
211	spin_lock_bh(&mux->lock);
212	list_for_each_entry(kcm, &mux->kcm_socks, kcm_sock_list) {
213		kcm_format_sock(kcm, seq, i, &len);
214		i++;
215	}
216	i = 0;
217	list_for_each_entry(psock, &mux->psocks, psock_list) {
218		kcm_format_psock(psock, seq, i, &len);
219		i++;
220	}
221	spin_unlock_bh(&mux->lock);
222}
223
224static int kcm_seq_show(struct seq_file *seq, void *v)
225{
226	struct kcm_proc_mux_state *mux_state;
227
228	mux_state = seq->private;
229	if (v == SEQ_START_TOKEN) {
230		mux_state->idx = 0;
231		kcm_format_mux_header(seq);
232	} else {
233		kcm_format_mux(v, mux_state->idx, seq);
234		mux_state->idx++;
235	}
236	return 0;
237}
238
239static const struct file_operations kcm_seq_fops = {
240	.owner		= THIS_MODULE,
241	.open		= kcm_seq_open,
242	.read		= seq_read,
243	.llseek		= seq_lseek,
244};
245
246static struct kcm_seq_muxinfo kcm_seq_muxinfo = {
247	.name		= "kcm",
248	.seq_fops	= &kcm_seq_fops,
249	.seq_ops	= {
250		.show	= kcm_seq_show,
251		.start	= kcm_seq_start,
252		.next	= kcm_seq_next,
253		.stop	= kcm_seq_stop,
254	}
255};
256
257static int kcm_proc_register(struct net *net, struct kcm_seq_muxinfo *muxinfo)
258{
259	struct proc_dir_entry *p;
260	int rc = 0;
261
262	p = proc_create_data(muxinfo->name, S_IRUGO, net->proc_net,
263			     muxinfo->seq_fops, muxinfo);
264	if (!p)
265		rc = -ENOMEM;
266	return rc;
267}
268EXPORT_SYMBOL(kcm_proc_register);
269
270static void kcm_proc_unregister(struct net *net,
271				struct kcm_seq_muxinfo *muxinfo)
272{
273	remove_proc_entry(muxinfo->name, net->proc_net);
274}
275EXPORT_SYMBOL(kcm_proc_unregister);
276
277static int kcm_stats_seq_show(struct seq_file *seq, void *v)
278{
279	struct kcm_psock_stats psock_stats;
280	struct kcm_mux_stats mux_stats;
 
281	struct kcm_mux *mux;
282	struct kcm_psock *psock;
283	struct net *net = seq->private;
284	struct kcm_net *knet = net_generic(net, kcm_net_id);
285
286	memset(&mux_stats, 0, sizeof(mux_stats));
287	memset(&psock_stats, 0, sizeof(psock_stats));
 
288
289	mutex_lock(&knet->mutex);
290
291	aggregate_mux_stats(&knet->aggregate_mux_stats, &mux_stats);
292	aggregate_psock_stats(&knet->aggregate_psock_stats,
293			      &psock_stats);
 
 
294
295	list_for_each_entry_rcu(mux, &knet->mux_list, kcm_mux_list) {
296		spin_lock_bh(&mux->lock);
297		aggregate_mux_stats(&mux->stats, &mux_stats);
298		aggregate_psock_stats(&mux->aggregate_psock_stats,
299				      &psock_stats);
300		list_for_each_entry(psock, &mux->psocks, psock_list)
 
 
301			aggregate_psock_stats(&psock->stats, &psock_stats);
 
 
 
302		spin_unlock_bh(&mux->lock);
303	}
304
305	mutex_unlock(&knet->mutex);
306
307	seq_printf(seq,
308		   "%-8s %-10s %-16s %-10s %-16s %-10s %-10s %-10s %-10s %-10s\n",
309		   "MUX",
310		   "RX-Msgs",
311		   "RX-Bytes",
312		   "TX-Msgs",
313		   "TX-Bytes",
314		   "TX-Retries",
315		   "Attach",
316		   "Unattach",
317		   "UnattchRsvd",
318		   "RX-RdyDrops");
319
320	seq_printf(seq,
321		   "%-8s %-10llu %-16llu %-10llu %-16llu %-10u %-10u %-10u %-10u %-10u\n",
322		   "",
323		   mux_stats.rx_msgs,
324		   mux_stats.rx_bytes,
325		   mux_stats.tx_msgs,
326		   mux_stats.tx_bytes,
327		   mux_stats.tx_retries,
328		   mux_stats.psock_attach,
329		   mux_stats.psock_unattach_rsvd,
330		   mux_stats.psock_unattach,
331		   mux_stats.rx_ready_drops);
332
333	seq_printf(seq,
334		   "%-8s %-10s %-16s %-10s %-16s %-10s %-10s %-10s %-10s %-10s %-10s %-10s %-10s %-10s\n",
335		   "Psock",
336		   "RX-Msgs",
337		   "RX-Bytes",
338		   "TX-Msgs",
339		   "TX-Bytes",
340		   "Reserved",
341		   "Unreserved",
342		   "RX-Aborts",
 
 
343		   "RX-MemFail",
344		   "RX-NeedMor",
345		   "RX-BadLen",
346		   "RX-TooBig",
347		   "RX-Timeout",
348		   "TX-Aborts");
349
350	seq_printf(seq,
351		   "%-8s %-10llu %-16llu %-10llu %-16llu %-10llu %-10llu %-10u %-10u %-10u %-10u %-10u %-10u %-10u\n",
352		   "",
353		   psock_stats.rx_msgs,
354		   psock_stats.rx_bytes,
355		   psock_stats.tx_msgs,
356		   psock_stats.tx_bytes,
357		   psock_stats.reserved,
358		   psock_stats.unreserved,
359		   psock_stats.rx_aborts,
360		   psock_stats.rx_mem_fail,
361		   psock_stats.rx_need_more_hdr,
362		   psock_stats.rx_bad_hdr_len,
363		   psock_stats.rx_msg_too_big,
364		   psock_stats.rx_msg_timeouts,
 
 
365		   psock_stats.tx_aborts);
366
367	return 0;
368}
369
370static int kcm_stats_seq_open(struct inode *inode, struct file *file)
371{
372	return single_open_net(inode, file, kcm_stats_seq_show);
373}
374
375static const struct file_operations kcm_stats_seq_fops = {
376	.owner   = THIS_MODULE,
377	.open    = kcm_stats_seq_open,
378	.read    = seq_read,
379	.llseek  = seq_lseek,
380	.release = single_release_net,
381};
382
383static int kcm_proc_init_net(struct net *net)
384{
385	int err;
386
387	if (!proc_create("kcm_stats", S_IRUGO, net->proc_net,
388			 &kcm_stats_seq_fops)) {
389		err = -ENOMEM;
390		goto out_kcm_stats;
391	}
392
393	err = kcm_proc_register(net, &kcm_seq_muxinfo);
394	if (err)
395		goto out_kcm;
396
397	return 0;
398
399out_kcm:
400	remove_proc_entry("kcm_stats", net->proc_net);
401out_kcm_stats:
402	return err;
403}
404
405static void kcm_proc_exit_net(struct net *net)
406{
407	kcm_proc_unregister(net, &kcm_seq_muxinfo);
408	remove_proc_entry("kcm_stats", net->proc_net);
409}
410
411static struct pernet_operations kcm_net_ops = {
412	.init = kcm_proc_init_net,
413	.exit = kcm_proc_exit_net,
414};
415
416int __init kcm_proc_init(void)
417{
418	return register_pernet_subsys(&kcm_net_ops);
419}
420
421void __exit kcm_proc_exit(void)
422{
423	unregister_pernet_subsys(&kcm_net_ops);
424}
425
426#endif /* CONFIG_PROC_FS */
v6.13.7
  1// SPDX-License-Identifier: GPL-2.0
  2#include <linux/in.h>
  3#include <linux/inet.h>
  4#include <linux/list.h>
  5#include <linux/module.h>
  6#include <linux/net.h>
  7#include <linux/proc_fs.h>
  8#include <linux/rculist.h>
  9#include <linux/seq_file.h>
 10#include <linux/socket.h>
 11#include <net/inet_sock.h>
 12#include <net/kcm.h>
 13#include <net/net_namespace.h>
 14#include <net/netns/generic.h>
 15#include <net/tcp.h>
 16
 17#ifdef CONFIG_PROC_FS
 
 
 
 
 
 
 18static struct kcm_mux *kcm_get_first(struct seq_file *seq)
 19{
 20	struct net *net = seq_file_net(seq);
 21	struct kcm_net *knet = net_generic(net, kcm_net_id);
 22
 23	return list_first_or_null_rcu(&knet->mux_list,
 24				      struct kcm_mux, kcm_mux_list);
 25}
 26
 27static struct kcm_mux *kcm_get_next(struct kcm_mux *mux)
 28{
 29	struct kcm_net *knet = mux->knet;
 30
 31	return list_next_or_null_rcu(&knet->mux_list, &mux->kcm_mux_list,
 32				     struct kcm_mux, kcm_mux_list);
 33}
 34
 35static struct kcm_mux *kcm_get_idx(struct seq_file *seq, loff_t pos)
 36{
 37	struct net *net = seq_file_net(seq);
 38	struct kcm_net *knet = net_generic(net, kcm_net_id);
 39	struct kcm_mux *m;
 40
 41	list_for_each_entry_rcu(m, &knet->mux_list, kcm_mux_list) {
 42		if (!pos)
 43			return m;
 44		--pos;
 45	}
 46	return NULL;
 47}
 48
 49static void *kcm_seq_next(struct seq_file *seq, void *v, loff_t *pos)
 50{
 51	void *p;
 52
 53	if (v == SEQ_START_TOKEN)
 54		p = kcm_get_first(seq);
 55	else
 56		p = kcm_get_next(v);
 57	++*pos;
 58	return p;
 59}
 60
 61static void *kcm_seq_start(struct seq_file *seq, loff_t *pos)
 62	__acquires(rcu)
 63{
 64	rcu_read_lock();
 65
 66	if (!*pos)
 67		return SEQ_START_TOKEN;
 68	else
 69		return kcm_get_idx(seq, *pos - 1);
 70}
 71
 72static void kcm_seq_stop(struct seq_file *seq, void *v)
 73	__releases(rcu)
 74{
 75	rcu_read_unlock();
 76}
 77
 78struct kcm_proc_mux_state {
 79	struct seq_net_private p;
 80	int idx;
 81};
 82
 
 
 
 
 
 
 
 
 
 
 
 
 83static void kcm_format_mux_header(struct seq_file *seq)
 84{
 85	struct net *net = seq_file_net(seq);
 86	struct kcm_net *knet = net_generic(net, kcm_net_id);
 87
 88	seq_printf(seq,
 89		   "*** KCM statistics (%d MUX) ****\n",
 90		   knet->count);
 91
 92	seq_printf(seq,
 93		   "%-14s %-10s %-16s %-10s %-16s %-8s %-8s %-8s %-8s %s",
 94		   "Object",
 95		   "RX-Msgs",
 96		   "RX-Bytes",
 97		   "TX-Msgs",
 98		   "TX-Bytes",
 99		   "Recv-Q",
100		   "Rmem",
101		   "Send-Q",
102		   "Smem",
103		   "Status");
104
105	/* XXX: pdsts header stuff here */
106	seq_puts(seq, "\n");
107}
108
109static void kcm_format_sock(struct kcm_sock *kcm, struct seq_file *seq,
110			    int i, int *len)
111{
112	seq_printf(seq,
113		   "   kcm-%-7u %-10llu %-16llu %-10llu %-16llu %-8d %-8d %-8d %-8s ",
114		   kcm->index,
115		   kcm->stats.rx_msgs,
116		   kcm->stats.rx_bytes,
117		   kcm->stats.tx_msgs,
118		   kcm->stats.tx_bytes,
119		   kcm->sk.sk_receive_queue.qlen,
120		   sk_rmem_alloc_get(&kcm->sk),
121		   kcm->sk.sk_write_queue.qlen,
122		   "-");
123
124	if (kcm->tx_psock)
125		seq_printf(seq, "Psck-%u ", kcm->tx_psock->index);
126
127	if (kcm->tx_wait)
128		seq_puts(seq, "TxWait ");
129
130	if (kcm->tx_wait_more)
131		seq_puts(seq, "WMore ");
132
133	if (kcm->rx_wait)
134		seq_puts(seq, "RxWait ");
135
136	seq_puts(seq, "\n");
137}
138
139static void kcm_format_psock(struct kcm_psock *psock, struct seq_file *seq,
140			     int i, int *len)
141{
142	seq_printf(seq,
143		   "   psock-%-5u %-10llu %-16llu %-10llu %-16llu %-8d %-8d %-8d %-8d ",
144		   psock->index,
145		   psock->strp.stats.msgs,
146		   psock->strp.stats.bytes,
147		   psock->stats.tx_msgs,
148		   psock->stats.tx_bytes,
149		   psock->sk->sk_receive_queue.qlen,
150		   atomic_read(&psock->sk->sk_rmem_alloc),
151		   psock->sk->sk_write_queue.qlen,
152		   refcount_read(&psock->sk->sk_wmem_alloc));
153
154	if (psock->done)
155		seq_puts(seq, "Done ");
156
157	if (psock->tx_stopped)
158		seq_puts(seq, "TxStop ");
159
160	if (psock->strp.stopped)
161		seq_puts(seq, "RxStop ");
162
163	if (psock->tx_kcm)
164		seq_printf(seq, "Rsvd-%d ", psock->tx_kcm->index);
165
166	if (!psock->strp.paused && !psock->ready_rx_msg) {
167		if (psock->sk->sk_receive_queue.qlen) {
168			if (psock->strp.need_bytes)
169				seq_printf(seq, "RxWait=%u ",
170					   psock->strp.need_bytes);
171			else
172				seq_printf(seq, "RxWait ");
173		}
174	} else  {
175		if (psock->strp.paused)
176			seq_puts(seq, "RxPause ");
177
178		if (psock->ready_rx_msg)
179			seq_puts(seq, "RdyRx ");
180	}
181
182	seq_puts(seq, "\n");
183}
184
185static void
186kcm_format_mux(struct kcm_mux *mux, loff_t idx, struct seq_file *seq)
187{
188	int i, len;
189	struct kcm_sock *kcm;
190	struct kcm_psock *psock;
191
192	/* mux information */
193	seq_printf(seq,
194		   "%-6s%-8s %-10llu %-16llu %-10llu %-16llu %-8s %-8s %-8s %-8s ",
195		   "mux", "",
196		   mux->stats.rx_msgs,
197		   mux->stats.rx_bytes,
198		   mux->stats.tx_msgs,
199		   mux->stats.tx_bytes,
200		   "-", "-", "-", "-");
201
202	seq_printf(seq, "KCMs: %d, Psocks %d\n",
203		   mux->kcm_socks_cnt, mux->psocks_cnt);
204
205	/* kcm sock information */
206	i = 0;
207	spin_lock_bh(&mux->lock);
208	list_for_each_entry(kcm, &mux->kcm_socks, kcm_sock_list) {
209		kcm_format_sock(kcm, seq, i, &len);
210		i++;
211	}
212	i = 0;
213	list_for_each_entry(psock, &mux->psocks, psock_list) {
214		kcm_format_psock(psock, seq, i, &len);
215		i++;
216	}
217	spin_unlock_bh(&mux->lock);
218}
219
220static int kcm_seq_show(struct seq_file *seq, void *v)
221{
222	struct kcm_proc_mux_state *mux_state;
223
224	mux_state = seq->private;
225	if (v == SEQ_START_TOKEN) {
226		mux_state->idx = 0;
227		kcm_format_mux_header(seq);
228	} else {
229		kcm_format_mux(v, mux_state->idx, seq);
230		mux_state->idx++;
231	}
232	return 0;
233}
234
235static const struct seq_operations kcm_seq_ops = {
236	.show	= kcm_seq_show,
237	.start	= kcm_seq_start,
238	.next	= kcm_seq_next,
239	.stop	= kcm_seq_stop,
 
 
 
 
 
 
 
 
 
 
 
240};
241
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
242static int kcm_stats_seq_show(struct seq_file *seq, void *v)
243{
244	struct kcm_psock_stats psock_stats;
245	struct kcm_mux_stats mux_stats;
246	struct strp_aggr_stats strp_stats;
247	struct kcm_mux *mux;
248	struct kcm_psock *psock;
249	struct net *net = seq->private;
250	struct kcm_net *knet = net_generic(net, kcm_net_id);
251
252	memset(&mux_stats, 0, sizeof(mux_stats));
253	memset(&psock_stats, 0, sizeof(psock_stats));
254	memset(&strp_stats, 0, sizeof(strp_stats));
255
256	mutex_lock(&knet->mutex);
257
258	aggregate_mux_stats(&knet->aggregate_mux_stats, &mux_stats);
259	aggregate_psock_stats(&knet->aggregate_psock_stats,
260			      &psock_stats);
261	aggregate_strp_stats(&knet->aggregate_strp_stats,
262			     &strp_stats);
263
264	list_for_each_entry(mux, &knet->mux_list, kcm_mux_list) {
265		spin_lock_bh(&mux->lock);
266		aggregate_mux_stats(&mux->stats, &mux_stats);
267		aggregate_psock_stats(&mux->aggregate_psock_stats,
268				      &psock_stats);
269		aggregate_strp_stats(&mux->aggregate_strp_stats,
270				     &strp_stats);
271		list_for_each_entry(psock, &mux->psocks, psock_list) {
272			aggregate_psock_stats(&psock->stats, &psock_stats);
273			save_strp_stats(&psock->strp, &strp_stats);
274		}
275
276		spin_unlock_bh(&mux->lock);
277	}
278
279	mutex_unlock(&knet->mutex);
280
281	seq_printf(seq,
282		   "%-8s %-10s %-16s %-10s %-16s %-10s %-10s %-10s %-10s %-10s\n",
283		   "MUX",
284		   "RX-Msgs",
285		   "RX-Bytes",
286		   "TX-Msgs",
287		   "TX-Bytes",
288		   "TX-Retries",
289		   "Attach",
290		   "Unattach",
291		   "UnattchRsvd",
292		   "RX-RdyDrops");
293
294	seq_printf(seq,
295		   "%-8s %-10llu %-16llu %-10llu %-16llu %-10u %-10u %-10u %-10u %-10u\n",
296		   "",
297		   mux_stats.rx_msgs,
298		   mux_stats.rx_bytes,
299		   mux_stats.tx_msgs,
300		   mux_stats.tx_bytes,
301		   mux_stats.tx_retries,
302		   mux_stats.psock_attach,
303		   mux_stats.psock_unattach_rsvd,
304		   mux_stats.psock_unattach,
305		   mux_stats.rx_ready_drops);
306
307	seq_printf(seq,
308		   "%-8s %-10s %-16s %-10s %-16s %-10s %-10s %-10s %-10s %-10s %-10s %-10s %-10s %-10s %-10s %-10s\n",
309		   "Psock",
310		   "RX-Msgs",
311		   "RX-Bytes",
312		   "TX-Msgs",
313		   "TX-Bytes",
314		   "Reserved",
315		   "Unreserved",
316		   "RX-Aborts",
317		   "RX-Intr",
318		   "RX-Unrecov",
319		   "RX-MemFail",
320		   "RX-NeedMor",
321		   "RX-BadLen",
322		   "RX-TooBig",
323		   "RX-Timeout",
324		   "TX-Aborts");
325
326	seq_printf(seq,
327		   "%-8s %-10llu %-16llu %-10llu %-16llu %-10llu %-10llu %-10u %-10u %-10u %-10u %-10u %-10u %-10u %-10u %-10u\n",
328		   "",
329		   strp_stats.msgs,
330		   strp_stats.bytes,
331		   psock_stats.tx_msgs,
332		   psock_stats.tx_bytes,
333		   psock_stats.reserved,
334		   psock_stats.unreserved,
335		   strp_stats.aborts,
336		   strp_stats.interrupted,
337		   strp_stats.unrecov_intr,
338		   strp_stats.mem_fail,
339		   strp_stats.need_more_hdr,
340		   strp_stats.bad_hdr_len,
341		   strp_stats.msg_too_big,
342		   strp_stats.msg_timeouts,
343		   psock_stats.tx_aborts);
344
345	return 0;
346}
347
 
 
 
 
 
 
 
 
 
 
 
 
 
348static int kcm_proc_init_net(struct net *net)
349{
350	if (!proc_create_net_single("kcm_stats", 0444, net->proc_net,
351			 kcm_stats_seq_show, NULL))
 
 
 
352		goto out_kcm_stats;
 
353
354	if (!proc_create_net("kcm", 0444, net->proc_net, &kcm_seq_ops,
355			sizeof(struct kcm_proc_mux_state)))
356		goto out_kcm;
357
358	return 0;
359
360out_kcm:
361	remove_proc_entry("kcm_stats", net->proc_net);
362out_kcm_stats:
363	return -ENOMEM;
364}
365
366static void kcm_proc_exit_net(struct net *net)
367{
368	remove_proc_entry("kcm", net->proc_net);
369	remove_proc_entry("kcm_stats", net->proc_net);
370}
371
372static struct pernet_operations kcm_net_ops = {
373	.init = kcm_proc_init_net,
374	.exit = kcm_proc_exit_net,
375};
376
377int __init kcm_proc_init(void)
378{
379	return register_pernet_subsys(&kcm_net_ops);
380}
381
382void __exit kcm_proc_exit(void)
383{
384	unregister_pernet_subsys(&kcm_net_ops);
385}
386
387#endif /* CONFIG_PROC_FS */