Skip to content

Commit

Permalink
Make abort() call sites log first
Browse files Browse the repository at this point in the history
  • Loading branch information
roberth committed Jul 20, 2024
1 parent 1327e14 commit 530ec23
Show file tree
Hide file tree
Showing 35 changed files with 88 additions and 45 deletions.
2 changes: 1 addition & 1 deletion src/libcmd/repl.cc
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ ReplExitStatus NixRepl::mainLoop()
case ProcessLineResult::PromptAgain:
break;
default:
abort();
NIX_UNREACHABLE();
}
} catch (ParseError & e) {
if (e.msg().find("unexpected end of file") != std::string::npos) {
Expand Down
2 changes: 1 addition & 1 deletion src/libexpr/attr-path.cc
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ std::pair<SourcePath, uint32_t> findPackageFilename(EvalState & state, Value & v
return {SourcePath{path.accessor, CanonPath(fn.substr(0, colon))}, lineno};
} catch (std::invalid_argument & e) {
fail();
abort();
NIX_UNREACHABLE();
}
}

Expand Down
8 changes: 4 additions & 4 deletions src/libexpr/eval.cc
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ std::string_view showType(ValueType type, bool withArticle)
case nFloat: return WA("a", "float");
case nThunk: return WA("a", "thunk");
}
abort();
NIX_UNREACHABLE();
}


Expand Down Expand Up @@ -771,7 +771,7 @@ void EvalState::runDebugRepl(const Error * error, const Env & env, const Expr &
case ReplExitStatus::Continue:
break;
default:
abort();
NIX_UNREACHABLE();
}
}
}
Expand Down Expand Up @@ -1140,7 +1140,7 @@ inline void EvalState::evalAttrs(Env & env, Expr * e, Value & v, const PosIdx po

void Expr::eval(EvalState & state, Env & env, Value & v)
{
abort();
NIX_UNREACHABLE();
}


Expand Down Expand Up @@ -1573,7 +1573,7 @@ void EvalState::callFunction(Value & fun, size_t nrArgs, Value * * args, Value &
.withFrame(*fun.payload.lambda.env, lambda)
.debugThrow();
}
abort(); // can't happen
NIX_UNREACHABLE();
}
}

Expand Down
4 changes: 2 additions & 2 deletions src/libexpr/nixexpr.cc
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ std::ostream & operator <<(std::ostream & str, const SymbolStr & symbol)

void Expr::show(const SymbolTable & symbols, std::ostream & str) const
{
abort();
NIX_UNREACHABLE();
}

void ExprInt::show(const SymbolTable & symbols, std::ostream & str) const
Expand Down Expand Up @@ -269,7 +269,7 @@ std::string showAttrPath(const SymbolTable & symbols, const AttrPath & attrPath)

void Expr::bindVars(EvalState & es, const std::shared_ptr<const StaticEnv> & env)
{
abort();
NIX_UNREACHABLE();
}

void ExprInt::bindVars(EvalState & es, const std::shared_ptr<const StaticEnv> & env)
Expand Down
2 changes: 1 addition & 1 deletion src/libexpr/primops.cc
Original file line number Diff line number Diff line change
Expand Up @@ -426,7 +426,7 @@ static void prim_typeOf(EvalState & state, const PosIdx pos, Value * * args, Val
t = args[0]->external()->typeOf();
break;
case nFloat: t = "float"; break;
case nThunk: abort();
case nThunk: NIX_UNREACHABLE();
}
v.mkString(t);
}
Expand Down
2 changes: 1 addition & 1 deletion src/libexpr/print-ambiguous.cc
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ void printAmbiguous(
break;
default:
printError("Nix evaluator internal error: printAmbiguous: invalid value type");
abort();
NIX_UNREACHABLE();
}
}

Expand Down
4 changes: 2 additions & 2 deletions src/libexpr/print.cc
Original file line number Diff line number Diff line change
Expand Up @@ -475,7 +475,7 @@ class Printer
else
output << "primop";
} else {
abort();
NIX_UNREACHABLE();
}

output << "»";
Expand Down Expand Up @@ -504,7 +504,7 @@ class Printer
if (options.ansiColors)
output << ANSI_NORMAL;
} else {
abort();
NIX_UNREACHABLE();
}
}

Expand Down
3 changes: 2 additions & 1 deletion src/libexpr/symbol-table.hh
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

#include "types.hh"
#include "chunked-vector.hh"
#include "error.hh"

namespace nix {

Expand Down Expand Up @@ -113,7 +114,7 @@ public:
SymbolStr operator[](Symbol s) const
{
if (s.id == 0 || s.id > store.size())
abort();
NIX_UNREACHABLE();
return SymbolStr(store[s.id - 1]);
}

Expand Down
2 changes: 1 addition & 1 deletion src/libexpr/value.hh
Original file line number Diff line number Diff line change
Expand Up @@ -285,7 +285,7 @@ public:
if (invalidIsThunk)
return nThunk;
else
abort();
NIX_UNREACHABLE();
}

