Logger.cpp

/*
 * Copyright(c) Sophist Solutions, Inc. 1990-2025.  All rights reserved
 */
#include "Stroika/Foundation/StroikaPreComp.h"
 
#if qStroika_HasComponent_syslog
#include <syslog.h>
#endif
 
#include "Stroika/Foundation/Cache/SynchronizedCallerStalenessCache.h"
#include "Stroika/Foundation/Characters/CString/Utilities.h"
#include "Stroika/Foundation/Characters/Format.h"
#include "Stroika/Foundation/Characters/SDKChar.h"
#include "Stroika/Foundation/Characters/ToString.h"
#include "Stroika/Foundation/Containers/Collection.h"
#include "Stroika/Foundation/Debug/BackTrace.h"
#include "Stroika/Foundation/Debug/Debugger.h"
#include "Stroika/Foundation/Debug/Trace.h"
#include "Stroika/Foundation/Execution/BlockingQueue.h"
#include "Stroika/Foundation/Execution/Common.h"
#include "Stroika/Foundation/Execution/Logger.h"
#include "Stroika/Foundation/Execution/Process.h"
#include "Stroika/Foundation/Execution/Synchronized.h"
#include "Stroika/Foundation/Execution/Thread.h"
#include "Stroika/Foundation/Execution/TimeOutException.h"
#include "Stroika/Foundation/IO/FileSystem/FileOutputStream.h"
#include "Stroika/Foundation/Streams/TextToBinary.h"
#include "Stroika/Foundation/Time/DateTime.h"
 
#include "Logger.h"
 
using std::byte;
 
using namespace Stroika::Foundation;
using namespace Stroika::Foundation::Characters;
using namespace Stroika::Foundation::Containers;
using namespace Stroika::Foundation::Common;
using namespace Stroika::Foundation::Execution;
using namespace Stroika::Foundation::Traversal;
using namespace IO::FileSystem;
 
using Containers::Mapping;
using Time::Duration;
 
// Comment this in to turn on aggressive noisy DbgTrace in this module
//#define   USE_NOISY_TRACE_IN_THIS_MODULE_       1
 
/*
 ********************************************************************************
 ******************************** Execution::Logger *****************************
 ********************************************************************************
 */
struct Logger::Rep_ : enable_shared_from_this<Logger::Rep_> {
    using PriorityAndMessageType_ = pair<Logger::Priority, String>;
    bool                                               fBufferingEnabled_{false};
    Synchronized<Collection<shared_ptr<IAppenderRep>>> fAppenders_;
    BlockingQueue<PriorityAndMessageType_>             fOutMsgQ_;
    // @todo FIX - fOutQMaybeNeedsFlush_ setting can cause race - maybe lose this optimization - pretty harmless, but can lose a message
    // race at end of Flush_()
    bool                             fOutQMaybeNeedsFlush_{true}; // slight optimization when using buffering
    Synchronized<optional<Duration>> fSuppressDuplicatesThreshold_;
 
    struct LastMsgInfoType_ {
        Time::TimePointSeconds fLastSentAt{};
        unsigned int           fRepeatCount_{};
    };
    Synchronized<Mapping<PriorityAndMessageType_, LastMsgInfoType_>> fLastMessages_; // if suppressing duplicates, must save all messages in timerange of suppression to compare with, and track suppression counts
 
    Synchronized<Execution::Thread::Ptr>                                  fBookkeepingThread_;
    atomic<Time::DurationSeconds>                                         fMaxWindow_{};
    Cache::SynchronizedCallerStalenessCache<pair<Priority, String>, bool> fMsgSentMaybeSuppressed_;
 
