|
|
@@ -32,6 +32,7 @@ var allclient map[string]*Client = make(map[string]*Client)
|
|
|
var allservice map[int][]string = make(map[int][]string)
|
|
|
|
|
|
//记录空闲下载器
|
|
|
+
|
|
|
var (
|
|
|
allIdleServiceLock = &sync.Mutex{}
|
|
|
allIdleServiceMap = make(map[string]int)
|
|
|
@@ -250,7 +251,7 @@ func processmsg(msg *util.Packet) {
|
|
|
break
|
|
|
}
|
|
|
var service_machine_id string
|
|
|
- //先用空闲下载器
|
|
|
+ //优先使用空闲下载器
|
|
|
//allIdleServiceLock.Lock()
|
|
|
//fmt.Println("allIdleServiceMap：", len(allIdleServiceMap))
|
|
|
//for service_machine_id_tmp, num := range allIdleServiceMap {
|
