- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for LogIf (0.24 sec)
-
cmd/tier-journal.go
if err := jd.rotate(); err != nil { logger.LogIf(ctx, fmt.Errorf("tier-journal: failed to rotate pending deletes journal %s", err)) return } ro, err := jd.OpenRO() switch { case errors.Is(err, os.ErrNotExist): return // No read-only journal to process; nothing to do. case err != nil: logger.LogIf(ctx, fmt.Errorf("tier-journal: failed open read-only journal for processing %s", err))
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/tier-sweeper.go
// os.SetTransitionState(goi) // } // // // After the overwriting object operation is complete. // // if jentry, ok := os.ShouldRemoveRemoteObject(); ok { // err := globalTierJournal.AddEntry(jentry) // logger.LogIf(ctx, err) // } type objSweeper struct { Object string Bucket string VersionID string // version ID set by application, applies only to DeleteObject and DeleteObjects APIs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/logger/reqinfo.go
for _, t := range r.tags { tagsMap[t.Key] = t.Val } return } // SetReqInfo sets ReqInfo in the context. func SetReqInfo(ctx context.Context, req *ReqInfo) context.Context { if ctx == nil { LogIf(context.Background(), "", fmt.Errorf("context is nil")) return nil } return context.WithValue(ctx, contextLogKey, req) } // GetReqInfo returns ReqInfo if set. func GetReqInfo(ctx context.Context) *ReqInfo {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/logging.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 6.6K bytes - Viewed (0) -
internal/logger/audit.go
) const contextAuditKey = contextKeyType("audit-entry") // SetAuditEntry sets Audit info in the context. func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context { if ctx == nil { LogIf(context.Background(), "audit", fmt.Errorf("context is nil")) return nil } return context.WithValue(ctx, contextAuditKey, audit) } // GetAuditEntry returns Audit entry if set.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/tier-mem-journal.go
entries: make(chan jentry, nevents), } } func (j *tierMemJournal) processEntries(ctx context.Context) { for { select { case <-ctx.Done(): return case entry := <-j.entries: logger.LogIf(ctx, deleteObjectFromRemoteTier(ctx, entry.ObjName, entry.VersionID, entry.TierName)) } } } func (j *tierMemJournal) AddEntry(je jentry) error { select { case j.entries <- je: default:
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Aug 03 21:16:15 GMT 2023 - 1.5K bytes - Viewed (0) -
internal/logger/logonce.go
Count: 1, } } else if prev.Err.Error() == nerr.Error() { // if errors are equal do not log. prev.Count++ l.IDMap[id] = prev shouldLog = false } l.Unlock() if shouldLog { logIf(ctx, subsystem, err, errKind...) } } // Cleanup the map every one hour so that the log message is printed again for the user to notice. func (l *logOnceType) cleanupRoutine() { for { time.Sleep(time.Hour)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.8K bytes - Viewed (0)