| 153 | } |
| 154 | |
| 155 | TCP_Session::~TCP_Session() |
| 156 | { |
| 157 | CloseSocket(); |
| 158 | |
| 159 | // Clear out _recvBuff |
| 160 | while (!_recvBuff.IsQueueEmpty()) |
| 161 | { |
| 162 | ReceivedPayload retPay; |
| 163 | if (!_recvBuff.Dequeue(&retPay)) |
| 164 | { |
| 165 | using namespace std::chrono_literals; |
| 166 | std::this_thread::sleep_for(1ms); |
| 167 | continue; |
| 168 | } |
| 169 | } |
| 170 | } |
| 171 | } // namespace Sessions |
nothing calls this directly
no test coverage detected