- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for healingLogEvent (0.08 sec)
-
cmd/mrf.go
// the current heal status in one available disk func (m *mrfState) shutdown() { atomic.StoreInt32(&m.closing, 1) m.wg.Wait() close(m.opCh) atomic.StoreInt32(&m.closed, 1) if len(m.opCh) > 0 { healingLogEvent(context.Background(), "Saving MRF healing data (%d entries)", len(m.opCh)) } newReader := func() io.ReadCloser { r, w := io.Pipe() go func() { // Initialize MRF meta header. var data [4]byte
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/logging.go
logger.LogIf(ctx, "internal", err, errKind...) } func healingLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "healing", err, errKind...) } func healingLogEvent(ctx context.Context, msg string, args ...interface{}) { logger.Event(ctx, "healing", msg, args...) } func healingLogOnceIf(ctx context.Context, err error, errKind ...interface{}) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 03 18:49:48 UTC 2024 - 7.1K bytes - Viewed (0)