    Rep_ () = default;
    void FlushSuppressedDuplicates_ (bool forceEvenIfNotOutOfDate = false)
    {
#if USE_NOISY_TRACE_IN_THIS_MODULE_
        Debug::TraceContextBumper ctx{"Logger::Rep_::FlushSuppressedDuplicates_"};
#endif
        auto lastMsgsLocked = fLastMessages_.rwget ();
        /**
         *  @todo restructure so we dont hold the lock while we call the tmp->Log() - since that append could in principle do something calling us back/deadlock
         *        Maybe queue up the messages/and push them at the end of the loop. Advantage of no deadlock, but disavantage of
         *        there being a window where messages could get lost (error on tmp->Log - not sure we can handle that anyhow).
         *          -- LGP 2022-08-24
         */
        if (not lastMsgsLocked->empty ()) {
            Time::Duration suppressDuplicatesThreshold = fSuppressDuplicatesThreshold_.cget ()->value_or (0s);
            for (auto i = lastMsgsLocked->begin (); i != lastMsgsLocked->end ();) {
                bool writeThisOne = forceEvenIfNotOutOfDate or i->fValue.fLastSentAt + suppressDuplicatesThreshold < Time::GetTickCount ();
                if (writeThisOne) {
                    switch (i->fValue.fRepeatCount_) {
                        case 0:
                            break; // nothing to write
                        case 1:
                            // avoid races and critical sections (appender internally threadsafe)
                            for (shared_ptr<IAppenderRep> tmp : fAppenders_.load ()) {
                                tmp->Log (i->fKey.first, i->fKey.second);
                            }
                            break;
                        default:
                            // avoid races and critical sections (appender internally threadsafe)
                            for (shared_ptr<IAppenderRep> tmp : fAppenders_.load ()) {
                                tmp->Log (i->fKey.first, "[{} duplicates suppressed]: {}"_f(i->fValue.fRepeatCount_ - 1, i->fKey.second));
                            }
                            break;
                    }
                    lastMsgsLocked->Remove (i, &i);
                }
                else {
                    ++i;
                }
            }
        }
    }
    void Flush_ ()
    {
#if USE_NOISY_TRACE_IN_THIS_MODULE_
        Debug::TraceContextBumper ctx{"Logger::Rep_::Flush_"};
#endif
        if (not fAppenders_.cget ()->empty ()) {
            while (true) {
                optional<PriorityAndMessageType_> p = fOutMsgQ_.RemoveHeadIfPossible ();
                if (p.has_value ()) {
                    // avoid races and critical sections (between check and invoke)
                    for (shared_ptr<IAppenderRep> tmp : fAppenders_.load ()) {
                        tmp->Log (p->first, p->second);
                    }
                }
                else {
                    return; // no more entries
                }
            }
        }
        fOutQMaybeNeedsFlush_ = false;
    }
    void UpdateBookkeepingThread_ ()
    {
        Debug::TraceContextBumper ctx{"Logger::Rep_::UpdateBookkeepingThread_"};
        {
            auto bktLck = fBookkeepingThread_.rwget ();
            if (bktLck.cref () != nullptr) {
                bktLck->AbortAndWaitForDone ();
                bktLck.store (Thread::Ptr{});
            }
        }
 
        Time::Duration      suppressDuplicatesThreshold = fSuppressDuplicatesThreshold_.cget ()->value_or (0s);
        bool                suppressDuplicates          = suppressDuplicatesThreshold > 0s;
        static const String kThreadName_{"Logger Bookkeeping"sv};
        if (suppressDuplicates or fBufferingEnabled_) {
            Thread::Ptr      newBookKeepThread;
            shared_ptr<Rep_> useRepInThread = shared_from_this (); // capture by value the shared_ptr
            if (suppressDuplicates) {
                newBookKeepThread = Thread::New (
                    [suppressDuplicatesThreshold, useRepInThread] () {
                        Debug::TraceContextBumper ctx1{"Logger::Rep_::UpdateBookkeepingThread_... internal thread/1"};
                        while (true) {
                            Duration time2Wait = max<Duration> (2s, suppressDuplicatesThreshold); // never wait less than this
                            useRepInThread->FlushSuppressedDuplicates_ ();
                            if (auto p = useRepInThread->fOutMsgQ_.RemoveHeadIfPossible (time2Wait)) {
                                // avoid races and critical sections (between check and invoke)
                                for (shared_ptr<IAppenderRep> tmp : useRepInThread->fAppenders_.load ()) {
                                    IgnoreExceptionsExceptThreadAbortForCall (tmp->Log (p->first, p->second));
                                }
                            }
                        }
                    },
                    kThreadName_);
            }
            else {
                newBookKeepThread = Thread::New (
                    [useRepInThread] () {
                        Debug::TraceContextBumper ctx1{"Logger::Rep_::UpdateBookkeepingThread_... internal thread/2"};
                        while (true) {
                            AssertNotNull (useRepInThread);
                            auto p = useRepInThread->fOutMsgQ_.RemoveHead ();
                            // avoid races and critical sections (between check and invoke)
                            for (shared_ptr<IAppenderRep> tmp : useRepInThread->fAppenders_.load ()) {
                                tmp->Log (p.first, p.second);
                            }
                        }
                    },
                    kThreadName_);
            }
            newBookKeepThread.SetThreadPriority (Thread::Priority::eBelowNormal);
            newBookKeepThread.Start ();
            fBookkeepingThread_ = newBookKeepThread;
        }
 
        // manually push out pending messages
        Flush_ ();
    }
};
 
