- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 178 for unlocked (0.24 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/site-replication.go
buf, err := readConfig(ctx, objAPI, getSRStateFilePath()) if err != nil { if errors.Is(err, errConfigNotFound) { c.Lock() defer c.Unlock() c.state = srState{} c.enabled = false } return err } // attempt to read just the version key in the state file to ensure we // are reading a compatible version. var ver struct {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 184.8K bytes - Click Count (1) -
cmd/erasure-healing.go
} if !opts.NoLock { lk := er.NewNSLock(bucket, object) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return result, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } // Re-read when we have lock... partsMetadata, errs := readAllFileInfo(ctx, storageDisks, "", bucket, object, versionID, true, true) if isAllNotFound(errs) { err := errFileNotFoundCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
internal/rest/client.go
func (c *Client) MarkOffline(err error) bool { c.Lock() c.lastErr = err c.lastErrTime = time.Now() atomic.StoreInt64(&c.lastConn, time.Now().UnixNano()) c.Unlock() return c.runHealthCheck()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
cmd/xl-storage-disk-id-check.go
old := e.cached.Swap(newAcc) var a AccElem a.Size = atomic.LoadInt64(&old.Size) a.Total = atomic.LoadInt64(&old.Total) a.N = atomic.LoadInt64(&old.N) e.mu.Lock() e.addAll(t-1, a) e.mu.Unlock() acc = newAcc } else { // We may be able to grab the new accumulator by yielding. runtime.Gosched() acc = e.cached.Load() } } atomic.AddInt64(&acc.N, 1)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 34.5K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.34.md
- ReplicaSets and Deployments should always count `.status.availableReplicas` at the correct time without a delay. This results in faster reconciliation of Deployment conditions and faster, unblocked Deployment rollouts. ([#132121](https://github.com/kubernetes/kubernetes/pull/132121), [@atiratree](https://github.com/atiratree)) [SIG Apps]
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Mar 19 03:19:43 GMT 2026 - 368.7K bytes - Click Count (2) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
.contains("Service FailRunService [FAILED] has failed in the RUNNING state"); } /** * Tests that a ServiceManager can be fully shut down if one of its failure listeners is slow or * even permanently blocked. */ public void testListenerDeadlock() throws InterruptedException { CountDownLatch failEnter = new CountDownLatch(1); CountDownLatch failLeave = new CountDownLatch(1);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
try { currentFuture.cancel(mayInterruptIfRunning); } finally { lock.unlock(); } } @Override public boolean isCancelled() { lock.lock(); try { return currentFuture.isCancelled(); } finally { lock.unlock(); } } } @Override final Cancellable schedule(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
cmd/metacache-set.go
readers := make([]*metacacheReader, len(disks)) defer func() { for _, r := range readers { r.Close() } }() for i := range disks { r, w := io.Pipe() // Make sure we close the pipe so blocked writes doesn't stay around. defer r.CloseWithError(context.Canceled) readers[i] = newMetacacheReader(r) d := disks[i] // Send request to each disk. go func() { var werr error
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 30.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
internal fun removeStream(streamId: Int): Http2Stream? { withLock { val stream = streams.remove(streamId) // The removed stream may be blocked on a connection-wide window update. notifyAll() return stream } } internal fun updateConnectionFlowControl(read: Long) { withLock { readBytes.update(total = read)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 31.9K bytes - Click Count (0) -
docs/changelogs/changelog_4x.md
Previously OkHttp used its connection pool as a lock when making changes to connections and calls. With this change each connection is locked independently. * Upgrade: [Okio 2.7.0][okio_2_7_0]. ```kotlin implementation("com.squareup.okio:okio:2.7.0") ```Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Click Count (0)