diff options
Diffstat (limited to 'storage/src/vespa/storage/storageserver/mergethrottler.cpp')
| -rw-r--r-- | storage/src/vespa/storage/storageserver/mergethrottler.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/storage/src/vespa/storage/storageserver/mergethrottler.cpp b/storage/src/vespa/storage/storageserver/mergethrottler.cpp index a17c77f6ca4..05e50492206 100644 --- a/storage/src/vespa/storage/storageserver/mergethrottler.cpp +++ b/storage/src/vespa/storage/storageserver/mergethrottler.cpp @@ -395,7 +395,8 @@ MergeThrottler::enqueueMerge( if (!validateNewMerge(mergeCmd, nodeSeq, msgGuard)) { return; } - _queue.emplace(msg, _queueSequence++); + const bool is_forwarded_merge = _disable_queue_limits_for_chained_merges && !mergeCmd.getChain().empty(); + _queue.emplace(msg, _queueSequence++, is_forwarded_merge); _metrics->queueSize.set(_queue.size()); } |