Home
last modified time | relevance | path

Searched refs:QuicStreamPeer (Results 1 – 19 of 19) sorted by relevance

/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_stream_peer.cc18 void QuicStreamPeer::SetWriteSideClosed(bool value, QuicStream* stream) { in SetWriteSideClosed()
23 void QuicStreamPeer::SetStreamBytesWritten( in SetStreamBytesWritten()
32 void QuicStreamPeer::SetSendWindowOffset(QuicStream* stream, in SetSendWindowOffset()
39 QuicByteCount QuicStreamPeer::bytes_consumed(QuicStream* stream) { in bytes_consumed()
44 void QuicStreamPeer::SetReceiveWindowOffset(QuicStream* stream, in SetReceiveWindowOffset()
51 void QuicStreamPeer::SetMaxReceiveWindow(QuicStream* stream, in SetMaxReceiveWindow()
57 QuicByteCount QuicStreamPeer::SendWindowSize(QuicStream* stream) { in SendWindowSize()
62 QuicStreamOffset QuicStreamPeer::ReceiveWindowOffset(QuicStream* stream) { in ReceiveWindowOffset()
68 QuicByteCount QuicStreamPeer::ReceiveWindowSize(QuicStream* stream) { in ReceiveWindowSize()
73 QuicStreamOffset QuicStreamPeer::SendWindowOffset(QuicStream* stream) { in SendWindowOffset()
[all …]
Dquic_stream_peer.h22 class QuicStreamPeer {
24 QuicStreamPeer() = delete;
Dcrypto_test_utils.cc360 QuicSession* session = QuicStreamPeer::session(stream); in SendHandshakeMessageToStream()
595 QuicStreamPeer::session(client)->connection()); in CompareClientAndServerKeys()
597 QuicStreamPeer::session(server)->connection()); in CompareClientAndServerKeys()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_stream_test.cc284 EXPECT_EQ(QuicStreamPeer::SendWindowSize(&stream), in TEST_P()
481 QuicStreamPeer::SetStreamBytesWritten(kMaxStreamLength - data.length(), in TEST_P()
574 QuicStreamPeer::CloseReadSide(stream_); in TEST_P()
598 QuicStreamPeer::CloseReadSide(stream_); in TEST_P()
612 QuicStreamPeer::SendWindowOffset(stream_)); in TEST_P()
619 QuicStreamPeer::SendWindowOffset(stream_)); in TEST_P()
633 QuicStreamPeer::SendWindowOffset(stream_)); in TEST_P()
663 EXPECT_GT(frame.offset, QuicStreamPeer::ReceiveWindowOffset(stream_)); in TEST_P()
694 QuicStreamPeer::ReceiveWindowOffset(stream_)); in TEST_P()
747 QuicStreamPeer::ReceiveWindowOffset(stream_); in TEST_P()
[all …]
Dquic_stream_send_buffer.h20 class QuicStreamPeer; variable
132 friend class test::QuicStreamPeer;
Dquic_stream.h46 class QuicStreamPeer; variable
483 friend class test::QuicStreamPeer;
Dquic_session_test.cc370 QuicStreamPeer::SendBuffer(stream).SaveStreamData("not empty"); in SendStreamData()
374 QuicStreamPeer::SendBuffer(stream).OnStreamDataConsumed( in SendStreamData()
1693 EXPECT_TRUE(QuicStreamPeer::read_side_closed(stream)); in TEST_P()
2021 QuicStreamPeer::SendWindowSize(bidirectional_stream); in TEST_P()
2257 QuicStreamPeer::CloseReadSide(stream); in TEST_P()
2268 EXPECT_TRUE(QuicStreamPeer::read_side_closed(stream)); in TEST_P()
2333 QuicStreamPeer::SetStreamBytesWritten(3, stream2); in TEST_P()
2347 QuicStreamPeer::SetStreamBytesWritten(3, stream2); in TEST_P()
2372 EXPECT_EQ(1u, QuicStreamPeer::SendBuffer(stream2).size()); in TEST_P()
2649 QuicStreamPeer::CloseReadSide(stream2); in TEST_P()
[all …]
Dquic_crypto_client_stream_test.cc270 QuicStreamSequencer* sequencer = QuicStreamPeer::sequencer(stream()); in TEST_F()
Dquic_crypto_stream_test.cc209 QuicStreamPeer::StreamContributesToConnectionFlowControl(stream_)); in TEST_F()
/external/cronet/net/third_party/quiche/src/quiche/quic/tools/
Dquic_simple_server_stream_test.cc346 QuicStreamPeer::SetFinSent(stream_); in TEST_P()
415 QuicStreamPeer::SetFinReceived(stream_); in TEST_P()
425 EXPECT_FALSE(QuicStreamPeer::read_side_closed(stream_)); in TEST_P()
447 QuicStreamPeer::SetFinReceived(stream_); in TEST_P()
457 EXPECT_FALSE(QuicStreamPeer::read_side_closed(stream_)); in TEST_P()
477 QuicStreamPeer::SetFinReceived(stream_); in TEST_P()
487 EXPECT_FALSE(QuicStreamPeer::read_side_closed(stream_)); in TEST_P()
517 QuicStreamPeer::SetFinReceived(stream_); in TEST_P()
530 EXPECT_FALSE(QuicStreamPeer::read_side_closed(stream_)); in TEST_P()
572 QuicStreamPeer::SetFinReceived(stream_); in TEST_P()
[all …]
/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_spdy_stream_test.cc853 QuicStreamPeer::CloseReadSide(stream_); in TEST_P()
900 EXPECT_EQ(data.length(), QuicStreamPeer::bytes_consumed(stream_)); in TEST_P()
921 QuicStreamPeer::bytes_consumed(stream_)); in TEST_P()
984 QuicStreamPeer::SetSendWindowOffset(stream_, kWindow); in TEST_P()
985 EXPECT_EQ(kWindow, QuicStreamPeer::SendWindowOffset(stream_)); in TEST_P()
1002 EXPECT_EQ(0u, QuicStreamPeer::SendWindowSize(stream_)); in TEST_P()
1020 QuicStreamPeer::SetReceiveWindowOffset(stream_, kWindow); in TEST_P()
1021 QuicStreamPeer::SetMaxReceiveWindow(stream_, kWindow); in TEST_P()
1043 QuicStreamPeer::ReceiveWindowSize(stream_)); in TEST_P()
1052 QuicStreamPeer::ReceiveWindowSize(stream_)); in TEST_P()
[all …]
Dquic_spdy_stream.h48 class QuicStreamPeer; variable
373 friend class test::QuicStreamPeer;
Dend_to_end_test.cc701 EXPECT_EQ(QuicStreamPeer::SendWindowSize(client), in ExpectFlowControlsSynced()
702 QuicStreamPeer::ReceiveWindowSize(server)); in ExpectFlowControlsSynced()
703 EXPECT_EQ(QuicStreamPeer::ReceiveWindowSize(client), in ExpectFlowControlsSynced()
704 QuicStreamPeer::SendWindowSize(server)); in ExpectFlowControlsSynced()
973 QuicStreamPeer::sequencer(client_crypto_stream); in TEST_P()
1000 server_sequencer = QuicStreamPeer::sequencer(server_crypto_stream); in TEST_P()
2315 QuicStreamPeer::SetSendWindowOffset(stream, 0); in TEST_P()
2426 QuicStreamPeer::SetStreamBytesWritten(3, stream); in TEST_P()
2433 QuicStreamPeer::SetWriteSideClosed(false, client_->GetOrCreateStream()); in TEST_P()
3615 EXPECT_EQ(kServerStreamIFCW, QuicStreamPeer::SendWindowOffset(stream)); in TEST_P()
[all …]
Dquic_spdy_server_stream_base_test.cc71 QuicStreamPeer::SetFinSent(stream_); in TEST_F()
Dquic_spdy_session_test.cc367 QuicStreamPeer::SendBuffer(stream).SaveStreamData("not empty"); in SendStreamData()
371 QuicStreamPeer::SendBuffer(stream).OnStreamDataConsumed( in SendStreamData()
1585 QuicStreamPeer::SetSendWindowOffset(headers_stream, 0); in TEST_P()
1811 QuicStreamPeer::CloseReadSide(stream); in TEST_P()
1822 EXPECT_TRUE(QuicStreamPeer::read_side_closed(stream)); in TEST_P()
1858 QuicStreamPeer::SendBuffer(headers_stream); in TEST_P()
3694 QuicStreamPeer::SendBuffer(headers_stream); in TEST_P()
Dquic_receive_control_stream_test.cc113 return QuicStreamPeer::sequencer(receive_control_stream_) in NumBytesConsumed()
Dquic_spdy_client_session_test.cc1021 QuicStreamPeer::SendWindowOffset(control_stream)); in TEST_P()
1054 QuicStreamPeer::SendWindowOffset(control_stream)); in TEST_P()
Dquic_headers_stream_test.cc736 EXPECT_FALSE(QuicStreamPeer::StreamContributesToConnectionFlowControl( in TEST_P()
/external/cronet/net/quic/
Dquic_chromium_client_session_test.cc1811 quic::test::QuicStreamPeer::SendBuffer(stream).SaveStreamData(data); in TEST_P()
1812 quic::test::QuicStreamPeer::SetStreamBytesWritten(4, stream); in TEST_P()