Reinit stop sync to prevent deadlock on sequential start/stops

ackleymi · ackleymi · commit 87eef54ce3c2 · 2024-09-05T17:00:38.000-05:00
diff --git a/session.go b/session.go
@@ -848,6 +848,7 @@ func (s *session) onAdmin(msg interface{}) {
 }
 
 func (s *session) run() {
+	s.stopOnce = sync.Once{}
 	s.Start(s)
 	var stopChan = make(chan struct{})
 	s.stateTimer = internal.NewEventTimer(func() {

Original file line number	Diff line number	Diff line change
`@@ -848,6 +848,7 @@ func (s *session) onAdmin(msg interface{}) {`
`848`	`848`	`}`
`849`	`849`
`850`	`850`	`func (s *session) run() {`
	`851`	`+ s.stopOnce = sync.Once{}`
`851`	`852`	`s.Start(s)`
`852`	`853`	`var stopChan = make(chan struct{})`
`853`	`854`	`s.stateTimer = internal.NewEventTimer(func() {`