1 // SPDX-License-Identifier: GPL-2.0
3  * Copyright (C) 2001 - 2007 Jeff Dike (jdike@{linux.intel,addtoit}.com)
50 	fd = os_rcv_fd(conn->socket[0], &conn->helper_pid);  in pipe_interrupt()
52 		if (fd == -EAGAIN)  in pipe_interrupt()
56 		       -fd);  in pipe_interrupt()
57 		os_close_file(conn->fd);  in pipe_interrupt()
60 	list_del(&conn->list);  in pipe_interrupt()
62 	conn->fd = fd;  in pipe_interrupt()
63 	list_add(&conn->list, &conn->port->connections);  in pipe_interrupt()
65 	complete(&conn->port->done);  in pipe_interrupt()
81 	fd = port_connection(port->fd, socket, &pid);  in port_accept()
83 		if (fd != -EAGAIN)  in port_accept()
85 			       "returned %d\n", -fd);  in port_accept()
86 		goto out;  in port_accept()
96 		{ .list 	= LIST_HEAD_INIT(conn->list),  in port_accept()
109 	if (atomic_read(&port->wait_count) == 0) {  in port_accept()
113 	list_add(&conn->list, &port->pending);  in port_accept()
121  out:  in port_accept()
126 static LIST_HEAD(ports);
135 	list_for_each(ele, &ports) {  in port_work_proc()
137 		if (!port->has_connection)  in port_work_proc()
142 		port->has_connection = 0;  in port_work_proc()
153 	port->has_connection = 1;  in port_interrupt()
166 	list_for_each(ele, &ports) {  in port_data()
168 		if (port->port == port_num)  in port_data()
174 		goto out;  in port_data()
180 		       port_num, -fd);  in port_data()
191 		{ .list 	 	= LIST_HEAD_INIT(port->list),  in port_data()
196 		  .pending 		= LIST_HEAD_INIT(port->pending),  in port_data()
197 		  .connections 		= LIST_HEAD_INIT(port->connections) });  in port_data()
198 	spin_lock_init(&port->lock);  in port_data()
199 	init_completion(&port->done);  in port_data()
200 	list_add(&port->list, &ports);  in port_data()
206 		goto out;  in port_data()
210 				    .helper_pid  	= -1,  in port_data()
211 				    .telnetd_pid  	= -1 });  in port_data()
212 	goto out;  in port_data()
218  out:  in port_data()
227 	struct port_list *port = dev->port;  in port_wait()
230 	atomic_inc(&port->wait_count);  in port_wait()
232 		fd = -ERESTARTSYS;  in port_wait()
233 		if (wait_for_completion_interruptible(&port->done))  in port_wait()
234 			goto out;  in port_wait()
236 		spin_lock(&port->lock);  in port_wait()
238 		conn = list_entry(port->connections.next, struct connection,  in port_wait()
240 		list_del(&conn->list);  in port_wait()
241 		spin_unlock(&port->lock);  in port_wait()
243 		os_shutdown_socket(conn->socket[0], 1, 1);  in port_wait()
244 		os_close_file(conn->socket[0]);  in port_wait()
245 		os_shutdown_socket(conn->socket[1], 1, 1);  in port_wait()
246 		os_close_file(conn->socket[1]);  in port_wait()
251 		 * connection.  Then we loop here throwing out failed  in port_wait()
256 		if (conn->fd >= 0)  in port_wait()
258 		os_close_file(conn->fd);  in port_wait()
262 	fd = conn->fd;  in port_wait()
263 	dev->helper_pid = conn->helper_pid;  in port_wait()
264 	dev->telnetd_pid = conn->telnetd_pid;  in port_wait()
266  out:  in port_wait()
267 	atomic_dec(&port->wait_count);  in port_wait()
275 	if (dev->helper_pid != -1)  in port_remove_dev()
276 		os_kill_process(dev->helper_pid, 0);  in port_remove_dev()
277 	if (dev->telnetd_pid != -1)  in port_remove_dev()
278 		os_kill_process(dev->telnetd_pid, 1);  in port_remove_dev()
279 	dev->helper_pid = -1;  in port_remove_dev()
280 	dev->telnetd_pid = -1;  in port_remove_dev()
296 	list_for_each(ele, &ports) {  in free_port()
298 		free_irq_by_fd(port->fd);  in free_port()
299 		os_close_file(port->fd);  in free_port()