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_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()
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()
285 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_ioctl() local
289 if (!ap) in ppp_asynctty_ioctl()
295 if (put_user(ppp_channel_index(&ap->chan), p)) in ppp_asynctty_ioctl()
302 if (put_user(ppp_unit_number(&ap->chan), p)) in ppp_asynctty_ioctl()
310 ppp_async_flush_output(ap); in ppp_asynctty_ioctl()
326 ap_put(ap); in ppp_asynctty_ioctl()
335 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_receive() local
338 if (!ap) in ppp_asynctty_receive()
340 spin_lock_irqsave(&ap->recv_lock, flags); in ppp_asynctty_receive()
341 ppp_async_input(ap, buf, cflags, count); in ppp_asynctty_receive()
342 spin_unlock_irqrestore(&ap->recv_lock, flags); in ppp_asynctty_receive()
343 if (!skb_queue_empty(&ap->rqueue)) in ppp_asynctty_receive()
344 tasklet_schedule(&ap->tsk); in ppp_asynctty_receive()
345 ap_put(ap); in ppp_asynctty_receive()
352 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_wakeup() local
355 if (!ap) in ppp_asynctty_wakeup()
357 set_bit(XMIT_WAKEUP, &ap->xmit_flags); in ppp_asynctty_wakeup()
358 tasklet_schedule(&ap->tsk); in ppp_asynctty_wakeup()
359 ap_put(ap); in ppp_asynctty_wakeup()
395 struct asyncppp *ap = chan->private; in ppp_async_ioctl() local
404 val = ap->flags | ap->rbits; in ppp_async_ioctl()
412 ap->flags = val & ~SC_RCV_BITS; in ppp_async_ioctl()
413 spin_lock_irq(&ap->recv_lock); in ppp_async_ioctl()
414 ap->rbits = val & SC_RCV_BITS; in ppp_async_ioctl()
415 spin_unlock_irq(&ap->recv_lock); in ppp_async_ioctl()
420 if (put_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
425 if (get_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
431 if (put_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
436 if (get_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
442 if (copy_to_user(argp, ap->xaccm, sizeof(ap->xaccm))) in ppp_async_ioctl()
451 memcpy(ap->xaccm, accm, sizeof(ap->xaccm)); in ppp_async_ioctl()
456 if (put_user(ap->mru, p)) in ppp_async_ioctl()
469 ap->mru = val; in ppp_async_ioctl()
487 struct asyncppp *ap = from_tasklet(ap, t, tsk); in ppp_async_process() local
491 while ((skb = skb_dequeue(&ap->rqueue)) != NULL) { in ppp_async_process()
493 ppp_input_error(&ap->chan, 0); in ppp_async_process()
494 ppp_input(&ap->chan, skb); in ppp_async_process()
498 if (test_bit(XMIT_WAKEUP, &ap->xmit_flags) && ppp_async_push(ap)) in ppp_async_process()
499 ppp_output_wakeup(&ap->chan); in ppp_async_process()
514 #define PUT_BYTE(ap, buf, c, islcp) do { \ argument
515 if ((islcp && c < 0x20) || (ap->xaccm[c >> 5] & (1 << (c & 0x1f)))) {\
523 ppp_async_encode(struct asyncppp *ap) in ppp_async_encode() argument
530 buf = ap->obuf; in ppp_async_encode()
531 ap->olim = buf; in ppp_async_encode()
532 ap->optr = buf; in ppp_async_encode()
533 i = ap->tpkt_pos; in ppp_async_encode()
534 data = ap->tpkt->data; in ppp_async_encode()
535 count = ap->tpkt->len; in ppp_async_encode()
536 fcs = ap->tfcs; in ppp_async_encode()
548 async_lcp_peek(ap, data, count, 0); in ppp_async_encode()
555 time_after_eq(jiffies, ap->last_xmit + flag_time)) in ppp_async_encode()
557 ap->last_xmit = jiffies; in ppp_async_encode()
563 if ((ap->flags & SC_COMP_AC) == 0 || islcp) { in ppp_async_encode()
564 PUT_BYTE(ap, buf, 0xff, islcp); in ppp_async_encode()
566 PUT_BYTE(ap, buf, 0x03, islcp); in ppp_async_encode()
576 buflim = ap->obuf + OBUFSIZE - 6; in ppp_async_encode()
579 if (i == 1 && c == 0 && (ap->flags & SC_COMP_PROT)) in ppp_async_encode()
582 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
589 ap->olim = buf; in ppp_async_encode()
590 ap->tpkt_pos = i; in ppp_async_encode()
591 ap->tfcs = fcs; in ppp_async_encode()
600 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
602 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
604 ap->olim = buf; in ppp_async_encode()
606 consume_skb(ap->tpkt); in ppp_async_encode()
607 ap->tpkt = NULL; in ppp_async_encode()
624 struct asyncppp *ap = chan->private; in ppp_async_send() local
626 ppp_async_push(ap); in ppp_async_send()
628 if (test_and_set_bit(XMIT_FULL, &ap->xmit_flags)) in ppp_async_send()
630 ap->tpkt = skb; in ppp_async_send()
631 ap->tpkt_pos = 0; in ppp_async_send()
633 ppp_async_push(ap); in ppp_async_send()
641 ppp_async_push(struct asyncppp *ap) in ppp_async_push() argument
644 struct tty_struct *tty = ap->tty; in ppp_async_push()
656 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
658 spin_lock_bh(&ap->xmit_lock); in ppp_async_push()
660 if (test_and_clear_bit(XMIT_WAKEUP, &ap->xmit_flags)) in ppp_async_push()
662 if (!tty_stuffed && ap->optr < ap->olim) { in ppp_async_push()
663 avail = ap->olim - ap->optr; in ppp_async_push()
665 sent = tty->ops->write(tty, ap->optr, avail); in ppp_async_push()
668 ap->optr += sent; in ppp_async_push()
673 if (ap->optr >= ap->olim && ap->tpkt) { in ppp_async_push()
674 if (ppp_async_encode(ap)) { in ppp_async_push()
676 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
690 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
692 if (!(test_bit(XMIT_WAKEUP, &ap->xmit_flags) || in ppp_async_push()
693 (!tty_stuffed && ap->tpkt))) in ppp_async_push()
696 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
699 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
703 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
704 if (ap->tpkt) { in ppp_async_push()
705 kfree_skb(ap->tpkt); in ppp_async_push()
706 ap->tpkt = NULL; in ppp_async_push()
707 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
710 ap->optr = ap->olim; in ppp_async_push()
711 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
721 ppp_async_flush_output(struct asyncppp *ap) in ppp_async_flush_output() argument
725 spin_lock_bh(&ap->xmit_lock); in ppp_async_flush_output()
726 ap->optr = ap->olim; in ppp_async_flush_output()
727 if (ap->tpkt != NULL) { in ppp_async_flush_output()
728 kfree_skb(ap->tpkt); in ppp_async_flush_output()
729 ap->tpkt = NULL; in ppp_async_flush_output()
730 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_flush_output()
733 spin_unlock_bh(&ap->xmit_lock); in ppp_async_flush_output()
735 ppp_output_wakeup(&ap->chan); in ppp_async_flush_output()
744 scan_ordinary(struct asyncppp *ap, const unsigned char *buf, int count) in scan_ordinary() argument
751 (c < 0x20 && (ap->raccm & (1 << c)) != 0)) in scan_ordinary()
759 process_input_packet(struct asyncppp *ap) in process_input_packet() argument
765 skb = ap->rpkt; in process_input_packet()
766 if (ap->state & (SC_TOSS | SC_ESCAPE)) in process_input_packet()
801 async_lcp_peek(ap, p, skb->len, 1); in process_input_packet()
805 skb->cb[0] = ap->state; in process_input_packet()
806 skb_queue_tail(&ap->rqueue, skb); in process_input_packet()
807 ap->rpkt = NULL; in process_input_packet()
808 ap->state = 0; in process_input_packet()
813 ap->state = SC_PREV_ERROR; in process_input_packet()
825 ppp_async_input(struct asyncppp *ap, const u8 *buf, const u8 *flags, int count) in ppp_async_input() argument
832 if (~ap->rbits & SC_RCV_BITS) { in ppp_async_input()
842 ap->rbits |= s; in ppp_async_input()
847 if ((ap->state & SC_ESCAPE) && buf[0] == PPP_ESCAPE) in ppp_async_input()
850 n = scan_ordinary(ap, buf, count); in ppp_async_input()
853 if (flags && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
861 ap->state |= SC_TOSS; in ppp_async_input()
863 } else if (n > 0 && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
865 skb = ap->rpkt; in ppp_async_input()
867 skb = dev_alloc_skb(ap->mru + PPP_HDRLEN + 2); in ppp_async_input()
870 ap->rpkt = skb; in ppp_async_input()
884 ap->state |= SC_TOSS; in ppp_async_input()
887 if (ap->state & SC_ESCAPE) { in ppp_async_input()
889 ap->state &= ~SC_ESCAPE; in ppp_async_input()
899 ap->state |= SC_TOSS; in ppp_async_input()
901 process_input_packet(ap); in ppp_async_input()
903 ap->state |= SC_ESCAPE; in ppp_async_input()
904 } else if (I_IXON(ap->tty)) { in ppp_async_input()
905 if (c == START_CHAR(ap->tty)) in ppp_async_input()
906 start_tty(ap->tty); in ppp_async_input()
907 else if (c == STOP_CHAR(ap->tty)) in ppp_async_input()
908 stop_tty(ap->tty); in ppp_async_input()
922 ap->state |= SC_TOSS; in ppp_async_input()
943 static void async_lcp_peek(struct asyncppp *ap, unsigned char *data, in async_lcp_peek() argument
971 ap->lcp_fcs = fcs; in async_lcp_peek()
976 fcs ^= ap->lcp_fcs; in async_lcp_peek()
977 ap->lcp_fcs = -1; in async_lcp_peek()
992 ap->mru = val; in async_lcp_peek()
994 ap->chan.mtu = val; in async_lcp_peek()
999 ap->raccm = val; in async_lcp_peek()
1001 ap->xaccm[0] = val; in async_lcp_peek()