| 24 | } |
| 25 | |
| 26 | void MessageEndpoint::Destroy(){ |
| 27 | Message m; |
| 28 | while(queue.Dequeue(&m, 1)){ |
| 29 | if(m.size > 8 && m.dataP){ |
| 30 | delete[] m.dataP; |
| 31 | } |
| 32 | } |
| 33 | |
| 34 | if(peer.get()){ |
| 35 | peer->peer = nullptr; |
| 36 | } |
| 37 | } |
| 38 | |
| 39 | int64_t MessageEndpoint::Read(uint64_t* id, uint16_t* size, uint64_t* data){ |
| 40 | assert(id); |