Lines Matching refs:port
103 struct tty_port port; member
136 struct gs_port *port; member
207 gs_send_packet(struct gs_port *port, char *packet, unsigned size) in gs_send_packet() argument
211 len = kfifo_len(&port->port_write_buf); in gs_send_packet()
215 size = kfifo_out(&port->port_write_buf, packet, size); in gs_send_packet()
230 static int gs_start_tx(struct gs_port *port) in gs_start_tx() argument
236 struct list_head *pool = &port->write_pool; in gs_start_tx()
241 if (!port->port_usb) in gs_start_tx()
244 in = port->port_usb->in; in gs_start_tx()
246 while (!port->write_busy && !list_empty(pool)) { in gs_start_tx()
250 if (port->write_started >= QUEUE_SIZE) in gs_start_tx()
254 len = gs_send_packet(port, req->buf, in->maxpacket); in gs_start_tx()
256 wake_up_interruptible(&port->drain_wait); in gs_start_tx()
263 req->zero = kfifo_is_empty(&port->port_write_buf); in gs_start_tx()
265 pr_vdebug("ttyGS%d: tx len=%d, %3ph ...\n", port->port_num, len, req->buf); in gs_start_tx()
274 port->write_busy = true; in gs_start_tx()
275 spin_unlock(&port->port_lock); in gs_start_tx()
277 spin_lock(&port->port_lock); in gs_start_tx()
278 port->write_busy = false; in gs_start_tx()
287 port->write_started++; in gs_start_tx()
290 if (!port->port_usb) in gs_start_tx()
294 if (do_tty_wake && port->port.tty) in gs_start_tx()
295 tty_wakeup(port->port.tty); in gs_start_tx()
302 static unsigned gs_start_rx(struct gs_port *port) in gs_start_rx() argument
308 struct list_head *pool = &port->read_pool; in gs_start_rx()
309 struct usb_ep *out = port->port_usb->out; in gs_start_rx()
317 tty = port->port.tty; in gs_start_rx()
321 if (port->read_started >= QUEUE_SIZE) in gs_start_rx()
331 spin_unlock(&port->port_lock); in gs_start_rx()
333 spin_lock(&port->port_lock); in gs_start_rx()
341 port->read_started++; in gs_start_rx()
344 if (!port->port_usb) in gs_start_rx()
347 return port->read_started; in gs_start_rx()
363 struct gs_port *port = container_of(w, struct gs_port, push); in gs_rx_push() local
365 struct list_head *queue = &port->read_queue; in gs_rx_push()
370 spin_lock_irq(&port->port_lock); in gs_rx_push()
371 tty = port->port.tty; in gs_rx_push()
384 pr_vdebug("ttyGS%d: shutdown\n", port->port_num); in gs_rx_push()
390 port->port_num, req->status); in gs_rx_push()
405 n = port->n_read; in gs_rx_push()
411 count = tty_insert_flip_string(&port->port, packet, in gs_rx_push()
417 port->n_read += count; in gs_rx_push()
419 port->port_num, count, req->actual); in gs_rx_push()
422 port->n_read = 0; in gs_rx_push()
425 list_move(&req->list, &port->read_pool); in gs_rx_push()
426 port->read_started--; in gs_rx_push()
433 tty_flip_buffer_push(&port->port); in gs_rx_push()
444 schedule_delayed_work(&port->push, 1); in gs_rx_push()
447 if (!disconnect && port->port_usb) in gs_rx_push()
448 gs_start_rx(port); in gs_rx_push()
450 spin_unlock_irq(&port->port_lock); in gs_rx_push()
455 struct gs_port *port = ep->driver_data; in gs_read_complete() local
458 spin_lock(&port->port_lock); in gs_read_complete()
459 list_add_tail(&req->list, &port->read_queue); in gs_read_complete()
460 schedule_delayed_work(&port->push, 0); in gs_read_complete()
461 spin_unlock(&port->port_lock); in gs_read_complete()
466 struct gs_port *port = ep->driver_data; in gs_write_complete() local
468 spin_lock(&port->port_lock); in gs_write_complete()
469 list_add(&req->list, &port->write_pool); in gs_write_complete()
470 port->write_started--; in gs_write_complete()
480 gs_start_tx(port); in gs_write_complete()
489 spin_unlock(&port->port_lock); in gs_write_complete()
539 static int gs_start_io(struct gs_port *port) in gs_start_io() argument
541 struct list_head *head = &port->read_pool; in gs_start_io()
542 struct usb_ep *ep = port->port_usb->out; in gs_start_io()
553 &port->read_allocated); in gs_start_io()
557 status = gs_alloc_requests(port->port_usb->in, &port->write_pool, in gs_start_io()
558 gs_write_complete, &port->write_allocated); in gs_start_io()
560 gs_free_requests(ep, head, &port->read_allocated); in gs_start_io()
565 port->n_read = 0; in gs_start_io()
566 started = gs_start_rx(port); in gs_start_io()
569 gs_start_tx(port); in gs_start_io()
572 tty_wakeup(port->port.tty); in gs_start_io()
574 gs_free_requests(ep, head, &port->read_allocated); in gs_start_io()
575 gs_free_requests(port->port_usb->in, &port->write_pool, in gs_start_io()
576 &port->write_allocated); in gs_start_io()
595 struct gs_port *port; in gs_open() local
599 port = ports[port_num].port; in gs_open()
600 if (!port) { in gs_open()
605 spin_lock_irq(&port->port_lock); in gs_open()
608 if (!kfifo_initialized(&port->port_write_buf)) { in gs_open()
610 spin_unlock_irq(&port->port_lock); in gs_open()
617 status = kfifo_alloc(&port->port_write_buf, in gs_open()
625 spin_lock_irq(&port->port_lock); in gs_open()
629 if (port->port.count++) in gs_open()
632 tty->driver_data = port; in gs_open()
633 port->port.tty = tty; in gs_open()
636 if (port->port_usb) { in gs_open()
638 if (!port->suspended) { in gs_open()
639 struct gserial *gser = port->port_usb; in gs_open()
641 pr_debug("gs_open: start ttyGS%d\n", port->port_num); in gs_open()
642 gs_start_io(port); in gs_open()
647 pr_debug("delay start of ttyGS%d\n", port->port_num); in gs_open()
648 port->start_delayed = true; in gs_open()
652 pr_debug("gs_open: ttyGS%d (%p,%p)\n", port->port_num, tty, file); in gs_open()
655 spin_unlock_irq(&port->port_lock); in gs_open()
668 p->port.count > 1; in gs_close_flush_done()
676 struct gs_port *port = tty->driver_data; in gs_close() local
679 spin_lock_irq(&port->port_lock); in gs_close()
681 if (port->port.count != 1) { in gs_close()
683 if (port->port.count == 0) in gs_close()
686 --port->port.count; in gs_close()
690 pr_debug("gs_close: ttyGS%d (%p,%p) ...\n", port->port_num, tty, file); in gs_close()
692 gser = port->port_usb; in gs_close()
693 if (gser && !port->suspended && gser->disconnect) in gs_close()
699 if (kfifo_len(&port->port_write_buf) > 0 && gser) { in gs_close()
700 spin_unlock_irq(&port->port_lock); in gs_close()
701 wait_event_interruptible_timeout(port->drain_wait, in gs_close()
702 gs_close_flush_done(port), in gs_close()
704 spin_lock_irq(&port->port_lock); in gs_close()
706 if (port->port.count != 1) in gs_close()
709 gser = port->port_usb; in gs_close()
717 kfifo_free(&port->port_write_buf); in gs_close()
719 kfifo_reset(&port->port_write_buf); in gs_close()
721 port->start_delayed = false; in gs_close()
722 port->port.count = 0; in gs_close()
723 port->port.tty = NULL; in gs_close()
726 port->port_num, tty, file); in gs_close()
728 wake_up(&port->close_wait); in gs_close()
730 spin_unlock_irq(&port->port_lock); in gs_close()
735 struct gs_port *port = tty->driver_data; in gs_write() local
739 port->port_num, tty, count); in gs_write()
741 spin_lock_irqsave(&port->port_lock, flags); in gs_write()
743 count = kfifo_in(&port->port_write_buf, buf, count); in gs_write()
745 if (port->port_usb) in gs_write()
746 gs_start_tx(port); in gs_write()
747 spin_unlock_irqrestore(&port->port_lock, flags); in gs_write()
754 struct gs_port *port = tty->driver_data; in gs_put_char() local
759 port->port_num, tty, ch, __builtin_return_address(0)); in gs_put_char()
761 spin_lock_irqsave(&port->port_lock, flags); in gs_put_char()
762 status = kfifo_put(&port->port_write_buf, ch); in gs_put_char()
763 spin_unlock_irqrestore(&port->port_lock, flags); in gs_put_char()
770 struct gs_port *port = tty->driver_data; in gs_flush_chars() local
773 pr_vdebug("gs_flush_chars: (%d,%p)\n", port->port_num, tty); in gs_flush_chars()
775 spin_lock_irqsave(&port->port_lock, flags); in gs_flush_chars()
776 if (port->port_usb) in gs_flush_chars()
777 gs_start_tx(port); in gs_flush_chars()
778 spin_unlock_irqrestore(&port->port_lock, flags); in gs_flush_chars()
783 struct gs_port *port = tty->driver_data; in gs_write_room() local
787 spin_lock_irqsave(&port->port_lock, flags); in gs_write_room()
788 if (port->port_usb) in gs_write_room()
789 room = kfifo_avail(&port->port_write_buf); in gs_write_room()
790 spin_unlock_irqrestore(&port->port_lock, flags); in gs_write_room()
793 port->port_num, tty, room); in gs_write_room()
800 struct gs_port *port = tty->driver_data; in gs_chars_in_buffer() local
804 spin_lock_irqsave(&port->port_lock, flags); in gs_chars_in_buffer()
805 chars = kfifo_len(&port->port_write_buf); in gs_chars_in_buffer()
806 spin_unlock_irqrestore(&port->port_lock, flags); in gs_chars_in_buffer()
809 port->port_num, tty, chars); in gs_chars_in_buffer()
817 struct gs_port *port = tty->driver_data; in gs_unthrottle() local
820 spin_lock_irqsave(&port->port_lock, flags); in gs_unthrottle()
821 if (port->port_usb) { in gs_unthrottle()
826 pr_vdebug("ttyGS%d: unthrottle\n", port->port_num); in gs_unthrottle()
827 schedule_delayed_work(&port->push, 0); in gs_unthrottle()
829 spin_unlock_irqrestore(&port->port_lock, flags); in gs_unthrottle()
834 struct gs_port *port = tty->driver_data; in gs_break_ctl() local
839 port->port_num, duration); in gs_break_ctl()
841 spin_lock_irq(&port->port_lock); in gs_break_ctl()
842 gser = port->port_usb; in gs_break_ctl()
845 spin_unlock_irq(&port->port_lock); in gs_break_ctl()
959 static int gs_console_connect(struct gs_port *port) in gs_console_connect() argument
961 struct gs_console *cons = port->console; in gs_console_connect()
968 ep = port->port_usb->in; in gs_console_connect()
981 pr_debug("ttyGS%d: console connected!\n", port->port_num); in gs_console_connect()
988 static void gs_console_disconnect(struct gs_port *port) in gs_console_disconnect() argument
990 struct gs_console *cons = port->console; in gs_console_disconnect()
1012 static int gs_console_init(struct gs_port *port) in gs_console_init() argument
1017 if (port->console) in gs_console_init()
1020 cons = kzalloc(sizeof(*port->console), GFP_KERNEL); in gs_console_init()
1028 cons->console.index = port->port_num; in gs_console_init()
1035 pr_err("ttyGS%d: allocate console buffer failed\n", port->port_num); in gs_console_init()
1040 port->console = cons; in gs_console_init()
1043 spin_lock_irq(&port->port_lock); in gs_console_init()
1044 if (port->port_usb) in gs_console_init()
1045 gs_console_connect(port); in gs_console_init()
1046 spin_unlock_irq(&port->port_lock); in gs_console_init()
1051 static void gs_console_exit(struct gs_port *port) in gs_console_exit() argument
1053 struct gs_console *cons = port->console; in gs_console_exit()
1060 spin_lock_irq(&port->port_lock); in gs_console_exit()
1062 gs_console_disconnect(port); in gs_console_exit()
1063 spin_unlock_irq(&port->port_lock); in gs_console_exit()
1068 port->console = NULL; in gs_console_exit()
1073 struct gs_port *port; in gserial_set_console() local
1082 port = ports[port_num].port; in gserial_set_console()
1084 if (WARN_ON(port == NULL)) { in gserial_set_console()
1090 ret = gs_console_init(port); in gserial_set_console()
1092 gs_console_exit(port); in gserial_set_console()
1102 struct gs_port *port; in gserial_get_console() local
1106 port = ports[port_num].port; in gserial_get_console()
1108 if (WARN_ON(port == NULL)) in gserial_get_console()
1111 ret = sprintf(page, "%u\n", !!port->console); in gserial_get_console()
1121 static int gs_console_connect(struct gs_port *port) in gs_console_connect() argument
1126 static void gs_console_disconnect(struct gs_port *port) in gs_console_disconnect() argument
1130 static int gs_console_init(struct gs_port *port) in gs_console_init() argument
1135 static void gs_console_exit(struct gs_port *port) in gs_console_exit() argument
1144 struct gs_port *port; in gs_port_alloc() local
1148 if (ports[port_num].port) { in gs_port_alloc()
1153 port = kzalloc(sizeof(struct gs_port), GFP_KERNEL); in gs_port_alloc()
1154 if (port == NULL) { in gs_port_alloc()
1159 tty_port_init(&port->port); in gs_port_alloc()
1160 spin_lock_init(&port->port_lock); in gs_port_alloc()
1161 init_waitqueue_head(&port->drain_wait); in gs_port_alloc()
1162 init_waitqueue_head(&port->close_wait); in gs_port_alloc()
1164 INIT_DELAYED_WORK(&port->push, gs_rx_push); in gs_port_alloc()
1166 INIT_LIST_HEAD(&port->read_pool); in gs_port_alloc()
1167 INIT_LIST_HEAD(&port->read_queue); in gs_port_alloc()
1168 INIT_LIST_HEAD(&port->write_pool); in gs_port_alloc()
1170 port->port_num = port_num; in gs_port_alloc()
1171 port->port_line_coding = *coding; in gs_port_alloc()
1173 ports[port_num].port = port; in gs_port_alloc()
1179 static int gs_closed(struct gs_port *port) in gs_closed() argument
1183 spin_lock_irq(&port->port_lock); in gs_closed()
1184 cond = port->port.count == 0; in gs_closed()
1185 spin_unlock_irq(&port->port_lock); in gs_closed()
1190 static void gserial_free_port(struct gs_port *port) in gserial_free_port() argument
1192 cancel_delayed_work_sync(&port->push); in gserial_free_port()
1194 wait_event(port->close_wait, gs_closed(port)); in gserial_free_port()
1195 WARN_ON(port->port_usb != NULL); in gserial_free_port()
1196 tty_port_destroy(&port->port); in gserial_free_port()
1197 kfree(port); in gserial_free_port()
1202 struct gs_port *port; in gserial_free_line() local
1205 if (!ports[port_num].port) { in gserial_free_line()
1209 port = ports[port_num].port; in gserial_free_line()
1210 gs_console_exit(port); in gserial_free_line()
1211 ports[port_num].port = NULL; in gserial_free_line()
1214 gserial_free_port(port); in gserial_free_line()
1222 struct gs_port *port; in gserial_alloc_line_no_console() local
1245 port = ports[port_num].port; in gserial_alloc_line_no_console()
1246 tty_dev = tty_port_register_device(&port->port, in gserial_alloc_line_no_console()
1254 ports[port_num].port = NULL; in gserial_alloc_line_no_console()
1256 gserial_free_port(port); in gserial_alloc_line_no_console()
1270 gs_console_init(ports[*line_num].port); in gserial_alloc_line()
1299 struct gs_port *port; in gserial_connect() local
1306 port = ports[port_num].port; in gserial_connect()
1307 if (!port) { in gserial_connect()
1311 if (port->port_usb) { in gserial_connect()
1320 gser->in->driver_data = port; in gserial_connect()
1325 gser->out->driver_data = port; in gserial_connect()
1328 spin_lock_irqsave(&port->port_lock, flags); in gserial_connect()
1329 gser->ioport = port; in gserial_connect()
1330 port->port_usb = gser; in gserial_connect()
1335 gser->port_line_coding = port->port_line_coding; in gserial_connect()
1342 if (port->port.count) { in gserial_connect()
1343 pr_debug("gserial_connect: start ttyGS%d\n", port->port_num); in gserial_connect()
1344 gs_start_io(port); in gserial_connect()
1352 status = gs_console_connect(port); in gserial_connect()
1353 spin_unlock_irqrestore(&port->port_lock, flags); in gserial_connect()
1375 struct gs_port *port = gser->ioport; in gserial_disconnect() local
1378 if (!port) in gserial_disconnect()
1384 spin_lock(&port->port_lock); in gserial_disconnect()
1386 gs_console_disconnect(port); in gserial_disconnect()
1389 port->port_line_coding = gser->port_line_coding; in gserial_disconnect()
1391 port->port_usb = NULL; in gserial_disconnect()
1393 if (port->port.count > 0) { in gserial_disconnect()
1394 wake_up_interruptible(&port->drain_wait); in gserial_disconnect()
1395 if (port->port.tty) in gserial_disconnect()
1396 tty_hangup(port->port.tty); in gserial_disconnect()
1398 port->suspended = false; in gserial_disconnect()
1399 spin_unlock(&port->port_lock); in gserial_disconnect()
1407 spin_lock_irqsave(&port->port_lock, flags); in gserial_disconnect()
1408 if (port->port.count == 0) in gserial_disconnect()
1409 kfifo_free(&port->port_write_buf); in gserial_disconnect()
1410 gs_free_requests(gser->out, &port->read_pool, NULL); in gserial_disconnect()
1411 gs_free_requests(gser->out, &port->read_queue, NULL); in gserial_disconnect()
1412 gs_free_requests(gser->in, &port->write_pool, NULL); in gserial_disconnect()
1414 port->read_allocated = port->read_started = in gserial_disconnect()
1415 port->write_allocated = port->write_started = 0; in gserial_disconnect()
1417 spin_unlock_irqrestore(&port->port_lock, flags); in gserial_disconnect()
1423 struct gs_port *port = gser->ioport; in gserial_suspend() local
1426 spin_lock_irqsave(&port->port_lock, flags); in gserial_suspend()
1427 port->suspended = true; in gserial_suspend()
1428 spin_unlock_irqrestore(&port->port_lock, flags); in gserial_suspend()
1434 struct gs_port *port; in gserial_resume() local
1438 port = gser->ioport; in gserial_resume()
1440 if (!port) { in gserial_resume()
1445 spin_lock(&port->port_lock); in gserial_resume()
1447 port->suspended = false; in gserial_resume()
1448 if (!port->start_delayed) { in gserial_resume()
1449 spin_unlock_irqrestore(&port->port_lock, flags); in gserial_resume()
1453 pr_debug("delayed start ttyGS%d\n", port->port_num); in gserial_resume()
1454 gs_start_io(port); in gserial_resume()
1457 port->start_delayed = false; in gserial_resume()
1458 spin_unlock_irqrestore(&port->port_lock, flags); in gserial_resume()