| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/quic/core/quic_spdy_stream.h" | 5 #include "net/quic/core/quic_spdy_stream.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "net/quic/core/quic_connection.h" | 10 #include "net/quic/core/quic_connection.h" |
| (...skipping 955 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 966 "Trailers cannot be sent after a FIN"); | 966 "Trailers cannot be sent after a FIN"); |
| 967 } | 967 } |
| 968 | 968 |
| 969 TEST_P(QuicSpdyStreamTest, HeaderStreamNotiferCorrespondingSpdyStream) { | 969 TEST_P(QuicSpdyStreamTest, HeaderStreamNotiferCorrespondingSpdyStream) { |
| 970 Initialize(kShouldProcessData); | 970 Initialize(kShouldProcessData); |
| 971 if (!session_->use_stream_notifier()) { | 971 if (!session_->use_stream_notifier()) { |
| 972 return; | 972 return; |
| 973 } | 973 } |
| 974 EXPECT_CALL(*session_, WritevData(_, _, _, _, _, _)) | 974 EXPECT_CALL(*session_, WritevData(_, _, _, _, _, _)) |
| 975 .Times(AnyNumber()) | 975 .Times(AnyNumber()) |
| 976 .WillRepeatedly(Invoke(MockQuicSession::ConsumeAllData)); | 976 .WillRepeatedly( |
| 977 Invoke(session_.get(), &MockQuicSpdySession::ConsumeAndSaveAllData)); |
| 977 testing::InSequence s; | 978 testing::InSequence s; |
| 978 QuicReferenceCountedPointer<MockAckListener> ack_listener1( | 979 QuicReferenceCountedPointer<MockAckListener> ack_listener1( |
| 979 new MockAckListener()); | 980 new MockAckListener()); |
| 980 QuicReferenceCountedPointer<MockAckListener> ack_listener2( | 981 QuicReferenceCountedPointer<MockAckListener> ack_listener2( |
| 981 new MockAckListener()); | 982 new MockAckListener()); |
| 982 stream_->set_ack_listener(ack_listener1); | 983 stream_->set_ack_listener(ack_listener1); |
| 983 stream2_->set_ack_listener(ack_listener2); | 984 stream2_->set_ack_listener(ack_listener2); |
| 984 | 985 |
| 985 session_->headers_stream()->WriteOrBufferData("Header1", false, | 986 session_->headers_stream()->WriteOrBufferData("Header1", false, |
| 986 ack_listener1); | 987 ack_listener1); |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1023 // stream_ has unacked data and should become zombie. | 1024 // stream_ has unacked data and should become zombie. |
| 1024 EXPECT_TRUE(QuicContainsKey(QuicSessionPeer::zombie_streams(session_.get()), | 1025 EXPECT_TRUE(QuicContainsKey(QuicSessionPeer::zombie_streams(session_.get()), |
| 1025 stream_->id())); | 1026 stream_->id())); |
| 1026 EXPECT_TRUE(QuicSessionPeer::closed_streams(session_.get()).empty()); | 1027 EXPECT_TRUE(QuicSessionPeer::closed_streams(session_.get()).empty()); |
| 1027 } | 1028 } |
| 1028 } | 1029 } |
| 1029 | 1030 |
| 1030 } // namespace | 1031 } // namespace |
| 1031 } // namespace test | 1032 } // namespace test |
| 1032 } // namespace net | 1033 } // namespace net |
| OLD | NEW |