|
@@ -267,7 +267,7 @@ func processmsg(msg *util.Packet) {
|
|
|
//随机取某个下载器
|
|
|
if service_machine_id == "" {
|
|
|
service_machine_id = v[rand.Intn(len(v))]
|
|
|
- fmt.Println("default vps---", service_machine_id)
|
|
|
+ //fmt.Println("default vps---", service_machine_id)
|
|
|
}
|
|
|
lock.Lock()
|
|
|
client, ok := allclient[service_machine_id]
|
|
@@ -278,9 +278,9 @@ func processmsg(msg *util.Packet) {
|
|
|
updateheartbeat(service_machine_id)
|
|
|
break
|
|
|
} else {
|
|
|
- allIdleServiceLock.Lock()
|
|
|
- delete(allIdleServiceMap, service_machine_id) //删除不能通信的下载器
|
|
|
- allIdleServiceLock.Unlock()
|
|
|
+ //allIdleServiceLock.Lock()
|
|
|
+ //delete(allIdleServiceMap, service_machine_id) //删除不能通信的下载器
|
|
|
+ //allIdleServiceLock.Unlock()
|
|
|
removeClient(service_machine_id)
|
|
|
}
|
|
|
}
|