dnode.h 1.6 KB
Newer Older
S
#1177  
slguan 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * 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 <http://www.gnu.org/licenses/>.
 */

#ifndef TDENGINE_DNODE_H
#define TDENGINE_DNODE_H

#ifdef __cplusplus
extern "C" {
#endif

#include <stdint.h>
#include <pthread.h>
S
slguan 已提交
25 26

typedef struct {
S
slguan 已提交
27 28
  int32_t queryReqNum;
  int32_t submitReqNum;
S
slguan 已提交
29 30
  int32_t httpReqNum;
} SDnodeStatisInfo;
S
#1177  
slguan 已提交
31

S
#1177  
slguan 已提交
32 33 34 35 36 37 38 39 40
typedef struct {
  char  id[20];
  char  sid;
  void *thandle;
  int   mgmtIndex;
  char  status;  // 0:offline, 1:online
} SMgmtObj;

// global variables
S
slguan 已提交
41
extern uint32_t tsRebootTime;
S
#1177  
slguan 已提交
42 43 44 45 46

// dnodeCluster
extern void (*dnodeStartModules)();
extern void (*dnodeParseParameterK)();
extern int32_t (*dnodeCheckSystem)();
S
#1177  
slguan 已提交
47

S
#1177  
slguan 已提交
48

S
slguan 已提交
49 50 51 52 53
// dnodeSystem
extern void *tsDnodeMgmtQhandle;

void dnodeProcessMsgFromMgmt(char msgType, void *pCont, int contLen, void *pConn, int32_t code);

S
dnode  
slguan 已提交
54 55
// dnodeModule
extern void (*dnodeStartModules)();
S
slguan 已提交
56

S
#1177  
slguan 已提交
57 58 59 60
// multilevelStorage
extern int32_t (*dnodeInitStorage)();
extern void (*dnodeCleanupStorage)();

S
slguan 已提交
61
void dnodeCheckDataDirOpenned(const char* dir);
S
slguan 已提交
62

S
slguan 已提交
63 64 65 66
void dnodeLockVnodes();
void dnodeUnLockVnodes();
SDnodeStatisInfo dnodeGetStatisInfo();

S
#1177  
slguan 已提交
67 68 69 70 71
#ifdef __cplusplus
}
#endif

#endif