Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 351 for locking (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. .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)
  10. 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)
Back to top