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()
102 	struct atm_vcc *vcc = atm_sk(sk);  in vcc_writable()  local
104 	return (vcc->qos.txtp.max_sdu +  in vcc_writable()
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()
143 	struct atm_vcc *vcc;  in vcc_create()  local
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()
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()
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()
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()
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()
220 	clear_bit(ATM_VF_WAITING, &vcc->flags);  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()
240 		vcc->push(vcc, skb);  in vcc_process_recv_queue()
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()
313 static int check_ci(const struct atm_vcc *vcc, short vpi, int vci)  in check_ci()  argument
321 		if (walk->dev != vcc->dev)  in check_ci()
325 		    ATM_NONE && vcc->qos.txtp.traffic_class != ATM_NONE) ||  in check_ci()
327 		    vcc->qos.rxtp.traffic_class != ATM_NONE)))  in check_ci()
338 static int find_ci(const struct atm_vcc *vcc, short *vpi, int *vci)  in find_ci()  argument
347 		err = check_ci(vcc, *vpi, *vci);  in find_ci()
353 	else if (p >= 1 << vcc->dev->ci_range.vpi_bits)  in find_ci()
357 	else if (c < ATM_NOT_RSV_VCI || c >= 1 << vcc->dev->ci_range.vci_bits)  in find_ci()
362 		if (!check_ci(vcc, p, c)) {  in find_ci()
369 			if (c >= 1 << vcc->dev->ci_range.vci_bits)  in find_ci()
375 			if (p >= 1 << vcc->dev->ci_range.vpi_bits)  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()
397 	vcc->dev = dev;  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()
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()
447 		error = dev->ops->open(vcc);  in __vcc_connect()
458 	vcc->dev = NULL;  in __vcc_connect()
465 	struct atm_vcc *vcc = ATM_SD(sock);  in vcc_connect()  local
477 		clear_bit(ATM_VF_PARTIAL, &vcc->flags);  in vcc_connect()
479 		if (test_bit(ATM_VF_PARTIAL, &vcc->flags))  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()
492 	if (vcc->qos.txtp.traffic_class == ATM_ANYCLASS ||  in vcc_connect()
493 	    vcc->qos.rxtp.traffic_class == ATM_ANYCLASS)  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()
526 	struct atm_vcc *vcc;  in vcc_recvmsg()  local
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()
561 		atm_return(vcc, skb->truesize);  in vcc_recvmsg()
572 	struct atm_vcc *vcc;  in vcc_sendmsg()  local
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()
597 	if (size > vcc->qos.txtp.max_sdu) {  in vcc_sendmsg()
605 	while (!vcc_tx_ready(vcc, eff)) {  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()
634 	atm_account_tx(vcc, skb);  in vcc_sendmsg()
644 	error = vcc->dev->ops->send(vcc, skb);  in vcc_sendmsg()
654 	struct atm_vcc *vcc;  in vcc_poll()  local
660 	vcc = ATM_SD(sock);  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()
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()
703 	if (!vcc->dev->ops->change_qos)  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()
750 	struct atm_vcc *vcc;  in vcc_setsockopt()  local
757 	vcc = ATM_SD(sock);  in vcc_setsockopt()
769 			return atm_change_qos(vcc, &qos);  in vcc_setsockopt()
772 		vcc->qos = qos;  in vcc_setsockopt()
773 		set_bit(ATM_VF_HASQOS, &vcc->flags);  in vcc_setsockopt()
780 			vcc->atm_options |= ATM_ATMOPT_CLP;  in vcc_setsockopt()
782 			vcc->atm_options &= ~ATM_ATMOPT_CLP;  in vcc_setsockopt()
792 	struct atm_vcc *vcc;  in vcc_getsockopt()  local
800 	vcc = ATM_SD(sock);  in vcc_getsockopt()
803 		if (!test_bit(ATM_VF_HASQOS, &vcc->flags))  in vcc_getsockopt()
805 		return copy_to_user(optval, &vcc->qos, sizeof(vcc->qos))  in vcc_getsockopt()
808 		return put_user(vcc->atm_options & ATM_ATMOPT_CLP ? 1 : 0,  in vcc_getsockopt()
814 		if (!vcc->dev || !test_bit(ATM_VF_ADDR, &vcc->flags))  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()