diff options
| author | Tyler Seip <Tyler.Seip@mongodb.com> | 2021-03-19 18:28:46 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-03-23 17:37:22 +0000 |
| commit | 8c463d0aa0cce19073210d274dcbb04c156dc802 (patch) | |
| tree | 831640a2819370a0dc3641b02da5adad23e651a7 /src/mongo/executor/thread_pool_task_executor.cpp | |
| parent | f447e57dd2c5dbb39feef9cfe071ff1cc1de54d5 (diff) | |
| download | mongo-8c463d0aa0cce19073210d274dcbb04c156dc802.tar.gz | |
SERVER-53230: Rename cancelation -> cancellation everywhere
Diffstat (limited to 'src/mongo/executor/thread_pool_task_executor.cpp')
| -rw-r--r-- | src/mongo/executor/thread_pool_task_executor.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/executor/thread_pool_task_executor.cpp b/src/mongo/executor/thread_pool_task_executor.cpp index d1787313d76..b9a500deab7 100644 --- a/src/mongo/executor/thread_pool_task_executor.cpp +++ b/src/mongo/executor/thread_pool_task_executor.cpp @@ -613,14 +613,14 @@ void ThreadPoolTaskExecutor::scheduleIntoPool_inlock(WorkQueue* fromQueue, } _pool->schedule([this, cbState](auto status) { - invariant(status.isOK() || ErrorCodes::isCancelationError(status.code())); + invariant(status.isOK() || ErrorCodes::isCancellationError(status.code())); runCallback(std::move(cbState)); }); }); } else { _pool->schedule([this, cbState](auto status) { - if (ErrorCodes::isCancelationError(status.code())) { + if (ErrorCodes::isCancellationError(status.code())) { stdx::lock_guard<Latch> lk(_mutex); cbState->canceled.store(1); @@ -786,14 +786,14 @@ void ThreadPoolTaskExecutor::scheduleExhaustIntoPool_inlock(std::shared_ptr<Call } _pool->schedule([this, cbState, expectedExhaustIter](auto status) { - invariant(status.isOK() || ErrorCodes::isCancelationError(status.code())); + invariant(status.isOK() || ErrorCodes::isCancellationError(status.code())); runCallbackExhaust(cbState, expectedExhaustIter); }); }); } else { _pool->schedule([this, cbState, expectedExhaustIter](auto status) { - if (ErrorCodes::isCancelationError(status.code())) { + if (ErrorCodes::isCancellationError(status.code())) { stdx::lock_guard<Latch> lk(_mutex); cbState->canceled.store(1); |