Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for pin1 (0.34 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        peer.sendFrame().ping(false, 2, 3)
        peer.acceptFrame() // PING
        peer.play()
    
        // Play it back.
        connect(peer)
    
        // Verify the peer received what was expected.
        val ping = peer.takeFrame()
        assertThat(ping.type).isEqualTo(Http2.TYPE_PING)
        assertThat(ping.streamId).isEqualTo(0)
        assertThat(ping.payload1).isEqualTo(2)
        assertThat(ping.payload2).isEqualTo(3)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  2. docs/changelogs/changelog_3x.md

        when pooled connections are evicted).
    
        If you have a configured ping interval, you should confirm that it is long
        enough for a roundtrip from client to server. If your ping interval is too
        short, slow connections may be misinterpreted as failed connections. A ping
        interval of 30 seconds is reasonable for most use cases.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(response.protocol).isEqualTo(protocol)
    
        // Confirm a single ping was sent and received, and its reply was sent and received.
        val logs = testLogHandler.takeAll()
        assertThat(countFrames(logs, "FINE: >> 0x00000000     8 PING          "))
          .isEqualTo(1)
        assertThat(countFrames(logs, "FINE: << 0x00000000     8 PING          "))
          .isEqualTo(1)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

         * Sets the interval between HTTP/2 and web socket pings initiated by this client. Use this to
         * automatically send ping frames until either the connection fails or it is closed. This keeps
         * the connection alive and may detect connectivity failures.
         *
         * If the server does not respond to each ping with a pong within `interval`, this client will
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                final PingResponse pingResponse = searchEngineClient.ping();
                writeJsonResponse(pingResponse.getStatus() == 0 ? HttpServletResponse.SC_OK : HttpServletResponse.SC_SERVICE_UNAVAILABLE,
                        "\"data\":" + pingResponse.getMessage());
            } catch (final Exception e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to process a ping request.", e);
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 50.3K bytes
    - Viewed (0)
  6. docs/bucket/notifications/README.md

    ```
    mc cp myphoto.jpg myminio/images
    ```
    
    In the previous terminal, you will now see the operation that MinIO performs on Redis:
    
    ```
    127.0.0.1:6379> monitor
    OK
    1490686879.650649 [0 172.17.0.1:44710] "PING"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  7. okhttp/api/okhttp.api

    }
    
    public final class okhttp3/CertificatePinner$Companion {
    	public final fun pin (Ljava/security/cert/Certificate;)Ljava/lang/String;
    	public final fun sha1Hash (Ljava/security/cert/X509Certificate;)Lokio/ByteString;
    	public final fun sha256Hash (Ljava/security/cert/X509Certificate;)Lokio/ByteString;
    }
    
    public final class okhttp3/CertificatePinner$Pin {
    	public fun <init> (Ljava/lang/String;Ljava/lang/String;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

                    logger.error(() -> "Failed to flush " + stream(indices).get(stream -> stream.collect(Collectors.joining(", "))), e);
                }
            });
    
        }
    
        public PingResponse ping() {
            try {
                final ClusterHealthResponse response =
                        client.admin().cluster().prepareHealth().execute().actionGet(ComponentUtil.getFessConfig().getIndexHealthTimeout());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Oct 20 02:08:03 UTC 2024
    - 86.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Futures.java

      // have two requirements that significantly complicate their design.
      // 1. Cancellation should propagate from the returned future to the input future(s).
      // 2. The returned futures shouldn't unnecessarily 'pin' their inputs after completion.
      //
      // A consequence of these requirements is that the delegate futures cannot be stored in
      // final fields.
      //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/Futures.java

      // have two requirements that significantly complicate their design.
      // 1. Cancellation should propagate from the returned future to the input future(s).
      // 2. The returned futures shouldn't unnecessarily 'pin' their inputs after completion.
      //
      // A consequence of these requirements is that the delegate futures cannot be stored in
      // final fields.
      //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
Back to top