query_state::StdLog Class Reference

#include <QueryState.h>

Inheritance diagram for query_state::StdLog:

Collaboration diagram for query_state::StdLog:

Public Member Functions
template<typename... Pairs>
	StdLog (char const *file, unsigned line, char const *func, std::shared_ptr< Catalog_Namespace::SessionInfo > session_info, Pairs &&...pairs)
template<typename... Pairs>
	StdLog (char const *file, unsigned line, char const *func, std::shared_ptr< Catalog_Namespace::SessionInfo > session_info, std::shared_ptr< QueryState > query_state, Pairs &&...pairs)
template<typename... Pairs>
	StdLog (char const *file, unsigned line, char const *func, std::shared_ptr< QueryState > query_state, Pairs &&...pairs)
template<typename... Pairs>
	StdLog (char const *file, unsigned line, char const *func, Pairs &&...pairs)
	StdLog (StdLog const &)=delete
	StdLog (StdLog &&)=default
	~StdLog ()
template<typename... Pairs>
void	appendNameValuePairs (Pairs &&...pairs)
template<typename Units = std::chrono::milliseconds>
Units::rep	duration () const
std::shared_ptr < Catalog_Namespace::SessionInfo const >	getConstSessionInfo () const
std::shared_ptr < Catalog_Namespace::SessionInfo >	getSessionInfo () const
void	setQueryState (std::shared_ptr< QueryState >)
void	setSessionInfo (std::shared_ptr< Catalog_Namespace::SessionInfo >)

Private Member Functions
void	log (logger::Severity, char const *label)
void	logCallStack (logger::Severity, char const *label)

Static Private Member Functions
static logger::Severity	stdlogBeginSeverity (char const *func)

Private Attributes
std::shared_ptr < Catalog_Namespace::SessionInfo >	session_info_
std::shared_ptr< QueryState >	query_state_

Additional Inherited Members
Protected Member Functions inherited from query_state::StdLogData
template<typename... Pairs>
	StdLogData (char const *file, unsigned line, char const *func, Pairs &&...pairs)
Protected Attributes inherited from query_state::StdLogData
std::string const	file_
unsigned const	line_
char const *const	func_
Clock::time_point const	start_
int64_t const	match_
std::list< std::string >	name_value_pairs_
Static Protected Attributes inherited from query_state::StdLogData
static std::atomic< int64_t >	s_match {0}

Detailed Description

Definition at line 261 of file QueryState.h.

Constructor & Destructor Documentation

template<typename... Pairs>

query_state::StdLog::StdLog ( char const *  file, unsigned  line, char const *  func, std::shared_ptr< Catalog_Namespace::SessionInfo >  session_info, Pairs &&...  pairs  )

inline

Definition at line 270 of file QueryState.h.

References log(), and stdlogBeginSeverity().

      : StdLogData(file, line, func, std::forward<Pairs>(pairs)...)
      , session_info_(std::move(session_info)) {
    log(stdlogBeginSeverity(func), "stdlog_begin");
  }

Here is the call graph for this function:

template<typename... Pairs>

query_state::StdLog::StdLog ( char const *  file, unsigned  line, char const *  func, std::shared_ptr< Catalog_Namespace::SessionInfo >  session_info, std::shared_ptr< QueryState >  query_state, Pairs &&...  pairs  )

inline

Definition at line 281 of file QueryState.h.

References log(), and stdlogBeginSeverity().

      : StdLogData(file, line, func, std::forward<Pairs>(pairs)...)
      , session_info_(std::move(session_info))
      , query_state_(std::move(query_state)) {
    log(stdlogBeginSeverity(func), "stdlog_begin");
  }

Here is the call graph for this function:

template<typename... Pairs>

query_state::StdLog::StdLog ( char const *  file, unsigned  line, char const *  func, std::shared_ptr< QueryState >  query_state, Pairs &&...  pairs  )

inline

Definition at line 294 of file QueryState.h.

References log(), and stdlogBeginSeverity().

      : StdLogData(file, line, func, std::forward<Pairs>(pairs)...)
      , query_state_(std::move(query_state)) {
    log(stdlogBeginSeverity(func), "stdlog_begin");
  }

Here is the call graph for this function:

template<typename... Pairs>

query_state::StdLog::StdLog ( char const *  file, unsigned  line, char const *  func, Pairs &&...  pairs  )

inline

Definition at line 304 of file QueryState.h.