#if qStroika_Foundation_Debug_AssertionsChecked
Logger::~Logger ()
{
    Assert (&sThe == this);
    Assert (fRep_ == nullptr); // since Stroika 2.1.1, must use activator and destroy it before this is destroyed
}
#endif
 
void Logger::Shutdown_ ()
{
    Debug::TraceContextBumper ctx{"Logger::Shutdown"};
    // @todo FIX to assure all shutdown properly...
    // But this is OK for now pragmatically
#if 1
    // see http://stroika-bugs.sophists.com/browse/STK-917
    bool changed = false;
    RequireNotNull (fRep_); // not yet destroyed
    {
        [[maybe_unused]] lock_guard critSec{fRep_->fSuppressDuplicatesThreshold_};
        if (fRep_->fSuppressDuplicatesThreshold_.load ()) {
            fRep_->fSuppressDuplicatesThreshold_.store (nullopt);
            changed = true;
        }
    }
    if (fRep_->fBufferingEnabled_) {
        fRep_->fBufferingEnabled_ = false;
        changed                   = true;
    }
    if (changed) {
        fRep_->UpdateBookkeepingThread_ ();
    }
#endif
    SetSuppressDuplicates (nullopt);
    SetBufferingEnabled (false);
    Flush ();
    Ensure (fRep_->fBookkeepingThread_.load () == nullptr);
}
 
auto Logger::GetAppenders () const -> Traversal::Iterable<shared_ptr<IAppenderRep>>
{
    AssertNotNull (fRep_); // must be called while Logger::Activator exists (see Logger class description)
    return fRep_->fAppenders_;
}
 
void Logger::SetAppenders (const shared_ptr<IAppenderRep>& rep)
{
    SetAppenders (rep == nullptr ? Collection<shared_ptr<IAppenderRep>>{} : Collection<shared_ptr<IAppenderRep>>{rep});
}
 
void Logger::SetAppenders (const Iterable<shared_ptr<IAppenderRep>>& reps)
{
    AssertNotNull (fRep_); // must be called while Logger::Activator exists
    fRep_->fAppenders_ = Collection<shared_ptr<IAppenderRep>>{reps};
}
 
void Logger::AddAppender (const shared_ptr<IAppenderRep>& rep)
{
    RequireNotNull (rep);
    AssertNotNull (fRep_); // must be called while Logger::Activator exists
    fRep_->fAppenders_.rwget ()->Add (rep);
}
 
void Logger::Log_ (Priority logLevel, const String& msg)
{
    AssertNotNull (fRep_); // must be called while Logger::Activator exists
    if (not fRep_->fAppenders_->empty ()) {
        auto p = make_pair (logLevel, msg);
        if (fRep_->fSuppressDuplicatesThreshold_.cget ()->has_value ()) {
            auto lastMsgLocked = fRep_->fLastMessages_.rwget ();
            // @todo fix performance when we fix http://stroika-bugs.sophists.com/browse/STK-928 -
            if (auto msgInfo = lastMsgLocked->Lookup (p)) {
                Rep_::LastMsgInfoType_ mi = *msgInfo;
                ++mi.fRepeatCount_;
                mi.fLastSentAt = Time::GetTickCount ();
                lastMsgLocked->Add (p, mi); // this is the 928 - part - above - that could be Update
                return;                     // so will be handled later
            }
            else {
                lastMsgLocked->Add (p, Rep_::LastMsgInfoType_{Time::GetTickCount ()}); // add empty one so we can recognize this as a DUP
            }
        }
        if (GetBufferingEnabled ()) {
            fRep_->fOutQMaybeNeedsFlush_ = true;
            fRep_->fOutMsgQ_.AddTail (p);
        }
        else {
            if (fRep_->fOutQMaybeNeedsFlush_) {
                fRep_->Flush_ (); // in case recently disabled
            }
            // avoid races/deadlocks and critical sections (between check and invoke)
            for (shared_ptr<IAppenderRep> tmp : fRep_->fAppenders_.load ()) {
                tmp->Log (p.first, p.second);
            }
        }
    }
}
 
