refactor: node mgmt
This commit is contained in:
parent
7dbc1296db
commit
65e8316f35
|
@ -21,7 +21,7 @@ static void bmGetMonitorInfo(SBnodeMgmt *pMgmt, SMonBmInfo *bmInfo) {}
|
||||||
int32_t bmProcessGetMonBmInfoReq(SBnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
int32_t bmProcessGetMonBmInfoReq(SBnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
||||||
SMonBmInfo bmInfo = {0};
|
SMonBmInfo bmInfo = {0};
|
||||||
bmGetMonitorInfo(pMgmt, &bmInfo);
|
bmGetMonitorInfo(pMgmt, &bmInfo);
|
||||||
dmGetSystemInfo(&bmInfo.sys);
|
dmGetMonitorSystemInfo(&bmInfo.sys);
|
||||||
monGetLogs(&bmInfo.log);
|
monGetLogs(&bmInfo.log);
|
||||||
|
|
||||||
int32_t rspLen = tSerializeSMonBmInfo(NULL, 0, &bmInfo);
|
int32_t rspLen = tSerializeSMonBmInfo(NULL, 0, &bmInfo);
|
||||||
|
|
|
@ -23,7 +23,7 @@ static void mmGetMonitorInfo(SMnodeMgmt *pMgmt, SMonMmInfo *mmInfo) {
|
||||||
int32_t mmProcessGetMonitorInfoReq(SMnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
int32_t mmProcessGetMonitorInfoReq(SMnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
||||||
SMonMmInfo mmInfo = {0};
|
SMonMmInfo mmInfo = {0};
|
||||||
mmGetMonitorInfo(pMgmt, &mmInfo);
|
mmGetMonitorInfo(pMgmt, &mmInfo);
|
||||||
dmGetSystemInfo(&mmInfo.sys);
|
dmGetMonitorSystemInfo(&mmInfo.sys);
|
||||||
monGetLogs(&mmInfo.log);
|
monGetLogs(&mmInfo.log);
|
||||||
|
|
||||||
int32_t rspLen = tSerializeSMonMmInfo(NULL, 0, &mmInfo);
|
int32_t rspLen = tSerializeSMonMmInfo(NULL, 0, &mmInfo);
|
||||||
|
|
|
@ -21,7 +21,7 @@ static void qmGetMonitorInfo(SQnodeMgmt *pMgmt, SMonQmInfo *qmInfo) {}
|
||||||
int32_t qmProcessGetMonitorInfoReq(SQnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
int32_t qmProcessGetMonitorInfoReq(SQnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
||||||
SMonQmInfo qmInfo = {0};
|
SMonQmInfo qmInfo = {0};
|
||||||
qmGetMonitorInfo(pMgmt, &qmInfo);
|
qmGetMonitorInfo(pMgmt, &qmInfo);
|
||||||
dmGetSystemInfo(&qmInfo.sys);
|
dmGetMonitorSystemInfo(&qmInfo.sys);
|
||||||
monGetLogs(&qmInfo.log);
|
monGetLogs(&qmInfo.log);
|
||||||
|
|
||||||
int32_t rspLen = tSerializeSMonQmInfo(NULL, 0, &qmInfo);
|
int32_t rspLen = tSerializeSMonQmInfo(NULL, 0, &qmInfo);
|
||||||
|
|
|
@ -21,7 +21,7 @@ static void smGetMonitorInfo(SSnodeMgmt *pMgmt, SMonSmInfo *smInfo) {}
|
||||||
int32_t smProcessGetMonitorInfoReq(SSnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
int32_t smProcessGetMonitorInfoReq(SSnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
||||||
SMonSmInfo smInfo = {0};
|
SMonSmInfo smInfo = {0};
|
||||||
smGetMonitorInfo(pMgmt, &smInfo);
|
smGetMonitorInfo(pMgmt, &smInfo);
|
||||||
dmGetSystemInfo(&smInfo.sys);
|
dmGetMonitorSystemInfo(&smInfo.sys);
|
||||||
monGetLogs(&smInfo.log);
|
monGetLogs(&smInfo.log);
|
||||||
|
|
||||||
int32_t rspLen = tSerializeSMonSmInfo(NULL, 0, &smInfo);
|
int32_t rspLen = tSerializeSMonSmInfo(NULL, 0, &smInfo);
|
||||||
|
|
|
@ -85,7 +85,7 @@ static void vmGetMonitorInfo(SVnodeMgmt *pMgmt, SMonVmInfo *pInfo) {
|
||||||
int32_t vmProcessGetMonitorInfoReq(SVnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
int32_t vmProcessGetMonitorInfoReq(SVnodeMgmt *pMgmt, SNodeMsg *pReq) {
|
||||||
SMonVmInfo vmInfo = {0};
|
SMonVmInfo vmInfo = {0};
|
||||||
vmGetMonitorInfo(pMgmt, &vmInfo);
|
vmGetMonitorInfo(pMgmt, &vmInfo);
|
||||||
dmGetSystemInfo(&vmInfo.sys);
|
dmGetMonitorSystemInfo(&vmInfo.sys);
|
||||||
monGetLogs(&vmInfo.log);
|
monGetLogs(&vmInfo.log);
|
||||||
|
|
||||||
int32_t rspLen = tSerializeSMonVmInfo(NULL, 0, &vmInfo);
|
int32_t rspLen = tSerializeSMonVmInfo(NULL, 0, &vmInfo);
|
||||||
|
|
Loading…
Reference in New Issue