net_dev_state 223 src/dps8/dps8_net.c } net_dev_state; net_dev_state 482 src/dps8/dps8_net.c (void)memset(&net_dev_state, 0, sizeof ( net_dev_state )); net_dev_state 483 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 484 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 485 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 486 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 498 src/dps8/dps8_net.c while (net_dev_state.in_buffer_len - pos >= NET_FRAME_HEADER_SIZE) net_dev_state 500 src/dps8/dps8_net.c int len = (net_dev_state.in_buffer[pos] << 8) | net_dev_state 501 src/dps8/dps8_net.c net_dev_state.in_buffer[pos + 1]; net_dev_state 504 src/dps8/dps8_net.c net_dev_state.in_buffer_len - pos < NET_FRAME_HEADER_SIZE + len) net_dev_state 520 src/dps8/dps8_net.c if (complete_bytes != net_dev_state.in_buffer_len) net_dev_state 522 src/dps8/dps8_net.c net_dev_state.in_buffer_len - complete_bytes); net_dev_state 524 src/dps8/dps8_net.c net_dev_state.in_buffer_len = complete_bytes; net_dev_state 525 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 526 src/dps8/dps8_net.c net_dev_state.eof_draining = frames != 0; net_dev_state 527 src/dps8/dps8_net.c net_dev_state.eof_drain_progress = uv_hrtime(); net_dev_state 531 src/dps8/dps8_net.c if (!net_dev_state.eof_draining) net_dev_state 534 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len == 0) net_dev_state 536 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 540 src/dps8/dps8_net.c if (uv_hrtime() - net_dev_state.eof_drain_progress >= NET_EOF_DRAIN_IDLE_NS) net_dev_state 546 src/dps8/dps8_net.c frames, net_dev_state.in_buffer_len); net_dev_state 547 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 548 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 553 src/dps8/dps8_net.c size_t free_bytes = sizeof(net_dev_state.in_buffer) - (size_t)net_dev_state.in_buffer_len; net_dev_state 554 src/dps8/dps8_net.c buf->base = (char *)net_dev_state.in_buffer + net_dev_state.in_buffer_len; net_dev_state 559 src/dps8/dps8_net.c if (!net_dev_state.reading_stopped && net_dev_state 560 src/dps8/dps8_net.c (int)sizeof(net_dev_state.in_buffer) - net_dev_state.in_buffer_len < NET_MAX_FRAME) { net_dev_state 564 src/dps8/dps8_net.c net_dev_state.reading_stopped = 1; net_dev_state 568 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 578 src/dps8/dps8_net.c if (net_dev_state.reading_stopped && net_dev_state.pipe && net_dev_state 579 src/dps8/dps8_net.c net_dev_state.in_buffer_len <= (int)sizeof(net_dev_state.in_buffer) / 2) { net_dev_state 580 src/dps8/dps8_net.c int rc = uv_read_start((uv_stream_t*)net_dev_state.pipe, net_dev_state 584 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 587 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 588 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 607 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 611 src/dps8/dps8_net.c net_dev_state.in_buffer_len += (int)nread; net_dev_state 618 src/dps8/dps8_net.c if (net_dev_state.pipe) { net_dev_state 619 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 620 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 624 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 625 src/dps8/dps8_net.c int rc = uv_read_start((uv_stream_t*)net_dev_state.pipe, net_alloc_cb, net_read_cb); net_dev_state 628 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 629 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 636 src/dps8/dps8_net.c if (net_dev_state.pipe) return 0; net_dev_state 637 src/dps8/dps8_net.c if (net_dev_state.eof_draining) return -1; net_dev_state 639 src/dps8/dps8_net.c if (net_dev_state.ptw_failed_at > 0) net_dev_state 641 src/dps8/dps8_net.c if (time(NULL) - net_dev_state.ptw_failed_at < PTW_BACKOFF_SECS) net_dev_state 643 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = 0; net_dev_state 646 src/dps8/dps8_net.c net_dev_state.pipe = malloc(sizeof(uv_pipe_t)); net_dev_state 647 src/dps8/dps8_net.c if (!net_dev_state.pipe) net_dev_state 649 src/dps8/dps8_net.c uv_pipe_init(uv_default_loop(), net_dev_state.pipe, 0); net_dev_state 653 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 654 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 658 src/dps8/dps8_net.c uv_pipe_connect(req, net_dev_state.pipe, gateway_socket_path, net_connect_cb); net_dev_state 659 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 660 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 661 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 683 src/dps8/dps8_net.c if (!net_dev_state.pipe) { net_dev_state 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); net_dev_state 730 src/dps8/dps8_net.c if (!net_dev_state.pipe && !net_dev_state.eof_draining) return 0; net_dev_state 732 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len < NET_FRAME_HEADER_SIZE) return 0; net_dev_state 734 src/dps8/dps8_net.c int pktlen = (net_dev_state.in_buffer[0] << 8) | net_dev_state.in_buffer[1]; net_dev_state 737 src/dps8/dps8_net.c if (net_dev_state.pipe) { net_dev_state 738 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 739 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 741 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 742 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 746 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len < NET_FRAME_HEADER_SIZE + pktlen) { net_dev_state 750 src/dps8/dps8_net.c memcpy(pkt8, net_dev_state.in_buffer + NET_FRAME_HEADER_SIZE, pktlen); net_dev_state 752 src/dps8/dps8_net.c net_dev_state.in_buffer_len -= consumed; net_dev_state 753 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len > 0) { net_dev_state 754 src/dps8/dps8_net.c memmove(net_dev_state.in_buffer, net_dev_state.in_buffer + consumed, net_dev_state.in_buffer_len); net_dev_state 757 src/dps8/dps8_net.c if (net_dev_state.eof_draining) net_dev_state 759 src/dps8/dps8_net.c net_dev_state.eof_drain_progress = uv_hrtime(); net_dev_state 760 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len == 0) net_dev_state 761 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 770 src/dps8/dps8_net.c if (!net_dev_state.pipe && !net_dev_state.eof_draining) return 0; net_dev_state 771 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len < NET_FRAME_HEADER_SIZE) return 0; net_dev_state 773 src/dps8/dps8_net.c int pktlen = (net_dev_state.in_buffer[0] << 8) | net_dev_state.in_buffer[1]; net_dev_state 776 src/dps8/dps8_net.c return net_dev_state.in_buffer_len >= NET_FRAME_HEADER_SIZE + pktlen; net_dev_state 1305 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1343 src/dps8/dps8_net.c net_dev_state.want_to_read = 1; net_dev_state 1344 src/dps8/dps8_net.c net_dev_state.want_to_read_since = time(NULL); net_dev_state 1345 src/dps8/dps8_net.c net_dev_state.read_unit_idx = iom_unit_idx; net_dev_state 1346 src/dps8/dps8_net.c net_dev_state.read_unit_chan = chan; net_dev_state 1360 src/dps8/dps8_net.c net_dev_state.delivery_succeeded = 1; net_dev_state 1428 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1429 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1431 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1432 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1434 src/dps8/dps8_net.c net_dev_state.pipe = NULL; /* discard queued NOOPs */ net_dev_state 1454 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1455 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1457 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1458 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1460 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1548 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1549 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1551 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1552 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1554 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1797 src/dps8/dps8_net.c if (!net_dev_state.want_to_read) net_dev_state 1802 src/dps8/dps8_net.c uint iom_unit_idx = net_dev_state.read_unit_idx; net_dev_state 1803 src/dps8/dps8_net.c uint chan = net_dev_state.read_unit_chan; net_dev_state 1820 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1830 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 1833 src/dps8/dps8_net.c if (net_dev_state.masked_since == 0) net_dev_state 1835 src/dps8/dps8_net.c net_dev_state.masked_since = now; net_dev_state 1840 src/dps8/dps8_net.c else if (now - net_dev_state.masked_since >= MASKED_STUCK_TIMEOUT_SECS) net_dev_state 1846 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1848 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1849 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1851 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1852 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1853 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1854 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1875 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1877 src/dps8/dps8_net.c if (net_dev_state.want_to_read_since > 0 && net_dev_state 1878 src/dps8/dps8_net.c now_ma - net_dev_state.want_to_read_since >= NET_ABSENT_TIMEOUT_SECS) net_dev_state 1884 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1885 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1886 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1893 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1904 src/dps8/dps8_net.c net_dev_state.want_to_read, net_dev_state 1905 src/dps8/dps8_net.c net_dev_state.pipe, net_dev_state 1906 src/dps8/dps8_net.c net_dev_state.read_unit_idx, net_dev_state 1907 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1922 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL && !net_dev_state.eof_draining) net_dev_state 1926 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL) net_dev_state 1930 src/dps8/dps8_net.c if (now2 - net_dev_state.want_to_read_since >= NET_ABSENT_TIMEOUT_SECS) net_dev_state 1936 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1937 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1938 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1939 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1945 src/dps8/dps8_net.c net_dev_state.want_to_read_since = time(NULL); net_dev_state 1986 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2032 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2033 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); /* start reconnect backoff */ net_dev_state 2043 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 2045 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 net_dev_state 2047 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 2048 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2050 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2052 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2053 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2106 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2107 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2108 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2190 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2226 src/dps8/dps8_net.c net_dev_state.delivery_succeeded = 0; net_dev_state 2232 src/dps8/dps8_net.c if (net_dev_state.delivery_succeeded) net_dev_state 2244 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2246 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2249 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 2251 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 net_dev_state 2253 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 2254 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2257 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2259 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2260 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2269 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2270 src/dps8/dps8_net.c net_dev_state.read_unit_chan);