fix race

drpcorg · Dec 13, 2024 · ffb771d · ffb771d
1 parent 9e00455
commit ffb771d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sync.go b/sync.go
@@ -541,7 +541,7 @@ func (sync *Syncer) Drain(ctx context.Context, recs protocol.Records) (err error
 
 	recs = sync.processPings(recs)
 
-	switch sync.drainState {
+	switch sync.GetDrainState() {
 	case SendHandshake:
 		if len(recs) == 0 {
 			return ErrBadHPacket