References log(), and stdlogBeginSeverity().

      : StdLogData(file, line, func, std::forward<Pairs>(pairs)...) {
    log(stdlogBeginSeverity(func), "stdlog_begin");
  }

Here is the call graph for this function:

query_state::StdLog::StdLog ( StdLog const &  )

delete

query_state::StdLog::StdLog ( StdLog &&  )

default

query_state::StdLog::~StdLog

(

)

Definition at line 267 of file QueryState.cpp.

References logger::DEBUG1, logger::INFO, log(), logCallStack(), query_state_, and session_info_.

                {
  log(logger::Severity::INFO, "stdlog");
  logCallStack(logger::Severity::DEBUG1, "stacked_times");
  if (query_state_) {
    query_state_->setLogged(true);
  }
  if (session_info_) {
    session_info_->update_last_used_time();
  }
}

Here is the call graph for this function:

Member Function Documentation

template<typename... Pairs>

void query_state::StdLog::appendNameValuePairs ( Pairs &&...  pairs )

inline

Definition at line 312 of file QueryState.h.

References query_state::StdLogData::name_value_pairs_, and to_string().

Referenced by DBHandler::connect_impl().

                                              {
    static_assert(sizeof...(Pairs) % 2 == 0,
                  "appendNameValuePairs() requires an even number of parameters.");
    name_value_pairs_.splice(name_value_pairs_.cend(),
                             {to_string(std::forward<Pairs>(pairs))...});
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename Units = std::chrono::milliseconds>

Units::rep query_state::StdLog::duration ( ) const

inline

Definition at line 319 of file QueryState.h.

References query_state::StdLogData::start_.

                                     {
    return std::chrono::duration_cast<Units>(Clock::now() - start_).count();
  }

std::shared_ptr< Catalog_Namespace::SessionInfo const > query_state::StdLog::getConstSessionInfo

(

)

const

Definition at line 150 of file QueryState.cpp.

References session_info_.

Referenced by DBHandler::connect_impl(), and DBHandler::get_completion_hints_unsorted().

          {
  return session_info_;
}

Here is the caller graph for this function:

std::shared_ptr< Catalog_Namespace::SessionInfo > query_state::StdLog::getSessionInfo

(

)

const

Definition at line 155 of file QueryState.cpp.

References session_info_.

Referenced by DBHandler::get_table_details_impl().

                                                                         {
  return session_info_;
}

Here is the caller graph for this function:

void query_state::StdLog::log ( logger::Severity  severity, char const *  label  )

private

Definition at line 217 of file QueryState.cpp.

References logger::fast_logging_check(), query_state::StdLogData::file_, query_state::StdLogData::func_, hide_sensitive_data_from_query(), query_state::StdLogData::line_, query_state::StdLogData::match_, query_state::StdLogData::name_value_pairs_, query_state_, logger::ThreadLocalIds::request_id_, session_info_, logger::ThreadLocalIds::thread_id_, and logger::thread_local_ids().

Referenced by StdLog(), and ~StdLog().

                                                           {
  if (logger::fast_logging_check(severity)) {
    std::stringstream ss;
    logger::ThreadLocalIds const tlids = logger::thread_local_ids();
    ss << tlids.request_id_ << ' ' << tlids.thread_id_ << ' ' << file_ << ':' << line_
       << ' ' << label << ' ' << func_ << ' ' << match_ << ' '
       << duration<std::chrono::milliseconds>() << ' ';
    if (session_info_) {
      ss << SessionInfoFormatter{*session_info_} << ' ';
    } else if (query_state_ && query_state_->getSessionData()) {
      ss << *query_state_->getSessionData() << ' ';
    } else {
      ss << "   ";  // 3 spaces for 3 empty strings
    }
    auto const& nv = name_value_pairs_;
    if (nv.empty() && (!query_state_ || query_state_->emptyLog())) {
      ss << ' ';  // 1 space for final empty names/values arrays
    } else {
      // All values are logged after all names, so separate values stream is needed.
      std::stringstream values;
      unsigned nvalues = 0;
      if (query_state_ && !query_state_->getQueryStr().empty()) {
        ss << (nvalues ? ',' : '{') << std::quoted("query_str", '"', '"');
        values << (nvalues++ ? ',' : '{')
               << std::quoted(hide_sensitive_data_from_query(query_state_->getQueryStr()),
                              '"',
                              '"');
      }
      for (auto itr = nv.cbegin(); itr != nv.cend(); ++itr) {
        ss << (nvalues ? ',' : '{') << std::quoted(*itr, '"', '"');
        values << (nvalues++ ? ',' : '{') << std::quoted(*++itr, '"', '"');
      }
      ss << "} " << values.rdbuf() << '}';
    }
    BOOST_LOG_SEV(logger::gSeverityLogger::get(), severity) << ss.rdbuf();
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void query_state::StdLog::logCallStack ( logger::Severity  severity, char const *  label  )

private

Definition at line 255 of file QueryState.cpp.

References logger::fast_logging_check(), query_state::StdLogData::file_, query_state::StdLogData::func_, query_state::StdLogData::line_, query_state::StdLogData::match_, query_state_, logger::ThreadLocalIds::request_id_, logger::ThreadLocalIds::thread_id_, and logger::thread_local_ids().

Referenced by ~StdLog().

                                                                    {
  if (logger::fast_logging_check(severity) && query_state_) {
    std::stringstream ss;
    logger::ThreadLocalIds const tlids = logger::thread_local_ids();
    ss << tlids.request_id_ << ' ' << tlids.thread_id_ << ' ' << file_ << ':' << line_
       << ' ' << label << ' ' << func_ << ' ' << match_ << " total time "
       << duration<std::chrono::milliseconds>() << " ms";
    query_state_->logCallStack(ss);
    BOOST_LOG_SEV(logger::gSeverityLogger::get(), severity) << ss.rdbuf();
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void query_state::StdLog::setQueryState

(

std::shared_ptr< QueryState >

query_state

)

Definition at line 278 of file QueryState.cpp.

References query_state_.

Referenced by DBHandler::get_table_details_impl().

                                                                {
  query_state_ = std::move(query_state);
}

Here is the caller graph for this function:

void query_state::StdLog::setSessionInfo

(

std::shared_ptr< Catalog_Namespace::SessionInfo >

session_info

)

Definition at line 282 of file QueryState.cpp.

References session_info_.

Referenced by DBHandler::connect_impl().

                                                              {
  session_info_ = std::move(session_info);
}

Here is the caller graph for this function:

logger::Severity query_state::StdLog::stdlogBeginSeverity ( char const *  func )

staticprivate

Definition at line 190 of file QueryState.cpp.

References logger::DEBUG1, and logger::INFO.

Referenced by StdLog().

                                                           {
  logger::Severity const defaultSeverity = logger::Severity::DEBUG1;
  static std::unordered_map<std::string_view, logger::Severity> const map{
      {"connect", logger::Severity::INFO},
      {"disconnect", logger::Severity::INFO},
      {"switch_database", logger::Severity::INFO},
      {"clone_session", logger::Severity::INFO},
      {"get_tables_meta", logger::Severity::INFO},
      {"get_table_details", logger::Severity::INFO},
      {"sql_execute", logger::Severity::INFO},
      {"sql_execute_df", logger::Severity::INFO},
      {"sql_execute_gdf", logger::Severity::INFO},
      {"sql_validate", logger::Severity::INFO},
      {"render_vega", logger::Severity::INFO},
      {"get_result_row_for_pixel", logger::Severity::INFO},
      {"check_table_consistency", logger::Severity::INFO},
      {"start_query", logger::Severity::INFO},
      {"execute_query_step", logger::Severity::INFO},
      {"broadcast_serialized_rows", logger::Severity::INFO},
      {"start_render_query", logger::Severity::INFO},
      {"execute_next_render_step", logger::Severity::INFO},
      {"clear_gpu_memory", logger::Severity::INFO},
      {"clear_cpu_memory", logger::Severity::INFO}};
  auto const itr = map.find(func);
  return itr == map.cend() ? defaultSeverity : itr->second;
}

Here is the caller graph for this function:

Member Data Documentation

std::shared_ptr<QueryState> query_state::StdLog::query_state_

private

Definition at line 263 of file QueryState.h.

Referenced by log(), logCallStack(), setQueryState(), and ~StdLog().

std::shared_ptr<Catalog_Namespace::SessionInfo> query_state::StdLog::session_info_

private

Definition at line 262 of file QueryState.h.

Referenced by getConstSessionInfo(), getSessionInfo(), log(), setSessionInfo(), and ~StdLog().

---

The documentation for this class was generated from the following files:

• /home/jenkins-slave/workspace/core-os-doxygen/ThriftHandler/QueryState.h
• /home/jenkins-slave/workspace/core-os-doxygen/ThriftHandler/QueryState.cpp