// assert_util.cpp
/* Copyright 2009 10gen Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License, version 3,
* as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see .
*
* As a special exception, the copyright holders give permission to link the
* code of portions of this program with the OpenSSL library under certain
* conditions as described in each individual source file and distribute
* linked combinations including the program with the OpenSSL library. You
* must comply with the GNU Affero General Public License in all respects
* for all of the code used other than as permitted herein. If you modify
* file(s) with this exception, you may extend this exception to your
* version of the file(s), but you are not obligated to do so. If you do not
* wish to do so, delete this exception statement from your version. If you
* delete this exception statement from all source files in the program,
* then also delete it in the license file.
*/
#define MONGO_LOG_DEFAULT_COMPONENT ::mongo::logger::LogComponent::kDefault
#include "mongo/platform/basic.h"
#include "mongo/util/assert_util.h"
using namespace std;
#ifndef _WIN32
#include
#include
#endif
#include
#include
#include
#include "mongo/bson/bsonobjbuilder.h"
#include "mongo/config.h"
#include "mongo/util/debug_util.h"
#include "mongo/util/debugger.h"
#include "mongo/util/exit.h"
#include "mongo/util/log.h"
#include "mongo/util/mongoutils/str.h"
#include "mongo/util/quick_exit.h"
#include "mongo/util/stacktrace.h"
namespace mongo {
AssertionCount assertionCount;
AssertionCount::AssertionCount() : regular(0), warning(0), msg(0), user(0), rollovers(0) {}
void AssertionCount::rollover() {
rollovers++;
regular = 0;
warning = 0;
msg = 0;
user = 0;
}
void AssertionCount::condrollover(int newvalue) {
static const int rolloverPoint = (1 << 30);
if (newvalue >= rolloverPoint)
rollover();
}
std::atomic DBException::traceExceptions(false); // NOLINT
string DBException::toString() const {
stringstream ss;
ss << getCode() << " " << what();
return ss.str();
}
void DBException::traceIfNeeded(const DBException& e) {
if (traceExceptions) {
warning() << "DBException thrown" << causedBy(e) << endl;
printStackTrace();
}
}
ErrorCodes::Error DBException::convertExceptionCode(int exCode) {
if (exCode == 0) {
return ErrorCodes::UnknownError;
}
return ErrorCodes::fromInt(exCode);
}
void ExceptionInfo::append(BSONObjBuilder& b, const char* m, const char* c) const {
if (msg.empty())
b.append(m, "unknown assertion");
else
b.append(m, msg);
if (code)
b.append(c, code);
}
/* "warning" assert -- safe to continue, so we don't throw exception. */
NOINLINE_DECL void wasserted(const char* expr, const char* file, unsigned line) {
static bool rateLimited;
static time_t lastWhen;
static unsigned lastLine;
if (lastLine == line && time(0) - lastWhen < 5) {
if (!rateLimited) {
rateLimited = true;
log() << "rate limiting wassert" << endl;
}
return;
}
lastWhen = time(0);
lastLine = line;
log() << "warning assertion failure " << expr << ' ' << file << ' ' << dec << line << endl;
logContext();
assertionCount.condrollover(++assertionCount.warning);
#if defined(MONGO_CONFIG_DEBUG_BUILD)
// this is so we notice in buildbot
log() << "\n\n***aborting after wassert() failure in a debug/test build\n\n" << endl;
quickExit(EXIT_ABRUPT);
#endif
}
NOINLINE_DECL void verifyFailed(const char* expr, const char* file, unsigned line) {
assertionCount.condrollover(++assertionCount.regular);
log() << "Assertion failure " << expr << ' ' << file << ' ' << dec << line << endl;
logContext();
stringstream temp;
temp << "assertion " << file << ":" << line;
AssertionException e(temp.str(), 0);
breakpoint();
#if defined(MONGO_CONFIG_DEBUG_BUILD)
// this is so we notice in buildbot
log() << "\n\n***aborting after verify() failure as this is a debug/test build\n\n" << endl;
quickExit(EXIT_ABRUPT);
#endif
throw e;
}
NOINLINE_DECL void invariantFailed(const char* expr, const char* file, unsigned line) noexcept {
log() << "Invariant failure " << expr << ' ' << file << ' ' << dec << line << endl;
breakpoint();
log() << "\n\n***aborting after invariant() failure\n\n" << endl;
std::abort();
}
NOINLINE_DECL void invariantOKFailed(const char* expr,
const Status& status,
const char* file,
unsigned line) noexcept {
log() << "Invariant failure: " << expr << " resulted in status " << redact(status) << " at "
<< file << ' ' << dec << line;
breakpoint();
log() << "\n\n***aborting after invariant() failure\n\n" << endl;
std::abort();
}
NOINLINE_DECL void fassertFailedWithLocation(int msgid, const char* file, unsigned line) noexcept {
log() << "Fatal Assertion " << msgid << " at " << file << " " << dec << line;
breakpoint();
log() << "\n\n***aborting after fassert() failure\n\n" << endl;
std::abort();
}
NOINLINE_DECL void fassertFailedNoTraceWithLocation(int msgid,
const char* file,
unsigned line) noexcept {
log() << "Fatal Assertion " << msgid << " at " << file << " " << dec << line;
breakpoint();
log() << "\n\n***aborting after fassert() failure\n\n" << endl;
quickExit(EXIT_ABRUPT);
}
MONGO_COMPILER_NORETURN void fassertFailedWithStatusWithLocation(int msgid,
const Status& status,
const char* file,
unsigned line) noexcept {
log() << "Fatal assertion " << msgid << " " << redact(status) << " at " << file << " " << dec
<< line;
breakpoint();
log() << "\n\n***aborting after fassert() failure\n\n" << endl;
std::abort();
}
MONGO_COMPILER_NORETURN void fassertFailedWithStatusNoTraceWithLocation(int msgid,
const Status& status,
const char* file,
unsigned line) noexcept {
log() << "Fatal assertion " << msgid << " " << redact(status) << " at " << file << " " << dec
<< line;
breakpoint();
log() << "\n\n***aborting after fassert() failure\n\n" << endl;
quickExit(EXIT_ABRUPT);
}
void UserException::appendPrefix(stringstream& ss) const {
ss << "userassert:";
}
void MsgAssertionException::appendPrefix(stringstream& ss) const {
ss << "massert:";
}
void uassertedWithLocation(int msgid, const string& msg, const char* file, unsigned line) {
uassertedWithLocation(msgid, msg.c_str(), file, line);
}
NOINLINE_DECL void uassertedWithLocation(int msgid,
const char* msg,
const char* file,
unsigned line) {
assertionCount.condrollover(++assertionCount.user);
LOG(1) << "User Assertion: " << msgid << ":" << redact(msg) << ' ' << file << ' ' << dec << line
<< endl;
throw UserException(msgid, msg);
}
void msgassertedWithLocation(int msgid, const string& msg, const char* file, unsigned line) {
msgassertedWithLocation(msgid, msg.c_str(), file, line);
}
NOINLINE_DECL void msgassertedWithLocation(int msgid,
const char* msg,
const char* file,
unsigned line) {
assertionCount.condrollover(++assertionCount.warning);
log() << "Assertion: " << msgid << ":" << redact(msg) << ' ' << file << ' ' << dec << line
<< endl;
logContext();
throw MsgAssertionException(msgid, msg);
}
NOINLINE_DECL void msgassertedNoTraceWithLocation(int msgid,
const char* msg,
const char* file,
unsigned line) {
assertionCount.condrollover(++assertionCount.warning);
log() << "Assertion: " << msgid << ":" << redact(msg) << ' ' << file << ' ' << dec << line
<< endl;
throw MsgAssertionException(msgid, msg);
}
void msgassertedNoTraceWithLocation(int msgid,
const std::string& msg,
const char* file,
unsigned line) {
msgassertedNoTraceWithLocation(msgid, msg.c_str(), file, line);
}
void msgassertedNoTraceWithStatusWithLocation(int msgid,
const Status& status,
const char* file,
unsigned line) {
msgassertedNoTraceWithLocation(msgid, status.toString(), file, line);
}
std::string causedBy(const char* e) {
return std::string(" :: caused by :: ") + e;
}
std::string causedBy(const DBException& e) {
return causedBy(e.toString());
}
std::string causedBy(const std::exception& e) {
return causedBy(e.what());
}
std::string causedBy(const std::string& e) {
return causedBy(e.c_str());
}
std::string causedBy(const Status& e) {
return causedBy(e.toString());
}
string errnoWithPrefix(StringData prefix) {
const auto suffix = errnoWithDescription();
stringstream ss;
if (!prefix.empty())
ss << prefix << ": ";
ss << suffix;
return ss.str();
}
string demangleName(const type_info& typeinfo) {
#ifdef _WIN32
return typeinfo.name();
#else
int status;
char* niceName = abi::__cxa_demangle(typeinfo.name(), 0, 0, &status);
if (!niceName)
return typeinfo.name();
string s = niceName;
free(niceName);
return s;
#endif
}
Status exceptionToStatus() noexcept {
try {
throw;
} catch (const DBException& ex) {
return ex.toStatus();
} catch (const std::exception& ex) {
return Status(ErrorCodes::UnknownError,
str::stream() << "Caught std::exception of type " << demangleName(typeid(ex))
<< ": "
<< ex.what());
} catch (const boost::exception& ex) {
return Status(
ErrorCodes::UnknownError,
str::stream() << "Caught boost::exception of type " << demangleName(typeid(ex)) << ": "
<< boost::diagnostic_information(ex));
} catch (...) {
severe() << "Caught unknown exception in exceptionToStatus()";
std::terminate();
}
}
string ExceptionInfo::toString() const {
stringstream ss;
ss << "exception: " << code << " " << msg;
return ss.str();
}
}