We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 893bf52 commit 4dc6dd0Copy full SHA for 4dc6dd0
cluster/handler.go
@@ -21,6 +21,7 @@ import (
21
"github.com/lonng/nano/protocal/packet"
22
"github.com/lonng/nano/scheduler/schedulerapi"
23
"github.com/lonng/nano/session"
24
+ "github.com/timandy/routine"
25
)
26
27
type rpcHandler func(session *session.Session, msg *message.Message, noCopy bool)
@@ -184,7 +185,7 @@ func (h *LocalHandler) handle(conn net.Conn) {
184
185
}()
186
187
// startup write goroutine
- go agt.write()
188
+ routine.Go(agt.write)
189
190
if env.Debug {
191
log.Info("New session established: %s", agt.String())
0 commit comments