Skip to content

Commit

Permalink
rewrite comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
3AceShowHand committed Oct 17, 2024
1 parent 52e079c commit 6b1e6ee
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion cdc/kv/region_worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -379,7 +379,8 @@ func (w *regionWorker) resolveLock(ctx context.Context) error {
}
}

// processEvent is used as the event handle in the workerpool, controlled by the global server context.
// processEvent is used in local region worker, also used in worker pool.
// in the both case, should be controlled by the local region worker ctx, instead of the global server context.
func (w *regionWorker) processEvent(event *regionStatefulEvent) error {
// event.state is nil when resolvedTsEvent is not nil
skipEvent := event.state != nil && event.state.isStale()
Expand Down

0 comments on commit 6b1e6ee

Please sign in to comment.