query_state::QueryState Class Reference

#include <QueryState.h>

Inheritance diagram for query_state::QueryState:

Collaboration diagram for query_state::QueryState:

Public Member Functions
QueryStateProxy	createQueryStateProxy ()
QueryStateProxy	createQueryStateProxy (Events::iterator parent)
Timer	createTimer (char const *event_name, Events::iterator parent)
bool	emptyLog () const
Id	getId () const
std::string const &	getQueryStr () const
std::shared_ptr < Catalog_Namespace::SessionInfo const >	getConstSessionInfo () const
boost::optional< SessionData > const &	getSessionData () const
bool	isLogged () const
void	logCallStack (std::stringstream &)
void	setQuerySubmittedTime (const std::chrono::time_point< std::chrono::system_clock > t)
const std::chrono::time_point < std::chrono::system_clock >	getQuerySubmittedTime () const
void	setLogged (bool logged)

Static Public Member Functions
template<typename... ARGS>
static std::shared_ptr < QueryState >	create (ARGS &&...args)

Private Member Functions
void	logCallStack (std::stringstream &, unsigned const depth, Events::iterator parent)
	QueryState (std::shared_ptr< Catalog_Namespace::SessionInfo const > const &, std::string query_str)

Private Attributes
Id const	id_
boost::optional< SessionData >	session_data_
std::string const	query_str_
Events	events_
std::mutex	events_mutex_
std::atomic< bool >	logged_
std::chrono::time_point < std::chrono::system_clock >	submitted_

Static Private Attributes
static std::atomic< Id >	s_next_id {0}

Friends
class	QueryStates

Detailed Description

Definition at line 124 of file QueryState.h.

Constructor & Destructor Documentation

query_state::QueryState::QueryState ( std::shared_ptr< Catalog_Namespace::SessionInfo const > const &  session_info, std::string  query_str  )

private

Definition at line 55 of file QueryState.cpp.

References none.

Referenced by create().

    : id_(s_next_id++)
    , session_data_(session_info ? boost::make_optional<SessionData>(session_info)
                                 : boost::none)
    , query_str_(std::move(query_str))
    , logged_(false) {}

Here is the caller graph for this function:

Member Function Documentation

template<typename... ARGS>

static std::shared_ptr<QueryState> query_state::QueryState::create ( ARGS &&...  args )

inlinestatic

Definition at line 141 of file QueryState.h.

References run_benchmark_import::args, and QueryState().

