Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 829 for Pong (0.02 seconds)

  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. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

       * To differentiate the two cases we ping the server when a stream times out. If the overall
       * connection is fine the ping will receive a pong; otherwise it won't.
       *
       * The deadline to respond to this ping attempts to limit the cost of being wrong. If it is too
       * long, streams created while we await the pong will reuse broken connections and inevitably
       * fail. If it is too short, slow connections will be marked as failed and extra TCP and TLS
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 31.8K bytes
    - Click Count (0)
  5. 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)
  6. internal/grid/muxclient.go

    	case m.outBlock <- struct{}{}:
    	default:
    		gridLogIf(m.ctx, errors.New("output unblocked overflow"))
    	}
    }
    
    func (m *muxClient) pong(msg pongMsg) {
    	if msg.NotFound || msg.Err != nil {
    		err := errors.New("remote terminated call")
    		if msg.Err != nil {
    			err = fmt.Errorf("remove pong failed: %v", &msg.Err)
    		}
    		m.addResponse(Response{Err: err})
    		return
    	}
    	atomic.StoreInt64(&m.LastPong, time.Now().UnixNano())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top