- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for skipped (0.27 sec)
-
cmd/background-newdisks-heal-ops.go
h.mu.Lock() defer h.mu.Unlock() h.Object = object } func (h *healingTracker) updateProgress(success, skipped bool, bytes uint64) { h.mu.Lock() defer h.mu.Unlock() switch { case success: h.ItemsHealed++ h.BytesDone += bytes case skipped: h.ItemsSkipped++ h.BytesSkipped += bytes default: h.ItemsFailed++ h.BytesFailed += bytes } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/global-heal.go
}) expectedDisks := len(disks)/2 + 1 fallbackDisks := disks[expectedDisks:] disks = disks[:expectedDisks] type healEntryResult struct { bytes uint64 success bool skipped bool entryDone bool name string } healEntryDone := func(name string) healEntryResult { return healEntryResult{ entryDone: true, name: name, } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
cmd/metacache-set.go
} if !o.InclDeleted && entry.isObject() && entry.isLatestDeletemarker() && !entry.isObjectDir() { continue } if o.Lifecycle != nil || o.Replication.Config != nil { if skipped := triggerExpiryAndRepl(ctx, *o, entry); skipped == true { results.lastSkippedEntry = entry.name continue } } if o.Limit > 0 && results.len() >= o.Limit { // We have enough and we have more.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/api-headers.go
} } } // Set all other user defined metadata. for k, v := range objInfo.UserDefined { // Empty values for object lock and retention can be skipped. if v == "" && equals(k, xhttp.AmzObjectLockMode, xhttp.AmzObjectLockRetainUntilDate) { continue } if stringsHasPrefixFold(k, ReservedMetadataPrefixLower) { // Do not need to send any internal metadata
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.9K bytes - Viewed (1) -
cmd/erasure-metadata-utils.go
return shuffleDisksAndPartsMetadata(disks, metaArr, fi) } // Return shuffled partsMetadata depending on fi.Distribution. // additional validation is attempted and invalid metadata is // automatically skipped only when fi.ModTime is non-zero // indicating that this is called during read-phase
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/erasure-healing.go
if err != nil { return err } for _, volInfo := range volsInfo { // StorageAPI can send volume names which are // incompatible with buckets - these are // skipped, like the meta-bucket. if isReservedOrInvalidBucket(volInfo.Name, false) { continue } mu.Lock() if _, ok := healBuckets[volInfo.Name]; !ok { healBuckets[volInfo.Name] = volInfo }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
const ( notificationCurrentSendInProgress = "current_send_in_progress" notificationEventsErrorsTotal = "events_errors_total" notificationEventsSentTotal = "events_sent_total" notificationEventsSkippedTotal = "events_skipped_total" ) var ( notificationCurrentSendInProgressMD = NewCounterMD(notificationCurrentSendInProgress, "Number of concurrent async Send calls active to all targets")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
} s.RestartIAMSuite(c) } func (s *TestSuiteIAM) SetUpSuite(c *check) { // If etcd backend is specified and etcd server is not present, the test // is skipped. etcdServer := env.Get(EnvTestEtcdBackend, "") if s.withEtcdBackend && etcdServer == "" { c.Skip("Skipping etcd backend IAM test as no etcd server is configured.") } s.TestSuiteCommon.SetUpSuite(c)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
continue } if object.IsDeleteMarker { log.Println("SKIPPED: DELETE marker object:", objFullPath(object)) continue } if _, ok := object.UserMetadata["X-Amz-Server-Side-Encryption-Customer-Algorithm"]; ok { log.Println("SKIPPED: Objects encrypted with SSE-C do not have md5sum as ETag:", objFullPath(object)) continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Feb 17 01:15:57 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
// When "X-Amz-Content-Sha256" header is set to "UNSIGNED-PAYLOAD", validation of content sha256 has to be skipped. {"X-Amz-Content-Sha256", unsignedPayload, "X-Amz-Credential", "", true}, // Test case - 4. // Enabling PreSigned Signature v4, but X-Amz-Content-Sha256 not set has to be skipped. {"", "", "X-Amz-Credential", "", true}, // Test case - 5.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0)