| 18 | } |
| 19 | |
| 20 | void CPacketReader::Read(CConnection *connection) |
| 21 | { |
| 22 | if (connection->ReadyRead()) |
| 23 | { |
| 24 | if (!connection->Read()) |
| 25 | { |
| 26 | OnReadFailed(); |
| 27 | return; |
| 28 | } |
| 29 | |
| 30 | Wisp::CPacketMessage *parser = connection->m_MessageParser; |
| 31 | |
| 32 | while (true) |
| 33 | { |
| 34 | int offset = 0; |
| 35 | std::vector<uint8_t> packet = parser->Read(this, offset); |
| 36 | |
| 37 | if (packet.empty()) |
| 38 | { |
| 39 | break; |
| 40 | } |
| 41 | |
| 42 | if (MaxPacketStackSize != 0) |
| 43 | { |
| 44 | m_PacketsStack.push_back(packet); |
| 45 | |
| 46 | if ((int)m_PacketsStack.size() > MaxPacketStackSize) |
| 47 | { |
| 48 | m_PacketsStack.pop_front(); |
| 49 | } |
| 50 | } |
| 51 | |
| 52 | SetData((uint8_t *)&packet[0], packet.size(), offset); |
| 53 | OnPacket(); |
| 54 | } |
| 55 | } |
| 56 | } |
| 57 | |
| 58 | }; // namespace Wisp |