void Logger::SetBufferingEnabled (bool logBufferingEnabled)
{
    Debug::TraceContextBumper ctx{"Logger::SetBufferingEnabled", "logBufferingEnabled={}"_f, logBufferingEnabled};
    RequireNotNull (fRep_);
    if (fRep_->fBufferingEnabled_ != logBufferingEnabled) {
        fRep_->fBufferingEnabled_ = logBufferingEnabled;
        fRep_->UpdateBookkeepingThread_ ();
    }
}
 
void Logger::Flush ()
{
    Debug::TraceContextBumper ctx{"Logger::Flush"};
    RequireNotNull (fRep_);
    fRep_->Flush_ ();
}
 
bool Logger::GetBufferingEnabled () const
{
    RequireNotNull (fRep_);
    return fRep_->fBufferingEnabled_;
}
 
optional<Time::Duration> Logger::GetSuppressDuplicates () const
{
    RequireNotNull (fRep_);
    return fRep_->fSuppressDuplicatesThreshold_.load ();
}
 
void Logger::SetSuppressDuplicates (const optional<Duration>& suppressDuplicatesThreshold)
{
    Debug::TraceContextBumper ctx{Stroika_Foundation_Debug_OptionalizeTraceArgs ("Logger::SetSuppressDuplicates", "suppressDuplicatesThreshold={}"_f,
                                                                                 suppressDuplicatesThreshold)};
    Require (not suppressDuplicatesThreshold.has_value () or *suppressDuplicatesThreshold > 0.0s);
    RequireNotNull (fRep_); // not destroyed
    [[maybe_unused]] lock_guard critSec{fRep_->fSuppressDuplicatesThreshold_};
    if (fRep_->fSuppressDuplicatesThreshold_ != suppressDuplicatesThreshold) {
        fRep_->fSuppressDuplicatesThreshold_ = suppressDuplicatesThreshold;
        fRep_->UpdateBookkeepingThread_ ();
    }
}
 
#if qStroika_Foundation_Debug_DefaultTracingOn
void Logger::Log (Priority logLevel, const wchar_t* format, ...)
{
    va_list argsList;
    va_start (argsList, format);
    String msg = Characters::FormatV (format, argsList);
    va_end (argsList);
    DbgTrace ("Logger::Log ({}, \"{}\")"_f, logLevel, msg);
    if (WouldLog (logLevel)) {
        Log_ (logLevel, msg);
    }
    else {
        DbgTrace ("...suppressed by WouldLog"_f);
    }
}
#endif
 
#if qStroika_HasComponent_syslog
/*
 ********************************************************************************
 ************************ Execution::SysLogAppender *****************************
 ********************************************************************************
 */
namespace {
    string mkMsg_ (const String& applicationName)
    {
        return Characters::CString::Format ("%s[%d]", applicationName.AsNarrowSDKString (Characters::eIgnoreErrors).c_str (), GetCurrentProcessID ());
    }
}
Logger::SysLogAppender::SysLogAppender (const String& applicationName)
    : fApplicationName_{mkMsg_ (applicationName)}
{
    ::openlog (fApplicationName_.c_str (), 0, LOG_DAEMON); // not sure what facility to pass?
}
 
Logger::SysLogAppender::SysLogAppender (const String& applicationName, int facility)
    : fApplicationName_{mkMsg_ (applicationName)}
{
    ::openlog (fApplicationName_.c_str (), 0, facility);
}
 
Logger::SysLogAppender::~SysLogAppender ()
{
    ::closelog ();
}
 
void Logger::SysLogAppender::Log (Priority logLevel, const String& message)
{
    DbgTrace ("SYSLOG: {}: {}"_f, DefaultNames<Logger::Priority> ().GetName (logLevel), message);
    int sysLogLevel = LOG_NOTICE; // doesn't matter cuz assert error if hit
    switch (logLevel) {
        case Priority::eDebug:
            sysLogLevel = LOG_DEBUG;
            break;
        case Priority::eInfo:
            sysLogLevel = LOG_INFO;
            break;
        case Priority::eNotice:
            sysLogLevel = LOG_NOTICE;
            break;
        case Priority::eWarning:
            sysLogLevel = LOG_WARNING;
            break;
        case Priority::eError:
            sysLogLevel = LOG_ERR;
            break;
        case Priority::eCriticalError:
            sysLogLevel = LOG_CRIT;
            break;
        case Priority::eAlertError:
            sysLogLevel = LOG_ALERT;
            break;
        case Priority::eEmergency:
            sysLogLevel = LOG_EMERG;
            break;
        default:
            RequireNotReached ();
    }
    // According to http://pubs.opengroup.org/onlinepubs/000095399/functions/xsh_chap02_09.html#tag_02_09_01 this is threadsafe
    ::syslog (sysLogLevel, "%s", message.AsNarrowSDKString (Characters::eIgnoreErrors).c_str ());
}
#endif
 
