Skip to content

G
getty
Commit 389e30dd authored by wangoo's avatar wangoo
Browse files
Options

increase grNum before starting goroutine

parent b1e566ce
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
session.go
View file @ 389e30dd
...@@ -495,10 +495,11 @@ func (s *session) run() { ...@@ -495,10 +495,11 @@ func (s *session) run() {
return return
} }
s.grNum.Add(1)
if _, err := defaultTimerWheel.AddTimer(heartbeat, gxtime.TimerLoop, s.period, s); err != nil { if _, err := defaultTimerWheel.AddTimer(heartbeat, gxtime.TimerLoop, s.period, s); err != nil {
panic(fmt.Sprintf("failed to add session %s to defaultTimerWheel err:%v", s.Stat(), err)) panic(fmt.Sprintf("failed to add session %s to defaultTimerWheel err:%v", s.Stat(), err))
} }
s.grNum.Add(1)
// start read gr // start read gr
go s.handlePackage() go s.handlePackage()
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment