Lines Matching refs:ap
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_init(&ap->tsk, ppp_async_process, (unsigned long) ap); 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()
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()
288 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_ioctl() local
292 if (!ap) in ppp_asynctty_ioctl()
298 if (put_user(ppp_channel_index(&ap->chan), p)) in ppp_asynctty_ioctl()
305 if (put_user(ppp_unit_number(&ap->chan), p)) in ppp_asynctty_ioctl()
313 ppp_async_flush_output(ap); in ppp_asynctty_ioctl()
329 ap_put(ap); in ppp_asynctty_ioctl()
345 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_receive() local
348 if (!ap) in ppp_asynctty_receive()
350 spin_lock_irqsave(&ap->recv_lock, flags); in ppp_asynctty_receive()
351 ppp_async_input(ap, buf, cflags, count); in ppp_asynctty_receive()
352 spin_unlock_irqrestore(&ap->recv_lock, flags); in ppp_asynctty_receive()
353 if (!skb_queue_empty(&ap->rqueue)) in ppp_asynctty_receive()
354 tasklet_schedule(&ap->tsk); in ppp_asynctty_receive()
355 ap_put(ap); in ppp_asynctty_receive()
362 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_wakeup() local
365 if (!ap) in ppp_asynctty_wakeup()
367 set_bit(XMIT_WAKEUP, &ap->xmit_flags); in ppp_asynctty_wakeup()
368 tasklet_schedule(&ap->tsk); in ppp_asynctty_wakeup()
369 ap_put(ap); in ppp_asynctty_wakeup()
406 struct asyncppp *ap = chan->private; in ppp_async_ioctl() local
415 val = ap->flags | ap->rbits; in ppp_async_ioctl()
423 ap->flags = val & ~SC_RCV_BITS; in ppp_async_ioctl()
424 spin_lock_irq(&ap->recv_lock); in ppp_async_ioctl()
425 ap->rbits = val & SC_RCV_BITS; in ppp_async_ioctl()
426 spin_unlock_irq(&ap->recv_lock); in ppp_async_ioctl()
431 if (put_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
436 if (get_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
442 if (put_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
447 if (get_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
453 if (copy_to_user(argp, ap->xaccm, sizeof(ap->xaccm))) in ppp_async_ioctl()
462 memcpy(ap->xaccm, accm, sizeof(ap->xaccm)); in ppp_async_ioctl()
467 if (put_user(ap->mru, p)) in ppp_async_ioctl()
476 ap->mru = val; in ppp_async_ioctl()
494 struct asyncppp *ap = (struct asyncppp *) arg; in ppp_async_process() local
498 while ((skb = skb_dequeue(&ap->rqueue)) != NULL) { in ppp_async_process()
500 ppp_input_error(&ap->chan, 0); in ppp_async_process()
501 ppp_input(&ap->chan, skb); in ppp_async_process()
505 if (test_bit(XMIT_WAKEUP, &ap->xmit_flags) && ppp_async_push(ap)) in ppp_async_process()
506 ppp_output_wakeup(&ap->chan); in ppp_async_process()
521 #define PUT_BYTE(ap, buf, c, islcp) do { \ argument
522 if ((islcp && c < 0x20) || (ap->xaccm[c >> 5] & (1 << (c & 0x1f)))) {\
530 ppp_async_encode(struct asyncppp *ap) in ppp_async_encode() argument
537 buf = ap->obuf; in ppp_async_encode()
538 ap->olim = buf; in ppp_async_encode()
539 ap->optr = buf; in ppp_async_encode()
540 i = ap->tpkt_pos; in ppp_async_encode()
541 data = ap->tpkt->data; in ppp_async_encode()
542 count = ap->tpkt->len; in ppp_async_encode()
543 fcs = ap->tfcs; in ppp_async_encode()
555 async_lcp_peek(ap, data, count, 0); in ppp_async_encode()
562 time_after_eq(jiffies, ap->last_xmit + flag_time)) in ppp_async_encode()
564 ap->last_xmit = jiffies; in ppp_async_encode()
570 if ((ap->flags & SC_COMP_AC) == 0 || islcp) { in ppp_async_encode()
571 PUT_BYTE(ap, buf, 0xff, islcp); in ppp_async_encode()
573 PUT_BYTE(ap, buf, 0x03, islcp); in ppp_async_encode()
583 buflim = ap->obuf + OBUFSIZE - 6; in ppp_async_encode()
586 if (i == 1 && c == 0 && (ap->flags & SC_COMP_PROT)) in ppp_async_encode()
589 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
596 ap->olim = buf; in ppp_async_encode()
597 ap->tpkt_pos = i; in ppp_async_encode()
598 ap->tfcs = fcs; in ppp_async_encode()
607 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
609 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
611 ap->olim = buf; in ppp_async_encode()
613 consume_skb(ap->tpkt); in ppp_async_encode()
614 ap->tpkt = NULL; in ppp_async_encode()
631 struct asyncppp *ap = chan->private; in ppp_async_send() local
633 ppp_async_push(ap); in ppp_async_send()
635 if (test_and_set_bit(XMIT_FULL, &ap->xmit_flags)) in ppp_async_send()
637 ap->tpkt = skb; in ppp_async_send()
638 ap->tpkt_pos = 0; in ppp_async_send()
640 ppp_async_push(ap); in ppp_async_send()
648 ppp_async_push(struct asyncppp *ap) in ppp_async_push() argument
651 struct tty_struct *tty = ap->tty; in ppp_async_push()
663 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
665 spin_lock_bh(&ap->xmit_lock); in ppp_async_push()
667 if (test_and_clear_bit(XMIT_WAKEUP, &ap->xmit_flags)) in ppp_async_push()
669 if (!tty_stuffed && ap->optr < ap->olim) { in ppp_async_push()
670 avail = ap->olim - ap->optr; in ppp_async_push()
672 sent = tty->ops->write(tty, ap->optr, avail); in ppp_async_push()
675 ap->optr += sent; in ppp_async_push()
680 if (ap->optr >= ap->olim && ap->tpkt) { in ppp_async_push()
681 if (ppp_async_encode(ap)) { in ppp_async_push()
683 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
697 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
699 if (!(test_bit(XMIT_WAKEUP, &ap->xmit_flags) || in ppp_async_push()
700 (!tty_stuffed && ap->tpkt))) in ppp_async_push()
703 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
706 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
710 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
711 if (ap->tpkt) { in ppp_async_push()
712 kfree_skb(ap->tpkt); in ppp_async_push()
713 ap->tpkt = NULL; in ppp_async_push()
714 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
717 ap->optr = ap->olim; in ppp_async_push()
718 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
728 ppp_async_flush_output(struct asyncppp *ap) in ppp_async_flush_output() argument
732 spin_lock_bh(&ap->xmit_lock); in ppp_async_flush_output()
733 ap->optr = ap->olim; in ppp_async_flush_output()
734 if (ap->tpkt != NULL) { in ppp_async_flush_output()
735 kfree_skb(ap->tpkt); in ppp_async_flush_output()
736 ap->tpkt = NULL; in ppp_async_flush_output()
737 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_flush_output()
740 spin_unlock_bh(&ap->xmit_lock); in ppp_async_flush_output()
742 ppp_output_wakeup(&ap->chan); in ppp_async_flush_output()
751 scan_ordinary(struct asyncppp *ap, const unsigned char *buf, int count) in scan_ordinary() argument
758 (c < 0x20 && (ap->raccm & (1 << c)) != 0)) in scan_ordinary()
766 process_input_packet(struct asyncppp *ap) in process_input_packet() argument
772 skb = ap->rpkt; in process_input_packet()
773 if (ap->state & (SC_TOSS | SC_ESCAPE)) in process_input_packet()
808 async_lcp_peek(ap, p, skb->len, 1); in process_input_packet()
812 skb->cb[0] = ap->state; in process_input_packet()
813 skb_queue_tail(&ap->rqueue, skb); in process_input_packet()
814 ap->rpkt = NULL; in process_input_packet()
815 ap->state = 0; in process_input_packet()
820 ap->state = SC_PREV_ERROR; in process_input_packet()
832 ppp_async_input(struct asyncppp *ap, const unsigned char *buf, in ppp_async_input() argument
840 if (~ap->rbits & SC_RCV_BITS) { in ppp_async_input()
850 ap->rbits |= s; in ppp_async_input()
855 if ((ap->state & SC_ESCAPE) && buf[0] == PPP_ESCAPE) in ppp_async_input()
858 n = scan_ordinary(ap, buf, count); in ppp_async_input()
861 if (flags && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
869 ap->state |= SC_TOSS; in ppp_async_input()
871 } else if (n > 0 && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
873 skb = ap->rpkt; in ppp_async_input()
875 skb = dev_alloc_skb(ap->mru + PPP_HDRLEN + 2); in ppp_async_input()
878 ap->rpkt = skb; in ppp_async_input()
892 ap->state |= SC_TOSS; in ppp_async_input()
895 if (ap->state & SC_ESCAPE) { in ppp_async_input()
897 ap->state &= ~SC_ESCAPE; in ppp_async_input()
907 ap->state |= SC_TOSS; in ppp_async_input()
909 process_input_packet(ap); in ppp_async_input()
911 ap->state |= SC_ESCAPE; in ppp_async_input()
912 } else if (I_IXON(ap->tty)) { in ppp_async_input()
913 if (c == START_CHAR(ap->tty)) in ppp_async_input()
914 start_tty(ap->tty); in ppp_async_input()
915 else if (c == STOP_CHAR(ap->tty)) in ppp_async_input()
916 stop_tty(ap->tty); in ppp_async_input()
930 ap->state |= SC_TOSS; in ppp_async_input()
951 static void async_lcp_peek(struct asyncppp *ap, unsigned char *data, in async_lcp_peek() argument
979 ap->lcp_fcs = fcs; in async_lcp_peek()
984 fcs ^= ap->lcp_fcs; in async_lcp_peek()
985 ap->lcp_fcs = -1; in async_lcp_peek()
1000 ap->mru = val; in async_lcp_peek()
1002 ap->chan.mtu = val; in async_lcp_peek()
1007 ap->raccm = val; in async_lcp_peek()
1009 ap->xaccm[0] = val; in async_lcp_peek()