Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ack (0.01 sec)

  1. internal/grid/muxclient.go

    func (m *muxClient) error(err RemoteErr) {
    	if debugPrint {
    		fmt.Printf("mux %d: got remote err:%v\n", m.MuxID, string(err))
    	}
    	m.addResponse(Response{Err: &err})
    }
    
    func (m *muxClient) ack(seq uint32) {
    	if !m.checkSeq(seq) {
    		return
    	}
    	if m.acked || m.outBlock == nil {
    		return
    	}
    	available := cap(m.outBlock)
    	for range available {
    		m.outBlock <- struct{}{}
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(countFrames(logs, "FINE: << 0x00000000     8 PING          "))
          .isEqualTo(1)
        assertThat(countFrames(logs, "FINE: >> 0x00000000     8 PING          ACK"))
          .isEqualTo(1)
        assertThat(countFrames(logs, "FINE: << 0x00000000     8 PING          ACK"))
          .isEqualTo(1)
      }
    
      @Test
      fun missingPongsFailsConnection() {
        if (protocol === Protocol.HTTP_2) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (0)
Back to top