pipe 213 src/dps8/dps8_mgp.c uv_pipe_t *pipe; /* connected pipe to NCP process */ pipe 489 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 574 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 584 src/dps8/dps8_mgp.c if (mgp_dev_state.reading_stopped && mgp_dev_state.pipe && pipe 586 src/dps8/dps8_mgp.c int rc = uv_read_start((uv_stream_t *)mgp_dev_state.pipe, pipe 593 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 594 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 612 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 623 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) { pipe 624 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 625 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 631 src/dps8/dps8_mgp.c int rc = uv_read_start((uv_stream_t *)mgp_dev_state.pipe, pipe 635 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 636 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 650 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) return 0; /* already connected or pending */ pipe 661 src/dps8/dps8_mgp.c mgp_dev_state.pipe = malloc(sizeof(uv_pipe_t)); pipe 662 src/dps8/dps8_mgp.c if (!mgp_dev_state.pipe) pipe 664 src/dps8/dps8_mgp.c uv_pipe_init(uv_default_loop(), mgp_dev_state.pipe, 0); pipe 668 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 669 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 676 src/dps8/dps8_mgp.c uv_pipe_connect(req, mgp_dev_state.pipe, ncp_socket_path, ncp_connect_cb); pipe 703 src/dps8/dps8_mgp.c if (!mgp_dev_state.pipe) { pipe 732 src/dps8/dps8_mgp.c int rc = uv_write(&wr->req, (uv_stream_t *)mgp_dev_state.pipe, pipe 757 src/dps8/dps8_mgp.c if (!mgp_dev_state.pipe && !mgp_dev_state.eof_draining) pipe 768 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) { pipe 769 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 770 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 1312 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) pipe 1314 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 1315 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 1335 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) pipe 1337 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 1338 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 1407 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) pipe 1409 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 1410 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 1656 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL) pipe 1658 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 1659 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 1707 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL && mgp_dev_state.want_to_read_since > 0) pipe 1720 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) pipe 1722 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 1723 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 1767 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL) pipe 1783 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) pipe 1785 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 1786 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 1841 src/dps8/dps8_mgp.c mgp_dev_state.pipe, pipe 1858 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe == NULL && !mgp_dev_state.eof_draining) pipe 1862 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe == NULL) pipe 2177 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL) pipe 2179 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) //-V547 pipe 2181 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); pipe 2182 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; pipe 210 src/dps8/dps8_net.c uv_pipe_t *pipe; /* connected socket to gateway process */ pipe 483 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 568 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 578 src/dps8/dps8_net.c if (net_dev_state.reading_stopped && net_dev_state.pipe && pipe 580 src/dps8/dps8_net.c int rc = uv_read_start((uv_stream_t*)net_dev_state.pipe, pipe 587 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 588 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 607 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 618 src/dps8/dps8_net.c if (net_dev_state.pipe) { pipe 619 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 620 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 625 src/dps8/dps8_net.c int rc = uv_read_start((uv_stream_t*)net_dev_state.pipe, net_alloc_cb, net_read_cb); pipe 628 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 629 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 636 src/dps8/dps8_net.c if (net_dev_state.pipe) return 0; pipe 646 src/dps8/dps8_net.c net_dev_state.pipe = malloc(sizeof(uv_pipe_t)); pipe 647 src/dps8/dps8_net.c if (!net_dev_state.pipe) pipe 649 src/dps8/dps8_net.c uv_pipe_init(uv_default_loop(), net_dev_state.pipe, 0); pipe 653 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 654 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 658 src/dps8/dps8_net.c uv_pipe_connect(req, net_dev_state.pipe, gateway_socket_path, net_connect_cb); pipe 683 src/dps8/dps8_net.c if (!net_dev_state.pipe) { pipe 713 src/dps8/dps8_net.c int rc = uv_write(&wr->req, (uv_stream_t*)net_dev_state.pipe, &wr->buf, 1, net_write_cb); pipe 730 src/dps8/dps8_net.c if (!net_dev_state.pipe && !net_dev_state.eof_draining) return 0; pipe 737 src/dps8/dps8_net.c if (net_dev_state.pipe) { pipe 738 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 739 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 770 src/dps8/dps8_net.c if (!net_dev_state.pipe && !net_dev_state.eof_draining) return 0; pipe 1429 src/dps8/dps8_net.c if (net_dev_state.pipe) pipe 1431 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 1432 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 1434 src/dps8/dps8_net.c net_dev_state.pipe = NULL; /* discard queued NOOPs */ pipe 1455 src/dps8/dps8_net.c if (net_dev_state.pipe) pipe 1457 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 1458 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 1460 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 1549 src/dps8/dps8_net.c if (net_dev_state.pipe) pipe 1551 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 1552 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 1554 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 1830 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) pipe 1846 src/dps8/dps8_net.c if (net_dev_state.pipe) pipe 1848 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 1849 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 1851 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 1905 src/dps8/dps8_net.c net_dev_state.pipe, pipe 1922 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL && !net_dev_state.eof_draining) pipe 1926 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL) pipe 2043 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) pipe 2045 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 pipe 2047 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 2048 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 2050 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 2249 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) pipe 2251 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 pipe 2253 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); pipe 2254 src/dps8/dps8_net.c net_dev_state.pipe = NULL; pipe 2257 src/dps8/dps8_net.c net_dev_state.pipe = NULL;