mirror/ternfs-XTXMarkets
1
0
Fork 0
mirror of https://github.com/XTXMarkets/ternfs.git synced 2026-01-05 10:30:53 -06:00
Code Issues Packages Projects Releases Wiki Activity

cdc: remove adaptive msg receive

Browse Source
This commit is contained in:
Miroslav Crnic
2024-06-02 07:59:16 +00:00
parent 939688d81d
commit bb47c8f38d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cpp/cdc/CDC.cpp
View File

@@ -339,7 +339,7 @@ public:
if (unlikely(entries.size())) {
timeout = 0;
}
if (unlikely(!_channel.receiveMessages(_env,_shared.socks, _receiver, MAX_UPDATE_SIZE - _updateSize(), timeout))) {
if (unlikely(!_channel.receiveMessages(_env,_shared.socks, _receiver, MAX_UPDATE_SIZE, timeout))) {
return;
};