Referenced by query_state::QueryStates::create(), Parser::InsertIntoTableAsSelectStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Parser::ExportQueryStmt::execute(), and Parser::CreateViewStmt::execute().

                                                          {
    // Trick to call std::make_shared with private constructors.
    struct EnableMakeShared : public QueryState {
      EnableMakeShared(ARGS&&... args) : QueryState(std::forward<ARGS>(args)...) {}
    };
    return std::make_shared<EnableMakeShared>(std::forward<ARGS>(args)...);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

QueryStateProxy query_state::QueryState::createQueryStateProxy

(

)

Definition at line 64 of file QueryState.cpp.

References events_.

                                                  {
  return createQueryStateProxy(events_.end());
}

QueryStateProxy query_state::QueryState::createQueryStateProxy

(

Events::iterator

parent

)

Definition at line 68 of file QueryState.cpp.

                                                                       {
  return QueryStateProxy(*this, parent);
}

Timer query_state::QueryState::createTimer	(	char const *	event_name,
		Events::iterator	parent
	)

Definition at line 72 of file QueryState.cpp.

References events_, and events_mutex_.

Referenced by query_state::QueryStateProxy::createTimer().

                                                                           {
  std::lock_guard<std::mutex> lock(events_mutex_);
  return Timer(shared_from_this(), events_.emplace(events_.end(), event_name, parent));
}

Here is the caller graph for this function:

bool query_state::QueryState::emptyLog ( ) const

inline

Definition at line 151 of file QueryState.h.

References events_, and query_str_.

{ return events_.empty() && query_str_.empty(); }

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

(

)

const

Definition at line 77 of file QueryState.cpp.

References session_data_.

Referenced by Calcite::checkAccessedObjectsPrivileges(), DBHandler::execute_rel_alg(), DBHandler::execute_rel_alg_df(), Parser::LocalConnector::getOuterFragmentCount(), DBHandler::parse_to_ra(), Parser::InsertIntoTableAsSelectStmt::populateData(), Calcite::processImpl(), Parser::LocalConnector::query(), and DBHandler::sql_execute_impl().

          {
  if (!session_data_) {
    throw std::runtime_error("session_info_ was not set for this QueryState.");
  }
  if (auto retval = session_data_->session_info.lock()) {
    return retval;
  } else {
    // This can happen for a query on a database that is simultaneously dropped.
    throw std::runtime_error("session_info requested but has expired.");
  }
}

Here is the caller graph for this function:

Id query_state::QueryState::getId ( ) const

inline

Definition at line 152 of file QueryState.h.

References id_.

{ return id_; }

std::string const& query_state::QueryState::getQueryStr ( ) const

inline

Definition at line 153 of file QueryState.h.

References query_str_.

Referenced by DBHandler::execute_rel_alg_with_filter_push_down(), and DBHandler::sql_execute_impl().

{ return query_str_; }

Here is the caller graph for this function:

const std::chrono::time_point<std::chrono::system_clock> query_state::QueryState::getQuerySubmittedTime ( ) const

inline

Definition at line 163 of file QueryState.h.

References submitted_.

            {
    return submitted_;
  }

boost::optional<SessionData> const& query_state::QueryState::getSessionData ( ) const

inline

Definition at line 156 of file QueryState.h.

References session_data_.

{ return session_data_; }

bool query_state::QueryState::isLogged ( ) const

inline

Definition at line 157 of file QueryState.h.

References logged_.

{ return logged_.load(); }

void query_state::QueryState::logCallStack ( std::stringstream &  ss, unsigned const  depth, Events::iterator  parent  )

private

Definition at line 91 of file QueryState.cpp.

References events_.

Referenced by logCallStack().

                                                     {
  auto it = parent == events_.end() ? events_.begin() : std::next(parent);
  for (; it != events_.end(); ++it) {
    if (it->parent == parent) {
      auto duration = it->duration();  // std::optional, true if event completed
      ss << '\n'
         << std::setw(depth << 1) << ' ' << it->name << ' ' << it->thread_id
         << " - total time " << (duration ? *duration : -1) << " ms";
      logCallStack(ss, depth + 1, it);
      // If events_ is expendable, then this can be put here to speed-up large lists.
      // it = events_.erase(it); } else { ++it; } (and remove above ++it.)
    }
  }
}

Here is the caller graph for this function:

void query_state::QueryState::logCallStack

(

std::stringstream &

ss

)

Definition at line 108 of file QueryState.cpp.

References events_, events_mutex_, and logCallStack().

                                                 {
  std::lock_guard<std::mutex> lock(events_mutex_);
  logCallStack(ss, 1, events_.end());
}

Here is the call graph for this function:

void query_state::QueryState::setLogged ( bool  logged )

inline

Definition at line 167 of file QueryState.h.

References logged_.

{ logged_.store(logged); }

void query_state::QueryState::setQuerySubmittedTime ( const std::chrono::time_point< std::chrono::system_clock >  t )

inline

Definition at line 159 of file QueryState.h.

References submitted_, and generate_TableFunctionsFactory_init::t.

                                                          {
    submitted_ = t;
  }

Friends And Related Function Documentation

friend class QueryStates

friend

Definition at line 168 of file QueryState.h.

Member Data Documentation

Events query_state::QueryState::events_

private

Definition at line 129 of file QueryState.h.

Referenced by createQueryStateProxy(), createTimer(), emptyLog(), and logCallStack().

std::mutex query_state::QueryState::events_mutex_

mutableprivate

Definition at line 130 of file QueryState.h.

Referenced by createTimer(), and logCallStack().

Id const query_state::QueryState::id_

private

Definition at line 126 of file QueryState.h.

Referenced by getId().

std::atomic<bool> query_state::QueryState::logged_

private

Definition at line 131 of file QueryState.h.

Referenced by isLogged(), and setLogged().

std::string const query_state::QueryState::query_str_

private

Definition at line 128 of file QueryState.h.

Referenced by emptyLog(), and getQueryStr().

std::atomic< query_state::Id > query_state::QueryState::s_next_id {0}

staticprivate

Definition at line 125 of file QueryState.h.

boost::optional<SessionData> query_state::QueryState::session_data_

private

Definition at line 127 of file QueryState.h.

Referenced by getConstSessionInfo(), and getSessionData().

std::chrono::time_point<std::chrono::system_clock> query_state::QueryState::submitted_

private

Definition at line 132 of file QueryState.h.

Referenced by getQuerySubmittedTime(), and setQuerySubmittedTime().

---

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