Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 709 for Pong (0.02 sec)

  1. okhttp/src/test/java/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()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. okhttp/src/test/java/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)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  3. okhttp/src/main/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,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  4. okhttp/src/main/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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (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))
    	}
    	return
    }
    
    func (c *Connection) handleDisconnectClientMux(m message) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (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())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/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()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  8. docs/en/docs/img/sponsors/kong.png

    kong.png...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu May 30 13:28:20 UTC 2024
    - 30K bytes
    - Viewed (0)
  9. docs/en/docs/img/sponsors/kong-banner.png

    kong-banner.png...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu May 30 13:28:20 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  10. docs/vi/docs/features.md

    * Thậm chí, các dependency có thể có các dependency khác, tạo thành một phân cấp hoặc **"một đồ thị" của các dependency**.
    * Tất cả **được xử lí tự động** bởi framework.
    * Tất cả các dependency có thể yêu cầu dữ liệu từ request và **tăng cường các ràng buộc từ đường dẫn** và tự động tài liệu hóa.
    * **Tự động hóa validation**, thậm chí với các tham số *đường dẫn* định nghĩa trong các dependency.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 11.5K bytes
    - Viewed (0)
Back to top