net/atm/common.c

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