diff options
author | Billy Donahue <billy.donahue@mongodb.com> | 2020-11-19 17:22:13 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-11-20 01:12:35 +0000 |
commit | 32c4765e7a29ebbb7470a944dabf70d69134a486 (patch) | |
tree | ca1d1b3e3b39dcb4ee394e84bf9be1d10212f938 /src | |
parent | 304316278656273caffdd461ead2ef02e2ac7743 (diff) | |
download | mongo-32c4765e7a29ebbb7470a944dabf70d69134a486.tar.gz |
SERVER-50684 rename,cleanup internalAssert->iassert
Diffstat (limited to 'src')
-rw-r--r-- | src/mongo/db/operation_cpu_timer.cpp | 4 | ||||
-rw-r--r-- | src/mongo/db/service_entry_point_common.cpp | 6 | ||||
-rw-r--r-- | src/mongo/db/wire_version.cpp | 3 | ||||
-rw-r--r-- | src/mongo/transport/service_executor.h | 4 | ||||
-rw-r--r-- | src/mongo/transport/service_executor_fixed.cpp | 2 | ||||
-rw-r--r-- | src/mongo/util/assert_util.cpp | 2 | ||||
-rw-r--r-- | src/mongo/util/assert_util.h | 31 | ||||
-rw-r--r-- | src/mongo/util/assert_util_test.cpp | 8 | ||||
-rw-r--r-- | src/mongo/util/interruptible.h | 4 |
9 files changed, 25 insertions, 39 deletions
diff --git a/src/mongo/db/operation_cpu_timer.cpp b/src/mongo/db/operation_cpu_timer.cpp index 34cb63eb3d4..b870e621909 100644 --- a/src/mongo/db/operation_cpu_timer.cpp +++ b/src/mongo/db/operation_cpu_timer.cpp @@ -60,8 +60,8 @@ Nanoseconds getThreadCPUTime() { struct timespec t; if (auto ret = clock_gettime(CLOCK_THREAD_CPUTIME_ID, &t); ret != 0) { int ec = errno; - internalAssert(Status(ErrorCodes::InternalError, - "Unable to get time: {}"_format(errnoWithDescription(ec)))); + iassert(Status(ErrorCodes::InternalError, + "Unable to get time: {}"_format(errnoWithDescription(ec)))); } return Seconds(t.tv_sec) + Nanoseconds(t.tv_nsec); } diff --git a/src/mongo/db/service_entry_point_common.cpp b/src/mongo/db/service_entry_point_common.cpp index 9f3fd1a22d5..528b37d071e 100644 --- a/src/mongo/db/service_entry_point_common.cpp +++ b/src/mongo/db/service_entry_point_common.cpp @@ -1702,7 +1702,7 @@ void ExecCommandDatabase::_handleFailure(Status status) { if (ErrorCodes::isA<ErrorCategory::CloseConnectionError>(status.code())) { // Rethrow the exception to the top to signal that the client connection should be closed. - internalAssert(status); + iassert(status); } } @@ -1852,7 +1852,7 @@ Future<DbResponse> receivedCommands(std::shared_ptr<HandleRequest::ExecutionCont .onError([execContext](Status status) { if (ErrorCodes::isConnectionFatalMessageParseError(status.code())) { // If this error needs to fail the connection, propagate it out. - internalAssert(status); + iassert(status); } auto opCtx = execContext->getOpCtx(); @@ -1870,7 +1870,7 @@ Future<DbResponse> receivedCommands(std::shared_ptr<HandleRequest::ExecutionCont if (ErrorCodes::isA<ErrorCategory::CloseConnectionError>(status.code())) { // Return the exception to the top to signal that the client connection should be // closed. - internalAssert(status); + iassert(status); } }) .then([execContext] { return makeCommandResponse(std::move(execContext)); }); diff --git a/src/mongo/db/wire_version.cpp b/src/mongo/db/wire_version.cpp index c0757324dbc..03fc8543a87 100644 --- a/src/mongo/db/wire_version.cpp +++ b/src/mongo/db/wire_version.cpp @@ -70,8 +70,7 @@ void WireSpec::reset(Specification spec) { BSONObj oldSpec, newSpec; { stdx::lock_guard<Latch> lk(_mutex); - internalAssert( - ErrorCodes::NotYetInitialized, "WireSpec is not yet initialized", isInitialized()); + iassert(ErrorCodes::NotYetInitialized, "WireSpec is not yet initialized", isInitialized()); oldSpec = specToBSON(*_spec.get()); _spec = std::make_shared<Specification>(std::move(spec)); diff --git a/src/mongo/transport/service_executor.h b/src/mongo/transport/service_executor.h index b702198e6b5..b5a87c3a77c 100644 --- a/src/mongo/transport/service_executor.h +++ b/src/mongo/transport/service_executor.h @@ -92,8 +92,8 @@ public: * for execution on the service executor. May throw if "scheduleTask" returns a non-okay status. */ void schedule(OutOfLineExecutor::Task func) override { - internalAssert(scheduleTask([task = std::move(func)]() mutable { task(Status::OK()); }, - ScheduleFlags::kEmptyFlags)); + iassert(scheduleTask([task = std::move(func)]() mutable { task(Status::OK()); }, + ScheduleFlags::kEmptyFlags)); } /* diff --git a/src/mongo/transport/service_executor_fixed.cpp b/src/mongo/transport/service_executor_fixed.cpp index b068e487126..d0b918cf598 100644 --- a/src/mongo/transport/service_executor_fixed.cpp +++ b/src/mongo/transport/service_executor_fixed.cpp @@ -160,7 +160,7 @@ Status ServiceExecutorFixed::scheduleTask(Task task, ScheduleFlags flags) { // May throw if an attempt is made to schedule after the thread pool is shutdown. try { _threadPool->schedule([task = std::move(task)](Status status) mutable { - internalAssert(status); + iassert(status); invariant(_executorContext); _executorContext->run(std::move(task)); }); diff --git a/src/mongo/util/assert_util.cpp b/src/mongo/util/assert_util.cpp index 7039a5c1162..3013402eac4 100644 --- a/src/mongo/util/assert_util.cpp +++ b/src/mongo/util/assert_util.cpp @@ -269,7 +269,7 @@ MONGO_COMPILER_NOINLINE void msgassertedWithLocation(const Status& status, error_details::throwExceptionForStatus(status); } -void internalAssertWithLocation(SourceLocationHolder loc, const Status& status) { +void iassertWithLocation(SourceLocationHolder loc, const Status& status) { if (status.isOK()) return; LOGV2_DEBUG(4892201, 3, "Internal assertion", "error"_attr = status, "location"_attr = loc); diff --git a/src/mongo/util/assert_util.h b/src/mongo/util/assert_util.h index b44dceccafa..fd66dff2699 100644 --- a/src/mongo/util/assert_util.h +++ b/src/mongo/util/assert_util.h @@ -437,38 +437,25 @@ inline void massertStatusOKWithLocation(const Status& status, const char* file, } /** - * `internalAssert` is provided as an alternative for `uassert` variants (e.g., `uassertStatusOK`) + * `iassert` is provided as an alternative for `uassert` variants (e.g., `uassertStatusOK`) * to support cases where we expect a failure, the failure is recoverable, or accounting for the - * failure, updating assertion counters, isn't desired. `internalAssert` logs at D3 instead of D1, + * failure, updating assertion counters, isn't desired. `iassert` logs at D3 instead of D1, * which helps with reducing the noise of assertions in production. The goal is to keep one - * interface (i.e., `internalAssert(...)`) for all possible assertion variants, and use function + * interface (i.e., `iassert(...)`) for all possible assertion variants, and use function * overloading to expand type support as needed. */ -#define internalAssert(...) \ - ::mongo::internalAssertWithLocation(MONGO_SOURCE_LOCATION(), __VA_ARGS__) +#define iassert(...) ::mongo::iassertWithLocation(MONGO_SOURCE_LOCATION(), __VA_ARGS__) -void internalAssertWithLocation(SourceLocationHolder loc, const Status& status); +void iassertWithLocation(SourceLocationHolder loc, const Status& status); -inline void internalAssertWithLocation(SourceLocationHolder loc, Status&& status) { - internalAssertWithLocation(std::move(loc), status); -} - -inline void internalAssertWithLocation(SourceLocationHolder loc, - int msgid, - const std::string& msg, - bool expr) { +inline void iassertWithLocation(SourceLocationHolder loc, int msgid, std::string msg, bool expr) { if (MONGO_unlikely(!expr)) - internalAssertWithLocation(std::move(loc), Status(ErrorCodes::Error(msgid), msg)); -} - -template <typename T> -inline void internalAssertWithLocation(SourceLocationHolder loc, const StatusWith<T>& sw) { - internalAssertWithLocation(std::move(loc), sw.getStatus()); + iassertWithLocation(std::move(loc), Status(ErrorCodes::Error(msgid), std::move(msg))); } template <typename T> -inline void internalAssertWithLocation(SourceLocationHolder loc, StatusWith<T>&& sw) { - internalAssertWithLocation(std::move(loc), sw); +void iassertWithLocation(SourceLocationHolder loc, const StatusWith<T>& sw) { + iassertWithLocation(std::move(loc), sw.getStatus()); } /** diff --git a/src/mongo/util/assert_util_test.cpp b/src/mongo/util/assert_util_test.cpp index bb5a502a65d..a8af00a844a 100644 --- a/src/mongo/util/assert_util_test.cpp +++ b/src/mongo/util/assert_util_test.cpp @@ -233,13 +233,13 @@ TEST(AssertUtils, InternalAssertWithStatus) { auto userAssertions = assertionCount.user.load(); try { Status status = {ErrorCodes::BadValue, "Test"}; - internalAssert(status); + iassert(status); } catch (const DBException& ex) { ASSERT_EQ(ex.code(), ErrorCodes::BadValue); ASSERT_EQ(ex.reason(), "Test"); } - internalAssert(Status::OK()); + iassert(Status::OK()); ASSERT_EQ(userAssertions, assertionCount.user.load()); } @@ -247,13 +247,13 @@ TEST(AssertUtils, InternalAssertWithStatus) { TEST(AssertUtils, InternalAssertWithExpression) { auto userAssertions = assertionCount.user.load(); try { - internalAssert(48922, "Test", false); + iassert(48922, "Test", false); } catch (const DBException& ex) { ASSERT_EQ(ex.code(), 48922); ASSERT_EQ(ex.reason(), "Test"); } - internalAssert(48922, "Another test", true); + iassert(48922, "Another test", true); ASSERT_EQ(userAssertions, assertionCount.user.load()); } diff --git a/src/mongo/util/interruptible.h b/src/mongo/util/interruptible.h index 5b14c29bcc1..d1b8981adf3 100644 --- a/src/mongo/util/interruptible.h +++ b/src/mongo/util/interruptible.h @@ -317,7 +317,7 @@ public: * Raises a AssertionException if this operation is in a killed state. */ void checkForInterrupt() { - internalAssert(checkForInterruptNoAssert()); + iassert(checkForInterruptNoAssert()); } /** @@ -395,7 +395,7 @@ public: if (!swResult.isOK()) { _onWake(latchName, WakeReason::kInterrupt, speed); - internalAssert(std::move(swResult)); + iassert(std::move(swResult)); } if (pred()) { |