#include <boost/config.hpp>
#include <boost/log/sources/record_ostream.hpp>
#include <memory>
#include <set>
#include <type_traits>
#include <array>
#include <sstream>
#include <string>
#include <thread>
#include "../Shared/StackTrace.h"

Include dependency graph for Logger.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	logger::ThreadLocalIds

class	logger::LocalIdsScopeGuard

class	logger::LogOptions

struct	logger::LogShutdown

class	logger::Logger

class	logger::DebugTimer

Namespaces
	boost

	boost::program_options

	boost::filesystem

	logger

Macros
#define	SLOG(severity_or_channel)

#define	LOG(tag) SLOG(logger::tag)

#define	LOGGING(tag) logger::fast_logging_check(logger::tag)

#define	VLOGGING(n) logger::fast_logging_check(logger::DEBUG##n)

#define	CHECK(condition)

#define	CHECK_OP(OP, x, y)

#define	CHECK_EQ(x, y) CHECK_OP(EQ, x, y)

#define	CHECK_NE(x, y) CHECK_OP(NE, x, y)

#define	CHECK_LT(x, y) CHECK_OP(LT, x, y)

#define	CHECK_LE(x, y) CHECK_OP(LE, x, y)

#define	CHECK_GT(x, y) CHECK_OP(GT, x, y)

#define	CHECK_GE(x, y) CHECK_OP(GE, x, y)

#define	HEAVYDB_CHECKOP_FUNCTION(name, op)

#define	UNREACHABLE() LOG(FATAL) << "UNREACHABLE "

#define	LOG_IF(severity, condition)

#define	VLOG(n) LOG(DEBUG##n)

#define	DEBUG_TIMER(name) logger::DebugTimer(logger::INFO, __FILE__, __LINE__, name)

#define	DEBUG_TIMER_NEW_THREAD(parent_thread_id)

Typedefs
using	logger::RequestId = uint64_t

using	logger::ThreadId = uint64_t

using	logger::Channels = std::set< Channel >

using	logger::FatalFunc = void(*)() noexcept

Enumerations
enum	logger::Channel { logger::IR = 0, logger::PTX, logger::ASM, logger::EXECUTOR, logger::_NCHANNELS }

enum	logger::Severity { logger::DEBUG4 = 0, logger::DEBUG3, logger::DEBUG2, logger::DEBUG1, logger::INFO, logger::WARNING, logger::ERROR, logger::FATAL, logger::_NSEVERITIES }

Functions
RequestId	logger::request_id ()

ThreadId	logger::thread_id ()

ThreadLocalIds	logger::thread_local_ids ()

RequestId	logger::set_new_request_id ()

void	logger::set_request_id (RequestId const request_id)

void	logger::init (LogOptions const &log_opts)

void	logger::shutdown ()

void	logger::set_once_fatal_func (FatalFunc fatal_func)

bool	logger::fast_logging_check (Channel)

bool	logger::fast_logging_check (Severity severity)

template<typename X , typename Y >
BOOST_NOINLINE std::string *	logger::check_failed (X const &x, Y const &y, char const xstr, char const ystr, char const *op_str)

fs::path	logger::get_log_dir_path ()

void	logger::debug_timer_new_thread (ThreadId const parent_thread_id)

Variables
bool	g_enable_debug_timer

constexpr std::array< char const *, 4 >	logger::ChannelNames {"IR", "PTX", "ASM", "EXECUTOR"}

constexpr std::array< char, 4 >	logger::ChannelSymbols {'R', 'P', 'A', 'X'}

constexpr std::array< char const *, 8 >	logger::SeverityNames

constexpr std::array< char, 8 >	logger::SeveritySymbols {'4', '3', '2', '1', 'I', 'W', 'E', 'F'}

Macro Definition Documentation

#define CHECK ( condition )

Value:

if (BOOST_UNLIKELY(!(condition)))              \
  LOG(FATAL) << "Check failed: " #condition "\n" \
             << "Stack trace:\n"                 \
             << getCurrentStackTrace(1, nullptr, false)

Definition at line 291 of file Logger.h.

#define CHECK_EQ	(	x,
		y
	)	CHECK_OP(EQ, x, y)

Definition at line 301 of file Logger.h.

#define CHECK_GE	(	x,
		y
	)	CHECK_OP(GE, x, y)

Definition at line 306 of file Logger.h.

#define CHECK_GT	(	x,
		y
	)	CHECK_OP(GT, x, y)

Definition at line 305 of file Logger.h.

