summaryrefslogtreecommitdiff
path: root/chromium/net/base/file_stream_unittest.cc
diff options
context:
space:
mode:
authorAllan Sandfeld Jensen <allan.jensen@theqtcompany.com>2015-06-18 14:10:49 +0200
committerOswald Buddenhagen <oswald.buddenhagen@theqtcompany.com>2015-06-18 13:53:24 +0000
commit813fbf95af77a531c57a8c497345ad2c61d475b3 (patch)
tree821b2c8de8365f21b6c9ba17a236fb3006a1d506 /chromium/net/base/file_stream_unittest.cc
parentaf6588f8d723931a298c995fa97259bb7f7deb55 (diff)
downloadqtwebengine-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.cc39
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));