mgp_dev_state 195 src/dps8/dps8_mgp.c } mgp_dev_state; mgp_dev_state 454 src/dps8/dps8_mgp.c (void)memset(&mgp_dev_state, 0, sizeof ( mgp_dev_state )); mgp_dev_state 455 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 456 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer_len = 0; mgp_dev_state 476 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 482 src/dps8/dps8_mgp.c if (mgp_dev_state.in_buffer_len + (int)nread mgp_dev_state 483 src/dps8/dps8_mgp.c <= (int)sizeof(mgp_dev_state.in_buffer)) { mgp_dev_state 484 src/dps8/dps8_mgp.c memcpy(mgp_dev_state.in_buffer + mgp_dev_state.in_buffer_len, mgp_dev_state 486 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer_len += (int)nread; mgp_dev_state 490 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 491 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer_len = 0; mgp_dev_state 501 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) { mgp_dev_state 502 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 503 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 508 src/dps8/dps8_mgp.c uv_read_start((uv_stream_t *)mgp_dev_state.pipe, mgp_dev_state 522 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) return 0; /* already connected or pending */ mgp_dev_state 525 src/dps8/dps8_mgp.c if (mgp_dev_state.ptw_failed_at > 0) mgp_dev_state 527 src/dps8/dps8_mgp.c if (time(NULL) - mgp_dev_state.ptw_failed_at < PTW_BACKOFF_SECS) mgp_dev_state 529 src/dps8/dps8_mgp.c mgp_dev_state.ptw_failed_at = 0; mgp_dev_state 532 src/dps8/dps8_mgp.c mgp_dev_state.pipe = malloc(sizeof(uv_pipe_t)); mgp_dev_state 533 src/dps8/dps8_mgp.c if (!mgp_dev_state.pipe) mgp_dev_state 535 src/dps8/dps8_mgp.c uv_pipe_init(uv_default_loop(), mgp_dev_state.pipe, 0); mgp_dev_state 539 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 540 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 544 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer_len = 0; mgp_dev_state 545 src/dps8/dps8_mgp.c uv_pipe_connect(req, mgp_dev_state.pipe, ncp_socket_path, ncp_connect_cb); mgp_dev_state 572 src/dps8/dps8_mgp.c if (!mgp_dev_state.pipe) { mgp_dev_state 601 src/dps8/dps8_mgp.c int rc = uv_write(&wr->req, (uv_stream_t *)mgp_dev_state.pipe, mgp_dev_state 626 src/dps8/dps8_mgp.c if (!mgp_dev_state.pipe) { mgp_dev_state 631 src/dps8/dps8_mgp.c if (mgp_dev_state.in_buffer_len < NCP_FRAME_HEADER_SIZE) return 0; mgp_dev_state 633 src/dps8/dps8_mgp.c int pktlen = ((unsigned char)mgp_dev_state.in_buffer[0] << 8) mgp_dev_state 634 src/dps8/dps8_mgp.c | (unsigned char)mgp_dev_state.in_buffer[1]; mgp_dev_state 639 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) { mgp_dev_state 640 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 641 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 643 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer_len = 0; mgp_dev_state 647 src/dps8/dps8_mgp.c if (mgp_dev_state.in_buffer_len < NCP_FRAME_HEADER_SIZE + pktlen) return 0; mgp_dev_state 649 src/dps8/dps8_mgp.c memcpy(pkt8, mgp_dev_state.in_buffer + NCP_FRAME_HEADER_SIZE, pktlen); mgp_dev_state 651 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer_len -= consumed; mgp_dev_state 652 src/dps8/dps8_mgp.c if (mgp_dev_state.in_buffer_len > 0) mgp_dev_state 653 src/dps8/dps8_mgp.c memmove(mgp_dev_state.in_buffer, mgp_dev_state 654 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer + consumed, mgp_dev_state 655 src/dps8/dps8_mgp.c mgp_dev_state.in_buffer_len); mgp_dev_state 1073 src/dps8/dps8_mgp.c mgp_dev_state.ptw_failed_at = time(NULL); mgp_dev_state 1111 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 1; mgp_dev_state 1112 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read_since = time(NULL); mgp_dev_state 1113 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_idx = iom_unit_idx; mgp_dev_state 1114 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan = chan; mgp_dev_state 1128 src/dps8/dps8_mgp.c mgp_dev_state.delivery_succeeded = 1; mgp_dev_state 1174 src/dps8/dps8_mgp.c mgp_dev_state.ptw_failed_at = time(NULL); mgp_dev_state 1175 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) mgp_dev_state 1177 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 1178 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 1197 src/dps8/dps8_mgp.c mgp_dev_state.ptw_failed_at = time(NULL); mgp_dev_state 1198 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) mgp_dev_state 1200 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 1201 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 1269 src/dps8/dps8_mgp.c mgp_dev_state.ptw_failed_at = time(NULL); mgp_dev_state 1270 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) mgp_dev_state 1272 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 1273 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 1487 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL && mgp_dev_state.want_to_read_since > 0) mgp_dev_state 1490 src/dps8/dps8_mgp.c if (mgp_dev_state.last_progress_time == 0) mgp_dev_state 1492 src/dps8/dps8_mgp.c mgp_dev_state.last_progress_time = now_np; mgp_dev_state 1494 src/dps8/dps8_mgp.c else if (now_np - mgp_dev_state.last_progress_time >= NO_PROGRESS_TIMEOUT_SECS) mgp_dev_state 1500 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) mgp_dev_state 1502 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 1503 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 1505 src/dps8/dps8_mgp.c mgp_dev_state.last_progress_time = 0; mgp_dev_state 1506 src/dps8/dps8_mgp.c mgp_dev_state.masked_since = 0; mgp_dev_state 1507 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1508 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1509 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1514 src/dps8/dps8_mgp.c if (!mgp_dev_state.want_to_read) mgp_dev_state 1519 src/dps8/dps8_mgp.c uint iom_unit_idx = mgp_dev_state.read_unit_idx; mgp_dev_state 1520 src/dps8/dps8_mgp.c uint chan = mgp_dev_state.read_unit_chan; mgp_dev_state 1537 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1547 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL) mgp_dev_state 1550 src/dps8/dps8_mgp.c if (mgp_dev_state.masked_since == 0) mgp_dev_state 1552 src/dps8/dps8_mgp.c mgp_dev_state.masked_since = now; mgp_dev_state 1557 src/dps8/dps8_mgp.c else if (now - mgp_dev_state.masked_since >= MASKED_STUCK_TIMEOUT_SECS) mgp_dev_state 1563 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) mgp_dev_state 1565 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 1566 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 1568 src/dps8/dps8_mgp.c mgp_dev_state.masked_since = 0; mgp_dev_state 1569 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1570 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1591 src/dps8/dps8_mgp.c mgp_dev_state.masked_since = 0; mgp_dev_state 1593 src/dps8/dps8_mgp.c if (mgp_dev_state.want_to_read_since > 0 && mgp_dev_state 1594 src/dps8/dps8_mgp.c now_ma - mgp_dev_state.want_to_read_since >= NCP_ABSENT_TIMEOUT_SECS) mgp_dev_state 1600 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1601 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1602 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1609 src/dps8/dps8_mgp.c mgp_dev_state.masked_since = 0; mgp_dev_state 1620 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read, mgp_dev_state 1621 src/dps8/dps8_mgp.c mgp_dev_state.pipe, mgp_dev_state 1622 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_idx, mgp_dev_state 1623 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1638 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe == NULL) mgp_dev_state 1642 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe == NULL) mgp_dev_state 1646 src/dps8/dps8_mgp.c if (now2 - mgp_dev_state.want_to_read_since >= NCP_ABSENT_TIMEOUT_SECS) mgp_dev_state 1652 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1653 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1654 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1655 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1661 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read_since = time(NULL); mgp_dev_state 1737 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1792 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1793 src/dps8/dps8_mgp.c mgp_dev_state.ptw_failed_at = time(NULL); /* start reconnect backoff */ mgp_dev_state 1801 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL) mgp_dev_state 1803 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) //-V547 mgp_dev_state 1805 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 1806 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 1809 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1810 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1861 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1862 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1863 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1872 src/dps8/dps8_mgp.c mgp_dev_state.last_progress_time = time(NULL); mgp_dev_state 1905 src/dps8/dps8_mgp.c mgp_dev_state.delivery_succeeded = 0; mgp_dev_state 1910 src/dps8/dps8_mgp.c __func__, __LINE__, rc, mgp_dev_state.delivery_succeeded); mgp_dev_state 1915 src/dps8/dps8_mgp.c if (mgp_dev_state.delivery_succeeded) mgp_dev_state 1927 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1929 src/dps8/dps8_mgp.c mgp_dev_state.want_to_read = 0; mgp_dev_state 1932 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe != NULL) mgp_dev_state 1934 src/dps8/dps8_mgp.c if (mgp_dev_state.pipe) //-V547 mgp_dev_state 1936 src/dps8/dps8_mgp.c uv_close((uv_handle_t *)mgp_dev_state.pipe, ncp_close_cb); mgp_dev_state 1937 src/dps8/dps8_mgp.c mgp_dev_state.pipe = NULL; mgp_dev_state 1941 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1942 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan); mgp_dev_state 1951 src/dps8/dps8_mgp.c send_terminate_interrupt(mgp_dev_state.read_unit_idx, mgp_dev_state 1952 src/dps8/dps8_mgp.c mgp_dev_state.read_unit_chan);