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_headers_stream.h" | 5 #include "net/quic/core/quic_headers_stream.h" |
6 | 6 |
7 #include <cstdint> | 7 #include <cstdint> |
8 #include <ostream> | 8 #include <ostream> |
9 #include <string> | 9 #include <string> |
10 #include <tuple> | 10 #include <tuple> |
(...skipping 1030 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1041 EXPECT_EQ(consumed_data.fin_consumed, false); | 1041 EXPECT_EQ(consumed_data.fin_consumed, false); |
1042 } | 1042 } |
1043 | 1043 |
1044 TEST_P(QuicHeadersStreamTest, AckSentData) { | 1044 TEST_P(QuicHeadersStreamTest, AckSentData) { |
1045 if (!session_.use_stream_notifier()) { | 1045 if (!session_.use_stream_notifier()) { |
1046 return; | 1046 return; |
1047 } | 1047 } |
1048 EXPECT_CALL(session_, | 1048 EXPECT_CALL(session_, |
1049 WritevData(headers_stream_, kHeadersStreamId, _, _, NO_FIN, _)) | 1049 WritevData(headers_stream_, kHeadersStreamId, _, _, NO_FIN, _)) |
1050 .WillRepeatedly( | 1050 .WillRepeatedly( |
1051 WithArgs<2>(Invoke(this, &QuicHeadersStreamTest::SaveIov))); | 1051 Invoke(&session_, &MockQuicSpdySession::ConsumeAndSaveAllData)); |
1052 InSequence s; | 1052 InSequence s; |
1053 QuicReferenceCountedPointer<MockAckListener> ack_listener1( | 1053 QuicReferenceCountedPointer<MockAckListener> ack_listener1( |
1054 new MockAckListener()); | 1054 new MockAckListener()); |
1055 QuicReferenceCountedPointer<MockAckListener> ack_listener2( | 1055 QuicReferenceCountedPointer<MockAckListener> ack_listener2( |
1056 new MockAckListener()); | 1056 new MockAckListener()); |
1057 QuicReferenceCountedPointer<MockAckListener> ack_listener3( | 1057 QuicReferenceCountedPointer<MockAckListener> ack_listener3( |
1058 new MockAckListener()); | 1058 new MockAckListener()); |
1059 | 1059 |
1060 // Packet 1. | 1060 // Packet 1. |
1061 headers_stream_->WriteOrBufferData("Header5", false, ack_listener1); | 1061 headers_stream_->WriteOrBufferData("Header5", false, ack_listener1); |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1096 headers_stream_->OnStreamFrameAcked(frame1, QuicTime::Delta::Zero()); | 1096 headers_stream_->OnStreamFrameAcked(frame1, QuicTime::Delta::Zero()); |
1097 headers_stream_->OnStreamFrameAcked(frame2, QuicTime::Delta::Zero()); | 1097 headers_stream_->OnStreamFrameAcked(frame2, QuicTime::Delta::Zero()); |
1098 // Unsent data is acked. | 1098 // Unsent data is acked. |
1099 EXPECT_CALL(*connection_, CloseConnection(QUIC_INTERNAL_ERROR, _, _)); | 1099 EXPECT_CALL(*connection_, CloseConnection(QUIC_INTERNAL_ERROR, _, _)); |
1100 headers_stream_->OnStreamFrameAcked(frame3, QuicTime::Delta::Zero()); | 1100 headers_stream_->OnStreamFrameAcked(frame3, QuicTime::Delta::Zero()); |
1101 } | 1101 } |
1102 | 1102 |
1103 } // namespace | 1103 } // namespace |
1104 } // namespace test | 1104 } // namespace test |
1105 } // namespace net | 1105 } // namespace net |
OLD | NEW |