mmInt.h 2.5 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/*
 * 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/>.
 */

S
shm  
Shengliang Guan 已提交
16 17
#ifndef _TD_DND_MNODE_INT_H_
#define _TD_DND_MNODE_INT_H_
18

S
Shengliang 已提交
19
#include "dmUtil.h"
S
shm  
Shengliang Guan 已提交
20
#include "mnode.h"
S
shm  
Shengliang Guan 已提交
21

22 23 24 25
#ifdef __cplusplus
extern "C" {
#endif

S
shm  
Shengliang Guan 已提交
26
typedef struct SMnodeMgmt {
S
shm  
Shengliang Guan 已提交
27
  SMnode       *pMnode;
S
Shengliang 已提交
28
  SMsgCb        msgCb;
S
shm  
Shengliang Guan 已提交
29
  const char   *path;
S
Shengliang 已提交
30 31
  const char   *name;
  int32_t       dnodeId;
D
dapan1121 已提交
32
  SSingleWorker queryWorker;
S
Shengliang Guan 已提交
33 34 35
  SSingleWorker readWorker;
  SSingleWorker writeWorker;
  SSingleWorker syncWorker;
36
  SSingleWorker monitorWorker;
S
shm  
Shengliang Guan 已提交
37 38 39
  SReplica      replicas[TSDB_MAX_REPLICA];
  int8_t        replica;
  int8_t        selfIndex;
S
shm  
Shengliang Guan 已提交
40 41
} SMnodeMgmt;

S
shm  
Shengliang Guan 已提交
42
// mmFile.c
S
shm  
Shengliang Guan 已提交
43
int32_t mmReadFile(SMnodeMgmt *pMgmt, bool *pDeployed);
S
Shengliang 已提交
44
int32_t mmWriteFile(SMnodeMgmt *pMgmt, SDCreateMnodeReq *pReq, bool deployed);
S
shm  
Shengliang Guan 已提交
45

S
shm  
Shengliang Guan 已提交
46
// mmInt.c
S
shm  
Shengliang Guan 已提交
47
int32_t mmAlter(SMnodeMgmt *pMgmt, SDAlterMnodeReq *pReq);
S
shm  
Shengliang Guan 已提交
48

S
Shengliang Guan 已提交
49
// mmHandle.c
S
Shengliang 已提交
50 51 52
SArray *mmGetMsgHandles();
int32_t mmProcessCreateReq(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
int32_t mmProcessDropReq(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
S
shm  
Shengliang Guan 已提交
53
int32_t mmProcessAlterReq(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
S
Shengliang 已提交
54 55
int32_t mmProcessGetMonitorInfoReq(SMnodeMgmt *pMgmt, SNodeMsg *pReq);
int32_t mmProcessGetLoadsReq(SMnodeMgmt *pMgmt, SNodeMsg *pReq);
S
shm  
Shengliang Guan 已提交
56 57 58 59

// mmWorker.c
int32_t mmStartWorker(SMnodeMgmt *pMgmt);
void    mmStopWorker(SMnodeMgmt *pMgmt);
S
Shengliang 已提交
60 61 62 63 64 65 66 67 68
int32_t mmPutNodeMsgToWriteQueue(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
int32_t mmPutNodeMsgToSyncQueue(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
int32_t mmPutNodeMsgToReadQueue(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
int32_t mmPutNodeMsgToQueryQueue(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
int32_t mmPutNodeMsgToMonitorQueue(SMnodeMgmt *pMgmt, SNodeMsg *pMsg);
int32_t mmPutRpcMsgToQueryQueue(SMnodeMgmt *pMgmt, SRpcMsg *pRpc);
int32_t mmPutRpcMsgToReadQueue(SMnodeMgmt *pMgmt, SRpcMsg *pRpc);
int32_t mmPutRpcMsgToWriteQueue(SMnodeMgmt *pMgmt, SRpcMsg *pRpc);
int32_t mmPutRpcMsgToSyncQueue(SMnodeMgmt *pMgmt, SRpcMsg *pRpc);
S
shm  
Shengliang Guan 已提交
69

70 71 72 73
#ifdef __cplusplus
}
#endif

D
dapan1121 已提交
74
#endif /*_TD_DND_MNODE_INT_H_*/