Server : Apache/2.4.41 (Ubuntu) System : Linux absol.cf 5.4.0-198-generic #218-Ubuntu SMP Fri Sep 27 20:18:53 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory : /usr/local/lib/node_modules/mediasoup/worker/include/
Upload File :
Current File : //usr/local/lib/node_modules/mediasoup/worker/include/Logger.hpp
/**
* Logger facility.
*
* This include file defines logging macros for source files (.cpp). Each
* source file including Logger.hpp MUST define its own MS_CLASS macro. Include
* files (.hpp) MUST NOT include Logger.hpp.
*
* All the logging macros use the same format as printf(). The XXX_STD() version
* of a macro logs to stdoud/stderr instead of using the Channel instance.
* However some macros such as MS_ABORT() and MS_ASSERT() always log to stderr.
*
* If the macro MS_LOG_STD is defined, all the macros log to stdout/stderr.
*
* If the macro MS_LOG_FILE_LINE is defied, all the logging macros print more
* verbose information, including current file and line.
*
* MS_TRACE()
*
* Logs the current method/function if MS_LOG_TRACE macro is defined and the
* current log level is "debug".
*
* MS_HAS_DEBUG_TAG(tag)
* MS_HAS_WARN_TAG(tag)
*
* True if the current log level is satisfied and the given tag is enabled.
*
* MS_DEBUG_TAG(tag, ...)
* MS_WARN_TAG(tag, ...)
*
* Logs if the current log level is satisfied and the given tag is enabled.
*
* Example:
* MS_WARN_TAG(ice, "ICE failed");
*
* MS_DEBUG_2TAGS(tag1, tag2, ...)
* MS_WARN_2TAGS(tag1, tag2, ...)
*
* Logs if the current log level is satisfied and any of the given two tags
* is enabled.
*
* Example:
* MS_DEBUG_2TAGS(ice, dtls, "media connection established");
*
* MS_DEBUG_DEV(...)
*
* Logs if the current source file defines the MS_LOG_DEV_LEVEL macro with
* value 3.
*
* Example:
* MS_DEBUG_DEV("foo:%" PRIu32, foo);
*
* MS_WARN_DEV(...)
*
* Logs if the current source file defines the MS_LOG_DEV_LEVEL macro with
* value >= 2.
*
* Example:
* MS_WARN_DEV("foo:%" PRIu32, foo);
*
* MS_DUMP(...)
*
* Logs always. Useful for Dump() methods.
*
* Example:
* MS_DUMP("foo");
*
* MS_DUMP_DATA(const uint8_t* data, size_t len)
*
* Logs always. Prints the given data in hexadecimal format (Wireshark friendly).
*
* MS_ERROR(...)
*
* Logs an error if the current log level is satisfied (or if the current
* source file defines the MS_LOG_DEV_LEVEL macro with value >= 1). Must just
* be used for internal errors that should not happen.
*
* MS_ABORT(...)
*
* Logs the given error to stderr and aborts the process.
*
* MS_ASSERT(condition, ...)
*
* If the condition is not satisfied, it calls MS_ABORT().
*/
#ifndef MS_LOGGER_HPP
#define MS_LOGGER_HPP
#include "common.hpp"
#include "LogLevel.hpp"
#include "Settings.hpp"
#include "Channel/UnixStreamSocket.hpp"
#include <cstdio> // std::snprintf(), std::fprintf(), stdout, stderr
#include <cstdlib> // std::abort()
#include <cstring>
// clang-format off
#define _MS_TAG_ENABLED(tag) Settings::configuration.logTags.tag
#define _MS_TAG_ENABLED_2(tag1, tag2) (Settings::configuration.logTags.tag1 || Settings::configuration.logTags.tag2)
#if !defined(MS_LOG_DEV_LEVEL)
#define MS_LOG_DEV_LEVEL 0
#elif MS_LOG_DEV_LEVEL < 0 || MS_LOG_DEV_LEVEL > 3
#error "invalid MS_LOG_DEV_LEVEL macro value"
#endif
// Usage:
// MS_DEBUG_DEV("Leading text "MS_UINT16_TO_BINARY_PATTERN, MS_UINT16_TO_BINARY(value));
#define MS_UINT16_TO_BINARY_PATTERN "%c%c%c%c%c%c%c%c%c%c%c%c%c%c%c%c"
#define MS_UINT16_TO_BINARY(value) \
((value & 0x8000) ? '1' : '0'), \
((value & 0x4000) ? '1' : '0'), \
((value & 0x2000) ? '1' : '0'), \
((value & 0x1000) ? '1' : '0'), \
((value & 0x800) ? '1' : '0'), \
((value & 0x400) ? '1' : '0'), \
((value & 0x200) ? '1' : '0'), \
((value & 0x100) ? '1' : '0'), \
((value & 0x80) ? '1' : '0'), \
((value & 0x40) ? '1' : '0'), \
((value & 0x20) ? '1' : '0'), \
((value & 0x10) ? '1' : '0'), \
((value & 0x08) ? '1' : '0'), \
((value & 0x04) ? '1' : '0'), \
((value & 0x02) ? '1' : '0'), \
((value & 0x01) ? '1' : '0')
class Logger
{
public:
static void ClassInit(Channel::UnixStreamSocket* channel);
public:
static const int64_t pid;
static Channel::UnixStreamSocket* channel;
static const size_t bufferSize {50000};
static char buffer[];
};
/* Logging macros. */
#define _MS_LOG_SEPARATOR_CHAR_STD "\n"
#ifdef MS_LOG_FILE_LINE
#define _MS_LOG_STR "%s:%d | %s::%s()"
#define _MS_LOG_STR_DESC _MS_LOG_STR " | "
#define _MS_FILE (std::strchr(__FILE__, '/') ? std::strchr(__FILE__, '/') + 1 : __FILE__)
#define _MS_LOG_ARG _MS_FILE, __LINE__, MS_CLASS, __FUNCTION__
#else
#define _MS_LOG_STR "%s::%s()"
#define _MS_LOG_STR_DESC _MS_LOG_STR " | "
#define _MS_LOG_ARG MS_CLASS, __FUNCTION__
#endif
#ifdef MS_LOG_TRACE
#define MS_TRACE() \
do \
{ \
if (Settings::configuration.logLevel == LogLevel::LOG_DEBUG) \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "D(trace) " _MS_LOG_STR, _MS_LOG_ARG); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
} \
while (false)
#define MS_TRACE_STD() \
do \
{ \
if (Settings::configuration.logLevel == LogLevel::LOG_DEBUG) \
{ \
std::fprintf(stdout, "(trace) " _MS_LOG_STR _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG); \
std::fflush(stdout); \
} \
} \
while (false)
#else
#define MS_TRACE() {}
#define MS_TRACE_STD() {}
#endif
#define MS_HAS_DEBUG_TAG(tag) \
(Settings::configuration.logLevel == LogLevel::LOG_DEBUG && _MS_TAG_ENABLED(tag))
#define MS_HAS_WARN_TAG(tag) \
(Settings::configuration.logLevel >= LogLevel::LOG_WARN && _MS_TAG_ENABLED(tag))
#define MS_DEBUG_TAG(tag, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel == LogLevel::LOG_DEBUG && _MS_TAG_ENABLED(tag)) \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "D" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
} \
while (false)
#define MS_DEBUG_TAG_STD(tag, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel == LogLevel::LOG_DEBUG && _MS_TAG_ENABLED(tag)) \
{ \
std::fprintf(stdout, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stdout); \
} \
} \
while (false)
#define MS_WARN_TAG(tag, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel >= LogLevel::LOG_WARN && _MS_TAG_ENABLED(tag)) \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "W" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
} \
while (false)
#define MS_WARN_TAG_STD(tag, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel >= LogLevel::LOG_WARN && _MS_TAG_ENABLED(tag)) \
{ \
std::fprintf(stderr, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stderr); \
} \
} \
while (false)
#define MS_DEBUG_2TAGS(tag1, tag2, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel == LogLevel::LOG_DEBUG && _MS_TAG_ENABLED_2(tag1, tag2)) \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "D" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
} \
while (false)
#define MS_DEBUG_2TAGS_STD(tag1, tag2, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel == LogLevel::LOG_DEBUG && _MS_TAG_ENABLED_2(tag1, tag2)) \
{ \
std::fprintf(stdout, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stdout); \
} \
} \
while (false)
#define MS_WARN_2TAGS(tag1, tag2, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel >= LogLevel::LOG_WARN && _MS_TAG_ENABLED_2(tag1, tag2)) \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "W" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
} \
while (false)
#define MS_WARN_2TAGS_STD(tag1, tag2, desc, ...) \
do \
{ \
if (Settings::configuration.logLevel >= LogLevel::LOG_WARN && _MS_TAG_ENABLED_2(tag1, tag2)) \
{ \
std::fprintf(stderr, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stderr); \
} \
} \
while (false)
#if MS_LOG_DEV_LEVEL == 3
#define MS_DEBUG_DEV(desc, ...) \
do \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "D" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
while (false)
#define MS_DEBUG_DEV_STD(desc, ...) \
do \
{ \
std::fprintf(stdout, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stdout); \
} \
while (false)
#else
#define MS_DEBUG_DEV(desc, ...) {}
#define MS_DEBUG_DEV_STD(desc, ...) {}
#endif
#if MS_LOG_DEV_LEVEL >= 2
#define MS_WARN_DEV(desc, ...) \
do \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "W" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
while (false)
#define MS_WARN_DEV_STD(desc, ...) \
do \
{ \
std::fprintf(stderr, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stderr); \
} \
while (false)
#else
#define MS_WARN_DEV(desc, ...) {}
#define MS_WARN_DEV_STD(desc, ...) {}
#endif
#define MS_DUMP(desc, ...) \
do \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "X" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
while (false)
#define MS_DUMP_STD(desc, ...) \
do \
{ \
std::fprintf(stdout, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stdout); \
} \
while (false)
#define MS_DUMP_DATA(data, len) \
do \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "X(data) " _MS_LOG_STR, _MS_LOG_ARG); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
size_t bufferDataLen{ 0 }; \
for (size_t i{0}; i < len; ++i) \
{ \
if (i % 8 == 0) \
{ \
if (bufferDataLen != 0) \
{ \
Logger::channel->SendLog(Logger::buffer, bufferDataLen); \
bufferDataLen = 0; \
} \
int loggerWritten = std::snprintf(Logger::buffer + bufferDataLen, Logger::bufferSize, "X%06X ", static_cast<unsigned int>(i)); \
bufferDataLen += loggerWritten; \
} \
int loggerWritten = std::snprintf(Logger::buffer + bufferDataLen, Logger::bufferSize, "%02X ", static_cast<unsigned char>(data[i])); \
bufferDataLen += loggerWritten; \
} \
if (bufferDataLen != 0) \
Logger::channel->SendLog(Logger::buffer, bufferDataLen); \
} \
while (false)
#define MS_DUMP_DATA_STD(data, len) \
do \
{ \
std::fprintf(stdout, "(data) " _MS_LOG_STR _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG); \
size_t bufferDataLen{ 0 }; \
for (size_t i{0}; i < len; ++i) \
{ \
if (i % 8 == 0) \
{ \
if (bufferDataLen != 0) \
{ \
Logger::buffer[bufferDataLen] = '\0'; \
std::fprintf(stdout, "%s", Logger::buffer); \
bufferDataLen = 0; \
} \
int loggerWritten = std::snprintf(Logger::buffer + bufferDataLen, Logger::bufferSize, "\n%06X ", static_cast<unsigned int>(i)); \
bufferDataLen += loggerWritten; \
} \
int loggerWritten = std::snprintf(Logger::buffer + bufferDataLen, Logger::bufferSize, "%02X ", static_cast<unsigned char>(data[i])); \
bufferDataLen += loggerWritten; \
} \
if (bufferDataLen != 0) \
{ \
Logger::buffer[bufferDataLen] = '\0'; \
std::fprintf(stdout, "%s", Logger::buffer); \
} \
std::fflush(stdout); \
} \
while (false)
#define MS_ERROR(desc, ...) \
do \
{ \
if (Settings::configuration.logLevel >= LogLevel::LOG_ERROR || MS_LOG_DEV_LEVEL >= 1) \
{ \
int loggerWritten = std::snprintf(Logger::buffer, Logger::bufferSize, "E" _MS_LOG_STR_DESC desc, _MS_LOG_ARG, ##__VA_ARGS__); \
Logger::channel->SendLog(Logger::buffer, loggerWritten); \
} \
} \
while (false)
#define MS_ERROR_STD(desc, ...) \
do \
{ \
if (Settings::configuration.logLevel >= LogLevel::LOG_ERROR || MS_LOG_DEV_LEVEL >= 1) \
{ \
std::fprintf(stderr, _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stderr); \
} \
} \
while (false)
#define MS_ABORT(desc, ...) \
do \
{ \
std::fprintf(stderr, "(ABORT) " _MS_LOG_STR_DESC desc _MS_LOG_SEPARATOR_CHAR_STD, _MS_LOG_ARG, ##__VA_ARGS__); \
std::fflush(stderr); \
std::abort(); \
} \
while (false)
#define MS_ASSERT(condition, desc, ...) \
if (!(condition)) \
{ \
MS_ABORT("failed assertion `%s': " desc, #condition, ##__VA_ARGS__); \
}
#ifdef MS_LOG_STD
#undef MS_TRACE
#define MS_TRACE MS_TRACE_STD
#undef MS_DEBUG_TAG
#define MS_DEBUG_TAG MS_DEBUG_TAG_STD
#undef MS_WARN_TAG
#define MS_WARN_TAG MS_WARN_TAG_STD
#undef MS_DEBUG_2TAGS
#define MS_DEBUG_2TAGS MS_DEBUG_2TAGS_STD
#undef MS_WARN_2TAGS
#define MS_WARN_2TAGS MS_WARN_2TAGS_STD
#undef MS_DEBUG_DEV
#define MS_DEBUG_DEV MS_DEBUG_DEV_STD
#undef MS_WARN_DEV
#define MS_WARN_DEV MS_WARN_DEV_STD
#undef MS_DUMP
#define MS_DUMP MS_DUMP_STD
#undef MS_DUMP_DATA
#define MS_DUMP_DATA MS_DUMP_DATA_STD
#undef MS_ERROR
#define MS_ERROR MS_ERROR_STD
#endif
// clang-format on
#endif
Server : Apache/2.4.41 (Ubuntu)