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 <stddef.h> | 5 #include <stddef.h> |
6 #include <stdint.h> | 6 #include <stdint.h> |
7 | 7 |
8 #include "base/bind.h" | 8 #include "base/bind.h" |
9 #include "base/macros.h" | 9 #include "base/macros.h" |
10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
(...skipping 955 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
966 } | 966 } |
967 | 967 |
968 TEST_F(MultibufferDataSourceTest, Http_Read) { | 968 TEST_F(MultibufferDataSourceTest, Http_Read) { |
969 InitializeWith206Response(); | 969 InitializeWith206Response(); |
970 | 970 |
971 EXPECT_CALL(*this, ReadCallback(kDataSize)); | 971 EXPECT_CALL(*this, ReadCallback(kDataSize)); |
972 ReadAt(0, kDataSize * 2); | 972 ReadAt(0, kDataSize * 2); |
973 | 973 |
974 ReadAt(kDataSize, kDataSize); | 974 ReadAt(kDataSize, kDataSize); |
975 EXPECT_CALL(*this, ReadCallback(kDataSize)); | 975 EXPECT_CALL(*this, ReadCallback(kDataSize)); |
| 976 EXPECT_CALL(host_, |
| 977 AddBufferedByteRange(kDataSize, kDataSize + kDataSize / 2)); |
| 978 ReceiveData(kDataSize / 2); |
976 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize * 2)); | 979 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize * 2)); |
977 ReceiveData(kDataSize / 2); | 980 ReceiveData(kDataSize / 2); |
978 ReceiveData(kDataSize / 2); | |
979 | 981 |
980 EXPECT_TRUE(data_source_->downloading()); | 982 EXPECT_TRUE(data_source_->downloading()); |
981 Stop(); | 983 Stop(); |
982 } | 984 } |
983 | 985 |
984 TEST_F(MultibufferDataSourceTest, Http_ShareData) { | 986 TEST_F(MultibufferDataSourceTest, Http_ShareData) { |
985 InitializeWith206Response(); | 987 InitializeWith206Response(); |
986 | 988 |
987 EXPECT_CALL(*this, ReadCallback(kDataSize)); | 989 EXPECT_CALL(*this, ReadCallback(kDataSize)); |
988 ReadAt(0, kDataSize * 2); | 990 ReadAt(0, kDataSize * 2); |
989 | 991 |
990 ReadAt(kDataSize, kDataSize); | 992 ReadAt(kDataSize, kDataSize); |
991 EXPECT_CALL(*this, ReadCallback(kDataSize)); | 993 EXPECT_CALL(*this, ReadCallback(kDataSize)); |
| 994 EXPECT_CALL(host_, |
| 995 AddBufferedByteRange(kDataSize, kDataSize + kDataSize / 2)); |
| 996 ReceiveData(kDataSize / 2); |
992 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize * 2)); | 997 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize * 2)); |
993 ReceiveData(kDataSize / 2); | 998 ReceiveData(kDataSize / 2); |
994 ReceiveData(kDataSize / 2); | |
995 | 999 |
996 EXPECT_TRUE(data_source_->downloading()); | 1000 EXPECT_TRUE(data_source_->downloading()); |
997 | 1001 |
998 StrictMock<MockBufferedDataSourceHost> host2; | 1002 StrictMock<MockBufferedDataSourceHost> host2; |
999 MockMultibufferDataSource source2( | 1003 MockMultibufferDataSource source2( |
1000 GURL(kHttpUrl), UrlData::CORS_UNSPECIFIED, message_loop_.task_runner(), | 1004 GURL(kHttpUrl), UrlData::CORS_UNSPECIFIED, message_loop_.task_runner(), |
1001 url_index_, view_->mainFrame()->toWebLocalFrame(), &host2); | 1005 url_index_, view_->mainFrame()->toWebLocalFrame(), &host2); |
1002 source2.SetPreload(preload_); | 1006 source2.SetPreload(preload_); |
1003 | 1007 |
1004 EXPECT_CALL(*this, OnInitialize(true)); | 1008 EXPECT_CALL(*this, OnInitialize(true)); |
(...skipping 301 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1306 | 1310 |
1307 EXPECT_CALL(host_, SetTotalBytes(response_generator_->content_length())); | 1311 EXPECT_CALL(host_, SetTotalBytes(response_generator_->content_length())); |
1308 Respond(response_generator_->Generate206(0)); | 1312 Respond(response_generator_->Generate206(0)); |
1309 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize)); | 1313 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize)); |
1310 ReceiveData(kDataSize); | 1314 ReceiveData(kDataSize); |
1311 | 1315 |
1312 // Read a bit from the beginning. | 1316 // Read a bit from the beginning. |
1313 EXPECT_CALL(*this, ReadCallback(kDataSize)); | 1317 EXPECT_CALL(*this, ReadCallback(kDataSize)); |
1314 ReadAt(0); | 1318 ReadAt(0); |
1315 | 1319 |
| 1320 EXPECT_CALL(host_, AddBufferedByteRange(kDataSize, kDataSize + 1)); |
1316 ReceiveData(1); | 1321 ReceiveData(1); |
1317 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize * 3)); | 1322 EXPECT_CALL(host_, AddBufferedByteRange(0, kDataSize * 3)); |
1318 FinishLoading(); | 1323 FinishLoading(); |
1319 EXPECT_CALL(*this, ReadCallback(0)); | 1324 EXPECT_CALL(*this, ReadCallback(0)); |
1320 | 1325 |
1321 ReadAt(kDataSize + 5, kDataSize * 2); | 1326 ReadAt(kDataSize + 5, kDataSize * 2); |
1322 Stop(); | 1327 Stop(); |
1323 } | 1328 } |
1324 | 1329 |
1325 TEST_F(MultibufferDataSourceTest, Http_RetryThenRedirect) { | 1330 TEST_F(MultibufferDataSourceTest, Http_RetryThenRedirect) { |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1367 ReceiveData(kDataSize); | 1372 ReceiveData(kDataSize); |
1368 | 1373 |
1369 EXPECT_FALSE(data_source_->IsStreaming()); | 1374 EXPECT_FALSE(data_source_->IsStreaming()); |
1370 | 1375 |
1371 FinishLoading(); | 1376 FinishLoading(); |
1372 EXPECT_FALSE(loading()); | 1377 EXPECT_FALSE(loading()); |
1373 Stop(); | 1378 Stop(); |
1374 } | 1379 } |
1375 | 1380 |
1376 } // namespace media | 1381 } // namespace media |
OLD | NEW |