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

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

Completed in 1619 milliseconds