uv_stream_t 2781 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); uv_stream_t 2801 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); uv_stream_t 2814 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); uv_stream_t 2850 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); uv_stream_t 2887 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); uv_stream_t 2900 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); uv_stream_t 2913 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *)client); uv_stream_t 2984 src/dps8/dps8_fnp2.c close_connection ((uv_stream_t *) client); uv_stream_t 190 src/dps8/dps8_fnp2_iomcmd.c close_connection ((uv_stream_t *) linep->line_client); uv_stream_t 564 src/dps8/dps8_mgp.c static void ncp_stop_reading_if_full(uv_stream_t *stream) { uv_stream_t 581 src/dps8/dps8_mgp.c static void ncp_read_cb(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf); uv_stream_t 586 src/dps8/dps8_mgp.c int rc = uv_read_start((uv_stream_t *)mgp_dev_state.pipe, uv_stream_t 600 src/dps8/dps8_mgp.c static void ncp_read_cb(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) { uv_stream_t 631 src/dps8/dps8_mgp.c int rc = uv_read_start((uv_stream_t *)mgp_dev_state.pipe, uv_stream_t 732 src/dps8/dps8_mgp.c int rc = uv_write(&wr->req, (uv_stream_t *)mgp_dev_state.pipe, uv_stream_t 558 src/dps8/dps8_net.c static void net_stop_reading_if_full(uv_stream_t* stream) { uv_stream_t 575 src/dps8/dps8_net.c static void net_read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf); uv_stream_t 580 src/dps8/dps8_net.c int rc = uv_read_start((uv_stream_t*)net_dev_state.pipe, uv_stream_t 594 src/dps8/dps8_net.c static void net_read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { uv_stream_t 625 src/dps8/dps8_net.c int rc = uv_read_start((uv_stream_t*)net_dev_state.pipe, net_alloc_cb, net_read_cb); uv_stream_t 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); uv_stream_t 356 src/dps8/fnpuv.c return uv_stream_get_write_queue_size ((uv_stream_t *) client) > uv_stream_t 490 src/dps8/fnpuv.c void close_connection (uv_stream_t* stream) uv_stream_t 589 src/dps8/fnpuv.c static void fuv_read_cb (uv_stream_t* stream, uv_stream_t 754 src/dps8/fnpuv.c int ret = uv_write (req, (uv_stream_t *) stn_client, & buf, 1, fuv_write_3270_cb); uv_stream_t 796 src/dps8/fnpuv.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, fuv_write_cb); uv_stream_t 928 src/dps8/fnpuv.c uv_read_start ((uv_stream_t *) client, alloc_buffer, fuv_read_cb); uv_stream_t 939 src/dps8/fnpuv.c uv_read_stop ((uv_stream_t *) client); uv_stream_t 946 src/dps8/fnpuv.c static void on_new_connection (uv_stream_t * server, int status) uv_stream_t 969 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) uv_stream_t 1064 src/dps8/fnpuv.c close_connection ((uv_stream_t *)client); uv_stream_t 1130 src/dps8/fnpuv.c r = uv_listen ((uv_stream_t *) & fnpData.du_server, DEFAULT_BACKLOG, uv_stream_t 1165 src/dps8/fnpuv.c close_connection ((uv_stream_t *)p->client); uv_stream_t 1196 src/dps8/fnpuv.c close_connection ((uv_stream_t *)p->client); uv_stream_t 1240 src/dps8/fnpuv.c close_connection ((uv_stream_t *)client); uv_stream_t 1427 src/dps8/fnpuv.c close_connection ((uv_stream_t *)linep->line_client); uv_stream_t 1444 src/dps8/fnpuv.c close_connection ((uv_stream_t *)linep->line_client); uv_stream_t 1454 src/dps8/fnpuv.c close_connection ((uv_stream_t *)linep->line_client); uv_stream_t 1459 src/dps8/fnpuv.c uv_stream_t 1471 src/dps8/fnpuv.c uv_stream_t 1526 src/dps8/fnpuv.c r = uv_listen ((uv_stream_t *) & linep->server, DEFAULT_BACKLOG, uv_stream_t 1695 src/dps8/fnpuv.c static void on_new_3270_connection (uv_stream_t * server, int status) uv_stream_t 1719 src/dps8/fnpuv.c if (uv_accept (server, (uv_stream_t *) client) != 0) uv_stream_t 1789 src/dps8/fnpuv.c close_connection ((uv_stream_t *)client); uv_stream_t 1860 src/dps8/fnpuv.c r = uv_listen ((uv_stream_t *) & fnpData.du3270_server, DEFAULT_BACKLOG, uv_stream_t 67 src/dps8/fnpuv.h void close_connection (uv_stream_t* stream); uv_stream_t 326 src/dps8/uvutil.c static void accessReadCallback (uv_stream_t* stream, uv_stream_t 363 src/dps8/uvutil.c uv_read_start ((uv_stream_t *) client, alloc_buffer, accessReadCallback); uv_stream_t 377 src/dps8/uvutil.c size_t queued = uv_stream_get_write_queue_size ((uv_stream_t *)client); uv_stream_t 382 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 408 src/dps8/uvutil.c int ret = uv_write (req, (uv_stream_t *) client, & buf, 1, uv_stream_t 639 src/dps8/uvutil.c void accessCloseConnection (uv_stream_t* stream) uv_stream_t 685 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); uv_stream_t 693 src/dps8/uvutil.c (void)uv_read_stop ((uv_stream_t *)session->client); uv_stream_t 698 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); uv_stream_t 703 src/dps8/uvutil.c uv_stream_t * stream = req->handle; uv_stream_t 724 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)oldest->client); uv_stream_t 727 src/dps8/uvutil.c (void)uv_read_stop ((uv_stream_t *)client); uv_stream_t 742 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 749 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 752 src/dps8/uvutil.c if (uv_shutdown (req, (uv_stream_t *)client, uv_stream_t 756 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 790 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); uv_stream_t 812 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)access->client); uv_stream_t 824 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)access->client); uv_stream_t 837 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)access->client); uv_stream_t 1018 src/dps8/uvutil.c static void onNewAccess (uv_stream_t * server, int status) uv_stream_t 1043 src/dps8/uvutil.c if (uv_accept (server, (uv_stream_t *) client) == 0) uv_stream_t 1058 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 1069 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 1076 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 1092 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 1111 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)client); uv_stream_t 1166 src/dps8/uvutil.c r = uv_listen ((uv_stream_t *) & access->server, uv_stream_t 55 src/dps8/uvutil.h void accessCloseConnection (uv_stream_t* stream);