/* * Copyright (c) 2019 TAOS Data, Inc. * * This program is free software: you can use, redistribute, and/or modify * it under the terms of the GNU Affero General Public License, version 3 * or later ("AGPL"), as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ #ifndef _TD_DND_INT_H_ #define _TD_DND_INT_H_ #ifdef __cplusplus extern "C" { #endif #include "os.h" #include "cJSON.h" #include "tcache.h" #include "tcrc32c.h" #include "tep.h" #include "thash.h" #include "tlockfree.h" #include "tlog.h" #include "tmsg.h" #include "tqueue.h" #include "trpc.h" #include "tthread.h" #include "ttime.h" #include "tworker.h" #include "dnode.h" #include "bnode.h" #include "mnode.h" #include "qnode.h" #include "snode.h" #include "vnode.h" extern int32_t dDebugFlag; #define dFatal(...) { if (dDebugFlag & DEBUG_FATAL) { taosPrintLog("DND FATAL ", 255, __VA_ARGS__); }} #define dError(...) { if (dDebugFlag & DEBUG_ERROR) { taosPrintLog("DND ERROR ", 255, __VA_ARGS__); }} #define dWarn(...) { if (dDebugFlag & DEBUG_WARN) { taosPrintLog("DND WARN ", 255, __VA_ARGS__); }} #define dInfo(...) { if (dDebugFlag & DEBUG_INFO) { taosPrintLog("DND ", 255, __VA_ARGS__); }} #define dDebug(...) { if (dDebugFlag & DEBUG_DEBUG) { taosPrintLog("DND ", dDebugFlag, __VA_ARGS__); }} #define dTrace(...) { if (dDebugFlag & DEBUG_TRACE) { taosPrintLog("DND ", dDebugFlag, __VA_ARGS__); }} typedef enum { DND_STAT_INIT, DND_STAT_RUNNING, DND_STAT_STOPPED } EStat; typedef enum { DND_WORKER_SINGLE, DND_WORKER_MULTI } EWorkerType; typedef void (*DndMsgFp)(SDnode *pDnode, SRpcMsg *pMsg, SEpSet *pEps); typedef struct { EWorkerType type; const char *name; int32_t minNum; int32_t maxNum; void *queueFp; SDnode *pDnode; STaosQueue *queue; union { SWorkerPool pool; SMWorkerPool mpool; }; } SDnodeWorker; typedef struct { char *dnode; char *mnode; char *snode; char *bnode; char *vnodes; } SDnodeDir; typedef struct { int32_t dnodeId; int32_t dropped; int64_t clusterId; int64_t dver; int64_t rebootTime; int64_t updateTime; int8_t statusSent; SEpSet mnodeEpSet; char *file; SHashObj *dnodeHash; SDnodeEps *dnodeEps; pthread_t *threadId; SRWLatch latch; SDnodeWorker mgmtWorker; SDnodeWorker statusWorker; } SDnodeMgmt; typedef struct { int32_t refCount; int8_t deployed; int8_t dropped; SMnode *pMnode; SRWLatch latch; SDnodeWorker readWorker; SDnodeWorker writeWorker; SDnodeWorker syncWorker; int8_t replica; int8_t selfIndex; SReplica replicas[TSDB_MAX_REPLICA]; } SMnodeMgmt; typedef struct { int32_t refCount; int8_t deployed; int8_t dropped; SQnode *pQnode; SRWLatch latch; SDnodeWorker queryWorker; SDnodeWorker fetchWorker; } SQnodeMgmt; typedef struct { int32_t refCount; int8_t deployed; int8_t dropped; SSnode *pSnode; SRWLatch latch; SDnodeWorker writeWorker; } SSnodeMgmt; typedef struct { int32_t refCount; int8_t deployed; int8_t dropped; SBnode *pBnode; SRWLatch latch; SDnodeWorker writeWorker; } SBnodeMgmt; typedef struct { SHashObj *hash; int32_t openVnodes; int32_t totalVnodes; SRWLatch latch; SWorkerPool queryPool; SWorkerPool fetchPool; SMWorkerPool syncPool; SMWorkerPool writePool; } SVnodesMgmt; typedef struct { void *serverRpc; void *clientRpc; DndMsgFp msgFp[TDMT_MAX]; } STransMgmt; typedef struct SDnode { EStat stat; SDnodeOpt opt; SDnodeDir dir; FileFd lockFd; SDnodeMgmt dmgmt; SMnodeMgmt mmgmt; SQnodeMgmt qmgmt; SSnodeMgmt smgmt; SBnodeMgmt bmgmt; SVnodesMgmt vmgmt; STransMgmt tmgmt; SStartupReq startup; } SDnode; EStat dndGetStat(SDnode *pDnode); void dndSetStat(SDnode *pDnode, EStat stat); char *dndStatStr(EStat stat); void dndReportStartup(SDnode *pDnode, char *pName, char *pDesc); void dndGetStartup(SDnode *pDnode, SStartupReq *pStartup); #ifdef __cplusplus } #endif #endif /*_TD_DND_INT_H_*/