minor changes
This commit is contained in:
parent
4049155736
commit
35f16b2041
|
@ -28,8 +28,6 @@ typedef struct {
|
||||||
} SBnodeLoad;
|
} SBnodeLoad;
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
int32_t dnodeId;
|
|
||||||
int64_t clusterId;
|
|
||||||
SMgmtWrapper *pWrapper;
|
SMgmtWrapper *pWrapper;
|
||||||
SendReqFp sendReqFp;
|
SendReqFp sendReqFp;
|
||||||
SendMnodeReqFp sendMnodeReqFp;
|
SendMnodeReqFp sendMnodeReqFp;
|
||||||
|
|
|
@ -36,8 +36,6 @@ typedef struct {
|
||||||
} SQnodeLoad;
|
} SQnodeLoad;
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
int32_t dnodeId;
|
|
||||||
int64_t clusterId;
|
|
||||||
SMgmtWrapper *pWrapper;
|
SMgmtWrapper *pWrapper;
|
||||||
SendReqFp sendReqFp;
|
SendReqFp sendReqFp;
|
||||||
SendMnodeReqFp sendMnodeReqFp;
|
SendMnodeReqFp sendMnodeReqFp;
|
||||||
|
|
|
@ -32,8 +32,6 @@ typedef struct {
|
||||||
} SSnodeLoad;
|
} SSnodeLoad;
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
int32_t dnodeId;
|
|
||||||
int64_t clusterId;
|
|
||||||
SMgmtWrapper *pWrapper;
|
SMgmtWrapper *pWrapper;
|
||||||
SendReqFp sendReqFp;
|
SendReqFp sendReqFp;
|
||||||
SendMnodeReqFp sendMnodeReqFp;
|
SendMnodeReqFp sendMnodeReqFp;
|
||||||
|
|
|
@ -24,8 +24,6 @@ static void bmInitOption(SBnodeMgmt *pMgmt, SBnodeOpt *pOption) {
|
||||||
pOption->sendReqFp = dndSendReqToDnode;
|
pOption->sendReqFp = dndSendReqToDnode;
|
||||||
pOption->sendMnodeReqFp = dndSendReqToMnode;
|
pOption->sendMnodeReqFp = dndSendReqToMnode;
|
||||||
pOption->sendRspFp = dndSendRsp;
|
pOption->sendRspFp = dndSendRsp;
|
||||||
pOption->dnodeId = pDnode->dnodeId;
|
|
||||||
pOption->clusterId = pDnode->clusterId;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static int32_t bmOpenImp(SBnodeMgmt *pMgmt) {
|
static int32_t bmOpenImp(SBnodeMgmt *pMgmt) {
|
||||||
|
|
|
@ -24,8 +24,6 @@ static void qmInitOption(SQnodeMgmt *pMgmt, SQnodeOpt *pOption) {
|
||||||
pOption->sendReqFp = dndSendReqToDnode;
|
pOption->sendReqFp = dndSendReqToDnode;
|
||||||
pOption->sendMnodeReqFp = dndSendReqToMnode;
|
pOption->sendMnodeReqFp = dndSendReqToMnode;
|
||||||
pOption->sendRspFp = dndSendRsp;
|
pOption->sendRspFp = dndSendRsp;
|
||||||
pOption->dnodeId = pDnode->dnodeId;
|
|
||||||
pOption->clusterId = pDnode->clusterId;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static int32_t qmOpenImp(SQnodeMgmt *pMgmt) {
|
static int32_t qmOpenImp(SQnodeMgmt *pMgmt) {
|
||||||
|
|
|
@ -24,8 +24,6 @@ static void smInitOption(SSnodeMgmt *pMgmt, SSnodeOpt *pOption) {
|
||||||
pOption->sendReqFp = dndSendReqToDnode;
|
pOption->sendReqFp = dndSendReqToDnode;
|
||||||
pOption->sendMnodeReqFp = dndSendReqToMnode;
|
pOption->sendMnodeReqFp = dndSendReqToMnode;
|
||||||
pOption->sendRspFp = dndSendRsp;
|
pOption->sendRspFp = dndSendRsp;
|
||||||
pOption->dnodeId = pDnode->dnodeId;
|
|
||||||
pOption->clusterId = pDnode->clusterId;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static int32_t smOpenImp(SSnodeMgmt *pMgmt) {
|
static int32_t smOpenImp(SSnodeMgmt *pMgmt) {
|
||||||
|
|
Loading…
Reference in New Issue