Lines Matching refs:ap
100 static int ppp_async_encode(struct asyncppp *ap);
102 static int ppp_async_push(struct asyncppp *ap);
103 static void ppp_async_flush_output(struct asyncppp *ap);
104 static void ppp_async_input(struct asyncppp *ap, const unsigned char *buf,
110 static void async_lcp_peek(struct asyncppp *ap, unsigned char *data,
138 struct asyncppp *ap; in ap_get() local
141 ap = tty->disc_data; in ap_get()
142 if (ap != NULL) in ap_get()
143 atomic_inc(&ap->refcnt); in ap_get()
145 return ap; in ap_get()
148 static void ap_put(struct asyncppp *ap) in ap_put() argument
150 if (atomic_dec_and_test(&ap->refcnt)) in ap_put()
151 up(&ap->dead_sem); in ap_put()
161 struct asyncppp *ap; in ppp_asynctty_open() local
169 ap = kzalloc(sizeof(*ap), GFP_KERNEL); in ppp_asynctty_open()
170 if (!ap) in ppp_asynctty_open()
174 ap->tty = tty; in ppp_asynctty_open()
175 ap->mru = PPP_MRU; in ppp_asynctty_open()
176 spin_lock_init(&ap->xmit_lock); in ppp_asynctty_open()
177 spin_lock_init(&ap->recv_lock); in ppp_asynctty_open()
178 ap->xaccm[0] = ~0U; in ppp_asynctty_open()
179 ap->xaccm[3] = 0x60000000U; in ppp_asynctty_open()
180 ap->raccm = ~0U; in ppp_asynctty_open()
181 ap->optr = ap->obuf; in ppp_asynctty_open()
182 ap->olim = ap->obuf; in ppp_asynctty_open()
183 ap->lcp_fcs = -1; in ppp_asynctty_open()
185 skb_queue_head_init(&ap->rqueue); in ppp_asynctty_open()
186 tasklet_init(&ap->tsk, ppp_async_process, (unsigned long) ap); in ppp_asynctty_open()
188 atomic_set(&ap->refcnt, 1); in ppp_asynctty_open()
189 sema_init(&ap->dead_sem, 0); in ppp_asynctty_open()
191 ap->chan.private = ap; in ppp_asynctty_open()
192 ap->chan.ops = &async_ops; in ppp_asynctty_open()
193 ap->chan.mtu = PPP_MRU; in ppp_asynctty_open()
195 ap->chan.speed = speed; in ppp_asynctty_open()
196 err = ppp_register_channel(&ap->chan); in ppp_asynctty_open()
200 tty->disc_data = ap; in ppp_asynctty_open()
205 kfree(ap); in ppp_asynctty_open()
221 struct asyncppp *ap; in ppp_asynctty_close() local
224 ap = tty->disc_data; in ppp_asynctty_close()
227 if (!ap) in ppp_asynctty_close()
237 if (!atomic_dec_and_test(&ap->refcnt)) in ppp_asynctty_close()
238 down(&ap->dead_sem); in ppp_asynctty_close()
239 tasklet_kill(&ap->tsk); in ppp_asynctty_close()
241 ppp_unregister_channel(&ap->chan); in ppp_asynctty_close()
242 kfree_skb(ap->rpkt); in ppp_asynctty_close()
243 skb_queue_purge(&ap->rqueue); in ppp_asynctty_close()
244 kfree_skb(ap->tpkt); in ppp_asynctty_close()
245 kfree(ap); in ppp_asynctty_close()
291 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_ioctl() local
295 if (!ap) in ppp_asynctty_ioctl()
301 if (put_user(ppp_channel_index(&ap->chan), p)) in ppp_asynctty_ioctl()
308 if (put_user(ppp_unit_number(&ap->chan), p)) in ppp_asynctty_ioctl()
316 ppp_async_flush_output(ap); in ppp_asynctty_ioctl()
332 ap_put(ap); in ppp_asynctty_ioctl()
348 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_receive() local
351 if (!ap) in ppp_asynctty_receive()
353 spin_lock_irqsave(&ap->recv_lock, flags); in ppp_asynctty_receive()
354 ppp_async_input(ap, buf, cflags, count); in ppp_asynctty_receive()
355 spin_unlock_irqrestore(&ap->recv_lock, flags); in ppp_asynctty_receive()
356 if (!skb_queue_empty(&ap->rqueue)) in ppp_asynctty_receive()
357 tasklet_schedule(&ap->tsk); in ppp_asynctty_receive()
358 ap_put(ap); in ppp_asynctty_receive()
365 struct asyncppp *ap = ap_get(tty); in ppp_asynctty_wakeup() local
368 if (!ap) in ppp_asynctty_wakeup()
370 set_bit(XMIT_WAKEUP, &ap->xmit_flags); in ppp_asynctty_wakeup()
371 tasklet_schedule(&ap->tsk); in ppp_asynctty_wakeup()
372 ap_put(ap); in ppp_asynctty_wakeup()
409 struct asyncppp *ap = chan->private; in ppp_async_ioctl() local
418 val = ap->flags | ap->rbits; in ppp_async_ioctl()
426 ap->flags = val & ~SC_RCV_BITS; in ppp_async_ioctl()
427 spin_lock_irq(&ap->recv_lock); in ppp_async_ioctl()
428 ap->rbits = val & SC_RCV_BITS; in ppp_async_ioctl()
429 spin_unlock_irq(&ap->recv_lock); in ppp_async_ioctl()
434 if (put_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
439 if (get_user(ap->xaccm[0], (u32 __user *)argp)) in ppp_async_ioctl()
445 if (put_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
450 if (get_user(ap->raccm, (u32 __user *)argp)) in ppp_async_ioctl()
456 if (copy_to_user(argp, ap->xaccm, sizeof(ap->xaccm))) in ppp_async_ioctl()
465 memcpy(ap->xaccm, accm, sizeof(ap->xaccm)); in ppp_async_ioctl()
470 if (put_user(ap->mru, p)) in ppp_async_ioctl()
479 ap->mru = val; in ppp_async_ioctl()
497 struct asyncppp *ap = (struct asyncppp *) arg; in ppp_async_process() local
501 while ((skb = skb_dequeue(&ap->rqueue)) != NULL) { in ppp_async_process()
503 ppp_input_error(&ap->chan, 0); in ppp_async_process()
504 ppp_input(&ap->chan, skb); in ppp_async_process()
508 if (test_bit(XMIT_WAKEUP, &ap->xmit_flags) && ppp_async_push(ap)) in ppp_async_process()
509 ppp_output_wakeup(&ap->chan); in ppp_async_process()
524 #define PUT_BYTE(ap, buf, c, islcp) do { \ argument
525 if ((islcp && c < 0x20) || (ap->xaccm[c >> 5] & (1 << (c & 0x1f)))) {\
533 ppp_async_encode(struct asyncppp *ap) in ppp_async_encode() argument
540 buf = ap->obuf; in ppp_async_encode()
541 ap->olim = buf; in ppp_async_encode()
542 ap->optr = buf; in ppp_async_encode()
543 i = ap->tpkt_pos; in ppp_async_encode()
544 data = ap->tpkt->data; in ppp_async_encode()
545 count = ap->tpkt->len; in ppp_async_encode()
546 fcs = ap->tfcs; in ppp_async_encode()
558 async_lcp_peek(ap, data, count, 0); in ppp_async_encode()
565 time_after_eq(jiffies, ap->last_xmit + flag_time)) in ppp_async_encode()
567 ap->last_xmit = jiffies; in ppp_async_encode()
573 if ((ap->flags & SC_COMP_AC) == 0 || islcp) { in ppp_async_encode()
574 PUT_BYTE(ap, buf, 0xff, islcp); in ppp_async_encode()
576 PUT_BYTE(ap, buf, 0x03, islcp); in ppp_async_encode()
586 buflim = ap->obuf + OBUFSIZE - 6; in ppp_async_encode()
589 if (i == 1 && c == 0 && (ap->flags & SC_COMP_PROT)) in ppp_async_encode()
592 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
599 ap->olim = buf; in ppp_async_encode()
600 ap->tpkt_pos = i; in ppp_async_encode()
601 ap->tfcs = fcs; in ppp_async_encode()
610 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
612 PUT_BYTE(ap, buf, c, islcp); in ppp_async_encode()
614 ap->olim = buf; in ppp_async_encode()
616 consume_skb(ap->tpkt); in ppp_async_encode()
617 ap->tpkt = NULL; in ppp_async_encode()
634 struct asyncppp *ap = chan->private; in ppp_async_send() local
636 ppp_async_push(ap); in ppp_async_send()
638 if (test_and_set_bit(XMIT_FULL, &ap->xmit_flags)) in ppp_async_send()
640 ap->tpkt = skb; in ppp_async_send()
641 ap->tpkt_pos = 0; in ppp_async_send()
643 ppp_async_push(ap); in ppp_async_send()
651 ppp_async_push(struct asyncppp *ap) in ppp_async_push() argument
654 struct tty_struct *tty = ap->tty; in ppp_async_push()
666 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
668 spin_lock_bh(&ap->xmit_lock); in ppp_async_push()
670 if (test_and_clear_bit(XMIT_WAKEUP, &ap->xmit_flags)) in ppp_async_push()
672 if (!tty_stuffed && ap->optr < ap->olim) { in ppp_async_push()
673 avail = ap->olim - ap->optr; in ppp_async_push()
675 sent = tty->ops->write(tty, ap->optr, avail); in ppp_async_push()
678 ap->optr += sent; in ppp_async_push()
683 if (ap->optr >= ap->olim && ap->tpkt) { in ppp_async_push()
684 if (ppp_async_encode(ap)) { in ppp_async_push()
686 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
700 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
702 if (!(test_bit(XMIT_WAKEUP, &ap->xmit_flags) || in ppp_async_push()
703 (!tty_stuffed && ap->tpkt))) in ppp_async_push()
706 if (test_and_set_bit(XMIT_BUSY, &ap->xmit_flags)) in ppp_async_push()
709 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
713 clear_bit(XMIT_BUSY, &ap->xmit_flags); in ppp_async_push()
714 if (ap->tpkt) { in ppp_async_push()
715 kfree_skb(ap->tpkt); in ppp_async_push()
716 ap->tpkt = NULL; in ppp_async_push()
717 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_push()
720 ap->optr = ap->olim; in ppp_async_push()
721 spin_unlock_bh(&ap->xmit_lock); in ppp_async_push()
731 ppp_async_flush_output(struct asyncppp *ap) in ppp_async_flush_output() argument
735 spin_lock_bh(&ap->xmit_lock); in ppp_async_flush_output()
736 ap->optr = ap->olim; in ppp_async_flush_output()
737 if (ap->tpkt != NULL) { in ppp_async_flush_output()
738 kfree_skb(ap->tpkt); in ppp_async_flush_output()
739 ap->tpkt = NULL; in ppp_async_flush_output()
740 clear_bit(XMIT_FULL, &ap->xmit_flags); in ppp_async_flush_output()
743 spin_unlock_bh(&ap->xmit_lock); in ppp_async_flush_output()
745 ppp_output_wakeup(&ap->chan); in ppp_async_flush_output()
754 scan_ordinary(struct asyncppp *ap, const unsigned char *buf, int count) in scan_ordinary() argument
761 (c < 0x20 && (ap->raccm & (1 << c)) != 0)) in scan_ordinary()
769 process_input_packet(struct asyncppp *ap) in process_input_packet() argument
775 skb = ap->rpkt; in process_input_packet()
776 if (ap->state & (SC_TOSS | SC_ESCAPE)) in process_input_packet()
811 async_lcp_peek(ap, p, skb->len, 1); in process_input_packet()
815 skb->cb[0] = ap->state; in process_input_packet()
816 skb_queue_tail(&ap->rqueue, skb); in process_input_packet()
817 ap->rpkt = NULL; in process_input_packet()
818 ap->state = 0; in process_input_packet()
823 ap->state = SC_PREV_ERROR; in process_input_packet()
835 ppp_async_input(struct asyncppp *ap, const unsigned char *buf, in ppp_async_input() argument
843 if (~ap->rbits & SC_RCV_BITS) { in ppp_async_input()
853 ap->rbits |= s; in ppp_async_input()
858 if ((ap->state & SC_ESCAPE) && buf[0] == PPP_ESCAPE) in ppp_async_input()
861 n = scan_ordinary(ap, buf, count); in ppp_async_input()
864 if (flags && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
872 ap->state |= SC_TOSS; in ppp_async_input()
874 } else if (n > 0 && (ap->state & SC_TOSS) == 0) { in ppp_async_input()
876 skb = ap->rpkt; in ppp_async_input()
878 skb = dev_alloc_skb(ap->mru + PPP_HDRLEN + 2); in ppp_async_input()
881 ap->rpkt = skb; in ppp_async_input()
895 ap->state |= SC_TOSS; in ppp_async_input()
899 if (ap->state & SC_ESCAPE) { in ppp_async_input()
901 ap->state &= ~SC_ESCAPE; in ppp_async_input()
911 ap->state |= SC_TOSS; in ppp_async_input()
913 process_input_packet(ap); in ppp_async_input()
915 ap->state |= SC_ESCAPE; in ppp_async_input()
916 } else if (I_IXON(ap->tty)) { in ppp_async_input()
917 if (c == START_CHAR(ap->tty)) in ppp_async_input()
918 start_tty(ap->tty); in ppp_async_input()
919 else if (c == STOP_CHAR(ap->tty)) in ppp_async_input()
920 stop_tty(ap->tty); in ppp_async_input()
934 ap->state |= SC_TOSS; in ppp_async_input()
955 static void async_lcp_peek(struct asyncppp *ap, unsigned char *data, in async_lcp_peek() argument
983 ap->lcp_fcs = fcs; in async_lcp_peek()
988 fcs ^= ap->lcp_fcs; in async_lcp_peek()
989 ap->lcp_fcs = -1; in async_lcp_peek()
1004 ap->mru = val; in async_lcp_peek()
1006 ap->chan.mtu = val; in async_lcp_peek()
1011 ap->raccm = val; in async_lcp_peek()
1013 ap->xaccm[0] = val; in async_lcp_peek()