]> bbs.cooldavid.org Git - net-next-2.6.git/blame - net/atm/common.c
git://bbs.cooldavid.org / net-next-2.6.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
[NET] APPLETALK: Fix whitespace errors.
[net-next-2.6.git] / net / atm / common.c
CommitLineData
1da177e4
LT		 1/* net/atm/common.c - ATM sockets (common part for PVC and SVC) */
2
3/* Written 1995-2000 by Werner Almesberger, EPFL LRC/ICA */
4
5
1da177e4
LT		 6#include <linux/module.h>
7#include <linux/kmod.h>
8#include <linux/net.h> /* struct socket, struct proto_ops */
9#include <linux/atm.h> /* ATM stuff */
10#include <linux/atmdev.h>
11#include <linux/socket.h> /* SOL_SOCKET */
12#include <linux/errno.h> /* error codes */
13#include <linux/capability.h>
e49332bd 14#include <linux/mm.h>
1da177e4
LT		 15#include <linux/sched.h>
16#include <linux/time.h> /* struct timeval */
17#include <linux/skbuff.h>
18#include <linux/bitops.h>
19#include <linux/init.h>
20#include <net/sock.h> /* struct sock */
21
22#include <asm/uaccess.h>
23#include <asm/atomic.h>
24#include <asm/poll.h>
25
26
27#include "resources.h" /* atm_find_dev */
28#include "common.h" /* prototypes */
29#include "protocols.h" /* atm_init_<transport> */
30#include "addr.h" /* address registry */
31#include "signaling.h" /* for WAITING and sigd_attach */
32
33
34#if 0
35#define DPRINTK(format,args...) printk(KERN_DEBUG format,##args)
36#else
37#define DPRINTK(format,args...)
38#endif
39
40struct hlist_head vcc_hash[VCC_HTABLE_SIZE];
41DEFINE_RWLOCK(vcc_sklist_lock);
42
43static void __vcc_insert_socket(struct sock *sk)
44{
45 struct atm_vcc *vcc = atm_sk(sk);
46 struct hlist_head *head = &vcc_hash[vcc->vci &
47 (VCC_HTABLE_SIZE - 1)];
81c3d547 48 sk->sk_hash = vcc->vci & (VCC_HTABLE_SIZE - 1);
1da177e4
LT		 49 sk_add_node(sk, head);
50}
51
52void vcc_insert_socket(struct sock *sk)
53{
54 write_lock_irq(&vcc_sklist_lock);
55 __vcc_insert_socket(sk);
56 write_unlock_irq(&vcc_sklist_lock);
57}
58
59static void vcc_remove_socket(struct sock *sk)
60{
61 write_lock_irq(&vcc_sklist_lock);
62 sk_del_node_init(sk);
63 write_unlock_irq(&vcc_sklist_lock);
64}
65
66
67static struct sk_buff *alloc_tx(struct atm_vcc *vcc,unsigned int size)
68{
69 struct sk_buff *skb;
70 struct sock *sk = sk_atm(vcc);
71
72 if (atomic_read(&sk->sk_wmem_alloc) && !atm_may_send(vcc, size)) {
73 DPRINTK("Sorry: wmem_alloc = %d, size = %d, sndbuf = %d\n",
74 atomic_read(&sk->sk_wmem_alloc), size,
75 sk->sk_sndbuf);
76 return NULL;
77 }
78 while (!(skb = alloc_skb(size,GFP_KERNEL))) schedule();
79 DPRINTK("AlTx %d += %d\n", atomic_read(&sk->sk_wmem_alloc),
80 skb->truesize);
81 atomic_add(skb->truesize, &sk->sk_wmem_alloc);
82 return skb;
83}
84
85
86EXPORT_SYMBOL(vcc_hash);
87EXPORT_SYMBOL(vcc_sklist_lock);
88EXPORT_SYMBOL(vcc_insert_socket);
89
90static void vcc_sock_destruct(struct sock *sk)
91{
92 if (atomic_read(&sk->sk_rmem_alloc))
93 printk(KERN_DEBUG "vcc_sock_destruct: rmem leakage (%d bytes) detected.\n", atomic_read(&sk->sk_rmem_alloc));
94
95 if (atomic_read(&sk->sk_wmem_alloc))
96 printk(KERN_DEBUG "vcc_sock_destruct: wmem leakage (%d bytes) detected.\n", atomic_read(&sk->sk_wmem_alloc));
97}
98
99static void vcc_def_wakeup(struct sock *sk)
100{
101 read_lock(&sk->sk_callback_lock);
102 if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
103 wake_up(sk->sk_sleep);
104 read_unlock(&sk->sk_callback_lock);
105}
106
107static inline int vcc_writable(struct sock *sk)
108{
109 struct atm_vcc *vcc = atm_sk(sk);
110
111 return (vcc->qos.txtp.max_sdu +
112 atomic_read(&sk->sk_wmem_alloc)) <= sk->sk_sndbuf;
113}
114
115static void vcc_write_space(struct sock *sk)
116{
117 read_lock(&sk->sk_callback_lock);
118
119 if (vcc_writable(sk)) {
120 if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
121 wake_up_interruptible(sk->sk_sleep);
122
123 sk_wake_async(sk, 2, POLL_OUT);
124 }
125
126 read_unlock(&sk->sk_callback_lock);
127}
128
129static struct proto vcc_proto = {
130 .name = "VCC",
131 .owner = THIS_MODULE,
132 .obj_size = sizeof(struct atm_vcc),
133};
134
135int vcc_create(struct socket *sock, int protocol, int family)
136{
137 struct sock *sk;
138 struct atm_vcc *vcc;
139
140 sock->sk = NULL;
141 if (sock->type == SOCK_STREAM)
142 return -EINVAL;
143 sk = sk_alloc(family, GFP_KERNEL, &vcc_proto, 1);
144 if (!sk)
145 return -ENOMEM;
146 sock_init_data(sock, sk);
147 sk->sk_state_change = vcc_def_wakeup;
148 sk->sk_write_space = vcc_write_space;
149
150 vcc = atm_sk(sk);
151 vcc->dev = NULL;
152 memset(&vcc->local,0,sizeof(struct sockaddr_atmsvc));
153 memset(&vcc->remote,0,sizeof(struct sockaddr_atmsvc));
154 vcc->qos.txtp.max_sdu = 1 << 16; /* for meta VCs */
155 atomic_set(&sk->sk_wmem_alloc, 0);
156 atomic_set(&sk->sk_rmem_alloc, 0);
157 vcc->push = NULL;
158 vcc->pop = NULL;
159 vcc->push_oam = NULL;
160 vcc->vpi = vcc->vci = 0; /* no VCI/VPI yet */
161 vcc->atm_options = vcc->aal_options = 0;
162 sk->sk_destruct = vcc_sock_destruct;
163 return 0;
164}
165
166
167static void vcc_destroy_socket(struct sock *sk)
168{
169 struct atm_vcc *vcc = atm_sk(sk);
170 struct sk_buff *skb;
171
172 set_bit(ATM_VF_CLOSE, &vcc->flags);
173 clear_bit(ATM_VF_READY, &vcc->flags);
174 if (vcc->dev) {
175 if (vcc->dev->ops->close)
176 vcc->dev->ops->close(vcc);
177 if (vcc->push)
178 vcc->push(vcc, NULL); /* atmarpd has no push */
179
1da177e4
LT		 180 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) {
181 atm_return(vcc,skb->truesize);
182 kfree_skb(skb);
183 }
184
185 module_put(vcc->dev->ops->owner);
186 atm_dev_put(vcc->dev);
187 }
9301e320
CW		 188
189 vcc_remove_socket(sk);
1da177e4
LT		 190}
191
192
193int vcc_release(struct socket *sock)
194{
195 struct sock *sk = sock->sk;
196
197 if (sk) {
198 lock_sock(sk);
199 vcc_destroy_socket(sock->sk);
200 release_sock(sk);
201 sock_put(sk);
202 }
203
204 return 0;
205}
206
207
208void vcc_release_async(struct atm_vcc *vcc, int reply)
209{
210 struct sock *sk = sk_atm(vcc);
211
212 set_bit(ATM_VF_CLOSE, &vcc->flags);
213 sk->sk_shutdown |= RCV_SHUTDOWN;
214 sk->sk_err = -reply;
215 clear_bit(ATM_VF_WAITING, &vcc->flags);
216 sk->sk_state_change(sk);
217}
218
219
220EXPORT_SYMBOL(vcc_release_async);
221
222
64bf69dd
SG		 223void atm_dev_release_vccs(struct atm_dev *dev)
224{
225 int i;
226
227 write_lock_irq(&vcc_sklist_lock);
228 for (i = 0; i < VCC_HTABLE_SIZE; i++) {
229 struct hlist_head *head = &vcc_hash[i];
230 struct hlist_node *node, *tmp;
231 struct sock *s;
232 struct atm_vcc *vcc;
233
234 sk_for_each_safe(s, node, tmp, head) {
235 vcc = atm_sk(s);
236 if (vcc->dev == dev) {
237 vcc_release_async(vcc, -EPIPE);
238 sk_del_node_init(s);
239 }
240 }
241 }
242 write_unlock_irq(&vcc_sklist_lock);
243}
244
245
1da177e4
LT		 246static int adjust_tp(struct atm_trafprm *tp,unsigned char aal)
247{
248 int max_sdu;
249
250 if (!tp->traffic_class) return 0;
251 switch (aal) {
252 case ATM_AAL0:
253 max_sdu = ATM_CELL_SIZE-1;
254 break;
255 case ATM_AAL34:
256 max_sdu = ATM_MAX_AAL34_PDU;
257 break;
258 default:
259 printk(KERN_WARNING "ATM: AAL problems ... "
260 "(%d)\n",aal);
261 /* fall through */
262 case ATM_AAL5:
263 max_sdu = ATM_MAX_AAL5_PDU;
264 }
265 if (!tp->max_sdu) tp->max_sdu = max_sdu;
266 else if (tp->max_sdu > max_sdu) return -EINVAL;
267 if (!tp->max_cdv) tp->max_cdv = ATM_MAX_CDV;
268 return 0;
269}
270
271
272static int check_ci(struct atm_vcc *vcc, short vpi, int vci)
273{
274 struct hlist_head *head = &vcc_hash[vci &
275 (VCC_HTABLE_SIZE - 1)];
276 struct hlist_node *node;
277 struct sock *s;
278 struct atm_vcc *walk;
279
280 sk_for_each(s, node, head) {
281 walk = atm_sk(s);
282 if (walk->dev != vcc->dev)
283 continue;
284 if (test_bit(ATM_VF_ADDR, &walk->flags) && walk->vpi == vpi &&
285 walk->vci == vci && ((walk->qos.txtp.traffic_class !=
286 ATM_NONE && vcc->qos.txtp.traffic_class != ATM_NONE) ||
287 (walk->qos.rxtp.traffic_class != ATM_NONE &&
288 vcc->qos.rxtp.traffic_class != ATM_NONE)))
289 return -EADDRINUSE;
290 }
291
292 /* allow VCCs with same VPI/VCI iff they don't collide on
293 TX/RX (but we may refuse such sharing for other reasons,
294 e.g. if protocol requires to have both channels) */
295
296 return 0;
297}
298
299
300static int find_ci(struct atm_vcc *vcc, short *vpi, int *vci)
301{
302 static short p; /* poor man's per-device cache */
303 static int c;
304 short old_p;
305 int old_c;
306 int err;
307
308 if (*vpi != ATM_VPI_ANY && *vci != ATM_VCI_ANY) {
309 err = check_ci(vcc, *vpi, *vci);
310 return err;
311 }
312 /* last scan may have left values out of bounds for current device */
313 if (*vpi != ATM_VPI_ANY)
314 p = *vpi;
315 else if (p >= 1 << vcc->dev->ci_range.vpi_bits)
316 p = 0;
317 if (*vci != ATM_VCI_ANY)
318 c = *vci;
319 else if (c < ATM_NOT_RSV_VCI || c >= 1 << vcc->dev->ci_range.vci_bits)
320 c = ATM_NOT_RSV_VCI;
321 old_p = p;
322 old_c = c;
323 do {
324 if (!check_ci(vcc, p, c)) {
325 *vpi = p;
326 *vci = c;
327 return 0;
328 }
329 if (*vci == ATM_VCI_ANY) {
330 c++;
331 if (c >= 1 << vcc->dev->ci_range.vci_bits)
332 c = ATM_NOT_RSV_VCI;
333 }
334 if ((c == ATM_NOT_RSV_VCI || *vci != ATM_VCI_ANY) &&
335 *vpi == ATM_VPI_ANY) {
336 p++;
337 if (p >= 1 << vcc->dev->ci_range.vpi_bits) p = 0;
338 }
339 }
340 while (old_p != p || old_c != c);
341 return -EADDRINUSE;
342}
343
344
345static int __vcc_connect(struct atm_vcc *vcc, struct atm_dev *dev, short vpi,
346 int vci)
347{
348 struct sock *sk = sk_atm(vcc);
349 int error;
350
351 if ((vpi != ATM_VPI_UNSPEC && vpi != ATM_VPI_ANY &&
352 vpi >> dev->ci_range.vpi_bits) || (vci != ATM_VCI_UNSPEC &&
353 vci != ATM_VCI_ANY && vci >> dev->ci_range.vci_bits))
354 return -EINVAL;
355 if (vci > 0 && vci < ATM_NOT_RSV_VCI && !capable(CAP_NET_BIND_SERVICE))
356 return -EPERM;
64bf69dd 357 error = -ENODEV;
1da177e4 358 if (!try_module_get(dev->ops->owner))
64bf69dd 359 return error;
1da177e4
LT		 360 vcc->dev = dev;
361 write_lock_irq(&vcc_sklist_lock);
64bf69dd
SG		 362 if (test_bit(ATM_DF_REMOVED, &dev->flags) ||
363 (error = find_ci(vcc, &vpi, &vci))) {
1da177e4
LT		 364 write_unlock_irq(&vcc_sklist_lock);
365 goto fail_module_put;
366 }
367 vcc->vpi = vpi;
368 vcc->vci = vci;
369 __vcc_insert_socket(sk);
370 write_unlock_irq(&vcc_sklist_lock);
371 switch (vcc->qos.aal) {
372 case ATM_AAL0:
373 error = atm_init_aal0(vcc);
374 vcc->stats = &dev->stats.aal0;
375 break;
376 case ATM_AAL34:
377 error = atm_init_aal34(vcc);
378 vcc->stats = &dev->stats.aal34;
379 break;
380 case ATM_NO_AAL:
381 /* ATM_AAL5 is also used in the "0 for default" case */
382 vcc->qos.aal = ATM_AAL5;
383 /* fall through */
384 case ATM_AAL5:
385 error = atm_init_aal5(vcc);
386 vcc->stats = &dev->stats.aal5;
387 break;
388 default:
389 error = -EPROTOTYPE;
390 }
391 if (!error) error = adjust_tp(&vcc->qos.txtp,vcc->qos.aal);
392 if (!error) error = adjust_tp(&vcc->qos.rxtp,vcc->qos.aal);
393 if (error)
394 goto fail;
395 DPRINTK("VCC %d.%d, AAL %d\n",vpi,vci,vcc->qos.aal);
396 DPRINTK(" TX: %d, PCR %d..%d, SDU %d\n",vcc->qos.txtp.traffic_class,
397 vcc->qos.txtp.min_pcr,vcc->qos.txtp.max_pcr,vcc->qos.txtp.max_sdu);
398 DPRINTK(" RX: %d, PCR %d..%d, SDU %d\n",vcc->qos.rxtp.traffic_class,
399 vcc->qos.rxtp.min_pcr,vcc->qos.rxtp.max_pcr,vcc->qos.rxtp.max_sdu);
400
401 if (dev->ops->open) {
402 if ((error = dev->ops->open(vcc)))
403 goto fail;
404 }
405 return 0;
406
407fail:
408 vcc_remove_socket(sk);
409fail_module_put:
410 module_put(dev->ops->owner);
411 /* ensure we get dev module ref count correct */
412 vcc->dev = NULL;
413 return error;
414}
415
416
417int vcc_connect(struct socket *sock, int itf, short vpi, int vci)
418{
419 struct atm_dev *dev;
420 struct atm_vcc *vcc = ATM_SD(sock);
421 int error;
422
423 DPRINTK("vcc_connect (vpi %d, vci %d)\n",vpi,vci);
424 if (sock->state == SS_CONNECTED)
425 return -EISCONN;
426 if (sock->state != SS_UNCONNECTED)
427 return -EINVAL;
428 if (!(vpi || vci))
429 return -EINVAL;
430
431 if (vpi != ATM_VPI_UNSPEC && vci != ATM_VCI_UNSPEC)
432 clear_bit(ATM_VF_PARTIAL,&vcc->flags);
433 else
434 if (test_bit(ATM_VF_PARTIAL,&vcc->flags))
435 return -EINVAL;
436 DPRINTK("vcc_connect (TX: cl %d,bw %d-%d,sdu %d; "
437 "RX: cl %d,bw %d-%d,sdu %d,AAL %s%d)\n",
438 vcc->qos.txtp.traffic_class,vcc->qos.txtp.min_pcr,
439 vcc->qos.txtp.max_pcr,vcc->qos.txtp.max_sdu,
440 vcc->qos.rxtp.traffic_class,vcc->qos.rxtp.min_pcr,
441 vcc->qos.rxtp.max_pcr,vcc->qos.rxtp.max_sdu,
442 vcc->qos.aal == ATM_AAL5 ? "" : vcc->qos.aal == ATM_AAL0 ? "" :
443 " ??? code ",vcc->qos.aal == ATM_AAL0 ? 0 : vcc->qos.aal);
444 if (!test_bit(ATM_VF_HASQOS, &vcc->flags))
445 return -EBADFD;
446 if (vcc->qos.txtp.traffic_class == ATM_ANYCLASS ||
447 vcc->qos.rxtp.traffic_class == ATM_ANYCLASS)
448 return -EINVAL;
c9933d08 449 if (likely(itf != ATM_ITF_ANY)) {
50accc9c 450 dev = try_then_request_module(atm_dev_lookup(itf), "atm-device-%d", itf);
1da177e4 451 } else {
1da177e4 452 dev = NULL;
57b47a53 453 mutex_lock(&atm_dev_mutex);
c9933d08
MBJ		 454 if (!list_empty(&atm_devs)) {
455 dev = list_entry(atm_devs.next, struct atm_dev, dev_list);
1da177e4 456 atm_dev_hold(dev);
1da177e4 457 }
57b47a53 458 mutex_unlock(&atm_dev_mutex);
c9933d08
MBJ		 459 }
460 if (!dev)
461 return -ENODEV;
462 error = __vcc_connect(vcc, dev, vpi, vci);
463 if (error) {
464 atm_dev_put(dev);
465 return error;
1da177e4
LT		 466 }
467 if (vpi == ATM_VPI_UNSPEC || vci == ATM_VCI_UNSPEC)
468 set_bit(ATM_VF_PARTIAL,&vcc->flags);
469 if (test_bit(ATM_VF_READY,&ATM_SD(sock)->flags))
470 sock->state = SS_CONNECTED;
471 return 0;
472}
473
474
475int vcc_recvmsg(struct kiocb *iocb, struct socket *sock, struct msghdr *msg,
476 size_t size, int flags)
477{
478 struct sock *sk = sock->sk;
479 struct atm_vcc *vcc;
480 struct sk_buff *skb;
481 int copied, error = -EINVAL;
482
483 if (sock->state != SS_CONNECTED)
484 return -ENOTCONN;
485 if (flags & ~MSG_DONTWAIT) /* only handle MSG_DONTWAIT */
486 return -EOPNOTSUPP;
487 vcc = ATM_SD(sock);
488 if (test_bit(ATM_VF_RELEASED,&vcc->flags) ||
489 test_bit(ATM_VF_CLOSE,&vcc->flags) ||
490 !test_bit(ATM_VF_READY, &vcc->flags))
491 return 0;
492
493 skb = skb_recv_datagram(sk, flags, flags & MSG_DONTWAIT, &error);
494 if (!skb)
495 return error;
496
497 copied = skb->len;
498 if (copied > size) {
499 copied = size;
500 msg->msg_flags |= MSG_TRUNC;
501 }
502
503 error = skb_copy_datagram_iovec(skb, 0, msg->msg_iov, copied);
504 if (error)
505 return error;
506 sock_recv_timestamp(msg, sk, skb);
507 DPRINTK("RcvM %d -= %d\n", atomic_read(&sk->rmem_alloc), skb->truesize);
508 atm_return(vcc, skb->truesize);
509 skb_free_datagram(sk, skb);
510 return copied;
511}
512
513
514int vcc_sendmsg(struct kiocb *iocb, struct socket *sock, struct msghdr *m,
515 size_t total_len)
516{
517 struct sock *sk = sock->sk;
518 DEFINE_WAIT(wait);
519 struct atm_vcc *vcc;
520 struct sk_buff *skb;
521 int eff,error;
522 const void __user *buff;
523 int size;
524
525 lock_sock(sk);
526 if (sock->state != SS_CONNECTED) {
527 error = -ENOTCONN;
528 goto out;
529 }
530 if (m->msg_name) {
531 error = -EISCONN;
532 goto out;
533 }
534 if (m->msg_iovlen != 1) {
535 error = -ENOSYS; /* fix this later @@@ */
536 goto out;
537 }
538 buff = m->msg_iov->iov_base;
539 size = m->msg_iov->iov_len;
540 vcc = ATM_SD(sock);
541 if (test_bit(ATM_VF_RELEASED, &vcc->flags) ||
542 test_bit(ATM_VF_CLOSE, &vcc->flags) ||
543 !test_bit(ATM_VF_READY, &vcc->flags)) {
544 error = -EPIPE;
545 send_sig(SIGPIPE, current, 0);
546 goto out;
547 }
548 if (!size) {
549 error = 0;
550 goto out;
551 }
552 if (size < 0 || size > vcc->qos.txtp.max_sdu) {
553 error = -EMSGSIZE;
554 goto out;
555 }
e49332bd 556
1da177e4
LT		 557 eff = (size+3) & ~3; /* align to word boundary */
558 prepare_to_wait(sk->sk_sleep, &wait, TASK_INTERRUPTIBLE);
559 error = 0;
560 while (!(skb = alloc_tx(vcc,eff))) {
561 if (m->msg_flags & MSG_DONTWAIT) {
562 error = -EAGAIN;
563 break;
564 }
565 schedule();
566 if (signal_pending(current)) {
567 error = -ERESTARTSYS;
568 break;
569 }
570 if (test_bit(ATM_VF_RELEASED,&vcc->flags) ||
571 test_bit(ATM_VF_CLOSE,&vcc->flags) ||
572 !test_bit(ATM_VF_READY,&vcc->flags)) {
573 error = -EPIPE;
574 send_sig(SIGPIPE, current, 0);
575 break;
576 }
577 prepare_to_wait(sk->sk_sleep, &wait, TASK_INTERRUPTIBLE);
578 }
579 finish_wait(sk->sk_sleep, &wait);
580 if (error)
581 goto out;
582 skb->dev = NULL; /* for paths shared with net_device interfaces */
583 ATM_SKB(skb)->atm_options = vcc->atm_options;
584 if (copy_from_user(skb_put(skb,size),buff,size)) {
585 kfree_skb(skb);
586 error = -EFAULT;
587 goto out;
588 }
589 if (eff != size) memset(skb->data+size,0,eff-size);
590 error = vcc->dev->ops->send(vcc,skb);
591 error = error ? error : size;
592out:
593 release_sock(sk);
594 return error;
595}
596
597
598unsigned int vcc_poll(struct file *file, struct socket *sock, poll_table *wait)
599{
600 struct sock *sk = sock->sk;
601 struct atm_vcc *vcc;
602 unsigned int mask;
603
604 poll_wait(file, sk->sk_sleep, wait);
605 mask = 0;
606
607 vcc = ATM_SD(sock);
608
609 /* exceptional events */
610 if (sk->sk_err)
611 mask = POLLERR;
612
613 if (test_bit(ATM_VF_RELEASED, &vcc->flags) ||
614 test_bit(ATM_VF_CLOSE, &vcc->flags))
615 mask |= POLLHUP;
616
617 /* readable? */
618 if (!skb_queue_empty(&sk->sk_receive_queue))
619 mask |= POLLIN | POLLRDNORM;
620
621 /* writable? */
622 if (sock->state == SS_CONNECTING &&
623 test_bit(ATM_VF_WAITING, &vcc->flags))
624 return mask;
625
626 if (vcc->qos.txtp.traffic_class != ATM_NONE &&
627 vcc_writable(sk))
628 mask |= POLLOUT | POLLWRNORM | POLLWRBAND;
629
630 return mask;
631}
632
633
634static int atm_change_qos(struct atm_vcc *vcc,struct atm_qos *qos)
635{
636 int error;
637
638 /*
639 * Don't let the QoS change the already connected AAL type nor the
640 * traffic class.
641 */
642 if (qos->aal != vcc->qos.aal ||
643 qos->rxtp.traffic_class != vcc->qos.rxtp.traffic_class ||
644 qos->txtp.traffic_class != vcc->qos.txtp.traffic_class)
645 return -EINVAL;
646 error = adjust_tp(&qos->txtp,qos->aal);
647 if (!error) error = adjust_tp(&qos->rxtp,qos->aal);
648 if (error) return error;
649 if (!vcc->dev->ops->change_qos) return -EOPNOTSUPP;
650 if (sk_atm(vcc)->sk_family == AF_ATMPVC)
651 return vcc->dev->ops->change_qos(vcc,qos,ATM_MF_SET);
652 return svc_change_qos(vcc,qos);
653}
654
655
656static int check_tp(struct atm_trafprm *tp)
657{
658 /* @@@ Should be merged with adjust_tp */
659 if (!tp->traffic_class || tp->traffic_class == ATM_ANYCLASS) return 0;
660 if (tp->traffic_class != ATM_UBR && !tp->min_pcr && !tp->pcr &&
661 !tp->max_pcr) return -EINVAL;
662 if (tp->min_pcr == ATM_MAX_PCR) return -EINVAL;
663 if (tp->min_pcr && tp->max_pcr && tp->max_pcr != ATM_MAX_PCR &&
664 tp->min_pcr > tp->max_pcr) return -EINVAL;
665 /*
666 * We allow pcr to be outside [min_pcr,max_pcr], because later
667 * adjustment may still push it in the valid range.
668 */
669 return 0;
670}
671
672
673static int check_qos(struct atm_qos *qos)
674{
675 int error;
676
677 if (!qos->txtp.traffic_class && !qos->rxtp.traffic_class)
678 return -EINVAL;
679 if (qos->txtp.traffic_class != qos->rxtp.traffic_class &&
680 qos->txtp.traffic_class && qos->rxtp.traffic_class &&
681 qos->txtp.traffic_class != ATM_ANYCLASS &&
682 qos->rxtp.traffic_class != ATM_ANYCLASS) return -EINVAL;
683 error = check_tp(&qos->txtp);
684 if (error) return error;
685 return check_tp(&qos->rxtp);
686}
687
688int vcc_setsockopt(struct socket *sock, int level, int optname,
689 char __user *optval, int optlen)
690{
691 struct atm_vcc *vcc;
692 unsigned long value;
693 int error;
694
695 if (__SO_LEVEL_MATCH(optname, level) && optlen != __SO_SIZE(optname))
696 return -EINVAL;
697
698 vcc = ATM_SD(sock);
699 switch (optname) {
700 case SO_ATMQOS:
701 {
702 struct atm_qos qos;
703
704 if (copy_from_user(&qos,optval,sizeof(qos)))
705 return -EFAULT;
706 error = check_qos(&qos);
707 if (error) return error;
708 if (sock->state == SS_CONNECTED)
709 return atm_change_qos(vcc,&qos);
710 if (sock->state != SS_UNCONNECTED)
711 return -EBADFD;
712 vcc->qos = qos;
713 set_bit(ATM_VF_HASQOS,&vcc->flags);
714 return 0;
715 }
716 case SO_SETCLP:
717 if (get_user(value,(unsigned long __user *)optval))
718 return -EFAULT;
719 if (value) vcc->atm_options |= ATM_ATMOPT_CLP;
720 else vcc->atm_options &= ~ATM_ATMOPT_CLP;
721 return 0;
722 default:
723 if (level == SOL_SOCKET) return -EINVAL;
724 break;
725 }
726 if (!vcc->dev || !vcc->dev->ops->setsockopt) return -EINVAL;
727 return vcc->dev->ops->setsockopt(vcc,level,optname,optval,optlen);
728}
729
730
731int vcc_getsockopt(struct socket *sock, int level, int optname,
732 char __user *optval, int __user *optlen)
733{
734 struct atm_vcc *vcc;
735 int len;
736
737 if (get_user(len, optlen))
738 return -EFAULT;
739 if (__SO_LEVEL_MATCH(optname, level) && len != __SO_SIZE(optname))
740 return -EINVAL;
741
742 vcc = ATM_SD(sock);
743 switch (optname) {
744 case SO_ATMQOS:
745 if (!test_bit(ATM_VF_HASQOS,&vcc->flags))
746 return -EINVAL;
747 return copy_to_user(optval,&vcc->qos,sizeof(vcc->qos)) ?
748 -EFAULT : 0;
749 case SO_SETCLP:
750 return put_user(vcc->atm_options & ATM_ATMOPT_CLP ? 1 :
751 0,(unsigned long __user *)optval) ? -EFAULT : 0;
752 case SO_ATMPVC:
753 {
754 struct sockaddr_atmpvc pvc;
755
756 if (!vcc->dev ||
757 !test_bit(ATM_VF_ADDR,&vcc->flags))
758 return -ENOTCONN;
759 pvc.sap_family = AF_ATMPVC;
760 pvc.sap_addr.itf = vcc->dev->number;
761 pvc.sap_addr.vpi = vcc->vpi;
762 pvc.sap_addr.vci = vcc->vci;
763 return copy_to_user(optval,&pvc,sizeof(pvc)) ?
764 -EFAULT : 0;
765 }
766 default:
767 if (level == SOL_SOCKET) return -EINVAL;
768 break;
769 }
770 if (!vcc->dev || !vcc->dev->ops->getsockopt) return -EINVAL;
771 return vcc->dev->ops->getsockopt(vcc, level, optname, optval, len);
772}
773
774static int __init atm_init(void)
775{
776 int error;
777
778 if ((error = proto_register(&vcc_proto, 0)) < 0)
779 goto out;
780
781 if ((error = atmpvc_init()) < 0) {
782 printk(KERN_ERR "atmpvc_init() failed with %d\n", error);
783 goto out_unregister_vcc_proto;
784 }
785 if ((error = atmsvc_init()) < 0) {
786 printk(KERN_ERR "atmsvc_init() failed with %d\n", error);
787 goto out_atmpvc_exit;
788 }
789 if ((error = atm_proc_init()) < 0) {
790 printk(KERN_ERR "atm_proc_init() failed with %d\n",error);
791 goto out_atmsvc_exit;
792 }
656d98b0
RK		 793 if ((error = atm_sysfs_init()) < 0) {
794 printk(KERN_ERR "atm_sysfs_init() failed with %d\n",error);
795 goto out_atmproc_exit;
796 }
1da177e4
LT		 797out:
798 return error;
656d98b0
RK		 799out_atmproc_exit:
800 atm_proc_exit();
1da177e4
LT		 801out_atmsvc_exit:
802 atmsvc_exit();
803out_atmpvc_exit:
804 atmsvc_exit();
805out_unregister_vcc_proto:
806 proto_unregister(&vcc_proto);
807 goto out;
808}
809
810static void __exit atm_exit(void)
811{
812 atm_proc_exit();
656d98b0 813 atm_sysfs_exit();
1da177e4
LT		 814 atmsvc_exit();
815 atmpvc_exit();
816 proto_unregister(&vcc_proto);
817}
818
84ff602e
DW		 819subsys_initcall(atm_init);
820
1da177e4
LT		 821module_exit(atm_exit);
822
823MODULE_LICENSE("GPL");
824MODULE_ALIAS_NETPROTO(PF_ATMPVC);
825MODULE_ALIAS_NETPROTO(PF_ATMSVC);
Clone of davem's net-next-2.6 tree