|
@@ -243,10 +243,10 @@ func UpdateServerLoad(ip string, load float64) {
|
|
|
}
|
|
|
|
|
|
//
|
|
|
-func RemoveTimeoutService(timeout int64) {
|
|
|
+func removeTimeoutService(timeout int64) {
|
|
|
txn := mdb.Txn(true)
|
|
|
defer txn.Commit()
|
|
|
- rs, err := txn.Get("servicemeta", "id", "")
|
|
|
+ rs, err := txn.Get("servicemeta", "name", "")
|
|
|
if err != nil {
|
|
|
log.Fatalln(err.Error())
|
|
|
return
|
|
@@ -329,7 +329,6 @@ func ClearTimeoutUsedResource(ttl int64) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-
|
|
|
//过期服务清理
|
|
|
func ClearTimeoutService(ttl int64) {
|
|
|
timeout := ttl * 2
|
|
@@ -338,7 +337,7 @@ func ClearTimeoutService(ttl int64) {
|
|
|
select {
|
|
|
case <-tm.C:
|
|
|
//TODO 过滤过期服务
|
|
|
- RemoveTimeoutService(timeout)
|
|
|
+ removeTimeoutService(timeout)
|
|
|
}
|
|
|
}
|
|
|
}
|