| 113 | } |
| 114 | |
| 115 | inline long Poll(Message& m) const{ |
| 116 | uint64_t id; |
| 117 | uint16_t size; |
| 118 | uint8_t* data = new uint8_t[msgSize]; |
| 119 | long ret = EndpointDequeue(handle, &id, &size, data); |
| 120 | |
| 121 | if(ret > 0){ |
| 122 | m.Set(data, size, id); |
| 123 | } else { |
| 124 | delete[] data; |
| 125 | } |
| 126 | return ret; |
| 127 | } |
| 128 | |
| 129 | inline long Call(const Message& call, Message& rmsg, uint64_t id) const{ |
| 130 | uint16_t size = call.length(); |
nothing calls this directly
no test coverage detected