We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0ed8c46 commit e682913Copy full SHA for e682913
pc/user.cpp
@@ -339,8 +339,8 @@ void user::send_pending_upds()
339
int64_t curr_ts = get_now();
340
if (curr_ts - last_upd_ts_ > PC_FLUSH_INTERVAL) {
341
n_sent = pending_vec_.size();
342
- } else if (pending_vec_.size() > max_batch_size_) {
343
- n_sent = max_batch_size_;
+ } else if (pending_vec_.size() >= sptr_->get_max_batch_size()) {
+ n_sent = sptr_->get_max_batch_size();
344
}
345
346
if (n_sent == 0) {
0 commit comments