From 88b1f1d1d14a8fe9e3dde2f363a89d821fc0e641 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期四, 26 九月 2024 20:19:49 +0800
Subject: [PATCH] code format
---
cache/cache.go | 25 +++++++++++++++----------
1 files changed, 15 insertions(+), 10 deletions(-)
diff --git a/cache/cache.go b/cache/cache.go
index f0b725c..91dd9df 100644
--- a/cache/cache.go
+++ b/cache/cache.go
@@ -68,8 +68,9 @@
var dbpApi db.DbPersons
total, e := dbpApi.GetPersonTotal("")
- var psApi db.PersonStatus
- accessAreas, _ := psApi.GetPersonAccessedAreas()
+ // 鏆傛椂鍘绘帀鍒拌灏忓尯杩囨护
+ //var psApi db.PersonStatus
+ //accessAreas, _ := psApi.GetPersonAccessedAreas()
logger.Debugf("鎶撴媿妗ｆ搴撳叡鏈�%d鏉¤褰�", total)
if e == nil && total > 0 {
@@ -95,7 +96,7 @@
logger.Error(err)
return
}
- logger.Debugf(" eachNum:%d, 鑾峰彇%d鏉′汉鍛樹俊鎭�", queryEachNum, len(dbPersons))
+ logger.Debugf("eachNum:%d, 鑾峰彇%d鏉′汉鍛樹俊鎭�", queryEachNum, len(dbPersons))
CaptureDbMap.Lock()
areaId := ""
@@ -108,14 +109,14 @@
continue
}
- for _, areaId := range accessAreas[value.Id] {
- if _, ok := CaptureDbMap.Area[areaId]; !ok {
- CaptureDbMap.Area[areaId] = shardmap.New(uint8(*threadnum))
- }
-
- CaptureDbMap.Area[areaId].Set(value.Id, value)
- CaptureDbMap.Area[areaId].Settime()
+ //for _, areaId := range accessAreas[value.Id] {
+ if _, ok := CaptureDbMap.Area[areaId]; !ok {
+ CaptureDbMap.Area[areaId] = shardmap.New(uint8(*threadnum))
}
+
+ CaptureDbMap.Area[areaId].Set(value.Id, value)
+ CaptureDbMap.Area[areaId].Settime()
+ //}
}
CaptureDbMap.Unlock()
@@ -124,6 +125,10 @@
}
wg.Wait()
logger.Debug("鎶撴媿妗ｆ搴撲汉鍛樼紦瀛樺畬鎴愮敤鏃�:", time.Since(temptime))
+
+ for k, v := range CaptureDbMap.Area {
+ logger.Debugf("Cache area %s item len %d ", k, v.GetLen())
+ }
}
}
--
Gitblit v1.8.0