🚸 release: v0.2.1

This commit is contained in:
naiba committed 2021-01-16 14:11:51 +08:00
1 parent 92a273159e
commit 27fcfbf76a
10 files changed
+127 -72

No files matched your search

-3
View File
@@ -2,7 +2,6 @@ package rpc
import (
"fmt"
"log"
"net"
"time"
@@ -47,9 +46,7 @@ func DispatchTask(duration time.Duration) {
continue
}
hasAliveAgent = true
log.Println("DispatchTask 确认派发 >>>>>", i, index)
dao.SortedServerList[index].TaskStream.Send(tasks[i].PB())
log.Println("DispatchTask 确认派发 <<<<<", i, index)
index++
}
dao.ServerLock.RUnlock()