- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 106 for Locks (3.76 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt
import okhttp3.Dispatcher import okhttp3.internal.http2.Http2Connection import okhttp3.internal.http2.Http2Stream import okhttp3.internal.http2.Http2Writer /** * Centralisation of central locks according to docs/contribute/concurrency.md */ internal object Locks { inline fun <T> Dispatcher.withLock(action: () -> T): T { contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) } return lock.withLock(action) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* Thread acquires its first hold (and releases its last remaining hold). * <li>Before the lock is acquired, the lock is checked against the current set of acquired * locks---to each of the acquired locks, an edge from the soon-to-be-acquired lock is either * verified or created. * <li>If a new edge needs to be created, the outgoing edges of the acquired locks are traversed
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 35.9K bytes - Viewed (0) -
internal/dsync/drwmutex.go
break } } quorumLocked := checkQuorumLocked(locks, quorum) && locksFailed <= tolerance if !quorumLocked { log("dsync: Unable to acquire lock in quorum %#v\n", args) // Release all acquired locks without quorum. if !releaseAll(ctx, ds, tolerance, owner, locks, isReadLock, restClnts, names...) { log("Unable to release acquired locks, these locks will expire automatically %#v\n", args) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/lock-rest-server.go
const ( // Lock maintenance interval. lockMaintenanceInterval = 1 * time.Minute // Lock validity duration lockValidityDuration = 1 * time.Minute ) // lockMaintenance loops over all locks and discards locks // that have not been refreshed for some time. func lockMaintenance(ctx context.Context) { if !globalIsDistErasure { return } // Initialize a new ticker with 1 minute between each ticks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* object). So it is important to not call {@link #dispatch} while holding any locks. This is why * {@link #enqueue} and {@link #dispatch} are 2 different methods. It is expected that the decision * to run a particular event is made during the state change, but the decision to actually invoke * the listeners can be delayed slightly so that locks can be dropped. Also, because {@link
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
cmd/erasure-common.go
} ignoredErrs := []error{ errFileNotFound, errVolumeNotFound, errFileVersionNotFound, io.ErrUnexpectedEOF, // some times we would read without locks, ignore these errors io.EOF, // some times we would read without locks, ignore these errors context.DeadlineExceeded, context.Canceled, } ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...) errs := g.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
import java.net.SocketTimeoutException import java.util.ArrayDeque import java.util.concurrent.locks.Condition import java.util.concurrent.locks.ReentrantLock import okhttp3.Headers import okhttp3.internal.EMPTY_HEADERS import okhttp3.internal.assertNotHeld import okhttp3.internal.connection.Locks.withLock import okhttp3.internal.http2.flowcontrol.WindowCounter import okhttp3.internal.toHeaderList
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
import java.util.List; import java.util.Map; import java.util.Set; import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import org.apache.maven.api.SessionData; import org.apache.maven.api.services.MessageBuilderFactory; import org.apache.maven.artifact.Artifact;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Feb 28 23:31:09 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
package cmd import ( "context" "runtime" "time" "github.com/prometheus/procfs" ) const ( processLocksReadTotal = "locks_read_total" processLocksWriteTotal = "locks_write_total" processCPUTotalSeconds = "cpu_total_seconds" processGoRoutineTotal = "go_routine_total" processIORCharBytes = "io_rchar_bytes"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 6.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import junit.framework.TestCase; /** * Unittests for {@link CycleDetectingLockFactory}. * * @author Darick Tong */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.1K bytes - Viewed (1)