fail sets the error on the puller state compose of error, and marks the sharedPullerState as failed. Is a no-op when called on an already failed state.
(err error)
| 238 | // fail sets the error on the puller state compose of error, and marks the |
| 239 | // sharedPullerState as failed. Is a no-op when called on an already failed state. |
| 240 | func (s *sharedPullerState) fail(err error) { |
| 241 | s.mut.Lock() |
| 242 | defer s.mut.Unlock() |
| 243 | |
| 244 | s.failLocked(err) |
| 245 | } |
| 246 | |
| 247 | func (s *sharedPullerState) failLocked(err error) { |
| 248 | if s.err != nil || err == nil { |