()
| 239 | } |
| 240 | |
| 241 | func (pw *Wrapper) statusNormalCallback() { |
| 242 | xl := pw.xl |
| 243 | atomic.StoreUint32(&pw.health, 0) |
| 244 | _ = errors.PanicToError(func() { |
| 245 | select { |
| 246 | case pw.healthNotifyCh <- struct{}{}: |
| 247 | default: |
| 248 | } |
| 249 | }) |
| 250 | xl.Infof("health check success") |
| 251 | } |
| 252 | |
| 253 | func (pw *Wrapper) statusFailedCallback() { |
| 254 | xl := pw.xl |