1 #include <linux/config.h>
4 #include <linux/errno.h>
5 #include <linux/kernel.h>
6 #include <linux/string.h>
8 #include <linux/module.h>
9 #include <linux/proc_fs.h>
10 #include <linux/time.h>
11 #include <linux/seq_file.h>
12 #include <asm/uaccess.h>
13 #include <linux/atmmpc.h>
14 #include <linux/atm.h>
16 #include "mpoa_caches.h"
19 * mpoa_proc.c: Implementation MPOA client's proc
20 * file system statistics
24 #define dprintk printk /* debug */
26 #define dprintk(format,args...)
29 #define STAT_FILE_NAME "mpc" /* Our statistic file's name */
31 extern struct mpoa_client
*mpcs
;
32 extern struct proc_dir_entry
*atm_proc_root
; /* from proc.c. */
34 static int proc_mpc_open(struct inode
*inode
, struct file
*file
);
35 static ssize_t
proc_mpc_write(struct file
*file
, const char __user
*buff
,
36 size_t nbytes
, loff_t
*ppos
);
38 static int parse_qos(const char *buff
);
41 * Define allowed FILE OPERATIONS
43 static struct file_operations mpc_file_operations
= {
45 .open
= proc_mpc_open
,
48 .write
= proc_mpc_write
,
49 .release
= seq_release
,
53 * Returns the state of an ingress cache entry as a string
55 static const char *ingress_state_string(int state
){
57 case INGRESS_RESOLVING
:
60 case INGRESS_RESOLVED
:
66 case INGRESS_REFRESHING
:
75 * Returns the state of an egress cache entry as a string
77 static const char *egress_state_string(int state
){
94 * FIXME: mpcs (and per-mpc lists) have no locking whatsoever.
97 static void *mpc_start(struct seq_file
*m
, loff_t
*pos
)
100 struct mpoa_client
*mpc
;
103 return SEQ_START_TOKEN
;
104 for (mpc
= mpcs
; mpc
; mpc
= mpc
->next
)
110 static void *mpc_next(struct seq_file
*m
, void *v
, loff_t
*pos
)
112 struct mpoa_client
*p
= v
;
114 return v
== SEQ_START_TOKEN
? mpcs
: p
->next
;
117 static void mpc_stop(struct seq_file
*m
, void *v
)
122 * READING function - called when the /proc/atm/mpoa file is read from.
124 static int mpc_show(struct seq_file
*m
, void *v
)
126 struct mpoa_client
*mpc
= v
;
129 in_cache_entry
*in_entry
;
130 eg_cache_entry
*eg_entry
;
132 unsigned char ip_string
[16];
134 if (v
== SEQ_START_TOKEN
) {
135 atm_mpoa_disp_qos(m
);
139 seq_printf(m
, "\nInterface %d:\n\n", mpc
->dev_num
);
140 seq_printf(m
, "Ingress Entries:\nIP address State Holding time Packets fwded VPI VCI\n");
141 do_gettimeofday(&now
);
143 for (in_entry
= mpc
->in_cache
; in_entry
; in_entry
= in_entry
->next
) {
144 temp
= (unsigned char *)&in_entry
->ctrl_info
.in_dst_ip
;
145 sprintf(ip_string
,"%d.%d.%d.%d", temp
[0], temp
[1], temp
[2], temp
[3]);
146 seq_printf(m
, "%-16s%s%-14lu%-12u",
148 ingress_state_string(in_entry
->entry_state
),
149 in_entry
->ctrl_info
.holding_time
-(now
.tv_sec
-in_entry
->tv
.tv_sec
),
150 in_entry
->packets_fwded
);
151 if (in_entry
->shortcut
)
152 seq_printf(m
, " %-3d %-3d",in_entry
->shortcut
->vpi
,in_entry
->shortcut
->vci
);
157 seq_printf(m
, "Egress Entries:\nIngress MPC ATM addr\nCache-id State Holding time Packets recvd Latest IP addr VPI VCI\n");
158 for (eg_entry
= mpc
->eg_cache
; eg_entry
; eg_entry
= eg_entry
->next
) {
159 unsigned char *p
= eg_entry
->ctrl_info
.in_MPC_data_ATM_addr
;
160 for(i
= 0; i
< ATM_ESA_LEN
; i
++)
161 seq_printf(m
, "%02x", p
[i
]);
162 seq_printf(m
, "\n%-16lu%s%-14lu%-15u",
163 (unsigned long)ntohl(eg_entry
->ctrl_info
.cache_id
),
164 egress_state_string(eg_entry
->entry_state
),
165 (eg_entry
->ctrl_info
.holding_time
-(now
.tv_sec
-eg_entry
->tv
.tv_sec
)),
166 eg_entry
->packets_rcvd
);
168 /* latest IP address */
169 temp
= (unsigned char *)&eg_entry
->latest_ip_addr
;
170 sprintf(ip_string
, "%d.%d.%d.%d", temp
[0], temp
[1], temp
[2], temp
[3]);
171 seq_printf(m
, "%-16s", ip_string
);
173 if (eg_entry
->shortcut
)
174 seq_printf(m
, " %-3d %-3d",eg_entry
->shortcut
->vpi
,eg_entry
->shortcut
->vci
);
181 static struct seq_operations mpc_op
= {
188 static int proc_mpc_open(struct inode
*inode
, struct file
*file
)
190 return seq_open(file
, &mpc_op
);
193 static ssize_t
proc_mpc_write(struct file
*file
, const char __user
*buff
,
194 size_t nbytes
, loff_t
*ppos
)
202 if (nbytes
>= PAGE_SIZE
)
203 nbytes
= PAGE_SIZE
-1;
205 page
= (char *)__get_free_page(GFP_KERNEL
);
209 for (p
= page
, len
= 0; len
< nbytes
; p
++, len
++) {
210 if (get_user(*p
, buff
++)) {
211 free_page((unsigned long)page
);
214 if (*p
== '\0' || *p
== '\n')
220 if (!parse_qos(page
))
221 printk("mpoa: proc_mpc_write: could not parse '%s'\n", page
);
223 free_page((unsigned long)page
);
228 static int parse_qos(const char *buff
)
230 /* possible lines look like this
231 * add 130.230.54.142 tx=max_pcr,max_sdu rx=max_pcr,max_sdu
234 int tx_pcr
, tx_sdu
, rx_pcr
, rx_sdu
;
238 memset(&qos
, 0, sizeof(struct atm_qos
));
240 if (sscanf(buff
, "del %hhu.%hhu.%hhu.%hhu",
241 ip
, ip
+1, ip
+2, ip
+3) == 4) {
242 ipaddr
= *(uint32_t *)ip
;
243 return atm_mpoa_delete_qos(atm_mpoa_search_qos(ipaddr
));
246 if (sscanf(buff
, "add %hhu.%hhu.%hhu.%hhu tx=%d,%d rx=tx",
247 ip
, ip
+1, ip
+2, ip
+3, &tx_pcr
, &tx_sdu
) == 6) {
250 } else if (sscanf(buff
, "add %hhu.%hhu.%hhu.%hhu tx=%d,%d rx=%d,%d",
251 ip
, ip
+1, ip
+2, ip
+3, &tx_pcr
, &tx_sdu
, &rx_pcr
, &rx_sdu
) != 8)
254 ipaddr
= *(uint32_t *)ip
;
255 qos
.txtp
.traffic_class
= ATM_CBR
;
256 qos
.txtp
.max_pcr
= tx_pcr
;
257 qos
.txtp
.max_sdu
= tx_sdu
;
258 qos
.rxtp
.traffic_class
= ATM_CBR
;
259 qos
.rxtp
.max_pcr
= rx_pcr
;
260 qos
.rxtp
.max_sdu
= rx_sdu
;
262 dprintk("mpoa: mpoa_proc.c: parse_qos(): setting qos paramameters to tx=%d,%d rx=%d,%d\n",
269 atm_mpoa_add_qos(ipaddr
, &qos
);
274 * INITIALIZATION function - called when module is initialized/loaded.
276 int mpc_proc_init(void)
278 struct proc_dir_entry
*p
;
280 p
= create_proc_entry(STAT_FILE_NAME
, 0, atm_proc_root
);
282 printk(KERN_ERR
"Unable to initialize /proc/atm/%s\n", STAT_FILE_NAME
);
285 p
->proc_fops
= &mpc_file_operations
;
286 p
->owner
= THIS_MODULE
;
291 * DELETING function - called when module is removed.
293 void mpc_proc_clean(void)
295 remove_proc_entry(STAT_FILE_NAME
,atm_proc_root
);
299 #endif /* CONFIG_PROC_FS */