- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 39 for Visiting (0.13 sec)
-
cmd/erasure-server-pool.go
} if merged.lastSkippedEntry != "" { if merged.lastSkippedEntry > loi.NextMarker { // An object hidden by ILM was found during listing. Since the number of entries // fetched from drives is limited, set IsTruncated to true to ask the s3 client // to continue listing if it wishes in order to find if there is more objects. loi.IsTruncated = true loi.NextMarker = merged.lastSkippedEntry } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
src/net/http/fs_test.go
if !strings.HasPrefix(s, dirListPrefix) || !strings.HasSuffix(s, dirListSuffix) { t.Errorf("test %q: listing dir, full output is %q, want prefix %q and suffix %q", test.name, s, dirListPrefix, dirListSuffix) } if trimmed := strings.TrimSuffix(strings.TrimPrefix(s, dirListPrefix), dirListSuffix); trimmed != test.escaped { t.Errorf("test %q: listing dir, filename escaped to %q, want %q", test.name, trimmed, test.escaped) } res.Body.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
nonFreeVersions := len(x.versions) var ( freeFi FileInfo freeFound bool ) found := false for _, ver := range x.versions { header := &ver.header // skip listing free-version unless explicitly requested via versionID if header.FreeVersion() { nonFreeVersions-- // remember the latest free version; will return this FileInfo if no non-free version remain
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 29 19:14:09 UTC 2024 - 63.6K bytes - Viewed (0) -
cmd/xl-storage_test.go
if err != errDiskNotFound { t.Errorf("Expected: \"Drive not found\", got \"%s\"", err) } } // TestXLStorageListVols - Validates the result and the error output for xlStorage volume listing functionality xlStorage.ListVols(). func TestXLStorageListVols(t *testing.T) { // create xlStorage test setup xlStorage, path, err := newXLStorageTestSetup(t) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 11 17:45:28 UTC 2024 - 66.7K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// When PodDisruptionConditions is enabled, orphan Pods and unschedulable // terminating Pods are marked as Failed. So we only need to check the phase. // TODO(#113855): Stop limiting this behavior to Jobs with podFailurePolicy. // For now, we do so to avoid affecting all running Jobs without the // availability to opt-out into the old behavior. return p.Status.Phase == v1.PodFailed }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
SingularQualifiedResource schema.GroupResource // KeyRootFunc returns the root etcd key for this resource; should not // include trailing "/". This is used for operations that work on the // entire collection (listing and watching). // // KeyRootFunc and KeyFunc must be supplied together or not at all. KeyRootFunc func(ctx context.Context) string // KeyFunc returns the key for a specific object in the collection.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
if (strictParsing) { checkState( this.maximumSize == UNSET_INT, "weigher can not be combined with maximum size (%s provided)", this.maximumSize); } // safely limiting the kinds of caches this can produce @SuppressWarnings("unchecked") CacheBuilder<K1, V1> me = (CacheBuilder<K1, V1>) this; me.weigher = checkNotNull(weigher); return me; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
curNode := cur.(*v1.Node) if shouldIgnoreNodeUpdate(*oldNode, *curNode) { return } dsList, err := dsc.dsLister.List(labels.Everything()) if err != nil { logger.V(4).Info("Error listing daemon sets", "err", err) return } // TODO: it'd be nice to pass a hint with these enqueues, so that each ds would only examine the added node (unless it has other work to do, too). for _, ds := range dsList {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
src/runtime/mgcmark.go
// // TODO(mknyszek): Hide the details of inMarkAssist in tracer // functions and simplify all the state tracking. This is a lot. enteredMarkAssistForTracing := false retry: if gcCPULimiter.limiting() { // If the CPU limiter is enabled, intentionally don't // assist to reduce the amount of CPU time spent in the GC. if enteredMarkAssistForTracing { trace := traceAcquire() if trace.ok() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
if err != nil { proxier.logger.Error(err, "Error listing addresses binded to dummy interface") } // nodeAddressSet All addresses *except* those on the dummy interface nodeAddressSet, err := proxier.netlinkHandle.GetAllLocalAddressesExcept(defaultDummyDevice) if err != nil { proxier.logger.Error(err, "Error listing node addresses") } hasNodePort := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0)