Lines Matching +full:vcc +full:- +full:p
1 // SPDX-License-Identifier: GPL-2.0-only
2 /* net/atm/common.c - ATM sockets (common part for PVC and SVC) */
4 /* Written 1995-2000 by Werner Almesberger, EPFL LRC/ICA */
18 #include <linux/time64.h> /* 64-bit time for seconds */
45 struct atm_vcc *vcc = atm_sk(sk); in __vcc_insert_socket() local
46 struct hlist_head *head = &vcc_hash[vcc->vci & (VCC_HTABLE_SIZE - 1)]; in __vcc_insert_socket()
47 sk->sk_hash = vcc->vci & (VCC_HTABLE_SIZE - 1); in __vcc_insert_socket()
66 static bool vcc_tx_ready(struct atm_vcc *vcc, unsigned int size) in vcc_tx_ready() argument
68 struct sock *sk = sk_atm(vcc); in vcc_tx_ready()
70 if (sk_wmem_alloc_get(sk) && !atm_may_send(vcc, size)) { in vcc_tx_ready()
72 sk_wmem_alloc_get(sk), size, sk->sk_sndbuf); in vcc_tx_ready()
80 if (atomic_read(&sk->sk_rmem_alloc)) in vcc_sock_destruct()
82 __func__, atomic_read(&sk->sk_rmem_alloc)); in vcc_sock_destruct()
84 if (refcount_read(&sk->sk_wmem_alloc)) in vcc_sock_destruct()
86 __func__, refcount_read(&sk->sk_wmem_alloc)); in vcc_sock_destruct()
94 wq = rcu_dereference(sk->sk_wq); in vcc_def_wakeup()
96 wake_up(&wq->wait); in vcc_def_wakeup()
102 struct atm_vcc *vcc = atm_sk(sk); in vcc_writable() local
104 return (vcc->qos.txtp.max_sdu + in vcc_writable()
105 refcount_read(&sk->sk_wmem_alloc)) <= sk->sk_sndbuf; in vcc_writable()
115 wq = rcu_dereference(sk->sk_wq); in vcc_write_space()
117 wake_up_interruptible(&wq->wait); in vcc_write_space()
127 struct atm_vcc *vcc = atm_sk(sk); in vcc_release_cb() local
129 if (vcc->release_cb) in vcc_release_cb()
130 vcc->release_cb(vcc); in vcc_release_cb()
134 .name = "VCC",
143 struct atm_vcc *vcc; in vcc_create() local
145 sock->sk = NULL; in vcc_create()
146 if (sock->type == SOCK_STREAM) in vcc_create()
147 return -EINVAL; in vcc_create()
150 return -ENOMEM; in vcc_create()
152 sk->sk_state_change = vcc_def_wakeup; in vcc_create()
153 sk->sk_write_space = vcc_write_space; in vcc_create()
155 vcc = atm_sk(sk); in vcc_create()
156 vcc->dev = NULL; in vcc_create()
157 memset(&vcc->local, 0, sizeof(struct sockaddr_atmsvc)); in vcc_create()
158 memset(&vcc->remote, 0, sizeof(struct sockaddr_atmsvc)); in vcc_create()
159 vcc->qos.txtp.max_sdu = 1 << 16; /* for meta VCs */ in vcc_create()
160 refcount_set(&sk->sk_wmem_alloc, 1); in vcc_create()
161 atomic_set(&sk->sk_rmem_alloc, 0); in vcc_create()
162 vcc->push = NULL; in vcc_create()
163 vcc->pop = NULL; in vcc_create()
164 vcc->owner = NULL; in vcc_create()
165 vcc->push_oam = NULL; in vcc_create()
166 vcc->release_cb = NULL; in vcc_create()
167 vcc->vpi = vcc->vci = 0; /* no VCI/VPI yet */ in vcc_create()
168 vcc->atm_options = vcc->aal_options = 0; in vcc_create()
169 sk->sk_destruct = vcc_sock_destruct; in vcc_create()
175 struct atm_vcc *vcc = atm_sk(sk); in vcc_destroy_socket() local
178 set_bit(ATM_VF_CLOSE, &vcc->flags); in vcc_destroy_socket()
179 clear_bit(ATM_VF_READY, &vcc->flags); in vcc_destroy_socket()
180 if (vcc->dev && vcc->dev->ops->close) in vcc_destroy_socket()
181 vcc->dev->ops->close(vcc); in vcc_destroy_socket()
182 if (vcc->push) in vcc_destroy_socket()
183 vcc->push(vcc, NULL); /* atmarpd has no push */ in vcc_destroy_socket()
184 module_put(vcc->owner); in vcc_destroy_socket()
186 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) { in vcc_destroy_socket()
187 atm_return(vcc, skb->truesize); in vcc_destroy_socket()
191 if (vcc->dev && vcc->dev->ops->owner) { in vcc_destroy_socket()
192 module_put(vcc->dev->ops->owner); in vcc_destroy_socket()
193 atm_dev_put(vcc->dev); in vcc_destroy_socket()
201 struct sock *sk = sock->sk; in vcc_release()
205 vcc_destroy_socket(sock->sk); in vcc_release()
213 void vcc_release_async(struct atm_vcc *vcc, int reply) in vcc_release_async() argument
215 struct sock *sk = sk_atm(vcc); in vcc_release_async()
217 set_bit(ATM_VF_CLOSE, &vcc->flags); in vcc_release_async()
218 sk->sk_shutdown |= RCV_SHUTDOWN; in vcc_release_async()
219 sk->sk_err = -reply; in vcc_release_async()
220 clear_bit(ATM_VF_WAITING, &vcc->flags); in vcc_release_async()
221 sk->sk_state_change(sk); in vcc_release_async()
225 void vcc_process_recv_queue(struct atm_vcc *vcc) in vcc_process_recv_queue() argument
232 rq = &sk_atm(vcc)->sk_receive_queue; in vcc_process_recv_queue()
234 spin_lock_irqsave(&rq->lock, flags); in vcc_process_recv_queue()
236 spin_unlock_irqrestore(&rq->lock, flags); in vcc_process_recv_queue()
240 vcc->push(vcc, skb); in vcc_process_recv_queue()
247 pr_debug("%s signal=%d dev=%p number=%d dev->signal=%d\n", in atm_dev_signal_change()
248 __func__, signal, dev, dev->number, dev->signal); in atm_dev_signal_change()
253 if (dev->signal == signal) in atm_dev_signal_change()
256 dev->signal = signal; in atm_dev_signal_change()
271 struct atm_vcc *vcc; in atm_dev_release_vccs() local
274 vcc = atm_sk(s); in atm_dev_release_vccs()
275 if (vcc->dev == dev) { in atm_dev_release_vccs()
276 vcc_release_async(vcc, -EPIPE); in atm_dev_release_vccs()
289 if (!tp->traffic_class) in adjust_tp()
293 max_sdu = ATM_CELL_SIZE-1; in adjust_tp()
304 if (!tp->max_sdu) in adjust_tp()
305 tp->max_sdu = max_sdu; in adjust_tp()
306 else if (tp->max_sdu > max_sdu) in adjust_tp()
307 return -EINVAL; in adjust_tp()
308 if (!tp->max_cdv) in adjust_tp()
309 tp->max_cdv = ATM_MAX_CDV; in adjust_tp()
313 static int check_ci(const struct atm_vcc *vcc, short vpi, int vci) in check_ci() argument
315 struct hlist_head *head = &vcc_hash[vci & (VCC_HTABLE_SIZE - 1)]; in check_ci()
321 if (walk->dev != vcc->dev) in check_ci()
323 if (test_bit(ATM_VF_ADDR, &walk->flags) && walk->vpi == vpi && in check_ci()
324 walk->vci == vci && ((walk->qos.txtp.traffic_class != in check_ci()
325 ATM_NONE && vcc->qos.txtp.traffic_class != ATM_NONE) || in check_ci()
326 (walk->qos.rxtp.traffic_class != ATM_NONE && in check_ci()
327 vcc->qos.rxtp.traffic_class != ATM_NONE))) in check_ci()
328 return -EADDRINUSE; in check_ci()
338 static int find_ci(const struct atm_vcc *vcc, short *vpi, int *vci) in find_ci() argument
340 static short p; /* poor man's per-device cache */ in find_ci() local
347 err = check_ci(vcc, *vpi, *vci); in find_ci()
352 p = *vpi; in find_ci()
353 else if (p >= 1 << vcc->dev->ci_range.vpi_bits) in find_ci()
354 p = 0; in find_ci()
357 else if (c < ATM_NOT_RSV_VCI || c >= 1 << vcc->dev->ci_range.vci_bits) in find_ci()
359 old_p = p; in find_ci()
362 if (!check_ci(vcc, p, c)) { in find_ci()
363 *vpi = p; in find_ci()
369 if (c >= 1 << vcc->dev->ci_range.vci_bits) in find_ci()
374 p++; in find_ci()
375 if (p >= 1 << vcc->dev->ci_range.vpi_bits) in find_ci()
376 p = 0; in find_ci()
378 } while (old_p != p || old_c != c); in find_ci()
379 return -EADDRINUSE; in find_ci()
382 static int __vcc_connect(struct atm_vcc *vcc, struct atm_dev *dev, short vpi, in __vcc_connect() argument
385 struct sock *sk = sk_atm(vcc); in __vcc_connect()
389 vpi >> dev->ci_range.vpi_bits) || (vci != ATM_VCI_UNSPEC && in __vcc_connect()
390 vci != ATM_VCI_ANY && vci >> dev->ci_range.vci_bits)) in __vcc_connect()
391 return -EINVAL; in __vcc_connect()
393 return -EPERM; in __vcc_connect()
394 error = -ENODEV; in __vcc_connect()
395 if (!try_module_get(dev->ops->owner)) in __vcc_connect()
397 vcc->dev = dev; in __vcc_connect()
399 if (test_bit(ATM_DF_REMOVED, &dev->flags) || in __vcc_connect()
400 (error = find_ci(vcc, &vpi, &vci))) { in __vcc_connect()
404 vcc->vpi = vpi; in __vcc_connect()
405 vcc->vci = vci; in __vcc_connect()
408 switch (vcc->qos.aal) { in __vcc_connect()
410 error = atm_init_aal0(vcc); in __vcc_connect()
411 vcc->stats = &dev->stats.aal0; in __vcc_connect()
414 error = atm_init_aal34(vcc); in __vcc_connect()
415 vcc->stats = &dev->stats.aal34; in __vcc_connect()
419 vcc->qos.aal = ATM_AAL5; in __vcc_connect()
422 error = atm_init_aal5(vcc); in __vcc_connect()
423 vcc->stats = &dev->stats.aal5; in __vcc_connect()
426 error = -EPROTOTYPE; in __vcc_connect()
429 error = adjust_tp(&vcc->qos.txtp, vcc->qos.aal); in __vcc_connect()
431 error = adjust_tp(&vcc->qos.rxtp, vcc->qos.aal); in __vcc_connect()
434 pr_debug("VCC %d.%d, AAL %d\n", vpi, vci, vcc->qos.aal); in __vcc_connect()
436 vcc->qos.txtp.traffic_class, in __vcc_connect()
437 vcc->qos.txtp.min_pcr, in __vcc_connect()
438 vcc->qos.txtp.max_pcr, in __vcc_connect()
439 vcc->qos.txtp.max_sdu); in __vcc_connect()
441 vcc->qos.rxtp.traffic_class, in __vcc_connect()
442 vcc->qos.rxtp.min_pcr, in __vcc_connect()
443 vcc->qos.rxtp.max_pcr, in __vcc_connect()
444 vcc->qos.rxtp.max_sdu); in __vcc_connect()
446 if (dev->ops->open) { in __vcc_connect()
447 error = dev->ops->open(vcc); in __vcc_connect()
456 module_put(dev->ops->owner); in __vcc_connect()
458 vcc->dev = NULL; in __vcc_connect()
465 struct atm_vcc *vcc = ATM_SD(sock); in vcc_connect() local
469 if (sock->state == SS_CONNECTED) in vcc_connect()
470 return -EISCONN; in vcc_connect()
471 if (sock->state != SS_UNCONNECTED) in vcc_connect()
472 return -EINVAL; in vcc_connect()
474 return -EINVAL; in vcc_connect()
477 clear_bit(ATM_VF_PARTIAL, &vcc->flags); in vcc_connect()
479 if (test_bit(ATM_VF_PARTIAL, &vcc->flags)) in vcc_connect()
480 return -EINVAL; in vcc_connect()
481 pr_debug("(TX: cl %d,bw %d-%d,sdu %d; " in vcc_connect()
482 "RX: cl %d,bw %d-%d,sdu %d,AAL %s%d)\n", in vcc_connect()
483 vcc->qos.txtp.traffic_class, vcc->qos.txtp.min_pcr, in vcc_connect()
484 vcc->qos.txtp.max_pcr, vcc->qos.txtp.max_sdu, in vcc_connect()
485 vcc->qos.rxtp.traffic_class, vcc->qos.rxtp.min_pcr, in vcc_connect()
486 vcc->qos.rxtp.max_pcr, vcc->qos.rxtp.max_sdu, in vcc_connect()
487 vcc->qos.aal == ATM_AAL5 ? "" : in vcc_connect()
488 vcc->qos.aal == ATM_AAL0 ? "" : " ??? code ", in vcc_connect()
489 vcc->qos.aal == ATM_AAL0 ? 0 : vcc->qos.aal); in vcc_connect()
490 if (!test_bit(ATM_VF_HASQOS, &vcc->flags)) in vcc_connect()
491 return -EBADFD; in vcc_connect()
492 if (vcc->qos.txtp.traffic_class == ATM_ANYCLASS || in vcc_connect()
493 vcc->qos.rxtp.traffic_class == ATM_ANYCLASS) in vcc_connect()
494 return -EINVAL; in vcc_connect()
497 "atm-device-%d", itf); in vcc_connect()
509 return -ENODEV; in vcc_connect()
510 error = __vcc_connect(vcc, dev, vpi, vci); in vcc_connect()
516 set_bit(ATM_VF_PARTIAL, &vcc->flags); in vcc_connect()
517 if (test_bit(ATM_VF_READY, &ATM_SD(sock)->flags)) in vcc_connect()
518 sock->state = SS_CONNECTED; in vcc_connect()
525 struct sock *sk = sock->sk; in vcc_recvmsg()
526 struct atm_vcc *vcc; in vcc_recvmsg() local
528 int copied, error = -EINVAL; in vcc_recvmsg()
530 if (sock->state != SS_CONNECTED) in vcc_recvmsg()
531 return -ENOTCONN; in vcc_recvmsg()
535 return -EOPNOTSUPP; in vcc_recvmsg()
537 vcc = ATM_SD(sock); in vcc_recvmsg()
538 if (test_bit(ATM_VF_RELEASED, &vcc->flags) || in vcc_recvmsg()
539 test_bit(ATM_VF_CLOSE, &vcc->flags) || in vcc_recvmsg()
540 !test_bit(ATM_VF_READY, &vcc->flags)) in vcc_recvmsg()
547 copied = skb->len; in vcc_recvmsg()
550 msg->msg_flags |= MSG_TRUNC; in vcc_recvmsg()
559 pr_debug("%d -= %d\n", atomic_read(&sk->sk_rmem_alloc), in vcc_recvmsg()
560 skb->truesize); in vcc_recvmsg()
561 atm_return(vcc, skb->truesize); in vcc_recvmsg()
570 struct sock *sk = sock->sk; in vcc_sendmsg()
572 struct atm_vcc *vcc; in vcc_sendmsg() local
577 if (sock->state != SS_CONNECTED) { in vcc_sendmsg()
578 error = -ENOTCONN; in vcc_sendmsg()
581 if (m->msg_name) { in vcc_sendmsg()
582 error = -EISCONN; in vcc_sendmsg()
585 vcc = ATM_SD(sock); in vcc_sendmsg()
586 if (test_bit(ATM_VF_RELEASED, &vcc->flags) || in vcc_sendmsg()
587 test_bit(ATM_VF_CLOSE, &vcc->flags) || in vcc_sendmsg()
588 !test_bit(ATM_VF_READY, &vcc->flags)) { in vcc_sendmsg()
589 error = -EPIPE; in vcc_sendmsg()
597 if (size > vcc->qos.txtp.max_sdu) { in vcc_sendmsg()
598 error = -EMSGSIZE; in vcc_sendmsg()
605 while (!vcc_tx_ready(vcc, eff)) { in vcc_sendmsg()
606 if (m->msg_flags & MSG_DONTWAIT) { in vcc_sendmsg()
607 error = -EAGAIN; in vcc_sendmsg()
612 error = -ERESTARTSYS; in vcc_sendmsg()
615 if (test_bit(ATM_VF_RELEASED, &vcc->flags) || in vcc_sendmsg()
616 test_bit(ATM_VF_CLOSE, &vcc->flags) || in vcc_sendmsg()
617 !test_bit(ATM_VF_READY, &vcc->flags)) { in vcc_sendmsg()
618 error = -EPIPE; in vcc_sendmsg()
630 error = -ENOMEM; in vcc_sendmsg()
633 pr_debug("%d += %d\n", sk_wmem_alloc_get(sk), skb->truesize); in vcc_sendmsg()
634 atm_account_tx(vcc, skb); in vcc_sendmsg()
636 skb->dev = NULL; /* for paths shared with net_device interfaces */ in vcc_sendmsg()
637 if (!copy_from_iter_full(skb_put(skb, size), size, &m->msg_iter)) { in vcc_sendmsg()
639 error = -EFAULT; in vcc_sendmsg()
643 memset(skb->data + size, 0, eff-size); in vcc_sendmsg()
644 error = vcc->dev->ops->send(vcc, skb); in vcc_sendmsg()
653 struct sock *sk = sock->sk; in vcc_poll()
654 struct atm_vcc *vcc; in vcc_poll() local
660 vcc = ATM_SD(sock); in vcc_poll()
663 if (sk->sk_err) in vcc_poll()
666 if (test_bit(ATM_VF_RELEASED, &vcc->flags) || in vcc_poll()
667 test_bit(ATM_VF_CLOSE, &vcc->flags)) in vcc_poll()
671 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in vcc_poll()
675 if (sock->state == SS_CONNECTING && in vcc_poll()
676 test_bit(ATM_VF_WAITING, &vcc->flags)) in vcc_poll()
679 if (vcc->qos.txtp.traffic_class != ATM_NONE && in vcc_poll()
686 static int atm_change_qos(struct atm_vcc *vcc, struct atm_qos *qos) in atm_change_qos() argument
694 if (qos->aal != vcc->qos.aal || in atm_change_qos()
695 qos->rxtp.traffic_class != vcc->qos.rxtp.traffic_class || in atm_change_qos()
696 qos->txtp.traffic_class != vcc->qos.txtp.traffic_class) in atm_change_qos()
697 return -EINVAL; in atm_change_qos()
698 error = adjust_tp(&qos->txtp, qos->aal); in atm_change_qos()
700 error = adjust_tp(&qos->rxtp, qos->aal); in atm_change_qos()
703 if (!vcc->dev->ops->change_qos) in atm_change_qos()
704 return -EOPNOTSUPP; in atm_change_qos()
705 if (sk_atm(vcc)->sk_family == AF_ATMPVC) in atm_change_qos()
706 return vcc->dev->ops->change_qos(vcc, qos, ATM_MF_SET); in atm_change_qos()
707 return svc_change_qos(vcc, qos); in atm_change_qos()
713 if (!tp->traffic_class || tp->traffic_class == ATM_ANYCLASS) in check_tp()
715 if (tp->traffic_class != ATM_UBR && !tp->min_pcr && !tp->pcr && in check_tp()
716 !tp->max_pcr) in check_tp()
717 return -EINVAL; in check_tp()
718 if (tp->min_pcr == ATM_MAX_PCR) in check_tp()
719 return -EINVAL; in check_tp()
720 if (tp->min_pcr && tp->max_pcr && tp->max_pcr != ATM_MAX_PCR && in check_tp()
721 tp->min_pcr > tp->max_pcr) in check_tp()
722 return -EINVAL; in check_tp()
734 if (!qos->txtp.traffic_class && !qos->rxtp.traffic_class) in check_qos()
735 return -EINVAL; in check_qos()
736 if (qos->txtp.traffic_class != qos->rxtp.traffic_class && in check_qos()
737 qos->txtp.traffic_class && qos->rxtp.traffic_class && in check_qos()
738 qos->txtp.traffic_class != ATM_ANYCLASS && in check_qos()
739 qos->rxtp.traffic_class != ATM_ANYCLASS) in check_qos()
740 return -EINVAL; in check_qos()
741 error = check_tp(&qos->txtp); in check_qos()
744 return check_tp(&qos->rxtp); in check_qos()
750 struct atm_vcc *vcc; in vcc_setsockopt() local
755 return -EINVAL; in vcc_setsockopt()
757 vcc = ATM_SD(sock); in vcc_setsockopt()
764 return -EFAULT; in vcc_setsockopt()
768 if (sock->state == SS_CONNECTED) in vcc_setsockopt()
769 return atm_change_qos(vcc, &qos); in vcc_setsockopt()
770 if (sock->state != SS_UNCONNECTED) in vcc_setsockopt()
771 return -EBADFD; in vcc_setsockopt()
772 vcc->qos = qos; in vcc_setsockopt()
773 set_bit(ATM_VF_HASQOS, &vcc->flags); in vcc_setsockopt()
778 return -EFAULT; in vcc_setsockopt()
780 vcc->atm_options |= ATM_ATMOPT_CLP; in vcc_setsockopt()
782 vcc->atm_options &= ~ATM_ATMOPT_CLP; in vcc_setsockopt()
785 return -EINVAL; in vcc_setsockopt()
792 struct atm_vcc *vcc; in vcc_getsockopt() local
796 return -EFAULT; in vcc_getsockopt()
798 return -EINVAL; in vcc_getsockopt()
800 vcc = ATM_SD(sock); in vcc_getsockopt()
803 if (!test_bit(ATM_VF_HASQOS, &vcc->flags)) in vcc_getsockopt()
804 return -EINVAL; in vcc_getsockopt()
805 return copy_to_user(optval, &vcc->qos, sizeof(vcc->qos)) in vcc_getsockopt()
806 ? -EFAULT : 0; in vcc_getsockopt()
808 return put_user(vcc->atm_options & ATM_ATMOPT_CLP ? 1 : 0, in vcc_getsockopt()
809 (unsigned long __user *)optval) ? -EFAULT : 0; in vcc_getsockopt()
814 if (!vcc->dev || !test_bit(ATM_VF_ADDR, &vcc->flags)) in vcc_getsockopt()
815 return -ENOTCONN; in vcc_getsockopt()
818 pvc.sap_addr.itf = vcc->dev->number; in vcc_getsockopt()
819 pvc.sap_addr.vpi = vcc->vpi; in vcc_getsockopt()
820 pvc.sap_addr.vci = vcc->vci; in vcc_getsockopt()
821 return copy_to_user(optval, &pvc, sizeof(pvc)) ? -EFAULT : 0; in vcc_getsockopt()
824 return -EINVAL; in vcc_getsockopt()