diff --git a/module/worker/connect.go b/module/worker/connect.go index ce3443f8..eac4fc5a 100644 --- a/module/worker/connect.go +++ b/module/worker/connect.go @@ -56,13 +56,13 @@ func Receiver(pod *socket.WsConn) error { switch rq.Method { case "Exec": - recv.Exec(rq) + go recv.Exec(rq) case "Stat": - recv.Stat(rq) + go recv.Stat(rq) case "Filer": - recv.Filer(rq) + go recv.Filer(rq) case "Ping:resp": - resp.Ping(rq) + go resp.Ping(rq) case "Register:resp": go resp.Register(rq) default: diff --git a/module/workhub/connect.go b/module/workhub/connect.go index c9998642..6b58aad9 100644 --- a/module/workhub/connect.go +++ b/module/workhub/connect.go @@ -65,15 +65,15 @@ func Receiver(worker *Worker) error { switch rq.Method { case "Register": - recv.Register(rq) + go recv.Register(rq) case "Ping": - recv.Ping(rq) + go recv.Ping(rq) case "Exec:resp": - resp.Exec(rq) + go resp.Exec(rq) case "Filer:resp": - resp.Filer(rq) + go resp.Filer(rq) case "Stat:resp": - resp.Stat(rq) + go resp.Stat(rq) default: logman.Warn("unknown task", "request", rq) }