81 static void vhost_user_server_new_connection(int fd, void *data, int *remove);
82 static void vhost_user_read_cb(int fd, void *dat, int *remove);
88 		.fd = { [0 ... MAX_FDS - 1] = {-1, NULL, NULL, NULL, 0} },
204 vhost_user_add_connection(int fd, struct vhost_user_socket *vsocket)  in vhost_user_add_connection()  argument
217 		close(fd);  in vhost_user_add_connection()
254 				vsocket->path, fd);  in vhost_user_add_connection()
259 	conn->connfd = fd;  in vhost_user_add_connection()
262 	ret = fdset_add(&vhost_user.fdset, fd, vhost_user_read_cb,  in vhost_user_add_connection()
266 			vsocket->path, fd);  in vhost_user_add_connection()
285 	close(fd);  in vhost_user_add_connection()
290 vhost_user_server_new_connection(int fd, void *dat, int *remove __rte_unused)  in vhost_user_server_new_connection()  argument
294 	fd = accept(fd, NULL, NULL);  in vhost_user_server_new_connection()
295 	if (fd < 0)  in vhost_user_server_new_connection()
299 			vsocket->path, fd);  in vhost_user_server_new_connection()
300 	vhost_user_add_connection(fd, vsocket);  in vhost_user_server_new_connection()
341 	int fd;  in create_unix_socket()  local
344 	fd = socket(AF_UNIX, SOCK_STREAM, 0);  in create_unix_socket()
345 	if (fd < 0)  in create_unix_socket()
348 		vsocket->path, vsocket->is_server ? "server" : "client", fd);  in create_unix_socket()
350 	if (!vsocket->is_server && fcntl(fd, F_SETFL, O_NONBLOCK)) {  in create_unix_socket()
353 			vsocket->path, fd, strerror(errno));  in create_unix_socket()
354 		close(fd);  in create_unix_socket()
363 	vsocket->socket_fd = fd;  in create_unix_socket()
371 	int fd = vsocket->socket_fd;  in vhost_user_start_server()  local
384 	ret = bind(fd, (struct sockaddr *)&vsocket->un, sizeof(vsocket->un));  in vhost_user_start_server()
392 	ret = listen(fd, MAX_VIRTIO_BACKLOG);  in vhost_user_start_server()
396 	ret = fdset_add(&vhost_user.fdset, fd, vhost_user_server_new_connection,  in vhost_user_start_server()
401 			path, fd);  in vhost_user_start_server()
408 	close(fd);  in vhost_user_start_server()
414 	int fd;  member
430 vhost_user_connect_nonblock(char *path, int fd, struct sockaddr *un, size_t sz)  in vhost_user_connect_nonblock()  argument
434 	ret = connect(fd, un, sz);  in vhost_user_connect_nonblock()
438 	flags = fcntl(fd, F_GETFL, 0);  in vhost_user_connect_nonblock()
441 				path, fd, strerror(errno));  in vhost_user_connect_nonblock()
444 	if ((flags & O_NONBLOCK) && fcntl(fd, F_SETFL, flags & ~O_NONBLOCK)) {  in vhost_user_connect_nonblock()
445 		VHOST_LOG_CONFIG(ERR, "(%s) can't disable nonblocking on fd %d\n", path, fd);  in vhost_user_connect_nonblock()
468 			ret = vhost_user_connect_nonblock(reconn->vsocket->path, reconn->fd,  in vhost_user_client_reconnect()
472 				close(reconn->fd);  in vhost_user_client_reconnect()
474 					reconn->vsocket->path, reconn->fd);  in vhost_user_client_reconnect()
481 			vhost_user_add_connection(reconn->fd, reconn->vsocket);  in vhost_user_client_reconnect()
521 	int fd = vsocket->socket_fd;  in vhost_user_start_client()  local
525 	ret = vhost_user_connect_nonblock(vsocket->path, fd, (struct sockaddr *)&vsocket->un,  in vhost_user_start_client()
528 		vhost_user_add_connection(fd, vsocket);  in vhost_user_start_client()
535 		close(fd);  in vhost_user_start_client()
543 		close(fd);  in vhost_user_start_client()
547 	reconn->fd = fd;  in vhost_user_start_client()
979 			close(reconn->fd);  in vhost_user_remove_reconnect()