Home
last modified time | relevance | path

Searched refs:flow_controller (Results 1 – 14 of 14) sorted by relevance

/external/chromium_org/net/quic/test_tools/
Dquic_flow_controller_peer.cc17 QuicFlowController* flow_controller, in SetSendWindowOffset() argument
19 flow_controller->send_window_offset_ = offset; in SetSendWindowOffset()
24 QuicFlowController* flow_controller, in SetReceiveWindowOffset() argument
26 flow_controller->receive_window_offset_ = offset; in SetReceiveWindowOffset()
31 QuicFlowController* flow_controller, uint64 window_size) { in SetMaxReceiveWindow() argument
32 flow_controller->max_receive_window_ = window_size; in SetMaxReceiveWindow()
37 QuicFlowController* flow_controller) { in SendWindowOffset() argument
38 return flow_controller->send_window_offset_; in SendWindowOffset()
43 QuicFlowController* flow_controller) { in SendWindowSize() argument
44 return flow_controller->SendWindowSize(); in SendWindowSize()
[all …]
Dquic_flow_controller_peer.h18 static void SetSendWindowOffset(QuicFlowController* flow_controller,
21 static void SetReceiveWindowOffset(QuicFlowController* flow_controller,
24 static void SetMaxReceiveWindow(QuicFlowController* flow_controller,
27 static uint64 SendWindowOffset(QuicFlowController* flow_controller);
29 static uint64 SendWindowSize(QuicFlowController* flow_controller);
31 static uint64 ReceiveWindowOffset(QuicFlowController* flow_controller);
33 static uint64 ReceiveWindowSize(QuicFlowController* flow_controller);
/external/chromium_org/net/quic/
Dquic_data_stream_test.cc292 QuicFlowControllerPeer::SetSendWindowOffset(stream_->flow_controller(), in TEST_P()
295 stream_->flow_controller())); in TEST_P()
310 QuicFlowControllerPeer::SendWindowSize(stream_->flow_controller())); in TEST_P()
334 QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(), in TEST_P()
336 QuicFlowControllerPeer::SetMaxReceiveWindow(stream_->flow_controller(), in TEST_P()
339 stream_->flow_controller())); in TEST_P()
352 stream_->flow_controller())); in TEST_P()
362 QuicFlowControllerPeer::ReceiveWindowSize(stream_->flow_controller())); in TEST_P()
377 QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(), in TEST_P()
379 QuicFlowControllerPeer::SetMaxReceiveWindow(stream_->flow_controller(), in TEST_P()
[all …]
Dquic_session_test.cc537 QuicFlowControllerPeer::SetSendWindowOffset(session_.flow_controller(), 0); in TEST_P()
538 EXPECT_TRUE(session_.flow_controller()->IsBlocked()); in TEST_P()
648 EXPECT_FALSE(stream2->flow_controller()->IsBlocked()); in TEST_P()
650 EXPECT_TRUE(stream2->flow_controller()->IsBlocked()); in TEST_P()
661 EXPECT_FALSE(stream2->flow_controller()->IsBlocked()); in TEST_P()
672 EXPECT_FALSE(crypto_stream->flow_controller()->IsBlocked()); in TEST_P()
675 EXPECT_FALSE(headers_stream->flow_controller()->IsBlocked()); in TEST_P()
678 while (!crypto_stream->flow_controller()->IsBlocked() && i < 1000) { in TEST_P()
685 EXPECT_TRUE(crypto_stream->flow_controller()->IsBlocked()); in TEST_P()
686 EXPECT_FALSE(headers_stream->flow_controller()->IsBlocked()); in TEST_P()
[all …]
Dreliable_quic_stream_test.cc407 QuicFlowControllerPeer::SendWindowOffset(stream_->flow_controller())); in TEST_F()
414 QuicFlowControllerPeer::SendWindowOffset(stream_->flow_controller())); in TEST_F()
426 QuicFlowControllerPeer::SendWindowOffset(stream_->flow_controller())); in TEST_F()
449 EXPECT_FALSE(stream_->flow_controller()->IsBlocked()); in TEST_F()
472 stream_->flow_controller()->UpdateSendWindowOffset(kDataSize + 1); in TEST_F()
473 session_->flow_controller()->UpdateSendWindowOffset(kDataSize + 1); in TEST_F()
525 stream_->flow_controller()->UpdateSendWindowOffset(kDataSize + 1); in TEST_F()
526 session_->flow_controller()->UpdateSendWindowOffset(kDataSize + 1); in TEST_F()
640 stream_->flow_controller())); in TEST_F()
Dquic_crypto_stream_test.cc107 EXPECT_FALSE(stream_.flow_controller()->IsEnabled()); in TEST_F()
109 EXPECT_TRUE(stream_.flow_controller()->IsEnabled()); in TEST_F()
Dquic_session.cc339 if (stream != NULL && !stream->flow_controller()->IsBlocked()) { in OnCanWrite()
428 stream->flow_controller()->IsEnabled()) { in CloseStreamInner()
430 stream->flow_controller()->highest_received_byte_offset(); in CloseStreamInner()
774 GetCryptoStream()->flow_controller()->Disable(); in OnSuccessfulVersionNegotiation()
775 headers_stream_->flow_controller()->Disable(); in OnSuccessfulVersionNegotiation()
780 it->second->flow_controller()->Disable(); in OnSuccessfulVersionNegotiation()
Dreliable_quic_stream.h102 QuicFlowController* flow_controller() { return &flow_controller_; } in flow_controller() function
Dquic_headers_stream_test.cc330 EXPECT_FALSE(headers_stream_->flow_controller()->IsEnabled()); in TEST_P()
332 EXPECT_TRUE(headers_stream_->flow_controller()->IsEnabled()); in TEST_P()
Dquic_session.h207 QuicFlowController* flow_controller() { return flow_controller_.get(); } in flow_controller() function
Dreliable_quic_stream.cc162 connection_flow_controller_(session_->flow_controller()), in ReliableQuicStream()
Dquic_client_session.cc454 DCHECK(flow_controller()); in CryptoConnect()
/external/chromium_org/net/tools/quic/
Dend_to_end_test.cc801 QuicFlowControllerPeer::SetSendWindowOffset(stream->flow_controller(), 0); in TEST_P()
802 QuicFlowControllerPeer::SetSendWindowOffset(session->flow_controller(), 0); in TEST_P()
803 EXPECT_TRUE(stream->flow_controller()->IsBlocked()); in TEST_P()
804 EXPECT_TRUE(session->flow_controller()->IsBlocked()); in TEST_P()
1297 stream->flow_controller())); in TEST_P()
1300 client_->client()->session()->flow_controller())); in TEST_P()
1312 session->flow_controller())); in TEST_P()
1340 QuicFlowControllerPeer::SendWindowSize(crypto_stream->flow_controller()), in TEST_P()
1343 client_->client()->session()->flow_controller())); in TEST_P()
1352 QuicFlowControllerPeer::SendWindowSize(headers_stream->flow_controller()), in TEST_P()
[all …]
Dquic_client_session.cc67 DCHECK(flow_controller()); in CryptoConnect()