/* * 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 TDENGINE_DNODESYSTEM_H #define TDENGINE_DNODESYSTEM_H #ifdef __cplusplus extern "C" { #endif #include #define tsetModuleStatus(mod) \ { tsModuleStatus |= (1 << mod); } #define tclearModuleStatus(mod) \ { tsModuleStatus &= ~(1 << mod); } enum _module { TSDB_MOD_MGMT, TSDB_MOD_HTTP, TSDB_MOD_MONITOR, TSDB_MOD_MAX }; typedef struct { char *name; int (*initFp)(); void (*cleanUpFp)(); int (*startFp)(); void (*stopFp)(); int num; int curNum; int equalVnodeNum; } SModule; extern uint32_t tsModuleStatus; extern SModule tsModule[]; extern pthread_mutex_t dmutex; void dnodeCleanUpSystem(); int dnodeInitSystem(); int dnodeInitSystemSpec(); void dnodeStartModuleSpec(); void dnodeParseParameterK(); void dnodeProcessModuleStatus(uint32_t status); void dnodeResetSystem(); void dnodeCheckDbRunning(const char* dir); void vnodeCleanUpSystem(); int vnodeInitSystem(); void vnodeInitMgmtIp(); void vnodeInitQHandle(); int mgmtInitSystem(); void mgmtCleanUpSystem(); int mgmtStartSystem(); void mgmtStopSystem(); int taosCreateTierDirectory(); void taosCleanupTier(); #ifdef __cplusplus } #endif #endif