Skip to content
This repository was archived by the owner on Nov 24, 2023. It is now read-only.

Commit

Permalink
Merge branch 'cant-start-relay' of github.com:lance6716/dm into cant-…
Browse files Browse the repository at this point in the history
…start-relay
  • Loading branch information
lance6716 committed Oct 18, 2021
2 parents e8b1011 + 28f23d4 commit c32c4cb
Showing 1 changed file with 0 additions and 6 deletions.
6 changes: 0 additions & 6 deletions dm/worker/relay.go
Original file line number Diff line number Diff line change
Expand Up @@ -241,12 +241,6 @@ func (h *realRelayHolder) Stage() pb.Stage {
return h.stage
}

func (h *realRelayHolder) setStage(stage pb.Stage) {
h.Lock()
defer h.Unlock()
h.stage = stage
}

// setStageIfNot sets stage to newStage if its current value is not oldStage, similar to CAS.
func (h *realRelayHolder) setStageIfNot(oldStage, newStage pb.Stage) bool {
h.Lock()
Expand Down

0 comments on commit c32c4cb

Please sign in to comment.