diff options
author | Allan Sandfeld Jensen <allan.jensen@theqtcompany.com> | 2015-06-18 14:10:49 +0200 |
---|---|---|
committer | Oswald Buddenhagen <oswald.buddenhagen@theqtcompany.com> | 2015-06-18 13:53:24 +0000 |
commit | 813fbf95af77a531c57a8c497345ad2c61d475b3 (patch) | |
tree | 821b2c8de8365f21b6c9ba17a236fb3006a1d506 /chromium/net/base/file_stream_unittest.cc | |
parent | af6588f8d723931a298c995fa97259bb7f7deb55 (diff) | |
download | qtwebengine-chromium-813fbf95af77a531c57a8c497345ad2c61d475b3.tar.gz |
BASELINE: Update chromium to 44.0.2403.47
Change-Id: Ie056fedba95cf5e5c76b30c4b2c80fca4764aa2f
Reviewed-by: Oswald Buddenhagen <oswald.buddenhagen@theqtcompany.com>
Diffstat (limited to 'chromium/net/base/file_stream_unittest.cc')
-rw-r--r-- | chromium/net/base/file_stream_unittest.cc | 39 |
1 files changed, 22 insertions, 17 deletions
diff --git a/chromium/net/base/file_stream_unittest.cc b/chromium/net/base/file_stream_unittest.cc index fc9257e5d1c..1e6e6dbb198 100644 --- a/chromium/net/base/file_stream_unittest.cc +++ b/chromium/net/base/file_stream_unittest.cc @@ -17,10 +17,10 @@ #include "base/test/test_timeouts.h" #include "base/threading/sequenced_worker_pool.h" #include "base/threading/thread_restrictions.h" -#include "net/base/capturing_net_log.h" #include "net/base/io_buffer.h" #include "net/base/net_errors.h" #include "net/base/test_completion_callback.h" +#include "net/log/test_net_log.h" #include "testing/gtest/include/gtest/gtest.h" #include "testing/platform_test.h" @@ -546,6 +546,25 @@ class TestWriteReadCompletionCallback { const CompletionCallback& callback() const { return callback_; } + void ValidateWrittenData() { + TestCompletionCallback callback; + int rv = 0; + for (;;) { + scoped_refptr<IOBufferWithSize> buf = new IOBufferWithSize(4); + rv = stream_->Read(buf.get(), buf->size(), callback.callback()); + if (rv == ERR_IO_PENDING) { + base::MessageLoop::ScopedNestableTaskAllower allow( + base::MessageLoop::current()); + rv = callback.WaitForResult(); + } + EXPECT_LE(0, rv); + if (rv <= 0) + break; + *total_bytes_read_ += rv; + data_read_->append(buf->data(), rv); + } + } + private: void OnComplete(int result) { DCHECK_LT(0, result); @@ -577,22 +596,6 @@ class TestWriteReadCompletionCallback { base::MessageLoop::current()); EXPECT_LE(0, callback64.WaitForResult()); } - - TestCompletionCallback callback; - for (;;) { - scoped_refptr<IOBufferWithSize> buf = new IOBufferWithSize(4); - rv = stream_->Read(buf.get(), buf->size(), callback.callback()); - if (rv == ERR_IO_PENDING) { - base::MessageLoop::ScopedNestableTaskAllower allow( - base::MessageLoop::current()); - rv = callback.WaitForResult(); - } - EXPECT_LE(0, rv); - if (rv <= 0) - break; - *total_bytes_read_ += rv; - data_read_->append(buf->data(), rv); - } } result_ = *total_bytes_written_; @@ -646,6 +649,8 @@ TEST_F(FileStreamTest, WriteRead) { EXPECT_LT(0, rv); EXPECT_EQ(kTestDataSize, total_bytes_written); + callback.ValidateWrittenData(); + stream.reset(); EXPECT_TRUE(base::GetFileSize(temp_file_path(), &file_size)); |