Referenced by anonymous_namespace{RelAlgOptimizer.cpp}::add_new_indices_for(), foreign_storage::anonymous_namespace{LogFileBufferParser.cpp}::add_nonce_values(), anonymous_namespace{RelAlgDag.cpp}::add_window_function_pre_project(), PerfectJoinHashTableBuilder::allocateDeviceMemory(), foreign_storage::ParquetArrayDetectEncoder::appendArrayItem(), RangeJoinHashTable::approximateTupleCount(), BoundingBoxIntersectJoinHashTable::approximateTupleCount(), BaselineJoinHashTable::BaselineJoinHashTable(), BoundingBoxIntersectJoinHashTable::BoundingBoxIntersectJoinHashTable(), Buffer_Namespace::BufferMgr::BufferMgr(), StringDictionary::buildDictionaryNumericTranslationMap(), QueryFragmentDescriptor::buildFragmentPerKernelForTable(), QueryFragmentDescriptor::buildFragmentPerKernelMap(), QueryFragmentDescriptor::buildFragmentPerKernelMapForUnion(), StringDictionaryProxy::buildIntersectionTranslationMapToOtherProxyUnlocked(), ExecutorResourceMgr_Namespace::ExecutorResourcePool::calc_min_max_resource_grants_for_request(), GeoRaster< T, Z >::calculate_bins_and_scales(), ExecutorResourceMgr_Namespace::ExecutorResourcePool::can_currently_satisfy_chunk_request(), foreign_storage::LocalMultiFileReader::checkForMoreRows(), spatial_type::StartEndPoint::codegen(), spatial_type::NPoints::codegenLoads(), GroupByAndAggregate::codegenPerfectHashFunction(), shared::convert_temporal_to_iso_format(), StringDictionary::copyStrings(), count_distinct_set_size(), create_dev_group_by_buffers(), Catalog_Namespace::Catalog::createCustomExpression(), Executor::createKernels(), RelAlgExecutor::createSortInputWorkUnit(), RelAlgExecutor::createTableFunctionWorkUnit(), Catalog_Namespace::Catalog::delDictionaryNontransactional(), import_export::Loader::distributeToShards(), anonymous_namespace{ExtensionFunctionsWhitelist.cpp}::drop_suffix(), anonymous_namespace{RowFunctionManager.h}::drop_suffix_impl(), table_functions::anonymous_namespace{TableFunctionsFactory.cpp}::drop_suffix_impl(), Fragmenter_Namespace::InsertOrderFragmenter::dropFragmentsToSizeNoInsertLock(), Executor::executeUpdate(), RelAlgExecutor::executeWorkUnit(), ExecutorResourceMgr_Namespace::ExecutorResourceMgr::ExecutorResourceMgr(), File_Namespace::FileBuffer::FileBuffer(), fill_one_to_many_baseline_hash_table(), fill_one_to_many_hash_table_impl(), fill_one_to_many_hash_table_sharded_impl(), find_string_literals(), Buffer_Namespace::BufferMgr::findFreeBuffer(), foreign_storage::RegexFileBufferParser::findRowEndPosition(), ExecutorResourceMgr_Namespace::generate_executor_resource_mgr(), get_available_gpus(), anonymous_namespace{PerfectJoinHashTable.cpp}::get_bucketized_hash_entry_info(), get_column_descriptor(), get_entries_per_device(), anonymous_namespace{RelAlgExecutor.cpp}::get_join_source_used_inputs(), Fragmenter_Namespace::get_null_padding(), heavyai::get_root_abs_path(), anonymous_namespace{Execute.cpp}::get_table_name(), foreign_storage::anonymous_namespace{AbstractTextFileDataWrapper.cpp}::get_thread_count(), QueryMemoryDescriptor::getColOffInBytes(), ColSlotContext::getCompactByteWidth(), foreign_storage::RefreshTimeCalculator::getCurrentTime(), StringDictionary::getEquals(), Geospatial::GeoTypesFactory::getGeoColumnsImpl(), Data_Namespace::DataMgr::getGpuBufferMgr(), HashtableRecycler::getHashtableAccessPathInfo(), HashJoin::getInstance(), getLeafColumnRange(), HashJoin::getMaximumNumHashEntriesCanHold(), ColumnFetcher::getOneTableColumnFragment(), StringDictionary::getRegexpLike(), GroupByAndAggregate::getShardedTopBucket(), init_agg_val_vec(), DBHandler::init_executor_resource_mgr(), ArrowResultSetConverter::initializeColumnBuilder(), Fragmenter_Namespace::InsertOrderFragmenter::insertChunksImpl(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), ColumnFetcher::linearizeColumnFragments(), foreign_storage::ParquetDataWrapper::loadBuffersUsingLazyParquetChunkLoader(), anonymous_namespace{CompareIR.cpp}::lower_multicol_compare(), ColumnFetcher::makeJoinColumn(), ResultSet::makeVarlenTargetValue(), ExecutorResourceMgr_Namespace::ExecutorResourceMgr::mark_request_timed_out(), anonymous_namespace{ExtensionFunctionsBinding.cpp}::match_numeric_argument(), ResultSetStorage::moveEntriesToBuffer(), HashJoin::normalizeColumnPair(), TableFunctions_Namespace::OneHotEncoder_Namespace::one_hot_encode(), pluck_ptrs(), foreign_storage::populate_chunks_using_data_blocks(), AlterTableAlterColumnCommand::populateAndWriteRecoveryInfo(), foreign_storage::CachingForeignStorageMgr::populateChunkBuffersSafely(), Data_Namespace::DataMgr::populateMgrs(), pre_translate_string_ops(), File_Namespace::MultiPage::push(), ResultSetRecycler::putItemToCache(), ExecutorResourceMgr_Namespace::OutstandingQueueRequests::queue_request_and_wait_with_timeout(), ResultSet::radixSortOnGpu(), anonymous_namespace{RelLeftDeepInnerJoin.cpp}::RebindRexInputsFromLeftDeepJoin::RebindRexInputsFromLeftDeepJoin(), AlterTableAlterColumnCommandRecoveryMgr::recoverAlterTableAlterColumnFromFile(), ResultSetStorage::reduce(), foreign_storage::LogFileBufferParser::regexMatchColumns(), foreign_storage::RegexFileBufferParser::regexMatchColumns(), Catalog_Namespace::Catalog::restoreOldOwners(), ResultSetStorage::rewriteAggregateBufferOffsets(), QueryRewriter::rewriteAggregateOnGroupByColumn(), ExecutionKernel::runImpl(), SegmentTree< INPUT_TYPE, AGG_TYPE >::SegmentTree(), Catalog_Namespace::anonymous_namespace{Catalog.cpp}::set_dict_key(), RowSetMemoryOwner::setKernelMemoryAllocator(), File_Namespace::CachingFileMgr::setMaxSizes(), QueryMemoryInitializer::setupTableFunctionGpuBuffers(), Fragmenter_Namespace::SortedOrderFragmenter::sortData(), CrossSectionTableFunctions::tf_cross_section_1d_impl(), CrossSectionTableFunctions::tf_cross_section_2d_impl(), GDALTableFunctions::tf_raster_contour_direct_impl(), GDALTableFunctions::tf_raster_contour_rasterize_impl(), RelAlgTranslator::translateBinaryGeoFunction(), RelAlgTranslator::translateGeoBoundingBoxIntersectOper(), RelAlgTranslator::translateOper(), Fragmenter_Namespace::InsertOrderFragmenter::updateColumn(), File_Namespace::FileMgr::updateMappedPagesVisibility(), anonymous_namespace{QueryMemoryDescriptor.cpp}::use_streaming_top_n(), anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor::visitInput(), and Buffer_Namespace::Buffer::write().

