greenplumn ITask 源码
greenplumn ITask 代码
文件路径：/src/backend/gporca/libgpos/include/gpos/task/ITask.h
//---------------------------------------------------------------------------
// Greenplum Database
// Copyright (C) 2008 - 2010 Greenplum, Inc.
//
// @filename:
// ITask.h
//
// @doc:
// Interface class for task abstraction
//---------------------------------------------------------------------------
#ifndef GPOS_ITask_H
#define GPOS_ITask_H
#include "gpos/task/IWorker.h"
#include "gpos/task/traceflags.h"
#include "gpos/types.h"
// trace flag macro definitions
#define GPOS_FTRACE(x) ITask::Self()->IsTraceSet(x)
#define GPOS_SET_TRACE(x) (void) ITask::Self()->SetTrace(x, true /*value*/)
#define GPOS_UNSET_TRACE(x) (void) ITask::Self()->SetTrace(x, false /*value*/)
namespace gpos
{
// forward declarations
class ILogger;
class CMemoryPool;
class CTaskContext;
class CTaskLocalStorage;
class IErrorContext;
class ITask
{
private:
public:
ITask(const ITask &) = delete;
// task status
enum ETaskStatus
{
EtsInit, // task initialized but not scheduled
EtsQueued, // task added to scheduler's queue
EtsDequeued, // task removed from scheduler's queue, ready to run
EtsRunning, // task currently executing
EtsCompleted, // task completed executing with no error
EtsError // exception encountered while task was executed
};
// ctor
ITask() = default;
// dtor
virtual ~ITask() = default;
// accessor for memory pool, e.g. used for allocating task parameters in
virtual CMemoryPool *Pmp() const = 0;
// TLS
virtual CTaskLocalStorage &GetTls() = 0;
// task context accessor
virtual CTaskContext *GetTaskCtxt() const = 0;
// basic output streams
virtual ILogger *GetOutputLogger() const = 0;
virtual ILogger *GetErrorLogger() const = 0;
// manipulate traceflags
virtual BOOL SetTrace(ULONG, BOOL) = 0;
virtual BOOL IsTraceSet(ULONG) = 0;
// current locale
virtual ELocale Locale() const = 0;
// error context
virtual IErrorContext *GetErrCtxt() const = 0;
// any pending exceptions?
virtual BOOL HasPendingExceptions() const = 0;
static ITask *Self();
}; // class ITask
} // namespace gpos
#endif // !GPOS_ITask_H
// EOF
相关信息
相关文章
greenplumn CAutoSuspendAbort 源码
greenplumn CTaskLocalStorage 源码
greenplumn CTaskLocalStorageObject 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