Skip to content
Snippets Groups Projects
Commit 38d854e6 authored by Adrien Béraud's avatar Adrien Béraud
Browse files

dhtrunner: read correct size from buffer

parent e0241ccf
No related branches found
No related tags found
No related merge requests found
......@@ -474,7 +474,7 @@ DhtRunner::loop_()
if (clock::now() - pck.received > RX_QUEUE_MAX_DELAY)
dropped++;
else
wakeup = dht->periodic(pck.data.data(), pck.data.size()-1, pck.from);
wakeup = dht->periodic(pck.data.data(), pck.data.size(), pck.from);
received.pop();
}
} else {
......@@ -634,7 +634,7 @@ DhtRunner::startNetwork(const SockAddr sin4, const SockAddr sin6)
std::cerr << "Dropping packet: queue is full!" << std::endl;
rcv.pop();
}
rcv.emplace(ReceivedPacket {Blob {buf.begin(), buf.begin()+rc+1}, SockAddr(from, from_len), clock::now()});
rcv.emplace(ReceivedPacket {Blob {buf.begin(), buf.begin()+rc}, SockAddr(from, from_len), clock::now()});
}
cv.notify_all();
} else if (rc == -1) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment