- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 5,554 for acquired (0.41 sec)
-
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
opIndex = previousOpIndex } } } return opIndex != -1, opIndex } func (grm *nestedPendingOperations) getOperation(key operationKey) (uint, error) { // Assumes lock has been acquired by caller. for i, op := range grm.operations { if op.key.volumeName == key.volumeName && op.key.podName == key.podName && op.key.nodeName == key.nodeName { return uint(i), nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K 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) -
cmd/sts-datatypes.go
// in Using IAM. // // Arn is a required field Arn string // A unique identifier that contains the role ID and the role session name of // the role that is being assumed. The role ID is generated by AWS when the // role is created. // // AssumedRoleId is a required field AssumedRoleID string `xml:"AssumeRoleId"` // contains filtered or unexported fields }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 27 00:58:09 UTC 2022 - 9.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
StartTime: asof, }); err != nil { log.Printf("upload failed: %v", err) } } // acquireUploadToken acquires a token permitting the caller to upload. // To limit the frequency of uploads, only one token is issue per // machine per time period. // The boolean indicates whether the token was acquired. func acquireUploadToken() bool { if telemetry.Default.LocalDir() == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0) -
src/runtime/metrics.go
// sysStatsAggregate represents system memory stats obtained // from the runtime. This set of stats is grouped together because // they're all relatively cheap to acquire and generally independent // of one another and other runtime memory stats. The fact that they // may be acquired at different times, especially with respect to // heapStatsAggregate, means there could be some skew, but because of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 26K bytes - Viewed (0) -
docs/en/docs/deployment/https.md
* For HTTPS, **the server** needs to **have "certificates"** generated by a **third party**. * Those certificates are actually **acquired** from the third party, not "generated". * Certificates have a **lifetime**. * They **expire**. * And then they need to be **renewed**, **acquired again** from the third party. * The encryption of the connection happens at the **TCP level**. * That's one layer **below HTTP**.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Jan 11 16:31:18 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kube/krt/collection.go
log *istiolog.Scope // recomputeMu blocks a recomputation of I->O. recomputeMu sync.Mutex // mu protects all items grouped below. // This is acquired for reads and writes of data. // This can be acquired with recomputeMu held, but only with strict ordering (mu inside recomputeMu) mu sync.Mutex collectionState multiIndex[I, O]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
public void waitForCompletion() throws MultipleBuildOperationFailures { signalNoMoreWork(); // Use this thread to process any work - this allows work to be executed using the // worker lease acquired by this thread even if the executor thread pool is full of // workers from other queues. In other words, it ensures that all worker leases // are being utilized, regardless of the bounds of the thread pool.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultExclusiveCacheAccessCoordinatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 24K bytes - Viewed (0) -
src/runtime/lockrank.go
return "BAD RANK" } return lockNames[rank] } // lockPartialOrder is the transitive closure of the lock rank graph. // An entry for rank X lists all of the ranks that can already be held // when rank X is acquired. // // Lock ranks that allow self-cycles list themselves. var lockPartialOrder [][]lockRank = [][]lockRank{ lockRankSysmon: {}, lockRankScavenge: {lockRankSysmon},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 19.9K bytes - Viewed (0)