From 153cefeedc4a9859848f0cdedf8349454fb66468 Mon Sep 17 00:00:00 2001
From: Ganlin Zhao <ganlinzhao@hotmail.com>
Date: Tue, 2 Nov 2021 14:25:30 +0800
Subject: [PATCH] [TD-6452]<feature>: taoskeeper added
 io_read_disk/io_write_disk

---
 src/plugins/monitor/src/monMain.c | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/src/plugins/monitor/src/monMain.c b/src/plugins/monitor/src/monMain.c
index bf56f6b222..dc4d0dd5fa 100644
--- a/src/plugins/monitor/src/monMain.c
+++ b/src/plugins/monitor/src/monMain.c
@@ -826,6 +826,17 @@ static int32_t monBuildDnodeUptimeSql(char *sql) {
   return sprintf(sql, ", %" PRId64, dnodeUptime);
 }
 
+static int32_t monBuildDnodeIoSql(char *sql) {
+  float rcharKB = 0, wcharKB = 0;
+  float rbyteKB = 0, wbyteKB = 0;
+  rcharKB = tsMonStat.io_read;
+  wcharKB = tsMonStat.io_write;
+  rbyteKB = tsMonStat.io_read_disk;
+  wbyteKB = tsMonStat.io_write_disk;
+
+  return sprintf(sql, ", %f, %f, %f, %f", rcharKB, wcharKB, rbyteKB, wbyteKB);
+}
+
 static int32_t monBuildNetworkIOSql(char *sql) {
   float netInKb = 0, netOutKb = 0;
   bool  suc = taosGetNetworkIO(&netInKb, &netOutKb);
@@ -982,7 +993,7 @@ static void monSaveDnodesInfo() {
   pos += monBuildMemorySql(sql + pos);
   pos += monBuildDnodeDiskSql(sql + pos);
   pos += monBuildNetworkIOSql(sql + pos);
-  pos += monBuildIoSql(sql + pos);
+  pos += monBuildDnodeIoSql(sql + pos);
   pos += monBuildDnodeReqSql(sql + pos);
   pos += monBuildDnodeErrorsSql(sql + pos);
   pos += monBuildDnodeVnodesSql(sql + pos);
-- 
GitLab