Lines Matching refs:mp
167 static int capincci_add_ack(struct capiminor *mp, u16 datahandle) in capincci_add_ack() argument
179 spin_lock_irqsave(&mp->ackqlock, flags); in capincci_add_ack()
180 list_add_tail(&n->list, &mp->ackqueue); in capincci_add_ack()
181 mp->nack++; in capincci_add_ack()
182 spin_unlock_irqrestore(&mp->ackqlock, flags); in capincci_add_ack()
186 static int capiminor_del_ack(struct capiminor *mp, u16 datahandle) in capiminor_del_ack() argument
191 spin_lock_irqsave(&mp->ackqlock, flags); in capiminor_del_ack()
192 list_for_each_entry_safe(p, tmp, &mp->ackqueue, list) { in capiminor_del_ack()
196 mp->nack--; in capiminor_del_ack()
197 spin_unlock_irqrestore(&mp->ackqlock, flags); in capiminor_del_ack()
201 spin_unlock_irqrestore(&mp->ackqlock, flags); in capiminor_del_ack()
205 static void capiminor_del_all_ack(struct capiminor *mp) in capiminor_del_all_ack() argument
210 spin_lock_irqsave(&mp->ackqlock, flags); in capiminor_del_all_ack()
211 list_for_each_entry_safe(p, tmp, &mp->ackqueue, list) { in capiminor_del_all_ack()
214 mp->nack--; in capiminor_del_all_ack()
216 spin_unlock_irqrestore(&mp->ackqlock, flags); in capiminor_del_all_ack()
224 struct capiminor *mp, *p; in capiminor_alloc() local
228 mp = kzalloc(sizeof(*mp), GFP_ATOMIC); in capiminor_alloc()
229 if (!mp) { in capiminor_alloc()
234 mp->ap = ap; in capiminor_alloc()
235 mp->ncci = ncci; in capiminor_alloc()
236 mp->msgid = 0; in capiminor_alloc()
237 atomic_set(&mp->ttyopencount,0); in capiminor_alloc()
238 INIT_LIST_HEAD(&mp->ackqueue); in capiminor_alloc()
239 spin_lock_init(&mp->ackqlock); in capiminor_alloc()
241 skb_queue_head_init(&mp->inqueue); in capiminor_alloc()
242 skb_queue_head_init(&mp->outqueue); in capiminor_alloc()
248 list_add(&mp->list, &capiminor_list); in capiminor_alloc()
257 mp->minor = minor; in capiminor_alloc()
258 list_add(&mp->list, p->list.prev); in capiminor_alloc()
265 kfree(mp); in capiminor_alloc()
269 return mp; in capiminor_alloc()
272 static void capiminor_free(struct capiminor *mp) in capiminor_free() argument
277 list_del(&mp->list); in capiminor_free()
280 if (mp->ttyskb) kfree_skb(mp->ttyskb); in capiminor_free()
281 mp->ttyskb = NULL; in capiminor_free()
282 skb_queue_purge(&mp->inqueue); in capiminor_free()
283 skb_queue_purge(&mp->outqueue); in capiminor_free()
284 capiminor_del_all_ack(mp); in capiminor_free()
285 kfree(mp); in capiminor_free()
313 struct capiminor *mp = NULL; in capincci_alloc() local
322 mp = NULL; in capincci_alloc()
324 mp = np->minorp = capiminor_alloc(&cdev->ap, ncci); in capincci_alloc()
325 if (mp) { in capincci_alloc()
326 mp->nccip = np; in capincci_alloc()
331 capifs_new_ncci(mp->minor, MKDEV(capi_ttymajor, mp->minor)); in capincci_alloc()
345 struct capiminor *mp; in capincci_free() local
354 if ((mp = np->minorp) != NULL) { in capincci_free()
356 capifs_free_ncci(mp->minor); in capincci_free()
358 if (mp->tty) { in capincci_free()
359 mp->nccip = NULL; in capincci_free()
363 tty_hangup(mp->tty); in capincci_free()
365 capiminor_free(mp); in capincci_free()
432 gen_data_b3_resp_for(struct capiminor *mp, struct sk_buff *skb) in gen_data_b3_resp_for() argument
440 capimsg_setu16(s, 2, mp->ap->applid); in gen_data_b3_resp_for()
443 capimsg_setu16(s, 6, mp->msgid++); in gen_data_b3_resp_for()
444 capimsg_setu32(s, 8, mp->ncci); in gen_data_b3_resp_for()
450 static int handle_recv_skb(struct capiminor *mp, struct sk_buff *skb) in handle_recv_skb() argument
458 if (mp->tty == NULL) in handle_recv_skb()
466 ld = tty_ldisc_ref(mp->tty); in handle_recv_skb()
475 if (mp->ttyinstop) { in handle_recv_skb()
481 if (mp->tty->receive_room < datalen) { in handle_recv_skb()
487 if ((nskb = gen_data_b3_resp_for(mp, skb)) == NULL) { in handle_recv_skb()
492 errcode = capi20_put_message(mp->ap, nskb); in handle_recv_skb()
504 ld->ops->receive_buf(mp->tty, skb->data, NULL, skb->len); in handle_recv_skb()
513 static void handle_minor_recv(struct capiminor *mp) in handle_minor_recv() argument
516 while ((skb = skb_dequeue(&mp->inqueue)) != NULL) { in handle_minor_recv()
518 mp->inbytes -= len; in handle_minor_recv()
519 if (handle_recv_skb(mp, skb) < 0) { in handle_minor_recv()
520 skb_queue_head(&mp->inqueue, skb); in handle_minor_recv()
521 mp->inbytes += len; in handle_minor_recv()
527 static int handle_minor_send(struct capiminor *mp) in handle_minor_send() argument
535 if (mp->tty && mp->ttyoutstop) { in handle_minor_send()
542 while ((skb = skb_dequeue(&mp->outqueue)) != NULL) { in handle_minor_send()
543 datahandle = mp->datahandle; in handle_minor_send()
548 capimsg_setu16(skb->data, 2, mp->ap->applid); in handle_minor_send()
551 capimsg_setu16(skb->data, 6, mp->msgid++); in handle_minor_send()
552 capimsg_setu32(skb->data, 8, mp->ncci); /* NCCI */ in handle_minor_send()
558 if (capincci_add_ack(mp, datahandle) < 0) { in handle_minor_send()
560 skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
563 errcode = capi20_put_message(mp->ap, skb); in handle_minor_send()
565 mp->datahandle++; in handle_minor_send()
567 mp->outbytes -= len; in handle_minor_send()
574 capiminor_del_ack(mp, datahandle); in handle_minor_send()
578 skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
584 mp->outbytes -= len; in handle_minor_send()
597 struct capiminor *mp; in capi_recv_message() local
638 mp = np->minorp; in capi_recv_message()
639 if (!mp) { in capi_recv_message()
654 skb_queue_tail(&mp->inqueue, skb); in capi_recv_message()
655 mp->inbytes += skb->len; in capi_recv_message()
656 handle_minor_recv(mp); in capi_recv_message()
667 (void)capiminor_del_ack(mp, datahandle); in capi_recv_message()
668 if (mp->tty) in capi_recv_message()
669 tty_wakeup(mp->tty); in capi_recv_message()
670 (void)handle_minor_send(mp); in capi_recv_message()
936 struct capiminor *mp; in capi_ioctl() local
949 if ((mp = nccip->minorp) != NULL) { in capi_ioctl()
950 count += atomic_read(&mp->ttyopencount); in capi_ioctl()
962 struct capiminor *mp; in capi_ioctl() local
970 if (!nccip || (mp = nccip->minorp) == NULL) { in capi_ioctl()
974 unit = mp->minor; in capi_ioctl()
1028 struct capiminor *mp; in capinc_tty_open() local
1031 if ((mp = capiminor_find(iminor(file->f_path.dentry->d_inode))) == NULL) in capinc_tty_open()
1033 if (mp->nccip == NULL) in capinc_tty_open()
1036 tty->driver_data = (void *)mp; in capinc_tty_open()
1039 if (atomic_read(&mp->ttyopencount) == 0) in capinc_tty_open()
1040 mp->tty = tty; in capinc_tty_open()
1041 atomic_inc(&mp->ttyopencount); in capinc_tty_open()
1043 printk(KERN_DEBUG "capinc_tty_open ocount=%d\n", atomic_read(&mp->ttyopencount)); in capinc_tty_open()
1045 handle_minor_recv(mp); in capinc_tty_open()
1052 struct capiminor *mp; in capinc_tty_close() local
1054 mp = (struct capiminor *)tty->driver_data; in capinc_tty_close()
1055 if (mp) { in capinc_tty_close()
1056 if (atomic_dec_and_test(&mp->ttyopencount)) { in capinc_tty_close()
1061 mp->tty = NULL; in capinc_tty_close()
1064 printk(KERN_DEBUG "capinc_tty_close ocount=%d\n", atomic_read(&mp->ttyopencount)); in capinc_tty_close()
1066 if (mp->nccip == NULL) in capinc_tty_close()
1067 capiminor_free(mp); in capinc_tty_close()
1078 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_write() local
1086 if (!mp || !mp->nccip) { in capinc_tty_write()
1094 skb = mp->ttyskb; in capinc_tty_write()
1096 mp->ttyskb = NULL; in capinc_tty_write()
1097 skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1098 mp->outbytes += skb->len; in capinc_tty_write()
1111 skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1112 mp->outbytes += skb->len; in capinc_tty_write()
1113 (void)handle_minor_send(mp); in capinc_tty_write()
1114 (void)handle_minor_recv(mp); in capinc_tty_write()
1121 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_put_char() local
1130 if (!mp || !mp->nccip) { in capinc_tty_put_char()
1138 skb = mp->ttyskb; in capinc_tty_put_char()
1145 mp->ttyskb = NULL; in capinc_tty_put_char()
1146 skb_queue_tail(&mp->outqueue, skb); in capinc_tty_put_char()
1147 mp->outbytes += skb->len; in capinc_tty_put_char()
1148 (void)handle_minor_send(mp); in capinc_tty_put_char()
1154 mp->ttyskb = skb; in capinc_tty_put_char()
1165 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_flush_chars() local
1173 if (!mp || !mp->nccip) { in capinc_tty_flush_chars()
1181 skb = mp->ttyskb; in capinc_tty_flush_chars()
1183 mp->ttyskb = NULL; in capinc_tty_flush_chars()
1184 skb_queue_tail(&mp->outqueue, skb); in capinc_tty_flush_chars()
1185 mp->outbytes += skb->len; in capinc_tty_flush_chars()
1186 (void)handle_minor_send(mp); in capinc_tty_flush_chars()
1188 (void)handle_minor_recv(mp); in capinc_tty_flush_chars()
1194 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_write_room() local
1196 if (!mp || !mp->nccip) { in capinc_tty_write_room()
1202 room = CAPINC_MAX_SENDQUEUE-skb_queue_len(&mp->outqueue); in capinc_tty_write_room()
1212 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_chars_in_buffer() local
1213 if (!mp || !mp->nccip) { in capinc_tty_chars_in_buffer()
1221 mp->outbytes, mp->nack, in capinc_tty_chars_in_buffer()
1222 skb_queue_len(&mp->outqueue), in capinc_tty_chars_in_buffer()
1223 skb_queue_len(&mp->inqueue)); in capinc_tty_chars_in_buffer()
1225 return mp->outbytes; in capinc_tty_chars_in_buffer()
1249 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_throttle() local
1253 if (mp) in capinc_tty_throttle()
1254 mp->ttyinstop = 1; in capinc_tty_throttle()
1259 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_unthrottle() local
1264 if (mp) { in capinc_tty_unthrottle()
1266 mp->ttyinstop = 0; in capinc_tty_unthrottle()
1267 handle_minor_recv(mp); in capinc_tty_unthrottle()
1274 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_stop() local
1278 if (mp) { in capinc_tty_stop()
1279 mp->ttyoutstop = 1; in capinc_tty_stop()
1285 struct capiminor *mp = (struct capiminor *)tty->driver_data; in capinc_tty_start() local
1290 if (mp) { in capinc_tty_start()
1292 mp->ttyoutstop = 0; in capinc_tty_start()
1293 (void)handle_minor_send(mp); in capinc_tty_start()