Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 657 for Pong (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

        // At 0ms the server sends 3 unexpected pongs. The client accepts 'em and ignores em.
        server.webSocket!!.pong("pong 1".encodeUtf8())
        client.processNextFrame()
        server.webSocket!!.pong("pong 2".encodeUtf8())
        client.processNextFrame()
        taskFaker.runTasks()
        server.webSocket!!.pong("pong 3".encodeUtf8())
        client.processNextFrame()
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 18.7K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketReaderTest.kt

      }
    
      @Test fun clientTwoFrameHelloWithPongs() {
        data.write("010348656c".decodeHex()) // Hel
        data.write("8a00".decodeHex()) // Pong
        data.write("8a00".decodeHex()) // Pong
        data.write("8a00".decodeHex()) // Pong
        data.write("8a00".decodeHex()) // Pong
        data.write("80026c6f".decodeHex()) // lo
        clientReader.processNextFrame()
        callback.assertPong(EMPTY)
        callback.assertPong(EMPTY)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      private val pingIntervalMillis: Long,
      /**
       * For clients this is initially null, and will be assigned to the agreed-upon extensions. For
       * servers, it should be the agreed-upon extensions immediately.
       */
      private var extensions: WebSocketExtensions?,
      /** If compression is negotiated, outbound messages of this size and larger will be compressed. */
      private var minimumDeflateSize: Long,
      private val webSocketCloseTimeout: Long,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  4. internal/grid/connection.go

    		return
    	}
    	// Single calls do not support pinging.
    	if v, ok := c.inStream.Load(m.MuxID); ok {
    		pong := v.ping(m.Seq)
    		pong.T = ping.T
    		gridLogIf(ctx, c.queueMsg(m, &pong))
    	} else {
    		pong := pongMsg{NotFound: true, T: ping.T}
    		gridLogIf(ctx, c.queueMsg(m, &pong))
    	}
    }
    
    func (c *Connection) handleDisconnectClientMux(m message) {
    	if v, ok := c.outgoing.Load(m.MuxID); ok {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        clientListener.assertOpen()
    
        // Send messages until the client's outgoing buffer overflows!
        val message: ByteString = ByteString.of(*ByteArray(1024 * 1024))
        var messageCount: Long = 0
        while (true) {
          val success = webSocket.send(message)
          if (!success) break
          messageCount++
          val queueSize = webSocket.queueSize()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  6. docs/en/docs/img/sponsors/kong.png

    kong.png...
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu May 30 13:28:20 GMT 2024
    - 30K bytes
    - Click Count (0)
  7. docs/en/docs/img/sponsors/kong-banner.png

    kong-banner.png...
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu May 30 13:28:20 GMT 2024
    - 20.6K bytes
    - Click Count (0)
  8. src/main/java/jcifs/util/SmbCircuitBreaker.java

                private final long totalRequests;
                private final long totalFailures;
                private final double failureRate;
                private final long averageResponseTime;
                private final long minResponseTime;
                private final long maxResponseTime;
    
                public WindowMetrics(long totalRequests, long totalFailures, double failureRate, long averageResponseTime, long minResponseTime,
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/entity/AccessResultImplTest.java

            // Test ID getter/setter
            AccessResultImpl<Long> result = new AccessResultImpl<>();
    
            result.setId(123L);
            assertEquals(Long.valueOf(123L), result.getId());
    
            result.setId(null);
            assertNull(result.getId());
        }
    
        public void test_sessionIdGetterSetter() {
            // Test session ID getter/setter
            AccessResultImpl<Long> result = new AccessResultImpl<>();
    
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Nov 13 13:29:22 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  10. src/test/java/jcifs/internal/fscc/FileEndOfFileInformationTest.java

        @DisplayName("Test encode and decode round trip")
        void testEncodeDecodeRoundTrip() throws SMBProtocolDecodingException {
            // Test various values
            long[] testValues = { 0L, 1L, -1L, Long.MAX_VALUE, Long.MIN_VALUE, 0x123456789ABCDEFL };
    
            for (long testValue : testValues) {
                // Create and encode
                FileEndOfFileInformation original = new FileEndOfFileInformation(testValue);
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.9K bytes
    - Click Count (0)
Back to Top