/*
 ********************************************************************************
 ************************** Execution::StreamAppender ***************************
 ********************************************************************************
 */
struct Logger::StreamAppender::Rep_ {
public:
    template <typename T>
    Rep_ (const T& out)
        : fWriter_ (Streams::TextToBinary::Writer::New (out))
    {
    }
    void Log (Priority logLevel, const String& message)
    {
        //@todo tmphack - write date and write logLevel??? and use TextStream API that does \r or \r\n as appropriate
        fWriter_.rwget ()->Write (
            "[{:5}][{:16}] {}\n"_f(Common::DefaultNames<Logger::Priority>{}.GetName (logLevel), Time::DateTime::Now ().Format (), message));
    }
 
private:
    Synchronized<Streams::OutputStream::Ptr<Characters::Character>> fWriter_; // All Stroika-provided appenders must be internally synchronized - http://stroika-bugs.sophists.com/browse/STK-610
};
 
Logger::StreamAppender::StreamAppender (const Streams::OutputStream::Ptr<byte>& out)
    : fRep_ (make_shared<Rep_> (out))
{
}
 
Logger::StreamAppender::StreamAppender (const Streams::OutputStream::Ptr<Characters::Character>& out)
    : fRep_ (make_shared<Rep_> (out))
{
}
 
void Logger::StreamAppender::Log (Priority logLevel, const String& message)
{
    fRep_->Log (logLevel, message);
}
 
/*
 ********************************************************************************
 ************************** Execution::FileAppender *****************************
 ********************************************************************************
 */
struct Logger::FileAppender::Rep_ {
public:
    Rep_ (const filesystem::path& fileName, bool truncateOnOpen)
        : fOut_ (StreamAppender (FileOutputStream::New (fileName, truncateOnOpen ? FileOutputStream::eStartFromStart : FileOutputStream::eAppend)))
    {
    }
    void Log (Priority logLevel, const String& message)
    {
        fOut_.Log (logLevel, message);
    }
 
private:
    StreamAppender fOut_; // no need to synchronize since our Logger::StreamAppender class is internally synchronized
};
 
Logger::FileAppender::FileAppender (const filesystem::path& fileName, bool truncateOnOpen)
    : fRep_ (make_shared<Rep_> (fileName, truncateOnOpen))
{
}
 
void Logger::FileAppender::Log (Priority logLevel, const String& message)
{
    fRep_->Log (logLevel, message);
}
 
#if qStroika_Foundation_Common_Platform_Windows
/*
 ********************************************************************************
 ********************** Execution::WindowsEventLogAppender **********************
 ********************************************************************************
 */
Logger::WindowsEventLogAppender::WindowsEventLogAppender (const String& eventSourceName)
    : fEventSourceName_{eventSourceName}
{
}
 
