net_dev_state 210 src/dps8/dps8_net.c } net_dev_state; net_dev_state 469 src/dps8/dps8_net.c (void)memset(&net_dev_state, 0, sizeof ( net_dev_state )); net_dev_state 470 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 471 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 472 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 473 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 485 src/dps8/dps8_net.c while (net_dev_state.in_buffer_len - pos >= NET_FRAME_HEADER_SIZE) net_dev_state 487 src/dps8/dps8_net.c int len = (net_dev_state.in_buffer[pos] << 8) | net_dev_state 488 src/dps8/dps8_net.c net_dev_state.in_buffer[pos + 1]; net_dev_state 491 src/dps8/dps8_net.c net_dev_state.in_buffer_len - pos < NET_FRAME_HEADER_SIZE + len) net_dev_state 507 src/dps8/dps8_net.c if (complete_bytes != net_dev_state.in_buffer_len) net_dev_state 509 src/dps8/dps8_net.c net_dev_state.in_buffer_len - complete_bytes); net_dev_state 511 src/dps8/dps8_net.c net_dev_state.in_buffer_len = complete_bytes; net_dev_state 512 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 513 src/dps8/dps8_net.c net_dev_state.eof_draining = frames != 0; net_dev_state 514 src/dps8/dps8_net.c net_dev_state.eof_drain_started = uv_hrtime(); net_dev_state 518 src/dps8/dps8_net.c if (!net_dev_state.eof_draining) net_dev_state 521 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len == 0) net_dev_state 523 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 527 src/dps8/dps8_net.c if (uv_hrtime() - net_dev_state.eof_drain_started >= NET_EOF_DRAIN_NS) net_dev_state 532 src/dps8/dps8_net.c frames, net_dev_state.in_buffer_len); net_dev_state 533 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 534 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 539 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 540 src/dps8/dps8_net.c buf->base = (char *)net_dev_state.in_buffer + net_dev_state.in_buffer_len; net_dev_state 545 src/dps8/dps8_net.c if (!net_dev_state.reading_stopped && net_dev_state 546 src/dps8/dps8_net.c (int)sizeof(net_dev_state.in_buffer) - net_dev_state.in_buffer_len < NET_MAX_FRAME) { net_dev_state 550 src/dps8/dps8_net.c net_dev_state.reading_stopped = 1; net_dev_state 554 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 564 src/dps8/dps8_net.c if (net_dev_state.reading_stopped && net_dev_state.pipe && net_dev_state 565 src/dps8/dps8_net.c net_dev_state.in_buffer_len <= (int)sizeof(net_dev_state.in_buffer) / 2) { net_dev_state 566 src/dps8/dps8_net.c int rc = uv_read_start((uv_stream_t*)net_dev_state.pipe, net_dev_state 570 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 573 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 574 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 593 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 597 src/dps8/dps8_net.c net_dev_state.in_buffer_len += (int)nread; net_dev_state 604 src/dps8/dps8_net.c if (net_dev_state.pipe) { net_dev_state 605 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 606 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 610 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 611 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 614 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 615 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 622 src/dps8/dps8_net.c if (net_dev_state.pipe) return 0; net_dev_state 623 src/dps8/dps8_net.c if (net_dev_state.eof_draining) return -1; net_dev_state 625 src/dps8/dps8_net.c if (net_dev_state.ptw_failed_at > 0) net_dev_state 627 src/dps8/dps8_net.c if (time(NULL) - net_dev_state.ptw_failed_at < PTW_BACKOFF_SECS) net_dev_state 629 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = 0; net_dev_state 632 src/dps8/dps8_net.c net_dev_state.pipe = malloc(sizeof(uv_pipe_t)); net_dev_state 633 src/dps8/dps8_net.c if (!net_dev_state.pipe) net_dev_state 635 src/dps8/dps8_net.c uv_pipe_init(uv_default_loop(), net_dev_state.pipe, 0); net_dev_state 639 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 640 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 644 src/dps8/dps8_net.c uv_pipe_connect(req, net_dev_state.pipe, gateway_socket_path, net_connect_cb); net_dev_state 645 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 646 src/dps8/dps8_net.c net_dev_state.reading_stopped = 0; net_dev_state 647 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 669 src/dps8/dps8_net.c if (!net_dev_state.pipe) { net_dev_state 699 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 716 src/dps8/dps8_net.c if (!net_dev_state.pipe && !net_dev_state.eof_draining) return 0; net_dev_state 718 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len < NET_FRAME_HEADER_SIZE) return 0; net_dev_state 720 src/dps8/dps8_net.c int pktlen = (net_dev_state.in_buffer[0] << 8) | net_dev_state.in_buffer[1]; net_dev_state 723 src/dps8/dps8_net.c if (net_dev_state.pipe) { net_dev_state 724 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 725 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 727 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 728 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 732 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len < NET_FRAME_HEADER_SIZE + pktlen) { net_dev_state 736 src/dps8/dps8_net.c memcpy(pkt8, net_dev_state.in_buffer + NET_FRAME_HEADER_SIZE, pktlen); net_dev_state 738 src/dps8/dps8_net.c net_dev_state.in_buffer_len -= consumed; net_dev_state 739 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len > 0) { net_dev_state 740 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 743 src/dps8/dps8_net.c if (net_dev_state.eof_draining && net_dev_state.in_buffer_len == 0) net_dev_state 744 src/dps8/dps8_net.c net_dev_state.eof_draining = 0; net_dev_state 1275 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1313 src/dps8/dps8_net.c net_dev_state.want_to_read = 1; net_dev_state 1314 src/dps8/dps8_net.c net_dev_state.want_to_read_since = time(NULL); net_dev_state 1315 src/dps8/dps8_net.c net_dev_state.read_unit_idx = iom_unit_idx; net_dev_state 1316 src/dps8/dps8_net.c net_dev_state.read_unit_chan = chan; net_dev_state 1330 src/dps8/dps8_net.c net_dev_state.delivery_succeeded = 1; net_dev_state 1398 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1399 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1401 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1402 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1404 src/dps8/dps8_net.c net_dev_state.pipe = NULL; /* discard queued NOOPs */ net_dev_state 1424 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1425 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1427 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1428 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1430 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1518 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1519 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1521 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1522 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1524 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1767 src/dps8/dps8_net.c if (!net_dev_state.want_to_read) net_dev_state 1772 src/dps8/dps8_net.c uint iom_unit_idx = net_dev_state.read_unit_idx; net_dev_state 1773 src/dps8/dps8_net.c uint chan = net_dev_state.read_unit_chan; net_dev_state 1790 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1800 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 1803 src/dps8/dps8_net.c if (net_dev_state.masked_since == 0) net_dev_state 1805 src/dps8/dps8_net.c net_dev_state.masked_since = now; net_dev_state 1810 src/dps8/dps8_net.c else if (now - net_dev_state.masked_since >= MASKED_STUCK_TIMEOUT_SECS) net_dev_state 1816 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1818 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1819 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1821 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1822 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1823 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1824 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1845 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1847 src/dps8/dps8_net.c if (net_dev_state.want_to_read_since > 0 && net_dev_state 1848 src/dps8/dps8_net.c now_ma - net_dev_state.want_to_read_since >= NET_ABSENT_TIMEOUT_SECS) net_dev_state 1854 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1855 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1856 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1863 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1874 src/dps8/dps8_net.c net_dev_state.want_to_read, net_dev_state 1875 src/dps8/dps8_net.c net_dev_state.pipe, net_dev_state 1876 src/dps8/dps8_net.c net_dev_state.read_unit_idx, net_dev_state 1877 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1892 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL && !net_dev_state.eof_draining) net_dev_state 1896 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL) net_dev_state 1900 src/dps8/dps8_net.c if (now2 - net_dev_state.want_to_read_since >= NET_ABSENT_TIMEOUT_SECS) net_dev_state 1906 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1907 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1908 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1909 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1915 src/dps8/dps8_net.c net_dev_state.want_to_read_since = time(NULL); net_dev_state 1954 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2020 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2021 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); /* start reconnect backoff */ net_dev_state 2029 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 2031 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 net_dev_state 2033 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 2034 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2036 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2038 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2039 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2092 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2093 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2094 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2158 src/dps8/dps8_net.c net_dev_state.delivery_succeeded = 0; net_dev_state 2164 src/dps8/dps8_net.c if (net_dev_state.delivery_succeeded) net_dev_state 2176 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2178 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2181 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 2183 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 net_dev_state 2185 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 2186 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2189 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2191 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2192 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2201 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2202 src/dps8/dps8_net.c net_dev_state.read_unit_chan);