greenplumn CSchedulerContext 源码
greenplumn CSchedulerContext 代码
文件路径：/src/backend/gporca/libgpopt/include/gpopt/search/CSchedulerContext.h
//---------------------------------------------------------------------------
// Greenplum Database
// Copyright (C) 2008-2011 Greenplum, Inc.
//
// @filename:
// CSchedulerContext.h
//
// @doc:
// Container for objects associated with scheduling context of a job
//---------------------------------------------------------------------------
#ifndef GPOPT_CSchedulerContext_H
#define GPOPT_CSchedulerContext_H
#include "gpos/base.h"
#define GPOPT_SCHED_CTXT_MEM_POOL_SIZE (64 * 1024 * 1024)
namespace gpopt
{
using namespace gpos;
// prototypes
class CJobFactory;
class CScheduler;
class CEngine;
//---------------------------------------------------------------------------
// @class:
// CSchedulerContext
//
// @doc:
// Scheduling context
//
//---------------------------------------------------------------------------
class CSchedulerContext
{
private:
// memory pool used by all workers
CMemoryPool *m_pmpGlobal{nullptr};
// memory pool used by only by current worker (scratch space)
CMemoryPool *m_pmpLocal{nullptr};
// job factory
CJobFactory *m_pjf;
// scheduler
CScheduler *m_psched{nullptr};
// optimization engine
CEngine *m_peng;
// flag indicating if context has been initialized
BOOL m_fInit{false};
BOOL
FInit() const
{
return m_fInit;
}
public:
CSchedulerContext(const CSchedulerContext &) = delete;
// ctor
CSchedulerContext();
// dtor
~CSchedulerContext();
// initialization
void Init(CMemoryPool *pmpGlobal, CJobFactory *pjf, CScheduler *psched,
CEngine *peng);
// global memory pool accessor
CMemoryPool *
GetGlobalMemoryPool() const
{
GPOS_ASSERT(FInit() && "Scheduling context is not initialized");
return m_pmpGlobal;
}
// local memory pool accessor
CMemoryPool *
PmpLocal() const
{
GPOS_ASSERT(FInit() && "Scheduling context is not initialized");
return m_pmpLocal;
}
// job factory accessor
CJobFactory *
Pjf() const
{
GPOS_ASSERT(FInit() && "Scheduling context is not initialized");
return m_pjf;
}
// scheduler accessor
CScheduler *
Psched() const
{
GPOS_ASSERT(FInit() && "Scheduling context is not initialized");
return m_psched;
}
// engine accessor
CEngine *
Peng() const
{
GPOS_ASSERT(FInit() && "Scheduling context is not initialized");
return m_peng;
}
}; // class CSchedulerContext
} // namespace gpopt
#endif // !GPOPT_CSchedulerContext_H
// EOF
相关信息
相关文章
greenplumn CGroupExpression 源码
greenplumn CJobGroupExploration 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
6、 golang
-
8、 openharmony