Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,765 for Pong (0.03 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/test/java/okhttp3/HeadersJvmTest.kt

            .add("ping:  pong  ") // Value whitespace is trimmed.
            .add("kit:kat") // Space after colon is not required.
            .build()
        assertThat(headers.values("foo")).containsExactly("bar", "baz", "bak")
        assertThat(headers.values("key")).containsExactly("value")
        assertThat(headers.values("ping")).containsExactly("pong")
        assertThat(headers.values("kit")).containsExactly("kat")
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        peer.acceptFrame() // DEGRADED PING
        peer.acceptFrame() // AWAIT PING
        peer.sendFrame().ping(true, Http2Connection.DEGRADED_PING, 1) // DEGRADED PONG
        peer.sendFrame().ping(true, Http2Connection.AWAIT_PING, 0) // AWAIT PONG
        peer.play()
    
        // Play it back.
        val connection = connect(peer)
        val stream = connection.newStream(headerEntries("b", "banana"), false)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  5. 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)
  6. okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt

      }
    
      fun assertPing(payload: ByteString) {
        assertThat(nextEvent()).isEqualTo(Ping(payload))
      }
    
      fun assertPong(payload: ByteString) {
        assertThat(nextEvent()).isEqualTo(Pong(payload))
      }
    
      fun assertClosing(
        code: Int,
        reason: String,
      ) {
        assertThat(nextEvent()).isEqualTo(Closing(code, reason))
      }
    
      fun assertClosed(
        code: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

    class WebSocketWriter(
      private val isClient: Boolean,
      val sink: BufferedSink,
      val random: Random,
      private val perMessageDeflate: Boolean,
      private val noContextTakeover: Boolean,
      private val minimumDeflateSize: Long,
    ) : Closeable {
      /** This holds outbound data for compression and masking. */
      private val messageBuffer = Buffer()
    
      /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top