Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 802 for srcset (0.06 sec)

  1. mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt

      @Test fun testIPv4() {
        val socket =
          MockWebServerSocket(
            FakeSocket(
              localAddress = InetAddress.getByAddress("127.0.0.1", byteArrayOf(127, 0, 0, 1)),
              localPort = 80,
            ),
          )
        val request = RecordedRequest(DEFAULT_REQUEST_LINE_HTTP_1, headers, emptyList(), 0, ByteString.EMPTY, 0, 0, socket)
        assertThat(request.url.toString()).isEqualTo("http://127.0.0.1/")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ForwardingNavigableSet.java

       * boolean, Object, boolean)} method. If you override {@link #subSet(Object, boolean, Object,
       * boolean)}, you may wish to override {@link #subSet(Object, Object)} to forward to this
       * implementation.
       */
      @Override
      protected SortedSet<E> standardSubSet(
          @ParametricNullness E fromElement, @ParametricNullness E toElement) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  3. docs/contribute/concurrency.md

    We can't rely on application threads to read data from the socket. Application threads are transient: sometimes they're reading and writing and sometimes they're off doing application-layer things. But the socket is permanent, and it needs constant attention: we dispatch all incoming frames so the connection is good-to-go when the application layer needs it.
    
    So we have a dedicated thread for every socket that just reads frames and dispatches them.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RetryConnectionTest.kt

        val attempt1 = attempt0.nextConnectionSpec(connectionSpecs, socket)
        assertThat(attempt1).isNotNull()
        assertThat(attempt1!!.isTlsFallback).isTrue()
        socket.close()
    
        // COMPATIBLE_TLS is used here.
        socket = createSocketWithEnabledProtocols(*enabledSocketTlsVersions)
        connectionSpecs[attempt1.connectionSpecIndex].apply(socket, attempt1.isTlsFallback)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt

          .build()
    
      class SocketClosingEventListener : EventListener() {
        var shouldClose: Boolean = false
        var lastSocket: Socket? = null
    
        override fun connectionAcquired(
          call: Call,
          connection: Connection,
        ) {
          lastSocket = connection.socket()
        }
    
        override fun requestHeadersStart(call: Call) {
          if (shouldClose) {
            lastSocket!!.close()
          }
        }
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 21:11:09 UTC 2025
    - 3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/ImmutableRangeSetTest.java

          for (int j = i + 1; j <= 20; j++) {
            assertEquals(expectedSet.subSet(i, false, j, false), asSet.subSet(i, false, j, false));
            assertEquals(expectedSet.subSet(i, true, j, false), asSet.subSet(i, true, j, false));
            assertEquals(expectedSet.subSet(i, false, j, true), asSet.subSet(i, false, j, true));
            assertEquals(expectedSet.subSet(i, true, j, true), asSet.subSet(i, true, j, true));
          }
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 25 16:19:30 UTC 2025
    - 21.7K bytes
    - Viewed (0)
  7. tensorflow/BUILD

    # filegroup(
    #     name = "copybara_library",
    #     srcs = glob(
    #         [
    #             "*.bara.sky",
    #             "*.dic",
    #             "*.ftrcp",
    #         ],
    #         exclude = [
    #             "copy.bara.sky",
    #         ],
    #     ),
    #     visibility = ["//visibility:public"],
    # )
    #
    # filegroup(
    #     name = "copybara_config",
    #     srcs = ["copy.bara.sky"],
    #     data = [
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Aug 28 19:11:51 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  8. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java

      }
    
      @Override public Socket createSocket(String host, int port) throws IOException {
        Socket result = createSocket();
    
        try {
          result.connect(new InetSocketAddress(host, port));
        } catch (IOException e) {
          result.close();
          throw e;
        }
        return result;
      }
    
      @Override public Socket createSocket(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Dec 03 21:33:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  9. src/main/resources/fess_label_en.properties

    labels.ldap_memberof_attribute=memberOf Attribute
    labels.notification_login=Login Page
    labels.notification_search_top=Search Top Page
    labels.storage_endpoint=Endpoint
    labels.storage_access_key=Access Key
    labels.storage_secret_key=Secret Key
    labels.storage_bucket=Bucket
    labels.send_testmail=Send Test Mail
    labels.backup_configuration=Backup
    labels.backup_name=Name
    labels.backup_bulk_file=Bulk File
    labels.backup_button_upload=Upload
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 10 04:56:21 UTC 2025
    - 40.7K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/MockSocketHandler.kt

      }
    
      override fun handle(socket: Socket) {
        val task = serviceSocketTask(socket.asBufferedSocket())
        results.add(task)
        task.run()
      }
    
      /** Returns a task that processes both request and response from [socket]. */
      private fun serviceSocketTask(socket: BufferedSocket): FutureTask<Void> {
        return FutureTask<Void> {
          socket.source.use {
            socket.sink.use {
              while (true) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top