- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 351 for locking (0.04 sec)
-
android/guava-testlib/test/com/google/common/testing/TestLogHandlerTest.java
* See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.testing; import java.util.logging.Level; import java.util.logging.LogRecord; import java.util.logging.Logger; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Unit test for {@link TestLogHandler}. * * @author kevinb */ @NullUnmarked
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 2.9K bytes - Viewed (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/AndroidLog.kt
*/ package okhttp3.internal.platform.android import android.util.Log import java.util.concurrent.CopyOnWriteArraySet import java.util.logging.Handler import java.util.logging.Level import java.util.logging.LogRecord import java.util.logging.Logger import okhttp3.OkHttpClient import okhttp3.internal.SuppressSignatureCheck import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.http2.Http2
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 22 20:03:31 UTC 2025 - 4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
* call this without consuming the complete response body, any remaining bytes in the response * body will be discarded before trailers are returned. * * If [Call.cancel] is called while this is blocking, this call will immediately throw. * * @throws IllegalStateException if the response is closed. * @throws IOException if the trailers cannot be loaded, such as if the network connection is * dropped.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 18.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt
if (headerNameIndex in 2..7) { // Only search a subset of the static header table. Most entries have an empty value, so // it's unnecessary to waste cycles looking at them. This check is built on the // observation that the header entries we care about are in adjacent pairs, and we // always know the first index of the pair.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 22.4K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableMap.java
entryOf(k4, v4), entryOf(k5, v5), entryOf(k6, v6), entryOf(k7, v7), entryOf(k8, v8), entryOf(k9, v9), entryOf(k10, v10)); } // looking for of() with > 10 entries? Use the builder instead. @SafeVarargs public static <K, V> ImmutableMap<K, V> ofEntries(Entry<? extends K, ? extends V>... entries) { return new RegularImmutableMap<>(entries); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Aug 06 18:32:41 UTC 2025 - 16.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
taskFaker.runTasks() } private fun connectHttp2( peer: MockHttp2Peer, realConnection: RealConnection, maxConcurrentStreams: Int, ): Http2Connection { // Write the mocking script. val settings1 = Settings() settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams peer.sendFrame().settings(settings1) peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 0)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 12.9K bytes - Viewed (0) -
settings.gradle.kts
include(":samples:simple-client") include(":samples:slack") include(":samples:static-server") include(":samples:tlssurvey") include(":samples:unixdomainsockets") include(":container-tests") project(":okhttp-logging-interceptor").name = "logging-interceptor" val androidHome = System.getenv("ANDROID_HOME") val localProperties = Properties().apply { val file = File("local.properties") if (file.exists()) { load(file.inputStream()) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jul 19 13:41:00 UTC 2025 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ForwardingMultiset.java
import java.util.Set; import org.jspecify.annotations.Nullable; /** * A multiset which forwards all its method calls to another multiset. Subclasses should override * one or more methods to modify the behavior of the backing multiset as desired per the <a * href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>. * * <p><b>Warning:</b> The methods of {@code ForwardingMultiset} forward <b>indiscriminately</b> to
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 10.3K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/feature_addition_request.yaml
#### Utility: compare with alternatives There is always *some* alternative to adding a new feature to Guava, even if it's just forking Guava yourself. We want to see that new features have some significant advantage over the alternatives. These advantages can take
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Nov 17 18:47:47 UTC 2023 - 5.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return result; } /** * Following the contract of {@link AbstractQueuedSynchronizer} we create a private subclass to * hold the synchronizer. This synchronizer is used to implement the blocking and waiting calls * as well as to handle state changes in a thread-safe manner. The current state of the future * is held in the Sync state, and the lock is released whenever the state changes to {@link
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jan 30 16:59:10 UTC 2025 - 13.7K bytes - Viewed (0)