Skip to content

Commit

Permalink
Merge pull request cubefs#976 from yinlei-jinan/master
Browse files Browse the repository at this point in the history
fix: avoid streamer become unable to write
  • Loading branch information
awzhgw authored Oct 10, 2020
2 parents a040d2c + ff82898 commit bd7abd5
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion sdk/data/stream/extent_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -612,6 +612,5 @@ func (eh *ExtentHandler) setRecovery() bool {
}

func (eh *ExtentHandler) setError() bool {
atomic.StoreInt32(&eh.stream.status, StreamerError)
return atomic.CompareAndSwapInt32(&eh.status, ExtentStatusRecovery, ExtentStatusError)
}

0 comments on commit bd7abd5

Please sign in to comment.