logos-messaging/negentropy
1
0
Fork 0
mirror of https://github.com/logos-messaging/negentropy.git synced 2026-05-05 17:49:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

sort pendingOutputs before building output: Can reduce round-trips in some cases

Browse Source
This commit is contained in:
Doug Hoyte 2023-08-12 00:05:03 -04:00
parent b7f6535e28
commit 53ac2c9815
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cpp/Negentropy.h
View File

@ -273,12 +273,14 @@ struct Negentropy {
auto currBound = XorElem(0, "");
uint64_t lastTimestampOut = 0;
std::sort(pendingOutputs.begin(), pendingOutputs.end(), [](const auto &a, const auto &b){ return a.start < b.start; });
while (pendingOutputs.size()) {
std::string o;
auto &p = pendingOutputs.front();
// When bounds are out of order, finish this message and we'll resume next time
// When bounds are out of order or overlapping, finish and resume next time (shouldn't happen because of sort above)
if (p.start < currBound) break;
if (currBound != p.start) {