Merge pull request #393 from askuy/feature/optimizecontextcancel

EnableConnTcpMetric
gotomicro · Jun 7, 2024 · 87aa236 · 87aa236
2 parents 5f8e627 + 3951fc2
commit 87aa236
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/core/emetric/tcpstat.go b/core/emetric/tcpstat.go
@@ -68,13 +68,13 @@ func NewTCPStatCollector() (*TcpStatCollector, error) {
 
 func (c *TcpStatCollector) Update() error {
 	go func() {
-		statsFile := path.Join("/proc", strconv.Itoa(os.Getpid()), "net", "tcp")
-		tcpStats, err := getTCPStats(statsFile)
-		if err != nil {
-			elog.EgoLogger.Error(fmt.Errorf("couldn't get tcpstats: %w", err).Error())
-			return
-		}
 		for {
+			statsFile := path.Join("/proc", strconv.Itoa(os.Getpid()), "net", "tcp")
+			tcpStats, err := getTCPStats(statsFile)
+			if err != nil {
+				elog.EgoLogger.Error(fmt.Errorf("couldn't get tcpstats: %w", err).Error())
+				return
+			}
 			for index, value := range tcpStats {
 				for addr, number := range value {
 					ClientStatsGauge.WithLabelValues(
@@ -83,8 +83,8 @@ func (c *TcpStatCollector) Update() error {
 						index.String(),
 					).Set(number)
 				}
-				time.Sleep(5 * time.Second)
 			}
+			time.Sleep(5 * time.Second)
 		}
 	}()