#define CHECK_LE	(	x,
		y
	)	CHECK_OP(LE, x, y)

Definition at line 304 of file Logger.h.

#define CHECK_LT	(	x,
		y
	)	CHECK_OP(LT, x, y)

Definition at line 303 of file Logger.h.

#define CHECK_NE	(	x,
		y
	)	CHECK_OP(NE, x, y)

Definition at line 302 of file Logger.h.

Referenced by StringDictionary::addStorageCapacity(), CodeGenerator::codegen(), CodeGenerator::codegenQualifierCmp(), anonymous_namespace{RelAlgDag.cpp}::compute_node_hash(), anonymous_namespace{SysCatalog.cpp}::copy_catalog_if_read_only(), File_Namespace::FileMgr::copySourcePageForCompaction(), Executor::executePlanWithGroupBy(), PerfectJoinHashTableBuilder::get_entries_per_shard(), anonymous_namespace{FromTableReordering.cpp}::get_join_qual_cost(), Analyzer::StringOper::get_return_type(), Parser::get_str_dict_cast_type(), ResultSet::getColumnarBaselineEntryAt(), getExpressionRange(), ColumnFetcher::getResultSetColumn(), ResultSet::getRowWiseBaselineEntryAt(), ResultSet::getStorageIndex(), RexSubQuery::getType(), anonymous_namespace{RelAlgDag.cpp}::handle_agg_over_join(), QueryMemoryInitializer::initColumnsPerRow(), pre_translate_string_ops(), StringNoneEncoder::readMetadata(), Catalog_Namespace::Catalog::reassignOwners(), Catalog_Namespace::Catalog::reloadForeignTableUnlocked(), HashJoin::translateCompositeStrDictProxies(), RelAlgTranslator::translateIntervalExprForWindowFraming(), RelAlgTranslator::translateUoper(), anonymous_namespace{RelAlgOptimizer.cpp}::RexInputRedirector::visitInput(), and writeBackCellGeoNestedArray().

