QuicDataStream 426 net/quic/quic_client_session.cc QuicDataStream* QuicClientSession::CreateIncomingDataStream( QuicDataStream 178 net/quic/quic_client_session.h virtual QuicDataStream* CreateIncomingDataStream(QuicStreamId id) OVERRIDE; QuicDataStream 29 net/quic/quic_data_stream.cc QuicDataStream::QuicDataStream(QuicStreamId id, QuicDataStream 43 net/quic/quic_data_stream.cc QuicDataStream::~QuicDataStream() { QuicDataStream 46 net/quic/quic_data_stream.cc size_t QuicDataStream::WriteHeaders( QuicDataStream 60 net/quic/quic_data_stream.cc size_t QuicDataStream::Readv(const struct iovec* iov, size_t iov_len) { QuicDataStream 86 net/quic/quic_data_stream.cc int QuicDataStream::GetReadableRegions(iovec* iov, size_t iov_len) { QuicDataStream 99 net/quic/quic_data_stream.cc bool QuicDataStream::IsDoneReading() const { QuicDataStream 106 net/quic/quic_data_stream.cc bool QuicDataStream::HasBytesToRead() const { QuicDataStream 110 net/quic/quic_data_stream.cc void QuicDataStream::set_priority(QuicPriority priority) { QuicDataStream 115 net/quic/quic_data_stream.cc QuicPriority QuicDataStream::EffectivePriority() const { QuicDataStream 119 net/quic/quic_data_stream.cc uint32 QuicDataStream::ProcessRawData(const char* data, uint32 data_len) { QuicDataStream 127 net/quic/quic_data_stream.cc const IPEndPoint& QuicDataStream::GetPeerAddress() { QuicDataStream 131 net/quic/quic_data_stream.cc bool QuicDataStream::GetSSLInfo(SSLInfo* ssl_info) { QuicDataStream 135 net/quic/quic_data_stream.cc uint32 QuicDataStream::ProcessHeaderData() { QuicDataStream 150 net/quic/quic_data_stream.cc void QuicDataStream::OnStreamHeaders(StringPiece headers_data) { QuicDataStream 155 net/quic/quic_data_stream.cc void QuicDataStream::OnStreamHeadersPriority(QuicPriority priority) { QuicDataStream 160 net/quic/quic_data_stream.cc void QuicDataStream::OnStreamHeadersComplete(bool fin, size_t frame_len) { QuicDataStream 171 net/quic/quic_data_stream.cc void QuicDataStream::OnClose() { QuicDataStream 183 net/quic/quic_data_stream.cc bool QuicDataStream::FinishedReadingHeaders() { QuicDataStream 187 net/quic/quic_data_stream.cc bool QuicDataStream::IsFlowControlEnabled() const { QuicDataStream 38 net/quic/quic_data_stream.h class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream { QuicDataStream 46 net/quic/quic_data_stream.h virtual void OnClose(QuicDataStream* stream) = 0; QuicDataStream 55 net/quic/quic_data_stream.h QuicDataStream(QuicStreamId id, QuicSession* session); QuicDataStream 57 net/quic/quic_data_stream.h virtual ~QuicDataStream(); QuicDataStream 145 net/quic/quic_data_stream.h DISALLOW_COPY_AND_ASSIGN(QuicDataStream); QuicDataStream 36 net/quic/quic_data_stream_test.cc class TestStream : public QuicDataStream { QuicDataStream 41 net/quic/quic_data_stream_test.cc : QuicDataStream(id, session), QuicDataStream 17 net/quic/quic_reliable_client_stream.cc : QuicDataStream(id, session), QuicDataStream 60 net/quic/quic_reliable_client_stream.cc return QuicDataStream::EffectivePriority(); QuicDataStream 23 net/quic/quic_reliable_client_stream.h class NET_EXPORT_PRIVATE QuicReliableClientStream : public QuicDataStream { QuicDataStream 64 net/quic/quic_reliable_client_stream.h using QuicDataStream::set_priority; QuicDataStream 84 net/quic/quic_reliable_client_stream.h using QuicDataStream::HasBufferedData; QuicDataStream 155 net/quic/quic_session.cc QuicDataStream* stream = GetDataStream(stream_id); QuicDataStream 165 net/quic/quic_session.cc QuicDataStream* stream = GetDataStream(stream_id); QuicDataStream 176 net/quic/quic_session.cc QuicDataStream* stream = GetDataStream(stream_id); QuicDataStream 197 net/quic/quic_session.cc QuicDataStream* stream = GetDataStream(frame.stream_id); QuicDataStream 245 net/quic/quic_session.cc QuicDataStream* stream = GetDataStream(stream_id); QuicDataStream 345 net/quic/quic_session.cc QuicDataStream* stream = it->second; QuicDataStream 426 net/quic/quic_session.cc void QuicSession::ActivateStream(QuicDataStream* stream) { QuicDataStream 449 net/quic/quic_session.cc QuicDataStream* QuicSession::GetDataStream(const QuicStreamId stream_id) { QuicDataStream 480 net/quic/quic_session.cc QuicDataStream* QuicSession::GetIncomingDataStream(QuicStreamId stream_id) { QuicDataStream 513 net/quic/quic_session.cc QuicDataStream* stream = CreateIncomingDataStream(stream_id); QuicDataStream 203 net/quic/quic_session.h typedef base::hash_map<QuicStreamId, QuicDataStream*> DataStreamMap; QuicDataStream 208 net/quic/quic_session.h virtual QuicDataStream* CreateIncomingDataStream(QuicStreamId id) = 0; QuicDataStream 212 net/quic/quic_session.h virtual QuicDataStream* CreateOutgoingDataStream() = 0; QuicDataStream 218 net/quic/quic_session.h virtual void ActivateStream(QuicDataStream* stream); QuicDataStream 223 net/quic/quic_session.h QuicDataStream* GetIncomingDataStream(QuicStreamId stream_id); QuicDataStream 225 net/quic/quic_session.h QuicDataStream* GetDataStream(const QuicStreamId stream_id); QuicDataStream 235 net/quic/quic_session.h base::hash_map<QuicStreamId, QuicDataStream*>* streams() { QuicDataStream 239 net/quic/quic_session.h const base::hash_map<QuicStreamId, QuicDataStream*>* streams() const { QuicDataStream 243 net/quic/quic_session.h std::vector<QuicDataStream*>* closed_streams() { return &closed_streams_; } QuicDataStream 265 net/quic/quic_session.h std::vector<QuicDataStream*> closed_streams_; QuicDataStream 69 net/quic/quic_session_test.cc class TestStream : public QuicDataStream { QuicDataStream 72 net/quic/quic_session_test.cc : QuicDataStream(id, session) { QuicDataStream 131 net/quic/quic_session_test.cc QuicDataStream* GetIncomingDataStream(QuicStreamId stream_id) { QuicDataStream 263 net/quic/quic_session_test.cc QuicDataStream* stream1 = session_.GetIncomingDataStream(stream_id1); QuicDataStream 265 net/quic/quic_session_test.cc QuicDataStream* stream2 = session_.GetIncomingDataStream(stream_id2); QuicDataStream 273 net/quic/quic_session_test.cc QuicDataStream* stream3 = session_.GetIncomingDataStream(stream_id2 + 4); QuicDataStream 13 net/quic/test_tools/quic_data_stream_peer.cc void QuicDataStreamPeer::SetHeadersDecompressed(QuicDataStream* stream, QuicDataStream 12 net/quic/test_tools/quic_data_stream_peer.h class QuicDataStream; QuicDataStream 18 net/quic/test_tools/quic_data_stream_peer.h static void SetHeadersDecompressed(QuicDataStream* stream, QuicDataStream 36 net/quic/test_tools/quic_session_peer.cc QuicDataStream* QuicSessionPeer::GetIncomingDataStream( QuicDataStream 13 net/quic/test_tools/quic_session_peer.h class QuicDataStream; QuicDataStream 25 net/quic/test_tools/quic_session_peer.h static QuicDataStream* GetIncomingDataStream(QuicSession* session, QuicDataStream 367 net/quic/test_tools/quic_test_utils.h MOCK_METHOD1(CreateIncomingDataStream, QuicDataStream*(QuicStreamId id)); QuicDataStream 369 net/quic/test_tools/quic_test_utils.h MOCK_METHOD0(CreateOutgoingDataStream, QuicDataStream*()); QuicDataStream 399 net/quic/test_tools/quic_test_utils.h MOCK_METHOD1(CreateIncomingDataStream, QuicDataStream*(QuicStreamId id)); QuicDataStream 400 net/quic/test_tools/quic_test_utils.h MOCK_METHOD0(CreateOutgoingDataStream, QuicDataStream*()); QuicDataStream 423 net/quic/test_tools/quic_test_utils.h MOCK_METHOD1(CreateIncomingDataStream, QuicDataStream*(QuicStreamId id)); QuicDataStream 424 net/quic/test_tools/quic_test_utils.h MOCK_METHOD0(CreateOutgoingDataStream, QuicDataStream*()); QuicDataStream 275 net/tools/quic/quic_client.cc void QuicClient::OnClose(QuicDataStream* stream) { QuicDataStream 39 net/tools/quic/quic_client.h public QuicDataStream::Visitor { QuicDataStream 117 net/tools/quic/quic_client.h virtual void OnClose(QuicDataStream* stream) OVERRIDE; QuicDataStream 70 net/tools/quic/quic_client_session.cc QuicDataStream* QuicClientSession::CreateIncomingDataStream( QuicDataStream 55 net/tools/quic/quic_client_session.h virtual QuicDataStream* CreateIncomingDataStream(QuicStreamId id) OVERRIDE; QuicDataStream 65 net/tools/quic/quic_server_session.cc QuicDataStream* QuicServerSession::CreateIncomingDataStream( QuicDataStream 74 net/tools/quic/quic_server_session.cc QuicDataStream* QuicServerSession::CreateOutgoingDataStream() { QuicDataStream 66 net/tools/quic/quic_server_session.h virtual QuicDataStream* CreateIncomingDataStream(QuicStreamId id) OVERRIDE; QuicDataStream 67 net/tools/quic/quic_server_session.h virtual QuicDataStream* CreateOutgoingDataStream() OVERRIDE; QuicDataStream 34 net/tools/quic/quic_server_session_test.cc static QuicDataStream* GetIncomingDataStream( QuicDataStream 38 net/tools/quic/quic_server_session_test.cc static QuicDataStream* GetDataStream(QuicServerSession* s, QuicStreamId id) { QuicDataStream 21 net/tools/quic/quic_spdy_client_stream.cc : QuicDataStream(id, session), QuicDataStream 37 net/tools/quic/quic_spdy_client_stream.cc return QuicDataStream::OnStreamFrame(frame); QuicDataStream 43 net/tools/quic/quic_spdy_client_stream.cc QuicDataStream::OnStreamHeadersComplete(fin, frame_len); QuicDataStream 27 net/tools/quic/quic_spdy_client_stream.h class QuicSpdyClientStream : public QuicDataStream { QuicDataStream 67 net/tools/quic/quic_spdy_client_stream.h using QuicDataStream::set_priority; QuicDataStream 23 net/tools/quic/quic_spdy_server_stream.cc : QuicDataStream(id, session), QuicDataStream 28 net/tools/quic/quic_spdy_server_stream.h class QuicSpdyServerStream : public QuicDataStream { QuicDataStream 483 net/tools/quic/test_tools/quic_test_client.cc void QuicTestClient::OnClose(QuicDataStream* stream) { QuicDataStream 60 net/tools/quic/test_tools/quic_test_client.h public QuicDataStream::Visitor { QuicDataStream 130 net/tools/quic/test_tools/quic_test_client.h virtual void OnClose(QuicDataStream* stream) OVERRIDE; QuicDataStream 110 net/tools/quic/test_tools/quic_test_utils.h MOCK_METHOD1(CreateIncomingDataStream, QuicDataStream*(QuicStreamId id)); QuicDataStream 111 net/tools/quic/test_tools/quic_test_utils.h MOCK_METHOD0(CreateOutgoingDataStream, QuicDataStream*());