Merge pull request #65 from cryptogarageinc/fix/multi-dynamic-session…

…-stop-deadlock fix: session.stop from quickfixgo/quickfix pr 531
cryptogarageinc · Dec 22, 2022 · 866dabd · 866dabd
2 parents c3d0804 + db28272
commit 866dabd
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/session.go b/session.go
@@ -35,6 +35,7 @@ type session struct {
 	stateTimer *internal.EventTimer
 	peerTimer  *internal.EventTimer
 	sentReset  bool
+	stopOnce sync.Once
 
 	targetDefaultApplVerID string
 
@@ -87,7 +88,10 @@ func (s *session) connect(msgIn <-chan fixIn, msgOut chan<- []byte) error {
 type stopReq struct{}
 
 func (s *session) stop() {
-	s.admin <- stopReq{}
+	//stop once
+	s.stopOnce.Do(func() {
+		s.admin <- stopReq{}
+	})
 }
 
 type waitChan <-chan interface{}