This commit is contained in:
Shengliang Guan 2022-03-15 14:50:04 +08:00
parent 2a5e231fd2
commit 06dbe69f87
16 changed files with 20 additions and 24 deletions

View File

@ -15,7 +15,7 @@
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "bmInt.h" #include "bmInt.h"
#include "bmHandle.h" #include "bmMsg.h"
bool bmRequireNode(SMgmtWrapper *pWrapper) { return false; } bool bmRequireNode(SMgmtWrapper *pWrapper) { return false; }

View File

@ -14,7 +14,7 @@
*/ */
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "bmHandle.h" #include "bmMsg.h"
#include "bmWorker.h" #include "bmWorker.h"
int32_t bmProcessCreateReq(SDnode *pDnode, SRpcMsg *pRpcMsg) {return 0;} int32_t bmProcessCreateReq(SDnode *pDnode, SRpcMsg *pRpcMsg) {return 0;}

View File

@ -22,30 +22,26 @@
extern "C" { extern "C" {
#endif #endif
typedef struct SMnodeMgmt { typedef struct SMnodeMgmt {
int32_t refCount; int32_t refCount;
int8_t deployed; int8_t deployed;
int8_t dropped; int8_t dropped;
int8_t replica;
int8_t selfIndex;
SReplica replicas[TSDB_MAX_REPLICA];
SMnode *pMnode; SMnode *pMnode;
SProcObj *pProcess;
bool singleProc;
SRWLatch latch; SRWLatch latch;
SDnodeWorker readWorker; SDnodeWorker readWorker;
SDnodeWorker writeWorker; SDnodeWorker writeWorker;
SDnodeWorker syncWorker; SDnodeWorker syncWorker;
int8_t replica;
int8_t selfIndex;
SReplica replicas[TSDB_MAX_REPLICA];
//
SProcObj *pProcess;
bool singleProc;
} SMnodeMgmt; } SMnodeMgmt;
// mmInt.h
// interface
void mmGetMgmtFp(SMgmtWrapper *pMgmt); void mmGetMgmtFp(SMgmtWrapper *pMgmt);
// mmMgmt.h
int32_t mmInit(SDnode *pDnode); int32_t mmInit(SDnode *pDnode);
void mmCleanup(SDnode *pDnode); void mmCleanup(SDnode *pDnode);

View File

@ -13,8 +13,8 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>. * along with this program. If not, see <http://www.gnu.org/licenses/>.
*/ */
#ifndef _TD_DND_MNODE_HANDLE_H_ #ifndef _TD_DND_MNODE_MSG_H_
#define _TD_DND_MNODE_HANDLE_H_ #define _TD_DND_MNODE_MSG_H_
#include "mmInt.h" #include "mmInt.h"
@ -36,4 +36,4 @@ int32_t mmGetMonitorInfo(SDnode *pDnode, SMonClusterInfo *pClusterInfo, SMonVgro
} }
#endif #endif
#endif /*_TD_DND_MNODE_HANDLE_H_*/ #endif /*_TD_DND_MNODE_MSG_H_*/

View File

@ -15,7 +15,7 @@
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "mmInt.h" #include "mmInt.h"
#include "mmHandle.h" #include "mmMsg.h"
bool mmRequireNode(SMgmtWrapper *pWrapper) { return false; } bool mmRequireNode(SMgmtWrapper *pWrapper) { return false; }

View File

@ -14,7 +14,7 @@
*/ */
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "mmHandle.h" #include "mmMsg.h"
#include "mmWorker.h" #include "mmWorker.h"
#if 0 #if 0

View File

@ -15,7 +15,7 @@
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "qmInt.h" #include "qmInt.h"
#include "qmHandle.h" #include "qmMsg.h"
bool qmRequireNode(SMgmtWrapper *pWrapper) { return false; } bool qmRequireNode(SMgmtWrapper *pWrapper) { return false; }

View File

@ -14,7 +14,7 @@
*/ */
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "qmHandle.h" #include "qmMsg.h"
#include "qmWorker.h" #include "qmWorker.h"
int32_t qmProcessCreateReq(SDnode *pDnode, SRpcMsg *pRpcMsg) {return 0;} int32_t qmProcessCreateReq(SDnode *pDnode, SRpcMsg *pRpcMsg) {return 0;}

View File

@ -15,7 +15,7 @@
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "smInt.h" #include "smInt.h"
#include "smHandle.h" #include "smMsg.h"
bool smRequireNode(SMgmtWrapper *pWrapper) { return false; } bool smRequireNode(SMgmtWrapper *pWrapper) { return false; }

View File

@ -14,7 +14,7 @@
*/ */
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "smHandle.h" #include "smMsg.h"
#include "smWorker.h" #include "smWorker.h"
int32_t smProcessCreateReq(SDnode *pDnode, SRpcMsg *pRpcMsg) {return 0;} int32_t smProcessCreateReq(SDnode *pDnode, SRpcMsg *pRpcMsg) {return 0;}

View File

@ -15,7 +15,7 @@
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "vmInt.h" #include "vmInt.h"
#include "vmHandle.h" #include "vmMsg.h"
#include "vmMgmt.h" #include "vmMgmt.h"
static int32_t vmInit(SMgmtWrapper *pWrapper) { static int32_t vmInit(SMgmtWrapper *pWrapper) {

View File

@ -14,7 +14,7 @@
*/ */
#define _DEFAULT_SOURCE #define _DEFAULT_SOURCE
#include "vmHandle.h" #include "vmMsg.h"
#include "vmWorker.h" #include "vmWorker.h"