void Logger::WindowsEventLogAppender::Log (Priority logLevel, const String& message)
{
    /*
     * VERY QUICK HACK - AT LEAST DUMPS SOME INFO TO EVENTLOG - BUT MUCH TWEAKING LEFT TODO
     */
    WORD eventType = EVENTLOG_ERROR_TYPE;
    switch (logLevel) {
        case Priority::eDebug:
            eventType = EVENTLOG_INFORMATION_TYPE;
            break;
        case Priority::eInfo:
            eventType = EVENTLOG_INFORMATION_TYPE;
            break;
        case Priority::eNotice:
            eventType = EVENTLOG_INFORMATION_TYPE;
            break;
        case Priority::eWarning:
            eventType = EVENTLOG_WARNING_TYPE;
            break;
        case Priority::eError:
            eventType = EVENTLOG_ERROR_TYPE;
            break;
        case Priority::eAlertError:
            eventType = EVENTLOG_ERROR_TYPE;
            break;
        case Priority::eEmergency:
            eventType = EVENTLOG_ERROR_TYPE;
            break;
    }
    constexpr auto CATEGORY_Normal = 0x00000001L;
    WORD           eventCategoryID = CATEGORY_Normal;
    // See SPR#565 for weirdness - where I cannot really get these paid attention to
    // by the Windows EventLog. So had to use the .Net eventlogger. It SEEMS
    constexpr auto EVENT_Message = 0x00000064L;
    const DWORD    kEventID      = EVENT_Message;
    HANDLE         hEventSource  = ::RegisterEventSource (NULL, fEventSourceName_.AsSDKString ().c_str ());
    Verify (hEventSource != NULL);
    [[maybe_unused]] auto&& cleanup = Execution::Finally ([hEventSource] () noexcept { Verify (::DeregisterEventSource (hEventSource)); });
    SDKString               tmp     = message.AsSDKString ();
    const Characters::SDKChar* msg  = tmp.c_str ();
    constexpr PSID             kUserSid_     = nullptr;
    constexpr bool             kWriteOldWay_ = true;
    if constexpr (kWriteOldWay_) {
        auto rslt = ::ReportEvent (hEventSource, eventType, eventCategoryID, kEventID, kUserSid_, (WORD)1, 0, &msg, nullptr);
        if (rslt == 0) {
            DbgTrace ("lasterr={}"_f, ::GetLastError ());
            WeakAssertNotReached (); // shouldn't happen, but I saw on 2025-01-07 in WTF, so now logging more details - but fundamentally no real
                                     // change here
        }
    }
    else {
        // Doing something like this appears to require using the message compiler, which is crazy; maybe a better way...
        DWORD dataSize = static_cast<DWORD> ((tmp.size () + 1) * sizeof (SDKChar));
        Verify (::ReportEvent (hEventSource, eventType, eventCategoryID, kEventID, kUserSid_, 0, dataSize, nullptr, (LPVOID)msg));
    }
}
#endif
 
/*
 ********************************************************************************
 ************************** Logger::Activator ***********************************
 ********************************************************************************
 */
Logger::Activator::Activator (const Options& options)
{
    Debug::TraceContextBumper ctx{"Logger::Activator::Activator"};
    Assert (sThe.fRep_ == nullptr); // only one activator object at a time
    sThe.fRep_ = make_shared<Rep_> ();
    sThe.SetSuppressDuplicates (options.fSuppressDuplicatesThreshold);
    if (options.fLogBufferingEnabled) {
        sThe.SetBufferingEnabled (*options.fLogBufferingEnabled);
    }
    if (options.fMinLogLevel) {
        sThe.SetMinLogLevel (*options.fMinLogLevel);
    }
}
 
Logger::Activator::~Activator ()
{
    Debug::TraceContextBumper ctx{"Logger::Activator::~Activator"};
    Assert (sThe.fRep_ != nullptr); // this is the only way it gets cleared so better not be null
    sThe.Shutdown_ ();              // @todo maybe cleanup this code now that we have activator architecture?
    sThe.fRep_.reset ();
}
 
/*
 ********************************************************************************
 ***************** Execution::DefaultLoggingFatalErrorHandler *******************
 ********************************************************************************
 */
void Execution::DefaultLoggingFatalErrorHandler (const Characters::SDKChar* msg) noexcept
{
    Thread::SuppressInterruptionInContext suppressCtx;
    DbgTrace ("Fatal Error: {} encountered"_f, String::FromSDKString (msg));
    Logger::sThe.Log (Logger::eCriticalError, "Fatal Error: {}; Aborting..."_f, String::FromSDKString (msg));
    Logger::sThe.Log (Logger::eCriticalError, "Backtrace: {}"_f, Debug::BackTrace::Capture ());
    Logger::sThe.Log (Logger::eCriticalError, "Uncaught exception: {}"_f, std::current_exception ());
    Logger::sThe.Flush ();
    std::_Exit (EXIT_FAILURE); // skip
}
 
/*
 ********************************************************************************
 ***************** Execution::DefaultLoggingCrashSignalHandler ******************
 ********************************************************************************
 */
void Execution::DefaultLoggingCrashSignalHandler (Execution::SignalID signal) noexcept
{
    Thread::SuppressInterruptionInContext suppressCtx;
    DbgTrace ("Fatal Signal: {} encountered"_f, Execution::SignalToName (signal));
    Logger::sThe.Log (Logger::eCriticalError, "Fatal Signal: {}; Aborting..."_f, Execution::SignalToName (signal));
    Logger::sThe.Log (Logger::eCriticalError, "Backtrace: {}"_f, Debug::BackTrace::Capture ());
    Logger::sThe.Flush ();
    std::_Exit (EXIT_FAILURE); // skip
}