Executor::CgenStateManager Class Reference

#include <Execute.h>

Collaboration diagram for Executor::CgenStateManager:

Public Member Functions
	CgenStateManager (Executor &executor)
	CgenStateManager (Executor &executor, const bool allow_lazy_fetch, const std::vector< InputTableInfo > &query_infos, const PlanState::DeletedColumnsMap &deleted_cols_map, const RelAlgExecutionUnit *ra_exe_unit)
	~CgenStateManager ()

Private Attributes
Executor &	executor_
std::chrono::steady_clock::time_point	lock_queue_clock_
std::lock_guard< std::mutex >	lock_
std::unique_ptr< CgenState >	cgen_state_

Detailed Description

Definition at line 1484 of file Execute.h.

Constructor & Destructor Documentation

Executor::CgenStateManager::CgenStateManager

(

Executor &

executor

)

Definition at line 438 of file Execute.cpp.

References executor_, lock_queue_clock_, and timer_stop().

    : executor_(executor)
    , lock_queue_clock_(timer_start())
    , lock_(executor_.compilation_mutex_)
    , cgen_state_(std::move(executor_.cgen_state_))  // store old CgenState instance
{
  executor_.compilation_queue_time_ms_ += timer_stop(lock_queue_clock_);
  executor_.cgen_state_.reset(new CgenState(0, false, &executor));
}

Here is the call graph for this function:

Executor::CgenStateManager::CgenStateManager	(	Executor &	executor,
		const bool	allow_lazy_fetch,
		const std::vector< InputTableInfo > &	query_infos,
		const PlanState::DeletedColumnsMap &	deleted_cols_map,
		const RelAlgExecutionUnit *	ra_exe_unit
	)

Definition at line 448 of file Execute.cpp.

References executor_, lock_queue_clock_, and timer_stop().

    : executor_(executor)
    , lock_queue_clock_(timer_start())
    , lock_(executor_.compilation_mutex_)
    , cgen_state_(std::move(executor_.cgen_state_))  // store old CgenState instance
{
  executor_.compilation_queue_time_ms_ += timer_stop(lock_queue_clock_);
  // nukeOldState creates new CgenState and PlanState instances for
  // the subsequent code generation.  It also resets
  // kernel_queue_time_ms_ and compilation_queue_time_ms_ that we do
  // not currently restore.. should we accumulate these timings?
  executor_.nukeOldState(allow_lazy_fetch, query_infos, deleted_cols_map, ra_exe_unit);
}

Here is the call graph for this function:

Executor::CgenStateManager::~CgenStateManager

(

)

Definition at line 467 of file Execute.cpp.

References Executor::cgen_state_, and executor_().

                                            {
  // prevent memory leak from hoisted literals
  for (auto& p : executor_.cgen_state_->row_func_hoisted_literals_) {
    auto inst = llvm::dyn_cast<llvm::LoadInst>(p.first);
    if (inst && inst->getNumUses() == 0 && inst->getParent() == nullptr) {
      // The llvm::Value instance stored in p.first is created by the
      // CodeGenerator::codegenHoistedConstantsPlaceholders method.
      p.first->deleteValue();
    }
  }
  executor_.cgen_state_->row_func_hoisted_literals_.clear();

  // move generated StringDictionaryTranslationMgrs and InValueBitmaps
  // to the old CgenState instance as the execution of the generated
  // code uses these bitmaps

  for (auto& bm : executor_.cgen_state_->in_values_bitmaps_) {
    cgen_state_->moveInValuesBitmap(bm);
  }
  executor_.cgen_state_->in_values_bitmaps_.clear();

  for (auto& str_dict_translation_mgr :
       executor_.cgen_state_->str_dict_translation_mgrs_) {
    cgen_state_->moveStringDictionaryTranslationMgr(std::move(str_dict_translation_mgr));
  }
  executor_.cgen_state_->str_dict_translation_mgrs_.clear();

  for (auto& tree_model_prediction_mgr :
       executor_.cgen_state_->tree_model_prediction_mgrs_) {
    cgen_state_->moveTreeModelPredictionMgr(std::move(tree_model_prediction_mgr));
  }
  executor_.cgen_state_->tree_model_prediction_mgrs_.clear();

  // Delete worker module that may have been set by
  // set_module_shallow_copy. If QueryMustRunOnCpu is thrown, the
  // worker module is not instantiated, so the worker module needs to
  // be deleted conditionally [see "Managing LLVM modules" comment in
  // CgenState.h]:
  if (executor_.cgen_state_->module_) {
    delete executor_.cgen_state_->module_;
  }

  // restore the old CgenState instance
  executor_.cgen_state_.reset(cgen_state_.release());
}

Here is the call graph for this function:

Member Data Documentation

std::unique_ptr<CgenState> Executor::CgenStateManager::cgen_state_

private

Definition at line 1498 of file Execute.h.

Executor& Executor::CgenStateManager::executor_

private

Definition at line 1495 of file Execute.h.

Referenced by CgenStateManager().

std::lock_guard<std::mutex> Executor::CgenStateManager::lock_

private

Definition at line 1497 of file Execute.h.

std::chrono::steady_clock::time_point Executor::CgenStateManager::lock_queue_clock_

private

Definition at line 1496 of file Execute.h.

Referenced by CgenStateManager().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/Execute.h
• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/Execute.cpp