- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for rlocked (0.68 sec)
-
src/runtime/proc.go
pp, _ = pidleget(0) } var locked bool if pp == nil { globrunqput(gp) // Below, we stoplockedm if gp is locked. globrunqput releases // ownership of gp, so we must check if gp is locked prior to // committing the release by unlocking sched.lock, otherwise we // could race with another M transitioning gp from unlocked to // locked. locked = gp.lockedm != 0 } else if sched.sysmonwait.Load() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
src/database/sql/sql.go
select { default: case <-ctx.Done(): return nil, nil, ctx.Err() } // closemu.RLock must come before the check for isDone to prevent the Tx from // closing while a query is executing. tx.closemu.RLock() if tx.isDone() { tx.closemu.RUnlock() return nil, nil, ErrTxDone } if hookTxGrabConn != nil { // test hook hookTxGrabConn() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
time.Sleep(1 * time.Second) err = expectSyncNotBlocked(fakeDiscoveryClient, &gc.workerLock) if err != nil { t.Fatalf("Expected garbagecollector.Sync to be running but it is blocked: %v", err) } assertMonitors(t, gc, "pods", "deployments") // Simulate the discovery client returning an error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/testdata/swagger.json
"description": "Represents a Flocker volume mounted by the Flocker agent. One and only one of datasetName and datasetUUID should be set. Flocker volumes do not support ownership management or SELinux relabeling.", "properties": { "datasetName": { "description": "Name of the dataset stored as metadata -> name on the dataset for Flocker should be considered as deprecated", "type": "string"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 229.4K bytes - Viewed (0) -
subprojects/diagnostics/src/integTest/groovy/org/gradle/api/tasks/diagnostics/DependencyInsightReportTaskIntegrationTest.groovy
succeeds 'dependencyInsight', '--configuration', 'lockedConf', '--dependency', 'foo' then: outputContains """ org:foo:1.0 FAILED Selection reasons: - By constraint: dependency was locked to version '1.0' Failures: - Could not resolve org:foo:{strictly 1.0}. - Cannot find a version of 'org:foo' that satisfies the version constraints:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 08 15:15:56 UTC 2024 - 102.3K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
}, { name: "blocked external to LB1", sourceIP: testExternalClientBlocked, destIP: svcLBIP1, destPort: svcPort, output: "DROP", }, { name: "blocked external to LB2", sourceIP: testExternalClientBlocked, destIP: svcLBIP2, destPort: svcPort, output: "DROP", }, { name: "pod to LB1 (blocked by LoadBalancerSourceRanges)",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
src/cmd/cgo/internal/test/callback.go
// Make sure panic during callback unwinds properly. if lockedOSThread() { t.Fatal("locked OS thread on entry to TestCallbackPanic") } defer func() { s := recover() if s == nil { t.Fatal("did not panic") } if s.(string) != "callback panic" { t.Fatal("wrong panic:", s) } if lockedOSThread() { t.Fatal("locked OS thread on exit from TestCallbackPanic") } }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 111.5K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
readCount.set(0); } finally { unlock(); } } } void runUnlockedCleanup() { // locked cleanup may generate notifications we can send unlocked if (!isHeldByCurrentThread()) { map.processPendingNotifications(); } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 143.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
readCount.set(0); } finally { unlock(); } } } void runUnlockedCleanup() { // locked cleanup may generate notifications we can send unlocked if (!isHeldByCurrentThread()) { map.processPendingNotifications(); } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 149.2K bytes - Viewed (0) -
cmd/admin-handlers.go
continue } args.Resources = append(args.Resources, path) } for _, lks := range z.serverPools[0].erasureLockers { lockers = append(lockers, lks...) } for _, locker := range lockers { locker.ForceUnlock(ctx, args) } } // TopLocksHandler Get list of locks in use func (a adminAPIHandlers) TopLocksHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0)