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()
287 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_ioctl() local
291 if (!ap) in ppp_asynctty_ioctl()
297 if (put_user(ppp_channel_index(&ap->chan), p)) in ppp_asynctty_ioctl()
304 if (put_user(ppp_unit_number(&ap->chan), p)) in ppp_asynctty_ioctl()
312 ppp_async_flush_output(ap); in ppp_asynctty_ioctl()
328 ap_put(ap); in ppp_asynctty_ioctl()
344 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_receive() local
347 if (!ap) in ppp_asynctty_receive()
349 spin_lock_irqsave(&ap->recv_lock, flags); in ppp_asynctty_receive()
350 ppp_async_input(ap, buf, cflags, count); in ppp_asynctty_receive()
351 spin_unlock_irqrestore(&ap->recv_lock, flags); in ppp_asynctty_receive()
352 if (!skb_queue_empty(&ap->rqueue)) in ppp_asynctty_receive()
353 tasklet_schedule(&ap->tsk); in ppp_asynctty_receive()
354 ap_put(ap); in ppp_asynctty_receive()
361 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_wakeup() local
364 if (!ap) in ppp_asynctty_wakeup()
366 set_bit(XMIT_WAKEUP, &ap->xmit_flags); in ppp_asynctty_wakeup()
367 tasklet_schedule(&ap->tsk); in ppp_asynctty_wakeup()
368 ap_put(ap); in ppp_asynctty_wakeup()
405 struct asyncppp *ap = chan->private; in ppp_async_ioctl() local
414 val = ap->flags | ap->rbits; in ppp_async_ioctl()
422 ap->flags = val & ~SC_RCV_BITS; in ppp_async_ioctl()
423 spin_lock_irq(&ap->recv_lock); in ppp_async_ioctl()
424 ap->rbits = val & SC_RCV_BITS; in ppp_async_ioctl()
425 spin_unlock_irq(&ap->recv_lock); in ppp_async_ioctl()
430 if (put_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
435 if (get_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
441 if (put_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
446 if (get_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
452 if (copy_to_user(argp, ap->xaccm, sizeof(ap->xaccm))) in ppp_async_ioctl()
461 memcpy(ap->xaccm, accm, sizeof(ap->xaccm)); in ppp_async_ioctl()
466 if (put_user(ap->mru, p)) in ppp_async_ioctl()
475 ap->mru = val; in ppp_async_ioctl()
493 struct asyncppp *ap = from_tasklet(ap, t, tsk); in ppp_async_process() local
497 while ((skb = skb_dequeue(&ap->rqueue)) != NULL) { in ppp_async_process()
499 ppp_input_error(&ap->chan, 0); in ppp_async_process()
500 ppp_input(&ap->chan, skb); in ppp_async_process()
504 if (test_bit(XMIT_WAKEUP, &ap->xmit_flags) && ppp_async_push(ap)) in ppp_async_process()
505 ppp_output_wakeup(&ap->chan); in ppp_async_process()
520 #define PUT_BYTE(ap, buf, c, islcp) do { \ argument
521 if ((islcp && c < 0x20) || (ap->xaccm[c >> 5] & (1 << (c & 0x1f)))) {\
529 ppp_async_encode(struct asyncppp *ap) in ppp_async_encode() argument
536 buf = ap->obuf; in ppp_async_encode()
537 ap->olim = buf; in ppp_async_encode()
538 ap->optr = buf; in ppp_async_encode()
539 i = ap->tpkt_pos; in ppp_async_encode()
540 data = ap->tpkt->data; in ppp_async_encode()
541 count = ap->tpkt->len; in ppp_async_encode()
542 fcs = ap->tfcs; in ppp_async_encode()
554 async_lcp_peek(ap, data, count, 0); in ppp_async_encode()
561 time_after_eq(jiffies, ap->last_xmit + flag_time)) in ppp_async_encode()
563 ap->last_xmit = jiffies; in ppp_async_encode()
569 if ((ap->flags & SC_COMP_AC) == 0 || islcp) { in ppp_async_encode()
570 PUT_BYTE(ap, buf, 0xff, islcp); in ppp_async_encode()
572 PUT_BYTE(ap, buf, 0x03, islcp); in ppp_async_encode()
582 buflim = ap->obuf + OBUFSIZE - 6; in ppp_async_encode()
585 if (i == 1 && c == 0 && (ap->flags & SC_COMP_PROT)) in ppp_async_encode()
588 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
595 ap->olim = buf; in ppp_async_encode()
596 ap->tpkt_pos = i; in ppp_async_encode()
597 ap->tfcs = fcs; in ppp_async_encode()
606 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
608 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
610 ap->olim = buf; in ppp_async_encode()
612 consume_skb(ap->tpkt); in ppp_async_encode()
613 ap->tpkt = NULL; in ppp_async_encode()
630 struct asyncppp *ap = chan->private; in ppp_async_send() local
632 ppp_async_push(ap); in ppp_async_send()
634 if (test_and_set_bit(XMIT_FULL, &ap->xmit_flags)) in ppp_async_send()
636 ap->tpkt = skb; in ppp_async_send()
637 ap->tpkt_pos = 0; in ppp_async_send()
639 ppp_async_push(ap); in ppp_async_send()
647 ppp_async_push(struct asyncppp *ap) in ppp_async_push() argument
650 struct tty_struct *tty = ap->tty; in ppp_async_push()
662 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
664 spin_lock_bh(&ap->xmit_lock); in ppp_async_push()
666 if (test_and_clear_bit(XMIT_WAKEUP, &ap->xmit_flags)) in ppp_async_push()
668 if (!tty_stuffed && ap->optr < ap->olim) { in ppp_async_push()
669 avail = ap->olim - ap->optr; in ppp_async_push()
671 sent = tty->ops->write(tty, ap->optr, avail); in ppp_async_push()
674 ap->optr += sent; in ppp_async_push()
679 if (ap->optr >= ap->olim && ap->tpkt) { in ppp_async_push()
680 if (ppp_async_encode(ap)) { in ppp_async_push()
682 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
696 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
698 if (!(test_bit(XMIT_WAKEUP, &ap->xmit_flags) || in ppp_async_push()
699 (!tty_stuffed && ap->tpkt))) in ppp_async_push()
702 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
705 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
709 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
710 if (ap->tpkt) { in ppp_async_push()
711 kfree_skb(ap->tpkt); in ppp_async_push()
712 ap->tpkt = NULL; in ppp_async_push()
713 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
716 ap->optr = ap->olim; in ppp_async_push()
717 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
727 ppp_async_flush_output(struct asyncppp *ap) in ppp_async_flush_output() argument
731 spin_lock_bh(&ap->xmit_lock); in ppp_async_flush_output()
732 ap->optr = ap->olim; in ppp_async_flush_output()
733 if (ap->tpkt != NULL) { in ppp_async_flush_output()
734 kfree_skb(ap->tpkt); in ppp_async_flush_output()
735 ap->tpkt = NULL; in ppp_async_flush_output()
736 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_flush_output()
739 spin_unlock_bh(&ap->xmit_lock); in ppp_async_flush_output()
741 ppp_output_wakeup(&ap->chan); in ppp_async_flush_output()
750 scan_ordinary(struct asyncppp *ap, const unsigned char *buf, int count) in scan_ordinary() argument
757 (c < 0x20 && (ap->raccm & (1 << c)) != 0)) in scan_ordinary()
765 process_input_packet(struct asyncppp *ap) in process_input_packet() argument
771 skb = ap->rpkt; in process_input_packet()
772 if (ap->state & (SC_TOSS | SC_ESCAPE)) in process_input_packet()
807 async_lcp_peek(ap, p, skb->len, 1); in process_input_packet()
811 skb->cb[0] = ap->state; in process_input_packet()
812 skb_queue_tail(&ap->rqueue, skb); in process_input_packet()
813 ap->rpkt = NULL; in process_input_packet()
814 ap->state = 0; in process_input_packet()
819 ap->state = SC_PREV_ERROR; in process_input_packet()
831 ppp_async_input(struct asyncppp *ap, const unsigned char *buf, in ppp_async_input() argument
839 if (~ap->rbits & SC_RCV_BITS) { in ppp_async_input()
849 ap->rbits |= s; in ppp_async_input()
854 if ((ap->state & SC_ESCAPE) && buf[0] == PPP_ESCAPE) in ppp_async_input()
857 n = scan_ordinary(ap, buf, count); in ppp_async_input()
860 if (flags && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
868 ap->state |= SC_TOSS; in ppp_async_input()
870 } else if (n > 0 && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
872 skb = ap->rpkt; in ppp_async_input()
874 skb = dev_alloc_skb(ap->mru + PPP_HDRLEN + 2); in ppp_async_input()
877 ap->rpkt = skb; in ppp_async_input()
891 ap->state |= SC_TOSS; in ppp_async_input()
894 if (ap->state & SC_ESCAPE) { in ppp_async_input()
896 ap->state &= ~SC_ESCAPE; in ppp_async_input()
906 ap->state |= SC_TOSS; in ppp_async_input()
908 process_input_packet(ap); in ppp_async_input()
910 ap->state |= SC_ESCAPE; in ppp_async_input()
911 } else if (I_IXON(ap->tty)) { in ppp_async_input()
912 if (c == START_CHAR(ap->tty)) in ppp_async_input()
913 start_tty(ap->tty); in ppp_async_input()
914 else if (c == STOP_CHAR(ap->tty)) in ppp_async_input()
915 stop_tty(ap->tty); in ppp_async_input()
929 ap->state |= SC_TOSS; in ppp_async_input()
950 static void async_lcp_peek(struct asyncppp *ap, unsigned char *data, in async_lcp_peek() argument
978 ap->lcp_fcs = fcs; in async_lcp_peek()
983 fcs ^= ap->lcp_fcs; in async_lcp_peek()
984 ap->lcp_fcs = -1; in async_lcp_peek()
999 ap->mru = val; in async_lcp_peek()
1001 ap->chan.mtu = val; in async_lcp_peek()
1006 ap->raccm = val; in async_lcp_peek()
1008 ap->xaccm[0] = val; in async_lcp_peek()