net_dev_state 190 src/dps8/dps8_net.c } net_dev_state; net_dev_state 449 src/dps8/dps8_net.c (void)memset(&net_dev_state, 0, sizeof ( net_dev_state )); net_dev_state 450 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 451 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 472 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 478 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len + nread <= (int)sizeof(net_dev_state.in_buffer)) { net_dev_state 479 src/dps8/dps8_net.c memcpy(net_dev_state.in_buffer + net_dev_state.in_buffer_len, buf->base, nread); net_dev_state 480 src/dps8/dps8_net.c net_dev_state.in_buffer_len += nread; net_dev_state 484 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 485 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 495 src/dps8/dps8_net.c if (net_dev_state.pipe) { net_dev_state 496 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 497 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 501 src/dps8/dps8_net.c uv_read_start((uv_stream_t*)net_dev_state.pipe, net_alloc_cb, net_read_cb); net_dev_state 507 src/dps8/dps8_net.c if (net_dev_state.pipe) return 0; net_dev_state 509 src/dps8/dps8_net.c if (net_dev_state.ptw_failed_at > 0) net_dev_state 511 src/dps8/dps8_net.c if (time(NULL) - net_dev_state.ptw_failed_at < PTW_BACKOFF_SECS) net_dev_state 513 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = 0; net_dev_state 516 src/dps8/dps8_net.c net_dev_state.pipe = malloc(sizeof(uv_pipe_t)); net_dev_state 517 src/dps8/dps8_net.c if (!net_dev_state.pipe) net_dev_state 519 src/dps8/dps8_net.c uv_pipe_init(uv_default_loop(), net_dev_state.pipe, 0); net_dev_state 523 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 524 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 528 src/dps8/dps8_net.c uv_pipe_connect(req, net_dev_state.pipe, gateway_socket_path, net_connect_cb); net_dev_state 529 src/dps8/dps8_net.c net_dev_state.in_buffer_len = 0; net_dev_state 551 src/dps8/dps8_net.c if (!net_dev_state.pipe) { net_dev_state 581 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 598 src/dps8/dps8_net.c if (!net_dev_state.pipe) { net_dev_state 602 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len < NET_FRAME_HEADER_SIZE) return 0; net_dev_state 604 src/dps8/dps8_net.c int pktlen = (net_dev_state.in_buffer[0] << 8) | net_dev_state.in_buffer[1]; net_dev_state 607 src/dps8/dps8_net.c if (net_dev_state.pipe) { net_dev_state 608 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 609 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 = 0; net_dev_state 615 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len < NET_FRAME_HEADER_SIZE + pktlen) { net_dev_state 619 src/dps8/dps8_net.c memcpy(pkt8, net_dev_state.in_buffer + NET_FRAME_HEADER_SIZE, pktlen); net_dev_state 621 src/dps8/dps8_net.c net_dev_state.in_buffer_len -= consumed; net_dev_state 622 src/dps8/dps8_net.c if (net_dev_state.in_buffer_len > 0) { net_dev_state 623 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 1155 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1193 src/dps8/dps8_net.c net_dev_state.want_to_read = 1; net_dev_state 1194 src/dps8/dps8_net.c net_dev_state.want_to_read_since = time(NULL); net_dev_state 1195 src/dps8/dps8_net.c net_dev_state.read_unit_idx = iom_unit_idx; net_dev_state 1196 src/dps8/dps8_net.c net_dev_state.read_unit_chan = chan; net_dev_state 1210 src/dps8/dps8_net.c net_dev_state.delivery_succeeded = 1; net_dev_state 1278 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1279 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1281 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1282 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1284 src/dps8/dps8_net.c net_dev_state.pipe = NULL; /* discard queued NOOPs */ net_dev_state 1304 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); net_dev_state 1305 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1307 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1308 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1310 src/dps8/dps8_net.c net_dev_state.pipe = NULL; 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; net_dev_state 1646 src/dps8/dps8_net.c if (!net_dev_state.want_to_read) net_dev_state 1651 src/dps8/dps8_net.c uint iom_unit_idx = net_dev_state.read_unit_idx; net_dev_state 1652 src/dps8/dps8_net.c uint chan = net_dev_state.read_unit_chan; net_dev_state 1669 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1679 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 1682 src/dps8/dps8_net.c if (net_dev_state.masked_since == 0) net_dev_state 1684 src/dps8/dps8_net.c net_dev_state.masked_since = now; net_dev_state 1689 src/dps8/dps8_net.c else if (now - net_dev_state.masked_since >= MASKED_STUCK_TIMEOUT_SECS) net_dev_state 1695 src/dps8/dps8_net.c if (net_dev_state.pipe) net_dev_state 1697 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1698 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1700 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1701 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1702 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1703 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1724 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1726 src/dps8/dps8_net.c if (net_dev_state.want_to_read_since > 0 && net_dev_state 1727 src/dps8/dps8_net.c now_ma - net_dev_state.want_to_read_since >= NET_ABSENT_TIMEOUT_SECS) net_dev_state 1733 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1734 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1735 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1742 src/dps8/dps8_net.c net_dev_state.masked_since = 0; net_dev_state 1753 src/dps8/dps8_net.c net_dev_state.want_to_read, net_dev_state 1754 src/dps8/dps8_net.c net_dev_state.pipe, net_dev_state 1755 src/dps8/dps8_net.c net_dev_state.read_unit_idx, net_dev_state 1756 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1771 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL) net_dev_state 1775 src/dps8/dps8_net.c if (net_dev_state.pipe == NULL) net_dev_state 1779 src/dps8/dps8_net.c if (now2 - net_dev_state.want_to_read_since >= NET_ABSENT_TIMEOUT_SECS) net_dev_state 1785 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1786 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1787 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1788 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1794 src/dps8/dps8_net.c net_dev_state.want_to_read_since = time(NULL); net_dev_state 1832 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1898 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1899 src/dps8/dps8_net.c net_dev_state.ptw_failed_at = time(NULL); /* start reconnect backoff */ net_dev_state 1907 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 1909 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 net_dev_state 1911 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 1912 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1914 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 1916 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1917 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 1970 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 1971 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 1972 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2036 src/dps8/dps8_net.c net_dev_state.delivery_succeeded = 0; net_dev_state 2042 src/dps8/dps8_net.c if (net_dev_state.delivery_succeeded) net_dev_state 2054 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2056 src/dps8/dps8_net.c net_dev_state.want_to_read = 0; net_dev_state 2059 src/dps8/dps8_net.c if (net_dev_state.pipe != NULL) net_dev_state 2061 src/dps8/dps8_net.c if (net_dev_state.pipe) //-V547 net_dev_state 2063 src/dps8/dps8_net.c uv_close((uv_handle_t*)net_dev_state.pipe, net_close_cb); net_dev_state 2064 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2067 src/dps8/dps8_net.c net_dev_state.pipe = NULL; net_dev_state 2069 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2070 src/dps8/dps8_net.c net_dev_state.read_unit_chan); net_dev_state 2079 src/dps8/dps8_net.c send_terminate_interrupt(net_dev_state.read_unit_idx, net_dev_state 2080 src/dps8/dps8_net.c net_dev_state.read_unit_chan);