96 static int ppp_async_encode(struct asyncppp *ap);
98 static int ppp_async_push(struct asyncppp *ap);
99 static void ppp_async_flush_output(struct asyncppp *ap);
100 static void ppp_async_input(struct asyncppp *ap, const unsigned char *buf,
106 static void async_lcp_peek(struct asyncppp *ap, unsigned char *data,
134 	struct asyncppp *ap;  in ap_get()  local
137 	ap = tty->disc_data;  in ap_get()
138 	if (ap != NULL)  in ap_get()
139 		refcount_inc(&ap->refcnt);  in ap_get()
141 	return ap;  in ap_get()
144 static void ap_put(struct asyncppp *ap)  in ap_put()  argument
146 	if (refcount_dec_and_test(&ap->refcnt))  in ap_put()
147 		complete(&ap->dead);  in ap_put()
157 	struct asyncppp *ap;  in ppp_asynctty_open()  local
165 	ap = kzalloc(sizeof(*ap), GFP_KERNEL);  in ppp_asynctty_open()
166 	if (!ap)  in ppp_asynctty_open()
170 	ap->tty = tty;  in ppp_asynctty_open()
171 	ap->mru = PPP_MRU;  in ppp_asynctty_open()
172 	spin_lock_init(&ap->xmit_lock);  in ppp_asynctty_open()
173 	spin_lock_init(&ap->recv_lock);  in ppp_asynctty_open()
174 	ap->xaccm[0] = ~0U;  in ppp_asynctty_open()
175 	ap->xaccm[3] = 0x60000000U;  in ppp_asynctty_open()
176 	ap->raccm = ~0U;  in ppp_asynctty_open()
177 	ap->optr = ap->obuf;  in ppp_asynctty_open()
178 	ap->olim = ap->obuf;  in ppp_asynctty_open()
179 	ap->lcp_fcs = -1;  in ppp_asynctty_open()
181 	skb_queue_head_init(&ap->rqueue);  in ppp_asynctty_open()
182 	tasklet_setup(&ap->tsk, ppp_async_process);  in ppp_asynctty_open()
184 	refcount_set(&ap->refcnt, 1);  in ppp_asynctty_open()
185 	init_completion(&ap->dead);  in ppp_asynctty_open()
187 	ap->chan.private = ap;  in ppp_asynctty_open()
188 	ap->chan.ops = &async_ops;  in ppp_asynctty_open()
189 	ap->chan.mtu = PPP_MRU;  in ppp_asynctty_open()
191 	ap->chan.speed = speed;  in ppp_asynctty_open()
192 	err = ppp_register_channel(&ap->chan);  in ppp_asynctty_open()
196 	tty->disc_data = ap;  in ppp_asynctty_open()
201 	kfree(ap);  in ppp_asynctty_open()
217 	struct asyncppp *ap;  in ppp_asynctty_close()  local
220 	ap = tty->disc_data;  in ppp_asynctty_close()
223 	if (!ap)  in ppp_asynctty_close()
227 	 * We have now ensured that nobody can start using ap from now  in ppp_asynctty_close()
233 	if (!refcount_dec_and_test(&ap->refcnt))  in ppp_asynctty_close()
234 		wait_for_completion(&ap->dead);  in ppp_asynctty_close()
235 	tasklet_kill(&ap->tsk);  in ppp_asynctty_close()
237 	ppp_unregister_channel(&ap->chan);  in ppp_asynctty_close()
238 	kfree_skb(ap->rpkt);  in ppp_asynctty_close()
239 	skb_queue_purge(&ap->rqueue);  in ppp_asynctty_close()
240 	kfree_skb(ap->tpkt);  in ppp_asynctty_close()
241 	kfree(ap);  in ppp_asynctty_close()
286 	struct asyncppp *ap = ap_get(tty);  in ppp_asynctty_ioctl()  local
290 	if (!ap)  in ppp_asynctty_ioctl()
296 		if (put_user(ppp_channel_index(&ap->chan), p))  in ppp_asynctty_ioctl()
303 		if (put_user(ppp_unit_number(&ap->chan), p))  in ppp_asynctty_ioctl()
311 			ppp_async_flush_output(ap);  in ppp_asynctty_ioctl()
327 	ap_put(ap);  in ppp_asynctty_ioctl()
343 	struct asyncppp *ap = ap_get(tty);  in ppp_asynctty_receive()  local
346 	if (!ap)  in ppp_asynctty_receive()
348 	spin_lock_irqsave(&ap->recv_lock, flags);  in ppp_asynctty_receive()
349 	ppp_async_input(ap, buf, cflags, count);  in ppp_asynctty_receive()
350 	spin_unlock_irqrestore(&ap->recv_lock, flags);  in ppp_asynctty_receive()
351 	if (!skb_queue_empty(&ap->rqueue))  in ppp_asynctty_receive()
352 		tasklet_schedule(&ap->tsk);  in ppp_asynctty_receive()
353 	ap_put(ap);  in ppp_asynctty_receive()
360 	struct asyncppp *ap = ap_get(tty);  in ppp_asynctty_wakeup()  local
363 	if (!ap)  in ppp_asynctty_wakeup()
365 	set_bit(XMIT_WAKEUP, &ap->xmit_flags);  in ppp_asynctty_wakeup()
366 	tasklet_schedule(&ap->tsk);  in ppp_asynctty_wakeup()
367 	ap_put(ap);  in ppp_asynctty_wakeup()
404 	struct asyncppp *ap = chan->private;  in ppp_async_ioctl()  local
413 		val = ap->flags | ap->rbits;  in ppp_async_ioctl()
421 		ap->flags = val & ~SC_RCV_BITS;  in ppp_async_ioctl()
422 		spin_lock_irq(&ap->recv_lock);  in ppp_async_ioctl()
423 		ap->rbits = val & SC_RCV_BITS;  in ppp_async_ioctl()
424 		spin_unlock_irq(&ap->recv_lock);  in ppp_async_ioctl()
429 		if (put_user(ap->xaccm[0], (u32 __user *)argp))  in ppp_async_ioctl()
434 		if (get_user(ap->xaccm[0], (u32 __user *)argp))  in ppp_async_ioctl()
440 		if (put_user(ap->raccm, (u32 __user *)argp))  in ppp_async_ioctl()
445 		if (get_user(ap->raccm, (u32 __user *)argp))  in ppp_async_ioctl()
451 		if (copy_to_user(argp, ap->xaccm, sizeof(ap->xaccm)))  in ppp_async_ioctl()
460 		memcpy(ap->xaccm, accm, sizeof(ap->xaccm));  in ppp_async_ioctl()
465 		if (put_user(ap->mru, p))  in ppp_async_ioctl()
474 		ap->mru = val;  in ppp_async_ioctl()
492 	struct asyncppp *ap = from_tasklet(ap, t, tsk);  in ppp_async_process()  local
496 	while ((skb = skb_dequeue(&ap->rqueue)) != NULL) {  in ppp_async_process()
498 			ppp_input_error(&ap->chan, 0);  in ppp_async_process()
499 		ppp_input(&ap->chan, skb);  in ppp_async_process()
503 	if (test_bit(XMIT_WAKEUP, &ap->xmit_flags) && ppp_async_push(ap))  in ppp_async_process()
504 		ppp_output_wakeup(&ap->chan);  in ppp_async_process()
515  * Assumes ap->tpkt != 0 on entry.
519 #define PUT_BYTE(ap, buf, c, islcp)	do {		\  argument
520 	if ((islcp && c < 0x20) || (ap->xaccm[c >> 5] & (1 << (c & 0x1f)))) {\
528 ppp_async_encode(struct asyncppp *ap)  in ppp_async_encode()  argument
535 	buf = ap->obuf;  in ppp_async_encode()
536 	ap->olim = buf;  in ppp_async_encode()
537 	ap->optr = buf;  in ppp_async_encode()
538 	i = ap->tpkt_pos;  in ppp_async_encode()
539 	data = ap->tpkt->data;  in ppp_async_encode()
540 	count = ap->tpkt->len;  in ppp_async_encode()
541 	fcs = ap->tfcs;  in ppp_async_encode()
553 			async_lcp_peek(ap, data, count, 0);  in ppp_async_encode()
560 		    time_after_eq(jiffies, ap->last_xmit + flag_time))  in ppp_async_encode()
562 		ap->last_xmit = jiffies;  in ppp_async_encode()
568 		if ((ap->flags & SC_COMP_AC) == 0 || islcp) {  in ppp_async_encode()
569 			PUT_BYTE(ap, buf, 0xff, islcp);  in ppp_async_encode()
571 			PUT_BYTE(ap, buf, 0x03, islcp);  in ppp_async_encode()
581 	buflim = ap->obuf + OBUFSIZE - 6;  in ppp_async_encode()
584 		if (i == 1 && c == 0 && (ap->flags & SC_COMP_PROT))  in ppp_async_encode()
587 		PUT_BYTE(ap, buf, c, islcp);  in ppp_async_encode()
594 		ap->olim = buf;  in ppp_async_encode()
595 		ap->tpkt_pos = i;  in ppp_async_encode()
596 		ap->tfcs = fcs;  in ppp_async_encode()
605 	PUT_BYTE(ap, buf, c, islcp);  in ppp_async_encode()
607 	PUT_BYTE(ap, buf, c, islcp);  in ppp_async_encode()
609 	ap->olim = buf;  in ppp_async_encode()
611 	consume_skb(ap->tpkt);  in ppp_async_encode()
612 	ap->tpkt = NULL;  in ppp_async_encode()
629 	struct asyncppp *ap = chan->private;  in ppp_async_send()  local
631 	ppp_async_push(ap);  in ppp_async_send()
633 	if (test_and_set_bit(XMIT_FULL, &ap->xmit_flags))  in ppp_async_send()
635 	ap->tpkt = skb;  in ppp_async_send()
636 	ap->tpkt_pos = 0;  in ppp_async_send()
638 	ppp_async_push(ap);  in ppp_async_send()
646 ppp_async_push(struct asyncppp *ap)  in ppp_async_push()  argument
649 	struct tty_struct *tty = ap->tty;  in ppp_async_push()
661 	if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags))  in ppp_async_push()
663 	spin_lock_bh(&ap->xmit_lock);  in ppp_async_push()
665 		if (test_and_clear_bit(XMIT_WAKEUP, &ap->xmit_flags))  in ppp_async_push()
667 		if (!tty_stuffed && ap->optr < ap->olim) {  in ppp_async_push()
668 			avail = ap->olim - ap->optr;  in ppp_async_push()
670 			sent = tty->ops->write(tty, ap->optr, avail);  in ppp_async_push()
673 			ap->optr += sent;  in ppp_async_push()
678 		if (ap->optr >= ap->olim && ap->tpkt) {  in ppp_async_push()
679 			if (ppp_async_encode(ap)) {  in ppp_async_push()
680 				/* finished processing ap->tpkt */  in ppp_async_push()
681 				clear_bit(XMIT_FULL, &ap->xmit_flags);  in ppp_async_push()
695 		clear_bit(XMIT_BUSY, &ap->xmit_flags);  in ppp_async_push()
697 		if (!(test_bit(XMIT_WAKEUP, &ap->xmit_flags) ||  in ppp_async_push()
698 		      (!tty_stuffed && ap->tpkt)))  in ppp_async_push()
701 		if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags))  in ppp_async_push()
704 	spin_unlock_bh(&ap->xmit_lock);  in ppp_async_push()
708 	clear_bit(XMIT_BUSY, &ap->xmit_flags);  in ppp_async_push()
709 	if (ap->tpkt) {  in ppp_async_push()
710 		kfree_skb(ap->tpkt);  in ppp_async_push()
711 		ap->tpkt = NULL;  in ppp_async_push()
712 		clear_bit(XMIT_FULL, &ap->xmit_flags);  in ppp_async_push()
715 	ap->optr = ap->olim;  in ppp_async_push()
716 	spin_unlock_bh(&ap->xmit_lock);  in ppp_async_push()
726 ppp_async_flush_output(struct asyncppp *ap)  in ppp_async_flush_output()  argument
730 	spin_lock_bh(&ap->xmit_lock);  in ppp_async_flush_output()
731 	ap->optr = ap->olim;  in ppp_async_flush_output()
732 	if (ap->tpkt != NULL) {  in ppp_async_flush_output()
733 		kfree_skb(ap->tpkt);  in ppp_async_flush_output()
734 		ap->tpkt = NULL;  in ppp_async_flush_output()
735 		clear_bit(XMIT_FULL, &ap->xmit_flags);  in ppp_async_flush_output()
738 	spin_unlock_bh(&ap->xmit_lock);  in ppp_async_flush_output()
740 		ppp_output_wakeup(&ap->chan);  in ppp_async_flush_output()
749 scan_ordinary(struct asyncppp *ap, const unsigned char *buf, int count)  in scan_ordinary()  argument
756 		    (c < 0x20 && (ap->raccm & (1 << c)) != 0))  in scan_ordinary()
764 process_input_packet(struct asyncppp *ap)  in process_input_packet()  argument
770 	skb = ap->rpkt;  in process_input_packet()
771 	if (ap->state & (SC_TOSS | SC_ESCAPE))  in process_input_packet()
806 			async_lcp_peek(ap, p, skb->len, 1);  in process_input_packet()
810 	skb->cb[0] = ap->state;  in process_input_packet()
811 	skb_queue_tail(&ap->rqueue, skb);  in process_input_packet()
812 	ap->rpkt = NULL;  in process_input_packet()
813 	ap->state = 0;  in process_input_packet()
818 	ap->state = SC_PREV_ERROR;  in process_input_packet()
830 ppp_async_input(struct asyncppp *ap, const unsigned char *buf,  in ppp_async_input()  argument
838 	if (~ap->rbits & SC_RCV_BITS) {  in ppp_async_input()
848 		ap->rbits |= s;  in ppp_async_input()
853 		if ((ap->state & SC_ESCAPE) && buf[0] == PPP_ESCAPE)  in ppp_async_input()
856 			n = scan_ordinary(ap, buf, count);  in ppp_async_input()
859 		if (flags && (ap->state & SC_TOSS) == 0) {  in ppp_async_input()
867 			ap->state |= SC_TOSS;  in ppp_async_input()
869 		} else if (n > 0 && (ap->state & SC_TOSS) == 0) {  in ppp_async_input()
871 			skb = ap->rpkt;  in ppp_async_input()
873 				skb = dev_alloc_skb(ap->mru + PPP_HDRLEN + 2);  in ppp_async_input()
876 				ap->rpkt = skb;  in ppp_async_input()
890 				ap->state |= SC_TOSS;  in ppp_async_input()
893 				if (ap->state & SC_ESCAPE) {  in ppp_async_input()
895 					ap->state &= ~SC_ESCAPE;  in ppp_async_input()
905 			ap->state |= SC_TOSS;  in ppp_async_input()
907 			process_input_packet(ap);  in ppp_async_input()
909 			ap->state |= SC_ESCAPE;  in ppp_async_input()
910 		} else if (I_IXON(ap->tty)) {  in ppp_async_input()
911 			if (c == START_CHAR(ap->tty))  in ppp_async_input()
912 				start_tty(ap->tty);  in ppp_async_input()
913 			else if (c == STOP_CHAR(ap->tty))  in ppp_async_input()
914 				stop_tty(ap->tty);  in ppp_async_input()
928 	ap->state |= SC_TOSS;  in ppp_async_input()
949 static void async_lcp_peek(struct asyncppp *ap, unsigned char *data,  in async_lcp_peek()  argument
977 			ap->lcp_fcs = fcs;  in async_lcp_peek()
982 		fcs ^= ap->lcp_fcs;  in async_lcp_peek()
983 		ap->lcp_fcs = -1;  in async_lcp_peek()
998 				ap->mru = val;  in async_lcp_peek()
1000 				ap->chan.mtu = val;  in async_lcp_peek()
1005 				ap->raccm = val;  in async_lcp_peek()
1007 				ap->xaccm[0] = val;  in async_lcp_peek()