Fixes driskell#294

driskell · driskell · commit 138b9a40af80 · 2016-03-24T20:48:02.000Z
diff --git a/lc-lib/endpoint/sink.go b/lc-lib/endpoint/sink.go
@@ -243,7 +243,7 @@ func (f *Sink) ForceFailure(endpoint *Endpoint) {
 // recoverFailed removes an endpoint from the failed list and marks it ready
 func (f *Sink) recoverFailed(endpoint *Endpoint) {
 	// Ignore if we haven't failed
-	if !endpoint.IsAlive() {
+	if !endpoint.IsFailed() {
 		return
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -243,7 +243,7 @@ func (f Sink) ForceFailure(endpoint Endpoint) {`
`243`	`243`	`// recoverFailed removes an endpoint from the failed list and marks it ready`
`244`	`244`	`func (f Sink) recoverFailed(endpoint Endpoint) {`
`245`	`245`	`// Ignore if we haven't failed`
`246`		`- if !endpoint.IsAlive() {`
	`246`	`+ if !endpoint.IsFailed() {`
`247`	`247`	`return`
`248`	`248`	`}`
`249`	`249`