| 2349 | } |
| 2350 | |
| 2351 | ACTOR static Future<Void> send(UDPSimSocket* self, |
| 2352 | Reference<UDPSimSocket> peerSocket, |
| 2353 | uint8_t const* begin, |
| 2354 | uint8_t const* end) { |
| 2355 | state Packet packet(std::make_shared<std::vector<uint8_t>>()); |
| 2356 | packet->resize(end - begin); |
| 2357 | std::copy(begin, end, packet->begin()); |
| 2358 | wait(delay(.002 * deterministicRandom()->random01())); |
| 2359 | peerSocket->recvBuffer.emplace_back(self->_localAddress, std::move(packet)); |
| 2360 | peerSocket->writtenPackets.set(peerSocket->writtenPackets.get() + 1); |
| 2361 | return Void(); |
| 2362 | } |
| 2363 | |
| 2364 | ACTOR static Future<int> receiveFrom(UDPSimSocket* self, uint8_t* begin, uint8_t* end, NetworkAddress* sender) { |
| 2365 | state TaskPriority currentTaskID = g_sim2.getCurrentTask(); |
no test coverage detected