Skip to content

Commit 2662dea

Browse files
committed
Update.
1 parent f689e77 commit 2662dea

File tree

1 file changed

+14
-6
lines changed

1 file changed

+14
-6
lines changed

service/singleton/singleton.go

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1326,10 +1326,14 @@ func SaveAllTrafficToBadgerDB() {
13261326
dbServer.CumulativeNetInTransfer = server.CumulativeNetInTransfer
13271327
dbServer.CumulativeNetOutTransfer = server.CumulativeNetOutTransfer
13281328

1329-
// 保存回数据库
1330-
if err := serverOps.SaveServer(dbServer); err != nil {
1331-
log.Printf("保存服务器 %s (ID:%d) 累计流量失败: %v", server.Name, serverID, err)
1329+
// 保存回数据库并记录耗时
1330+
start := time.Now()
1331+
err = serverOps.SaveServer(dbServer)
1332+
elapsed := time.Since(start)
1333+
if err != nil {
1334+
log.Printf("保存服务器 %s (ID:%d) 累计流量失败: %v (耗时: %v)", server.Name, serverID, err, elapsed)
13321335
} else {
1336+
log.Printf("保存服务器 %s (ID:%d) 累计流量成功 (耗时: %v)", server.Name, serverID, elapsed)
13331337
atomic.AddInt32(&successCount, 1)
13341338
}
13351339

@@ -1356,10 +1360,14 @@ func SaveAllTrafficToBadgerDB() {
13561360
dbServer.CumulativeNetInTransfer = server.CumulativeNetInTransfer
13571361
dbServer.CumulativeNetOutTransfer = server.CumulativeNetOutTransfer
13581362

1359-
// 保存回数据库
1360-
if err := serverOps.SaveServer(dbServer); err != nil {
1361-
log.Printf("保存服务器 %s (ID:%d) 累计流量失败: %v", server.Name, serverID, err)
1363+
// 保存回数据库并记录耗时
1364+
start := time.Now()
1365+
err = serverOps.SaveServer(dbServer)
1366+
elapsed := time.Since(start)
1367+
if err != nil {
1368+
log.Printf("保存服务器 %s (ID:%d) 累计流量失败: %v (耗时: %v)", server.Name, serverID, err, elapsed)
13621369
} else {
1370+
log.Printf("保存服务器 %s (ID:%d) 累计流量成功 (耗时: %v)", server.Name, serverID, elapsed)
13631371
atomic.AddInt32(&successCount, 1)
13641372
}
13651373

0 commit comments

Comments
 (0)