Commit | Line | Data |
---|---|---|
b2441318 | 1 | // SPDX-License-Identifier: GPL-2.0 |
99824461 | 2 | #define pr_fmt(fmt) KBUILD_MODNAME ":%s: " fmt, __func__ |
1da177e4 LT |
3 | |
4 | #ifdef CONFIG_PROC_FS | |
5 | #include <linux/errno.h> | |
6 | #include <linux/kernel.h> | |
f7d57453 | 7 | #include <linux/string.h> |
1da177e4 LT |
8 | #include <linux/mm.h> |
9 | #include <linux/module.h> | |
10 | #include <linux/proc_fs.h> | |
d750dbdc | 11 | #include <linux/ktime.h> |
1da177e4 | 12 | #include <linux/seq_file.h> |
f1e10049 | 13 | #include <linux/uaccess.h> |
1da177e4 LT |
14 | #include <linux/atmmpc.h> |
15 | #include <linux/atm.h> | |
5a0e3ad6 | 16 | #include <linux/gfp.h> |
1da177e4 LT |
17 | #include "mpc.h" |
18 | #include "mpoa_caches.h" | |
19 | ||
20 | /* | |
21 | * mpoa_proc.c: Implementation MPOA client's proc | |
f7d57453 | 22 | * file system statistics |
1da177e4 LT |
23 | */ |
24 | ||
25 | #if 1 | |
b50c2ea7 JP |
26 | #define dprintk(format, args...) \ |
27 | printk(KERN_DEBUG "mpoa:%s: " format, __FILE__, ##args) /* debug */ | |
1da177e4 | 28 | #else |
b50c2ea7 JP |
29 | #define dprintk(format, args...) \ |
30 | do { if (0) \ | |
31 | printk(KERN_DEBUG "mpoa:%s: " format, __FILE__, ##args);\ | |
32 | } while (0) | |
33 | #endif | |
34 | ||
35 | #if 0 | |
36 | #define ddprintk(format, args...) \ | |
37 | printk(KERN_DEBUG "mpoa:%s: " format, __FILE__, ##args) /* debug */ | |
38 | #else | |
39 | #define ddprintk(format, args...) \ | |
40 | do { if (0) \ | |
41 | printk(KERN_DEBUG "mpoa:%s: " format, __FILE__, ##args);\ | |
42 | } while (0) | |
1da177e4 LT |
43 | #endif |
44 | ||
45 | #define STAT_FILE_NAME "mpc" /* Our statistic file's name */ | |
46 | ||
47 | extern struct mpoa_client *mpcs; | |
48 | extern struct proc_dir_entry *atm_proc_root; /* from proc.c. */ | |
49 | ||
50 | static int proc_mpc_open(struct inode *inode, struct file *file); | |
51 | static ssize_t proc_mpc_write(struct file *file, const char __user *buff, | |
f7d57453 | 52 | size_t nbytes, loff_t *ppos); |
1da177e4 LT |
53 | |
54 | static int parse_qos(const char *buff); | |
55 | ||
56 | /* | |
57 | * Define allowed FILE OPERATIONS | |
58 | */ | |
9a32144e | 59 | static const struct file_operations mpc_file_operations = { |
1da177e4 LT |
60 | .open = proc_mpc_open, |
61 | .read = seq_read, | |
62 | .llseek = seq_lseek, | |
63 | .write = proc_mpc_write, | |
64 | .release = seq_release, | |
65 | }; | |
66 | ||
67 | /* | |
68 | * Returns the state of an ingress cache entry as a string | |
69 | */ | |
f1e10049 JP |
70 | static const char *ingress_state_string(int state) |
71 | { | |
72 | switch (state) { | |
1da177e4 | 73 | case INGRESS_RESOLVING: |
f7d57453 | 74 | return "resolving "; |
1da177e4 | 75 | case INGRESS_RESOLVED: |
f7d57453 | 76 | return "resolved "; |
1da177e4 | 77 | case INGRESS_INVALID: |
f7d57453 | 78 | return "invalid "; |
1da177e4 | 79 | case INGRESS_REFRESHING: |
f7d57453 | 80 | return "refreshing "; |
1da177e4 | 81 | } |
f1e10049 JP |
82 | |
83 | return ""; | |
1da177e4 LT |
84 | } |
85 | ||
86 | /* | |
87 | * Returns the state of an egress cache entry as a string | |
88 | */ | |
f1e10049 JP |
89 | static const char *egress_state_string(int state) |
90 | { | |
91 | switch (state) { | |
1da177e4 | 92 | case EGRESS_RESOLVED: |
f7d57453 | 93 | return "resolved "; |
1da177e4 | 94 | case EGRESS_PURGE: |
f7d57453 | 95 | return "purge "; |
1da177e4 | 96 | case EGRESS_INVALID: |
f7d57453 | 97 | return "invalid "; |
1da177e4 | 98 | } |
f1e10049 JP |
99 | |
100 | return ""; | |
1da177e4 LT |
101 | } |
102 | ||
103 | /* | |
104 | * FIXME: mpcs (and per-mpc lists) have no locking whatsoever. | |
105 | */ | |
106 | ||
107 | static void *mpc_start(struct seq_file *m, loff_t *pos) | |
108 | { | |
109 | loff_t l = *pos; | |
110 | struct mpoa_client *mpc; | |
111 | ||
112 | if (!l--) | |
113 | return SEQ_START_TOKEN; | |
114 | for (mpc = mpcs; mpc; mpc = mpc->next) | |
115 | if (!l--) | |
116 | return mpc; | |
117 | return NULL; | |
118 | } | |
119 | ||
120 | static void *mpc_next(struct seq_file *m, void *v, loff_t *pos) | |
121 | { | |
122 | struct mpoa_client *p = v; | |
123 | (*pos)++; | |
124 | return v == SEQ_START_TOKEN ? mpcs : p->next; | |
125 | } | |
126 | ||
127 | static void mpc_stop(struct seq_file *m, void *v) | |
128 | { | |
129 | } | |
130 | ||
131 | /* | |
132 | * READING function - called when the /proc/atm/mpoa file is read from. | |
133 | */ | |
134 | static int mpc_show(struct seq_file *m, void *v) | |
135 | { | |
136 | struct mpoa_client *mpc = v; | |
1da177e4 LT |
137 | int i; |
138 | in_cache_entry *in_entry; | |
139 | eg_cache_entry *eg_entry; | |
d750dbdc | 140 | time64_t now; |
1da177e4 LT |
141 | unsigned char ip_string[16]; |
142 | ||
143 | if (v == SEQ_START_TOKEN) { | |
144 | atm_mpoa_disp_qos(m); | |
145 | return 0; | |
146 | } | |
147 | ||
f7d57453 | 148 | seq_printf(m, "\nInterface %d:\n\n", mpc->dev_num); |
1da177e4 | 149 | seq_printf(m, "Ingress Entries:\nIP address State Holding time Packets fwded VPI VCI\n"); |
d750dbdc | 150 | now = ktime_get_seconds(); |
1da177e4 LT |
151 | |
152 | for (in_entry = mpc->in_cache; in_entry; in_entry = in_entry->next) { | |
d750dbdc TR |
153 | unsigned long seconds_delta = now - in_entry->time; |
154 | ||
f1e10049 | 155 | sprintf(ip_string, "%pI4", &in_entry->ctrl_info.in_dst_ip); |
1da177e4 | 156 | seq_printf(m, "%-16s%s%-14lu%-12u", |
f1e10049 JP |
157 | ip_string, |
158 | ingress_state_string(in_entry->entry_state), | |
159 | in_entry->ctrl_info.holding_time - | |
d750dbdc | 160 | seconds_delta, |
f1e10049 | 161 | in_entry->packets_fwded); |
1da177e4 | 162 | if (in_entry->shortcut) |
f1e10049 JP |
163 | seq_printf(m, " %-3d %-3d", |
164 | in_entry->shortcut->vpi, | |
165 | in_entry->shortcut->vci); | |
1da177e4 LT |
166 | seq_printf(m, "\n"); |
167 | } | |
168 | ||
169 | seq_printf(m, "\n"); | |
170 | seq_printf(m, "Egress Entries:\nIngress MPC ATM addr\nCache-id State Holding time Packets recvd Latest IP addr VPI VCI\n"); | |
171 | for (eg_entry = mpc->eg_cache; eg_entry; eg_entry = eg_entry->next) { | |
172 | unsigned char *p = eg_entry->ctrl_info.in_MPC_data_ATM_addr; | |
d750dbdc TR |
173 | unsigned long seconds_delta = now - eg_entry->time; |
174 | ||
f1e10049 | 175 | for (i = 0; i < ATM_ESA_LEN; i++) |
1da177e4 LT |
176 | seq_printf(m, "%02x", p[i]); |
177 | seq_printf(m, "\n%-16lu%s%-14lu%-15u", | |
178 | (unsigned long)ntohl(eg_entry->ctrl_info.cache_id), | |
179 | egress_state_string(eg_entry->entry_state), | |
d750dbdc | 180 | (eg_entry->ctrl_info.holding_time - seconds_delta), |
1da177e4 | 181 | eg_entry->packets_rcvd); |
f7d57453 | 182 | |
1da177e4 | 183 | /* latest IP address */ |
f1e10049 | 184 | sprintf(ip_string, "%pI4", &eg_entry->latest_ip_addr); |
1da177e4 LT |
185 | seq_printf(m, "%-16s", ip_string); |
186 | ||
187 | if (eg_entry->shortcut) | |
f1e10049 JP |
188 | seq_printf(m, " %-3d %-3d", |
189 | eg_entry->shortcut->vpi, | |
190 | eg_entry->shortcut->vci); | |
1da177e4 LT |
191 | seq_printf(m, "\n"); |
192 | } | |
193 | seq_printf(m, "\n"); | |
194 | return 0; | |
195 | } | |
196 | ||
56b3d975 | 197 | static const struct seq_operations mpc_op = { |
1da177e4 LT |
198 | .start = mpc_start, |
199 | .next = mpc_next, | |
200 | .stop = mpc_stop, | |
201 | .show = mpc_show | |
202 | }; | |
203 | ||
204 | static int proc_mpc_open(struct inode *inode, struct file *file) | |
205 | { | |
206 | return seq_open(file, &mpc_op); | |
207 | } | |
208 | ||
209 | static ssize_t proc_mpc_write(struct file *file, const char __user *buff, | |
f7d57453 | 210 | size_t nbytes, loff_t *ppos) |
1da177e4 | 211 | { |
f7d57453 | 212 | char *page, *p; |
95c96174 | 213 | unsigned int len; |
1da177e4 | 214 | |
f7d57453 | 215 | if (nbytes == 0) |
1da177e4 LT |
216 | return 0; |
217 | ||
f7d57453 | 218 | if (nbytes >= PAGE_SIZE) |
1da177e4 LT |
219 | nbytes = PAGE_SIZE-1; |
220 | ||
f7d57453 YH |
221 | page = (char *)__get_free_page(GFP_KERNEL); |
222 | if (!page) | |
1da177e4 LT |
223 | return -ENOMEM; |
224 | ||
f7d57453 YH |
225 | for (p = page, len = 0; len < nbytes; p++, len++) { |
226 | if (get_user(*p, buff++)) { | |
1da177e4 LT |
227 | free_page((unsigned long)page); |
228 | return -EFAULT; | |
229 | } | |
f7d57453 YH |
230 | if (*p == '\0' || *p == '\n') |
231 | break; | |
232 | } | |
1da177e4 | 233 | |
f7d57453 | 234 | *p = '\0'; |
1da177e4 LT |
235 | |
236 | if (!parse_qos(page)) | |
f7d57453 YH |
237 | printk("mpoa: proc_mpc_write: could not parse '%s'\n", page); |
238 | ||
239 | free_page((unsigned long)page); | |
1da177e4 | 240 | |
f7d57453 | 241 | return len; |
1da177e4 LT |
242 | } |
243 | ||
244 | static int parse_qos(const char *buff) | |
245 | { | |
f7d57453 YH |
246 | /* possible lines look like this |
247 | * add 130.230.54.142 tx=max_pcr,max_sdu rx=max_pcr,max_sdu | |
248 | */ | |
249 | unsigned char ip[4]; | |
1da177e4 | 250 | int tx_pcr, tx_sdu, rx_pcr, rx_sdu; |
f7d57453 YH |
251 | __be32 ipaddr; |
252 | struct atm_qos qos; | |
253 | ||
254 | memset(&qos, 0, sizeof(struct atm_qos)); | |
1da177e4 LT |
255 | |
256 | if (sscanf(buff, "del %hhu.%hhu.%hhu.%hhu", | |
257 | ip, ip+1, ip+2, ip+3) == 4) { | |
30d492da | 258 | ipaddr = *(__be32 *)ip; |
1da177e4 LT |
259 | return atm_mpoa_delete_qos(atm_mpoa_search_qos(ipaddr)); |
260 | } | |
261 | ||
262 | if (sscanf(buff, "add %hhu.%hhu.%hhu.%hhu tx=%d,%d rx=tx", | |
263 | ip, ip+1, ip+2, ip+3, &tx_pcr, &tx_sdu) == 6) { | |
264 | rx_pcr = tx_pcr; | |
265 | rx_sdu = tx_sdu; | |
266 | } else if (sscanf(buff, "add %hhu.%hhu.%hhu.%hhu tx=%d,%d rx=%d,%d", | |
267 | ip, ip+1, ip+2, ip+3, &tx_pcr, &tx_sdu, &rx_pcr, &rx_sdu) != 8) | |
268 | return 0; | |
269 | ||
f7d57453 | 270 | ipaddr = *(__be32 *)ip; |
1da177e4 LT |
271 | qos.txtp.traffic_class = ATM_CBR; |
272 | qos.txtp.max_pcr = tx_pcr; | |
273 | qos.txtp.max_sdu = tx_sdu; | |
274 | qos.rxtp.traffic_class = ATM_CBR; | |
275 | qos.rxtp.max_pcr = rx_pcr; | |
276 | qos.rxtp.max_sdu = rx_sdu; | |
f7d57453 | 277 | qos.aal = ATM_AAL5; |
f42cf8d6 | 278 | dprintk("parse_qos(): setting qos parameters to tx=%d,%d rx=%d,%d\n", |
b50c2ea7 JP |
279 | qos.txtp.max_pcr, qos.txtp.max_sdu, |
280 | qos.rxtp.max_pcr, qos.rxtp.max_sdu); | |
1da177e4 LT |
281 | |
282 | atm_mpoa_add_qos(ipaddr, &qos); | |
283 | return 1; | |
284 | } | |
285 | ||
286 | /* | |
287 | * INITIALIZATION function - called when module is initialized/loaded. | |
288 | */ | |
289 | int mpc_proc_init(void) | |
290 | { | |
291 | struct proc_dir_entry *p; | |
292 | ||
16e297b3 | 293 | p = proc_create(STAT_FILE_NAME, 0, atm_proc_root, &mpc_file_operations); |
1da177e4 | 294 | if (!p) { |
99824461 | 295 | pr_err("Unable to initialize /proc/atm/%s\n", STAT_FILE_NAME); |
f7d57453 YH |
296 | return -ENOMEM; |
297 | } | |
1da177e4 LT |
298 | return 0; |
299 | } | |
300 | ||
301 | /* | |
302 | * DELETING function - called when module is removed. | |
303 | */ | |
304 | void mpc_proc_clean(void) | |
305 | { | |
f1e10049 | 306 | remove_proc_entry(STAT_FILE_NAME, atm_proc_root); |
1da177e4 LT |
307 | } |
308 | ||
1da177e4 | 309 | #endif /* CONFIG_PROC_FS */ |