- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of about 10,000 for acquired (0.35 sec)
-
src/syscall/forkpipe2.go
// on ForkLock. forking int ) // hasWaitingReaders reports whether any goroutine is waiting // to acquire a read lock on rw. It is defined in the sync package. func hasWaitingReaders(rw *sync.RWMutex) bool // acquireForkLock acquires a write lock on ForkLock. // ForkLock is exported and we've promised that during a fork // we will call ForkLock.Lock, so that no other threads create
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jul 10 19:19:59 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1/generated.proto
// leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional optional int32 leaseDurationSeconds = 2; // acquireTime is a time when the current lease was acquired. // +optional optional .k8s.io.apimachinery.pkg.apis.meta.v1.MicroTime acquireTime = 3;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1/types.go
// leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional LeaseDurationSeconds *int32 `json:"leaseDurationSeconds,omitempty" protobuf:"varint,2,opt,name=leaseDurationSeconds"` // acquireTime is a time when the current lease was acquired. // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 3K bytes - Viewed (0) -
cmd/namespace-lock_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 3.1K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
return false } le.setObservedRecord(&leaderElectionRecord) return true } // tryAcquireOrRenew tries to acquire a leader lease if it is not already acquired, // else it tries to renew the lease if it has already been acquired. Returns true // on success else returns false. func (le *LeaderElector) tryAcquireOrRenew(ctx context.Context) bool { now := metav1.Now()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/filelock/LockStateAccess.java
if (fileLock == null) { return FileLockOutcome.LOCKED_BY_ANOTHER_PROCESS; } else { return FileLockOutcome.acquired(fileLock); } } catch (OverlappingFileLockException e) { return FileLockOutcome.LOCKED_BY_THIS_PROCESS; } } public int getRegionEnd() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 4K bytes - Viewed (0) -
common-protos/k8s.io/api/coordination/v1/generated.proto
// leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional optional int32 leaseDurationSeconds = 2; // acquireTime is a time when the current lease was acquired. // +optional optional k8s.io.apimachinery.pkg.apis.meta.v1.MicroTime acquireTime = 3;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1/types_swagger_doc_generated.go
"leaseDurationSeconds": "leaseDurationSeconds is a duration that candidates for a lease need to wait to force acquire it. This is measure against time of last observed renewTime.", "acquireTime": "acquireTime is a time when the current lease was acquired.", "renewTime": "renewTime is a time when the current holder of a lease has last updated the lease.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 00:51:25 UTC 2023 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/mutation/typeprovider.go
tp := &TypeProvider{typeResolver: resolver} var envOption cel.EnvOption = func(e *cel.Env) (*cel.Env, error) { // wrap the existing type provider (acquired from the env) // and set new type provider for the env. tp.underlyingTypeProvider = e.CELTypeProvider() typeProviderOption := cel.CustomTypeProvider(tp) return typeProviderOption(e) } return tp, envOption
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 21:02:36 UTC 2024 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/lease_manager.go
l.leaseAttachedObjectCount = 1 return lcr.ID, nil } // getReuseDurationSecondsLocked returns the reusable duration in seconds // based on the configuration. Lock has to be acquired before calling this // function. func (l *leaseManager) getReuseDurationSecondsLocked(ttl int64) int64 { reuseDurationSeconds := int64(l.leaseReuseDurationPercent * float64(ttl))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 4.8K bytes - Viewed (0)