Lines Matching refs:sock
279 struct pci_vtcon_sock *sock = NULL; in pci_vtcon_sock_add() local
308 sock = calloc(1, sizeof(struct pci_vtcon_sock)); in pci_vtcon_sock_add()
309 if (sock == NULL) { in pci_vtcon_sock_add()
377 sock->vss_port = pci_vtcon_port_add(sc, port, name, pci_vtcon_sock_tx, sock); in pci_vtcon_sock_add()
378 if (sock->vss_port == NULL) { in pci_vtcon_sock_add()
383 sock->vss_open = false; in pci_vtcon_sock_add()
384 sock->vss_conn_fd = -1; in pci_vtcon_sock_add()
385 sock->vss_server_fd = s; in pci_vtcon_sock_add()
386 sock->vss_server_evp = mevent_add(s, EVF_READ, pci_vtcon_sock_accept, in pci_vtcon_sock_add()
387 sock); in pci_vtcon_sock_add()
389 if (sock->vss_server_evp == NULL) { in pci_vtcon_sock_add()
401 free(sock); in pci_vtcon_sock_add()
410 struct pci_vtcon_sock *sock = (struct pci_vtcon_sock *)arg; in pci_vtcon_sock_accept() local
413 s = accept(sock->vss_server_fd, NULL, NULL); in pci_vtcon_sock_accept()
417 if (sock->vss_open) { in pci_vtcon_sock_accept()
422 sock->vss_open = true; in pci_vtcon_sock_accept()
423 sock->vss_conn_fd = s; in pci_vtcon_sock_accept()
424 sock->vss_conn_evp = mevent_add(s, EVF_READ, pci_vtcon_sock_rx, sock); in pci_vtcon_sock_accept()
426 pci_vtcon_open_port(sock->vss_port, true); in pci_vtcon_sock_accept()
433 struct pci_vtcon_sock *sock = (struct pci_vtcon_sock *)arg; in pci_vtcon_sock_rx() local
440 port = sock->vss_port; in pci_vtcon_sock_rx()
443 if (!sock->vss_open || !port->vsp_rx_ready) { in pci_vtcon_sock_rx()
444 len = read(sock->vss_conn_fd, dummybuf, sizeof(dummybuf)); in pci_vtcon_sock_rx()
452 len = read(sock->vss_conn_fd, dummybuf, sizeof(dummybuf)); in pci_vtcon_sock_rx()
463 len = readv(sock->vss_conn_fd, &iov, n); in pci_vtcon_sock_rx()
480 mevent_delete_close(sock->vss_conn_evp); in pci_vtcon_sock_rx()
481 sock->vss_conn_fd = -1; in pci_vtcon_sock_rx()
482 sock->vss_open = false; in pci_vtcon_sock_rx()
489 struct pci_vtcon_sock *sock; in pci_vtcon_sock_tx() local
496 sock = (struct pci_vtcon_sock *)arg; in pci_vtcon_sock_tx()
498 if (sock->vss_conn_fd == -1) in pci_vtcon_sock_tx()
502 ret = stream_write(sock->vss_conn_fd, iov[i].iov_base, in pci_vtcon_sock_tx()
509 mevent_delete_close(sock->vss_conn_evp); in pci_vtcon_sock_tx()
510 sock->vss_conn_fd = -1; in pci_vtcon_sock_tx()
511 sock->vss_open = false; in pci_vtcon_sock_tx()