xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

keep old protocal

This commit is contained in:
dmchen 2024-01-25 01:37:32 +00:00
parent d9af07de6f
commit f6ecd8d204
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
source/dnode/mgmt/node_mgmt/src/dmMonitor.c
View File

@ -19,7 +19,13 @@
#include "audit.h" #include "audit.h"
static void dmGetMonitorBasicInfo(SDnode *pDnode, SMonBasicInfo *pInfo) { static void dmGetMonitorBasicInfo(SDnode *pDnode, SMonBasicInfo *pInfo) {
//pInfo->protocol = 1; pInfo->protocol = 1;
pInfo->dnode_id = pDnode->data.dnodeId;
pInfo->cluster_id = pDnode->data.clusterId;
tstrncpy(pInfo->dnode_ep, tsLocalEp, TSDB_EP_LEN);
}
static void dmGetMonitorBasicInfoBasic(SDnode *pDnode, SMonBasicInfo *pInfo) {
pInfo->protocol = 2; pInfo->protocol = 2;
pInfo->dnode_id = pDnode->data.dnodeId; pInfo->dnode_id = pDnode->data.dnodeId;
pInfo->cluster_id = pDnode->data.clusterId; pInfo->cluster_id = pDnode->data.clusterId;
@ -45,6 +51,12 @@ static void dmGetDmMonitorInfo(SDnode *pDnode) {
monSetDmInfo(&dmInfo); monSetDmInfo(&dmInfo);
} }
static void dmGetDmMonitorInfoBasic(SDnode *pDnode) {
SMonDmInfo dmInfo = {0};
dmGetMonitorBasicInfoBasic(pDnode, &dmInfo.basic);
monSetDmInfo(&dmInfo);
}
static void dmGetMmMonitorInfo(SDnode *pDnode) { static void dmGetMmMonitorInfo(SDnode *pDnode) {
SMgmtWrapper *pWrapper = &pDnode->wrappers[MNODE]; SMgmtWrapper *pWrapper = &pDnode->wrappers[MNODE];
if (dmMarkWrapper(pWrapper) == 0) { if (dmMarkWrapper(pWrapper) == 0) {
@ -115,11 +127,8 @@ void dmSendMonitorReportBasic() {
dTrace("send monitor report to %s:%u", tsMonitorFqdn, tsMonitorPort); dTrace("send monitor report to %s:%u", tsMonitorFqdn, tsMonitorPort);
SDnode *pDnode = dmInstance(); SDnode *pDnode = dmInstance();
dmGetDmMonitorInfo(pDnode); dmGetDmMonitorInfoBasic(pDnode);
dmGetMmMonitorInfo(pDnode); dmGetMmMonitorInfo(pDnode);
//dmGetVmMonitorInfo(pDnode);
//dmGetQmMonitorInfo(pDnode);
//dmGetSmMonitorInfo(pDnode);
monGenAndSendReportBasic(); monGenAndSendReportBasic();
} }