- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for startm (0.11 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
createTime: clock.Now(), startBucketID: 0, clock: clock, bookmarkFrequency: bookmarkFrequency, } } // adds a watcher to the bucket, if the deadline is before the start, it will be // added to the first one. func (t *watcherBookmarkTimeBuckets) addWatcherThreadUnsafe(w *cacheWatcher) bool { // note that the returned time can be before t.createTime,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
// occurred after the pod scheduling attempt for that pod started. // They get removed when the scheduling attempt is done, at which // point all events that occurred in the meantime are processed. // // After removal of a pod, events at the start of the list are no // longer needed because all of the other in-flight pods started // later. Those events can be removed. inFlightEvents *list.List
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
cmd/xl-storage.go
return nil, time.Time{}, err } defer f.Close() stat, err := f.Stat() if err != nil { return nil, time.Time{}, err } if stat.IsDir() { return nil, time.Time{}, &os.PathError{ Op: "open", Path: itemPath, Err: syscall.EISDIR, } } buf, err := readXLMetaNoData(f, stat.Size()) if err != nil { return nil, stat.ModTime().UTC(), fmt.Errorf("%w -> %s", err, itemPath) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (0) -
src/time/format.go
if len(value) < 2 { err = errBad break } p, value = value[0:2], value[2:] year, err = atoi(p) if err != nil { break } if year >= 69 { // Unix time starts Dec 31 1969 in some time zones year += 1900 } else { year += 2000 } case stdLongYear: if len(value) < 4 || !isDigit(value, 0) { err = errBad break }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:09:28 UTC 2024 - 49.3K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.31.md
- Kubeadm: switched kubeadm to start using the CRI client library instead of shelling out of the `crictl` binary
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:34:14 UTC 2024 - 60.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
if len(cacher.bookmarkWatchers.watchersBuckets) != 0 { numWatchers := 0 for bucketID, v := range cacher.bookmarkWatchers.watchersBuckets { numWatchers += len(v) t.Errorf("there are %v watchers at bucket Id %v with start Id %v", len(v), bucketID, cacher.bookmarkWatchers.startBucketID) } t.Errorf("unexpected bookmark watchers %v", numWatchers) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
cmd/erasure-object.go
} // Reply back invalid range if the input offset and length fall out of range. if startOffset > fi.Size || startOffset+length > fi.Size { return InvalidRange{startOffset, length, fi.Size} } // Get start part index and offset. partIndex, partOffset, err := fi.ObjectToPartOffset(ctx, startOffset) if err != nil { return InvalidRange{startOffset, length, fi.Size} } // Calculate endOffset according to length
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
Limit: 2, Continue: encodeContinueOrDie("third/barfoo", int64(continueRV)), }, expectedOut: []example.Pod{*preset[4]}, }, { name: "filter returns one item for last page, starts on last item, full", prefix: "/pods", pred: storage.SelectionPredicate{ Field: fields.OneTermEqualSelector("metadata.name", "foo"), Label: labels.Everything(), Limit: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
cmd/api-errors.go
Code: "XMinioAdminRebalanceAlreadyStarted", Description: "Pool rebalance is already started", HTTPStatusCode: http.StatusConflict, }, ErrAdminRebalanceNotStarted: { Code: "XMinioAdminRebalanceNotStarted", Description: "Pool rebalance is not started", HTTPStatusCode: http.StatusNotFound, }, ErrMaximumExpires: {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (0) -
cmd/iam-store.go
// User was deleted - we update the cache. delete(m, accessKey) // Since cache was updated, we update the timestamp. defer func() { cache.updatedAt = time.Now() }() // 1. Start with updating user-group memberships if store.getUsersSysType() == MinIOUsersSysType { memberOf := cache.iamUserGroupMemberships[accessKey].ToSlice() for _, group := range memberOf {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0)