inline void finishValue(InternalType newType, Payload newPayload)
Expand Down
4 changes: 2 additions & 2 deletions src/libfetchers/attrs.cc
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ nlohmann::json attrsToJSON(const Attrs & attrs)
json[attr.first] = *v;
} else if (auto v = std::get_if<Explicit<bool>>(&attr.second)) {
json[attr.first] = v->t;
} else abort();
} else NIX_UNREACHABLE();
}
return json;
}
Expand Down Expand Up @@ -99,7 +99,7 @@ std::map<std::string, std::string> attrsToQuery(const Attrs & attrs)
query.insert_or_assign(attr.first, *v);
} else if (auto v = std::get_if<Explicit<bool>>(&attr.second)) {
query.insert_or_assign(attr.first, v->t ? "1" : "0");
} else abort();
} else NIX_UNREACHABLE();
}
return query;
}
Expand Down
2 changes: 1 addition & 1 deletion src/libmain/loggers.cc
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ Logger * makeDefaultLogger() {
return logger;
}
default:
abort();
NIX_UNREACHABLE();
}
}

Expand Down
2 changes: 1 addition & 1 deletion src/libstore/build/drv-output-substitution-goal.hh
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ public:
Co init() override;
Co realisationFetched(std::shared_ptr<const Realisation> outputInfo, nix::ref<nix::Store> sub);

void timedOut(Error && ex) override { abort(); };
void timedOut(Error && ex) override { NIX_UNREACHABLE(); };

std::string key() override;

Expand Down
4 changes: 2 additions & 2 deletions src/libstore/build/goal.hh
Original file line number Diff line number Diff line change
Expand Up @@ -400,12 +400,12 @@ public:

virtual void handleChildOutput(Descriptor fd, std::string_view data)
{
abort();
NIX_UNREACHABLE();
}

virtual void handleEOF(Descriptor fd)
{
abort();
NIX_UNREACHABLE();
}

void trace(std::string_view s);
Expand Down
2 changes: 1 addition & 1 deletion src/libstore/build/substitution-goal.hh
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public:
PathSubstitutionGoal(const StorePath & storePath, Worker & worker, RepairFlag repair = NoRepair, std::optional<ContentAddress> ca = std::nullopt);
~PathSubstitutionGoal();

void timedOut(Error && ex) override { abort(); };
void timedOut(Error && ex) override { NIX_UNREACHABLE(); };

/**
* We prepend "a$" to the key name to ensure substitution goals
Expand Down
4 changes: 2 additions & 2 deletions src/libstore/build/worker.cc
Original file line number Diff line number Diff line change
Expand Up @@ -216,7 +216,7 @@ void Worker::childStarted(GoalPtr goal, const std::set<MuxablePipePollState::Com
nrLocalBuilds++;
break;
default:
abort();
NIX_UNREACHABLE();
}
}
}
Expand All @@ -239,7 +239,7 @@ void Worker::childTerminated(Goal * goal, bool wakeSleepers)
nrLocalBuilds--;
break;
default:
abort();
NIX_UNREACHABLE();
}
}

Expand Down
2 changes: 1 addition & 1 deletion src/libstore/daemon.cc
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ Sink & operator << (Sink & sink, const Logger::Fields & fields)
sink << f.i;
else if (f.type == Logger::Field::tString)
sink << f.s;
else abort();
else NIX_UNREACHABLE();
}
return sink;
}
Expand Down
2 changes: 1 addition & 1 deletion src/libstore/gc.cc
Original file line number Diff line number Diff line change
Expand Up @@ -559,7 +559,7 @@ void LocalStore::collectGarbage(const GCOptions & options, GCResults & results)
non-blocking flag from the server socket, so
explicitly make it blocking. */
if (fcntl(fdClient.get(), F_SETFL, fcntl(fdClient.get(), F_GETFL) & ~O_NONBLOCK) == -1)
abort();
panic("Could not set non-blocking flag on client socket");

while (true) {
try {
Expand Down
2 changes: 1 addition & 1 deletion src/libstore/globals.cc
Original file line number Diff line number Diff line change
Expand Up @@ -297,7 +297,7 @@ template<> std::string BaseSetting<SandboxMode>::to_string() const
if (value == smEnabled) return "true";
else if (value == smRelaxed) return "relaxed";
else if (value == smDisabled) return "false";
else abort();
else NIX_UNREACHABLE();
}

template<> void BaseSetting<SandboxMode>::convertToArg(Args & args, const std::string & category)
Expand Down
4 changes: 2 additions & 2 deletions src/libstore/nar-info-disk-cache.cc
Original file line number Diff line number Diff line change
Expand Up @@ -164,7 +164,7 @@ class NarInfoDiskCacheImpl : public NarInfoDiskCache
Cache & getCache(State & state, const std::string & uri)
{
auto i = state.caches.find(uri);
if (i == state.caches.end()) abort();
if (i == state.caches.end()) NIX_UNREACHABLE();
return i->second;
}

Expand Down Expand Up @@ -211,7 +211,7 @@ class NarInfoDiskCacheImpl : public NarInfoDiskCache

{
auto r(state->insertCache.use()(uri)(time(0))(storeDir)(wantMassQuery)(priority));
if (!r.next()) { abort(); }
if (!r.next()) { NIX_UNREACHABLE(); }
ret.id = (int) r.getInt(0);
}

Expand Down
2 changes: 1 addition & 1 deletion src/libstore/unix/build/local-derivation-goal.cc
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@ void LocalDerivationGoal::killSandbox(bool getStats)
buildResult.cpuSystem = stats.cpuSystem;
}
#else
abort();
NIX_UNREACHABLE();
#endif
}

