|
@@ -251,18 +251,18 @@ func processmsg(msg *util.Packet) {
|
|
|
}
|
|
|
var service_machine_id string
|
|
|
//先用空闲下载器
|
|
|
- allIdleServiceLock.Lock()
|
|
|
- fmt.Println("allIdleServiceMap:", len(allIdleServiceMap))
|
|
|
- for service_machine_id_tmp, num := range allIdleServiceMap {
|
|
|
- service_machine_id = service_machine_id_tmp
|
|
|
- if tmpNum := num - 1; tmpNum <= 0 {
|
|
|
- delete(allIdleServiceMap, service_machine_id_tmp)
|
|
|
- } else {
|
|
|
- allIdleServiceMap[service_machine_id_tmp] = tmpNum
|
|
|
- }
|
|
|
- break
|
|
|
- }
|
|
|
- allIdleServiceLock.Unlock()
|
|
|
+ //allIdleServiceLock.Lock()
|
|
|
+ //fmt.Println("allIdleServiceMap:", len(allIdleServiceMap))
|
|
|
+ //for service_machine_id_tmp, num := range allIdleServiceMap {
|
|
|
+ // service_machine_id = service_machine_id_tmp
|
|
|
+ // if tmpNum := num - 1; tmpNum <= 0 {
|
|
|
+ // delete(allIdleServiceMap, service_machine_id_tmp)
|
|
|
+ // } else {
|
|
|
+ // allIdleServiceMap[service_machine_id_tmp] = tmpNum
|
|
|
+ // }
|
|
|
+ // break
|
|
|
+ //}
|
|
|
+ //allIdleServiceLock.Unlock()
|
|
|
//随机取某个下载器
|
|
|
if service_machine_id == "" {
|
|
|
service_machine_id = v[rand.Intn(len(v))]
|