Merge pull request #889 from cloudevents/testRaceFix

duglin · web-flow · commit 4fb49a39a22b · 2023-04-11T07:40:15.000-04:00
Trying to fix a race warning
diff --git a/protocol/kafka_sarama/v2/sender_test.go b/protocol/kafka_sarama/v2/sender_test.go
@@ -74,6 +74,8 @@ func (s *syncProducerMock) AbortTxn() error {
 }
 
 func (s *syncProducerMock) TxnStatus() sarama.ProducerTxnStatusFlag {
+	s.lock.Lock()
+	defer s.lock.Unlock()
 	return s.status
 }
 

Original file line number	Diff line number	Diff line change
`@@ -74,6 +74,8 @@ func (s *syncProducerMock) AbortTxn() error {`
`74`	`74`	`}`
`75`	`75`
`76`	`76`	`func (s *syncProducerMock) TxnStatus() sarama.ProducerTxnStatusFlag {`
	`77`	`+ s.lock.Lock()`
	`78`	`+ defer s.lock.Unlock()`
`77`	`79`	`return s.status`
`78`	`80`	`}`
`79`	`81`