Expand Down
2 changes: 1 addition & 1 deletion src/libstore/unix/pathlocks.cc
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ bool lockFile(Descriptor desc, LockType lockType, bool wait)
if (lockType == ltRead) type = LOCK_SH;
else if (lockType == ltWrite) type = LOCK_EX;
else if (lockType == ltNone) type = LOCK_UN;
else abort();
else NIX_UNREACHABLE();

if (wait) {
while (flock(desc, type) != 0) {
Expand Down
4 changes: 3 additions & 1 deletion src/libutil/chunked-vector.hh
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,8 @@
#include <vector>
#include <limits>

#include "error.hh"

namespace nix {

/**
Expand All @@ -30,7 +32,7 @@ private:
auto & addChunk()
{
if (size_ >= std::numeric_limits<uint32_t>::max() - ChunkSize)
abort();
NIX_UNREACHABLE();
chunks.emplace_back();
chunks.back().reserve(ChunkSize);
return chunks.back();
Expand Down
12 changes: 12 additions & 0 deletions src/libutil/error.cc
Original file line number Diff line number Diff line change
Expand Up @@ -430,4 +430,16 @@ std::ostream & showErrorInfo(std::ostream & out, const ErrorInfo & einfo, bool s
return out;
}

void panic(std::string_view msg)
{
printError(msg);
printError("This was a fatal error, aborting.");
abort();
}

void panic(const char * file, int line, const char * func)
{
panic(std::string("Unexpected condition in ") + func + " at " + file + ":" + std::to_string(line));
}

}
24 changes: 24 additions & 0 deletions src/libutil/error.hh
Original file line number Diff line number Diff line change
Expand Up @@ -273,4 +273,28 @@ using NativeSysError =
*/
void throwExceptionSelfCheck();

/**
* Print a message and abort().
*
* @note: This assumes that the logger is operational
*/
[[noreturn]]
void panic(std::string_view msg);

/**
* Print a basic error message with source position and abort().
* Use the NIX_UNREACHABLE macro to call this.
*
* @note: This assumes that the logger is operational
*/
[[noreturn]]
void panic(const char * file, int line, const char * func);

/**
* Print a basic error message with source position and abort().
*
* @note: This assumes that the logger is operational
*/
#define NIX_UNREACHABLE() (panic(__FILE__, __LINE__, __func__))

}
2 changes: 1 addition & 1 deletion src/libutil/file-content-address.cc
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ std::string_view renderFileIngestionMethod(FileIngestionMethod method)
case FileIngestionMethod::Git:
return "git";
default:
abort();
NIX_UNREACHABLE();
}
}

Expand Down
2 changes: 1 addition & 1 deletion src/libutil/fs-sink.cc
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ void copyRecursive(
throw Error("file '%1%' has an unsupported type", from);

default:
abort();
NIX_UNREACHABLE();
}
}

Expand Down
2 changes: 1 addition & 1 deletion src/libutil/git.cc
Original file line number Diff line number Diff line change
Expand Up @@ -201,7 +201,7 @@ std::optional<Mode> convertMode(SourceAccessor::Type type)
case SourceAccessor::tRegular: return Mode::Regular;
case SourceAccessor::tDirectory: return Mode::Directory;
case SourceAccessor::tMisc: return std::nullopt;
default: abort();
default: NIX_UNREACHABLE();
}
}

Expand Down
2 changes: 1 addition & 1 deletion src/libutil/hash.cc
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ static size_t regularHashSize(HashAlgorithm type) {
case HashAlgorithm::SHA256: return sha256HashSize;
case HashAlgorithm::SHA512: return sha512HashSize;
}
abort();
NIX_UNREACHABLE();
}


Expand Down
2 changes: 1 addition & 1 deletion src/libutil/logging.cc
Original file line number Diff line number Diff line change
Expand Up @@ -189,7 +189,7 @@ struct JSONLogger : Logger {
else if (f.type == Logger::Field::tString)
arr.push_back(f.s);
else
abort();
NIX_UNREACHABLE();
}

void write(const nlohmann::json & json)
Expand Down
Loading

0 comments on commit 530ec23

Please sign in to comment.