#define CHECK_OP	(	OP,
		x,
		y
	)

Value:

if (std::string* fatal_msg = logger::Check##OP(x, y, #x, #y)) \

LOG(FATAL) << *std::unique_ptr<std::string>(fatal_msg)

LOG

#define LOG(tag)

Definition: Logger.h:285

logger::FATAL

Definition: Logger.h:111

Definition at line 297 of file Logger.h.

#define DEBUG_TIMER ( name ) logger::DebugTimer(logger::INFO, __FILE__, __LINE__, name)

Definition at line 412 of file Logger.h.

#define DEBUG_TIMER_NEW_THREAD ( parent_thread_id )

Value:

do {                                                  \
    if (g_enable_debug_timer)                           \
      logger::debug_timer_new_thread(parent_thread_id); \
  } while (false)

Definition at line 417 of file Logger.h.

Referenced by BaselineJoinHashTableBuilder::initHashTableOnCpu(), Executor::launchKernelsImpl(), foreign_storage::ParquetDataWrapper::populateChunkBuffers(), RangeJoinHashTable::reifyForDevice(), BoundingBoxIntersectJoinHashTable::reifyForDevice(), PerfectJoinHashTable::reifyForDevice(), and BaselineJoinHashTable::reifyForDevice().

#define HEAVYDB_CHECKOP_FUNCTION	(	name,
		op
	)

Value:

template <typename X, typename Y>                                 \
  inline std::string* Check##name(                                  \
      X const& x, Y const& y, char const* xstr, char const* ystr) { \
    if (BOOST_LIKELY(x op y))                                       \
      return nullptr;                                               \
    else                                                            \
      return logger::check_failed(x, y, xstr, ystr, " " #op " ");   \
  }

Definition at line 321 of file Logger.h.

#define LOG ( tag ) SLOG(logger::tag)

Definition at line 285 of file Logger.h.

#define LOG_IF	(	severity,
		condition
	)

Value:

if (condition) \

LOG(severity)

LOG

#define LOG(tag)

Definition: Logger.h:285

Definition at line 384 of file Logger.h.

Referenced by anonymous_namespace{InputMetadata.cpp}::collect_table_infos(), import_export::RasterImporter::detect(), anonymous_namespace{RelAlgExecutor.cpp}::get_input_nest_levels(), DBHandler::importGeoTableSingle(), QueryRunner::QueryRunner::init(), Data_Namespace::AbstractBuffer::initEncoder(), Calcite::inner_close_calcite_server(), pair_to_double(), and CrossSectionTableFunctions::tf_cross_section_1d_impl().

#define LOGGING ( tag ) logger::fast_logging_check(logger::tag)

Definition at line 287 of file Logger.h.

#define SLOG ( severity_or_channel )

Value:

if (auto _heavydb_logger_severity_or_channel_ = severity_or_channel;                \
      logger::fast_logging_check(_heavydb_logger_severity_or_channel_))               \
    if (auto _heavydb_logger_ = logger::Logger(_heavydb_logger_severity_or_channel_)) \
  _heavydb_logger_.stream(__FILE__, __LINE__)

Definition at line 279 of file Logger.h.

#define UNREACHABLE ( ) LOG(FATAL) << "UNREACHABLE "

Definition at line 338 of file Logger.h.

#define VLOG ( n ) LOG(DEBUG##n)

Definition at line 388 of file Logger.h.

#define VLOGGING ( n ) logger::fast_logging_check(logger::DEBUG##n)

Definition at line 289 of file Logger.h.

Referenced by BaselineJoinHashTable::getInstance(), PerfectJoinHashTable::getInstance(), BoundingBoxIntersectJoinHashTable::getInstance(), and HashJoin::getInstance().

Variable Documentation

bool g_enable_debug_timer

Definition at line 17 of file Logger.cpp.

Classes

Namespaces

Macros

Typedefs

Enumerations

Functions

Variables

Macro Definition Documentation

Variable Documentation