Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 32 for pin2 (0.02 sec)

  1. okhttp/src/jvmTest/kotlin/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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/job/PingSearchEngineJob.java

                resultBuf.append("Status of ")
                        .append(ping.getClusterName())
                        .append(" is changed to ")
                        .append(ping.getClusterStatus())
                        .append('.');
            } else if (status == 0) {
                resultBuf.append(ping.getClusterName()).append(" is alive.");
            } else {
                resultBuf.append(ping.getClusterName()).append(" is not available.");
            }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java

            assertEquals("Status of production-cluster is changed to GREEN.", result);
        }
    
        // Test with exception during ping
        public void test_execute_pingException() {
            SearchEngineClient searchEngineClient = new SearchEngineClient() {
                @Override
                public PingResponse ping() {
                    throw new RuntimeException("Connection failed");
                }
            };
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        payload2: Int,
      ) {
        try {
          writer.ping(reply, payload1, payload2)
        } catch (e: IOException) {
          failConnection(e)
        }
      }
    
      /** For testing: sends a ping and waits for a pong. */
      @Throws(InterruptedException::class)
      fun writePingAndAwaitPong() {
        writePing()
        awaitPong()
      }
    
      /** For testing: sends a ping to be awaited with [awaitPong]. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

        taskFaker.advanceUntil(ns(500L))
        server.processNextFrame() // Ping.
        client.processNextFrame() // Pong.
        taskFaker.advanceUntil(ns(1000L))
        server.processNextFrame() // Ping.
        client.processNextFrame() // Pong.
        taskFaker.advanceUntil(ns(1500L))
        server.processNextFrame() // Ping.
        client.processNextFrame() // Pong.
      }
    
      @Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  6. docs/en/docs/deployment/versions.md

    ## Pin your `fastapi` version { #pin-your-fastapi-version }
    
    The first thing you should do is to "pin" the version of **FastAPI** you are using to the specific latest version that you know works correctly for your application.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  7. 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 Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 54.6K bytes
    - Viewed (1)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          awaitingPong = true
        }
    
        if (failedPing != -1) {
          failWebSocket(
            e =
              SocketTimeoutException(
                "sent ping but didn't receive pong within " +
                  "${pingIntervalMillis}ms (after ${failedPing - 1} successful ping/pongs)",
              ),
            isWriter = true,
          )
          return
        }
    
        try {
          writer.writePing(ByteString.EMPTY)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  9. ci/official/requirements_updater/requirements.in

    auditwheel >= 6.1.0
    # Install tensorboard, and keras
    # Note that here we want the latest version that matches TF major.minor version
    # Note that we must use nightly here as these are used in nightly jobs
    # For release jobs, we will pin these on the release branch
    keras-nightly ~= 3.10.0.dev
    tb-nightly ~= 2.20.0.a
    # For new protobuf, if V.x.y is gencode version, then runtime version U must be
    # V <= U <= V+1
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Wed Sep 03 23:57:17 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        val settings1 = Settings()
        settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams
        peer.sendFrame().settings(settings1)
        peer.acceptFrame() // ACK
        peer.sendFrame().ping(false, 2, 0)
        peer.acceptFrame() // PING
        peer.play()
    
        // Play it back.
        val connection =
          Http2Connection
            .Builder(true, TaskRunner.INSTANCE)
            .socket(peer.openSocket().asBufferedSocket(), "peer")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
Back to top