| 50 | } |
| 51 | |
| 52 | void Client::Read() |
| 53 | { |
| 54 | // BE_LOG(L"Read Calling %d\n", PACKET_LENGTH - m_nLength); |
| 55 | auto self(shared_from_this()); |
| 56 | socket_.async_read_some(asio::buffer(m_Buffer + m_nLength, PACKET_LENGTH - m_nLength), |
| 57 | [this, self](std::error_code ec, std::size_t length) |
| 58 | { |
| 59 | //BE_LOG(L"OnRead Called %d %d\n", ec.value(), length); |
| 60 | if (ec) { |
| 61 | Shutdown(); |
| 62 | return; |
| 63 | } |
| 64 | OnRead(length); |
| 65 | }); |
| 66 | } |
| 67 | |
| 68 | void Client::Write(BE1::Network::Buffer *pBuffer) |
| 69 | { |
no test coverage detected