| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/base/elements_upload_data_stream.h" | 5 #include "net/base/elements_upload_data_stream.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 651 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 662 element_readers_.push_back( | 662 element_readers_.push_back( |
| 663 new UploadFileElementReader(base::MessageLoopProxy::current().get(), | 663 new UploadFileElementReader(base::MessageLoopProxy::current().get(), |
| 664 temp_file_path, | 664 temp_file_path, |
| 665 0, | 665 0, |
| 666 kuint64max, | 666 kuint64max, |
| 667 base::Time())); | 667 base::Time())); |
| 668 scoped_ptr<UploadDataStream> stream( | 668 scoped_ptr<UploadDataStream> stream( |
| 669 new ElementsUploadDataStream(element_readers_.Pass(), 0)); | 669 new ElementsUploadDataStream(element_readers_.Pass(), 0)); |
| 670 | 670 |
| 671 std::vector<char> expected_data(kTestData, kTestData + kTestDataSize); | 671 std::vector<char> expected_data(kTestData, kTestData + kTestDataSize); |
| 672 expected_data.insert(expected_data.end(), expected_data.begin(), | 672 expected_data.insert(expected_data.end(), kTestData, |
| 673 expected_data.begin() + kTestDataSize); | 673 kTestData + kTestDataSize); |
| 674 | 674 |
| 675 // Call Init(). | 675 // Call Init(). |
| 676 TestCompletionCallback init_callback1; | 676 TestCompletionCallback init_callback1; |
| 677 ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); | 677 ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); |
| 678 EXPECT_EQ(OK, init_callback1.WaitForResult()); | 678 EXPECT_EQ(OK, init_callback1.WaitForResult()); |
| 679 EXPECT_FALSE(stream->IsEOF()); | 679 EXPECT_FALSE(stream->IsEOF()); |
| 680 EXPECT_EQ(kTestDataSize*2, stream->size()); | 680 EXPECT_EQ(kTestDataSize*2, stream->size()); |
| 681 | 681 |
| 682 // Read some. | 682 // Read some. |
| 683 TestCompletionCallback read_callback1; | 683 TestCompletionCallback read_callback1; |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 721 element_readers_.push_back( | 721 element_readers_.push_back( |
| 722 new UploadFileElementReader(base::MessageLoopProxy::current().get(), | 722 new UploadFileElementReader(base::MessageLoopProxy::current().get(), |
| 723 temp_file_path, | 723 temp_file_path, |
| 724 0, | 724 0, |
| 725 kuint64max, | 725 kuint64max, |
| 726 base::Time())); | 726 base::Time())); |
| 727 scoped_ptr<UploadDataStream> stream( | 727 scoped_ptr<UploadDataStream> stream( |
| 728 new ElementsUploadDataStream(element_readers_.Pass(), 0)); | 728 new ElementsUploadDataStream(element_readers_.Pass(), 0)); |
| 729 | 729 |
| 730 std::vector<char> expected_data(kTestData, kTestData + kTestDataSize); | 730 std::vector<char> expected_data(kTestData, kTestData + kTestDataSize); |
| 731 expected_data.insert(expected_data.end(), expected_data.begin(), | 731 expected_data.insert(expected_data.end(), kTestData, |
| 732 expected_data.begin() + kTestDataSize); | 732 kTestData + kTestDataSize); |
| 733 | 733 |
| 734 // Start Init. | 734 // Start Init. |
| 735 TestCompletionCallback init_callback1; | 735 TestCompletionCallback init_callback1; |
| 736 EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); | 736 EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); |
| 737 | 737 |
| 738 // Call Init again to cancel the previous init. | 738 // Call Init again to cancel the previous init. |
| 739 TestCompletionCallback init_callback2; | 739 TestCompletionCallback init_callback2; |
| 740 EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback2.callback())); | 740 EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback2.callback())); |
| 741 EXPECT_EQ(OK, init_callback2.WaitForResult()); | 741 EXPECT_EQ(OK, init_callback2.WaitForResult()); |
| 742 EXPECT_FALSE(stream->IsEOF()); | 742 EXPECT_FALSE(stream->IsEOF()); |
| (...skipping 27 matching lines...) Expand all Loading... |
| 770 element_readers_.push_back( | 770 element_readers_.push_back( |
| 771 new UploadFileElementReader(base::MessageLoopProxy::current().get(), | 771 new UploadFileElementReader(base::MessageLoopProxy::current().get(), |
| 772 temp_file_path, | 772 temp_file_path, |
| 773 0, | 773 0, |
| 774 kuint64max, | 774 kuint64max, |
| 775 base::Time())); | 775 base::Time())); |
| 776 scoped_ptr<UploadDataStream> stream( | 776 scoped_ptr<UploadDataStream> stream( |
| 777 new ElementsUploadDataStream(element_readers_.Pass(), 0)); | 777 new ElementsUploadDataStream(element_readers_.Pass(), 0)); |
| 778 | 778 |
| 779 std::vector<char> expected_data(kTestData, kTestData + kTestDataSize); | 779 std::vector<char> expected_data(kTestData, kTestData + kTestDataSize); |
| 780 expected_data.insert(expected_data.end(), expected_data.begin(), | 780 expected_data.insert(expected_data.end(), kTestData, |
| 781 expected_data.begin() + kTestDataSize); | 781 kTestData + kTestDataSize); |
| 782 | 782 |
| 783 // Call Init(). | 783 // Call Init(). |
| 784 TestCompletionCallback init_callback1; | 784 TestCompletionCallback init_callback1; |
| 785 ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); | 785 ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); |
| 786 EXPECT_EQ(OK, init_callback1.WaitForResult()); | 786 EXPECT_EQ(OK, init_callback1.WaitForResult()); |
| 787 EXPECT_FALSE(stream->IsEOF()); | 787 EXPECT_FALSE(stream->IsEOF()); |
| 788 EXPECT_EQ(kTestDataSize*2, stream->size()); | 788 EXPECT_EQ(kTestDataSize*2, stream->size()); |
| 789 | 789 |
| 790 // Start reading. | 790 // Start reading. |
| 791 TestCompletionCallback read_callback1; | 791 TestCompletionCallback read_callback1; |
| (...skipping 20 matching lines...) Expand all Loading... |
| 812 wrapped_buffer2.get(), buf2.size(), read_callback2.callback())); | 812 wrapped_buffer2.get(), buf2.size(), read_callback2.callback())); |
| 813 EXPECT_EQ(static_cast<int>(buf2.size()), read_callback2.WaitForResult()); | 813 EXPECT_EQ(static_cast<int>(buf2.size()), read_callback2.WaitForResult()); |
| 814 EXPECT_EQ(expected_data, buf2); | 814 EXPECT_EQ(expected_data, buf2); |
| 815 EXPECT_TRUE(stream->IsEOF()); | 815 EXPECT_TRUE(stream->IsEOF()); |
| 816 | 816 |
| 817 // Make sure callbacks are not called for cancelled operations. | 817 // Make sure callbacks are not called for cancelled operations. |
| 818 EXPECT_FALSE(read_callback1.have_result()); | 818 EXPECT_FALSE(read_callback1.have_result()); |
| 819 } | 819 } |
| 820 | 820 |
| 821 } // namespace net | 821 } // namespace net |
| OLD | NEW |