| 2030 | |
| 2031 | |
| 2032 | static bool_t xnet_write(RemoteXdr* xdrs) |
| 2033 | { |
| 2034 | /************************************** |
| 2035 | * |
| 2036 | * x n e t _ w r i t e |
| 2037 | * |
| 2038 | ************************************** |
| 2039 | * |
| 2040 | * Functional description |
| 2041 | * Signal remote interface that memory stream is |
| 2042 | * filled and ready for reading. |
| 2043 | * |
| 2044 | **************************************/ |
| 2045 | rem_port* port = xdrs->x_public; |
| 2046 | XCC xcc = port->port_xcc; |
| 2047 | XCH xch = xcc->xcc_send_channel; |
| 2048 | |
| 2049 | xch->xch_length = xdrs->x_private - xdrs->x_base; |
| 2050 | if (SetEvent(xcc->xcc_event_send_channel_filled)) |
| 2051 | { |
| 2052 | port->bumpPhysStats(rem_port::SEND, xch->xch_length); |
| 2053 | port->bumpLogBytes(rem_port::SEND, xch->xch_length); // XNET not calls REMOTE_deflate |
| 2054 | |
| 2055 | xdrs->x_private = xdrs->x_base; |
| 2056 | xdrs->x_handy = xch->xch_size; |
| 2057 | |
| 2058 | return TRUE; |
| 2059 | } |
| 2060 | |
| 2061 | return FALSE; |
| 2062 | } |
| 2063 | |
| 2064 | |
| 2065 | void XnetEndPoint::shutdown() |
no test coverage detected