diff options
Diffstat (limited to 'searchcore/src/vespa/searchcore/proton/persistenceengine/transport_latch.cpp')
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/persistenceengine/transport_latch.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/persistenceengine/transport_latch.cpp b/searchcore/src/vespa/searchcore/proton/persistenceengine/transport_latch.cpp index 61c240f0d6a..8a0955b3147 100644 --- a/searchcore/src/vespa/searchcore/proton/persistenceengine/transport_latch.cpp +++ b/searchcore/src/vespa/searchcore/proton/persistenceengine/transport_latch.cpp @@ -67,7 +67,7 @@ TransportLatch::send(ResultUP result, bool documentWasFound) _latch.countDown(); } -AsyncTranportContext::AsyncTranportContext(uint32_t cnt, OperationComplete::UP onComplete) +AsyncTransportContext::AsyncTransportContext(uint32_t cnt, OperationComplete::UP onComplete) : TransportMerger(cnt > 1), _countDown(cnt), _onComplete(std::move(onComplete)) @@ -78,17 +78,17 @@ AsyncTranportContext::AsyncTranportContext(uint32_t cnt, OperationComplete::UP o } void -AsyncTranportContext::completeIfDone() { +AsyncTransportContext::completeIfDone() { _countDown--; if (_countDown == 0) { _onComplete->onComplete(std::move(_result)); } } -AsyncTranportContext::~AsyncTranportContext() = default; +AsyncTransportContext::~AsyncTransportContext() = default; void -AsyncTranportContext::send(ResultUP result, bool documentWasFound) +AsyncTransportContext::send(ResultUP result, bool documentWasFound) { mergeResult(std::move(result), documentWasFound); } |