Searched refs:flowControlPing (Results 1 – 5 of 5) sorted by relevance
368 assertEquals(1, handler.flowControlPing().getPingCount()); in dataPingSentOnHeaderRecieved()379 long pingData = handler.flowControlPing().payload(); in dataPingAckIsRecognized()382 assertEquals(1, handler.flowControlPing().getPingCount()); in dataPingAckIsRecognized()383 assertEquals(1, handler.flowControlPing().getPingReturn()); in dataPingAckIsRecognized()401 assertEquals(length * 3, handler.flowControlPing().getDataSincePing()); in dataSizeSincePingAccumulates()426 long pingData = handler.flowControlPing().payload(); in windowUpdateMatchesTarget()429 assertEquals(accumulator, handler.flowControlPing().getDataSincePing()); in windowUpdateMatchesTarget()441 int maxWindow = handler.flowControlPing().maxWindow(); in windowShouldNotExceedMaxWindowSize()443 handler.flowControlPing().setDataSizeSincePing(maxWindow); in windowShouldNotExceedMaxWindowSize()444 long payload = handler.flowControlPing().payload(); in windowShouldNotExceedMaxWindowSize()
629 long pingData = handler().flowControlPing().payload(); in oustandingUserPingShouldNotInteractWithDataPing()632 assertEquals(1, handler().flowControlPing().getPingReturn()); in oustandingUserPingShouldNotInteractWithDataPing()637 assertEquals(1, handler().flowControlPing().getPingReturn()); in oustandingUserPingShouldNotInteractWithDataPing()
41 private final FlowControlPinger flowControlPing = new FlowControlPinger(); field in AbstractNettyHandler106 FlowControlPinger flowControlPing() { in flowControlPing() method in AbstractNettyHandler107 return flowControlPing; in flowControlPing()
353 flowControlPing().onDataRead(data.readableBytes(), padding); in onDataRead()777 if (ackPayload == flowControlPing().payload()) { in onPingAckRead()778 flowControlPing().updateWindow(); in onPingAckRead()
461 flowControlPing().onDataRead(data.readableBytes(), padding); in onDataRead()775 if (data == flowControlPing().payload()) { in onPingAckRead()776 flowControlPing().updateWindow(); in onPingAckRead()