| Index: content/browser/service_worker/service_worker_cache_writer_unittest.cc
|
| diff --git a/content/browser/service_worker/service_worker_cache_writer_unittest.cc b/content/browser/service_worker/service_worker_cache_writer_unittest.cc
|
| deleted file mode 100644
|
| index c58b57b52c117e18f77deb9fe380dc7e6fff471f..0000000000000000000000000000000000000000
|
| --- a/content/browser/service_worker/service_worker_cache_writer_unittest.cc
|
| +++ /dev/null
|
| @@ -1,697 +0,0 @@
|
| -// Copyright 2015 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "content/browser/service_worker/service_worker_cache_writer.h"
|
| -
|
| -#include <list>
|
| -#include <queue>
|
| -#include <string>
|
| -
|
| -#include "base/stl_util.h"
|
| -#include "content/browser/service_worker/service_worker_disk_cache.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -namespace content {
|
| -namespace {
|
| -
|
| -// A test implementation of ServiceWorkerResponseReader.
|
| -//
|
| -// This class exposes the ability to expect reads (see ExpectRead*() below).
|
| -// Each call to ReadInfo() or ReadData() consumes another expected read, in the
|
| -// order those reads were expected, so:
|
| -// reader->ExpectReadInfoOk(5, false);
|
| -// reader->ExpectReadDataOk("abcdef", false);
|
| -// reader->ExpectReadDataOk("ghijkl", false);
|
| -// Expects these calls, in this order:
|
| -// reader->ReadInfo(...); // reader writes 5 into
|
| -// // |info_buf->response_data_size|
|
| -// reader->ReadData(...); // reader writes "abcdef" into |buf|
|
| -// reader->ReadData(...); // reader writes "ghijkl" into |buf|
|
| -// If an unexpected call happens, this class DCHECKs.
|
| -// If an expected read is marked "async", it will not complete immediately, but
|
| -// must be completed by the test using CompletePendingRead().
|
| -// These is a convenience method AllExpectedReadsDone() which returns whether
|
| -// there are any expected reads that have not yet happened.
|
| -class MockServiceWorkerResponseReader : public ServiceWorkerResponseReader {
|
| - public:
|
| - MockServiceWorkerResponseReader() : ServiceWorkerResponseReader(0, nullptr) {}
|
| - ~MockServiceWorkerResponseReader() override {}
|
| -
|
| - // ServiceWorkerResponseReader overrides
|
| - void ReadInfo(HttpResponseInfoIOBuffer* info_buf,
|
| - const net::CompletionCallback& callback) override;
|
| - void ReadData(net::IOBuffer* buf,
|
| - int buf_len,
|
| - const net::CompletionCallback& callback) override;
|
| -
|
| - // Test helpers. ExpectReadInfo() and ExpectReadData() give precise control
|
| - // over both the data to be written and the result to return.
|
| - // ExpectReadInfoOk() and ExpectReadDataOk() are convenience functions for
|
| - // expecting successful reads, which always have their length as their result.
|
| -
|
| - // Expect a call to ReadInfo() on this reader. For these functions, |len| will
|
| - // be used as |response_data_size|, not as the length of this particular read.
|
| - void ExpectReadInfo(size_t len, bool async, int result);
|
| - void ExpectReadInfoOk(size_t len, bool async);
|
| -
|
| - // Expect a call to ReadData() on this reader. For these functions, |len| is
|
| - // the length of the data to be written back; in ExpectReadDataOk(), |len| is
|
| - // implicitly the length of |data|.
|
| - void ExpectReadData(const char* data, size_t len, bool async, int result);
|
| - void ExpectReadDataOk(const std::string& data, bool async);
|
| -
|
| - // Complete a pending async read. It is an error to call this function without
|
| - // a pending async read (ie, a previous call to ReadInfo() or ReadData()
|
| - // having not run its callback yet).
|
| - void CompletePendingRead();
|
| -
|
| - // Returns whether all expected reads have occurred.
|
| - bool AllExpectedReadsDone() { return expected_reads_.size() == 0; }
|
| -
|
| - private:
|
| - struct ExpectedRead {
|
| - ExpectedRead(size_t len, bool async, int result)
|
| - : data(nullptr), len(len), info(true), async(async), result(result) {}
|
| - ExpectedRead(const char* data, size_t len, bool async, int result)
|
| - : data(data), len(len), info(false), async(async), result(result) {}
|
| - const char* data;
|
| - size_t len;
|
| - bool info;
|
| - bool async;
|
| - int result;
|
| - };
|
| -
|
| - std::queue<ExpectedRead> expected_reads_;
|
| - scoped_refptr<net::IOBuffer> pending_buffer_;
|
| - size_t pending_buffer_len_;
|
| - scoped_refptr<HttpResponseInfoIOBuffer> pending_info_;
|
| - net::CompletionCallback pending_callback_;
|
| -};
|
| -
|
| -void MockServiceWorkerResponseReader::ReadInfo(
|
| - HttpResponseInfoIOBuffer* info_buf,
|
| - const net::CompletionCallback& callback) {
|
| - DCHECK(!expected_reads_.empty());
|
| - ExpectedRead expected = expected_reads_.front();
|
| - EXPECT_TRUE(expected.info);
|
| - if (expected.async) {
|
| - pending_info_ = info_buf;
|
| - pending_callback_ = callback;
|
| - } else {
|
| - expected_reads_.pop();
|
| - info_buf->response_data_size = expected.len;
|
| - callback.Run(expected.result);
|
| - }
|
| -}
|
| -
|
| -void MockServiceWorkerResponseReader::ReadData(
|
| - net::IOBuffer* buf,
|
| - int buf_len,
|
| - const net::CompletionCallback& callback) {
|
| - DCHECK(!expected_reads_.empty());
|
| - ExpectedRead expected = expected_reads_.front();
|
| - EXPECT_FALSE(expected.info);
|
| - if (expected.async) {
|
| - pending_callback_ = callback;
|
| - pending_buffer_ = buf;
|
| - pending_buffer_len_ = static_cast<size_t>(buf_len);
|
| - } else {
|
| - expected_reads_.pop();
|
| - if (expected.len > 0) {
|
| - size_t to_read = std::min(static_cast<size_t>(buf_len), expected.len);
|
| - memcpy(buf->data(), expected.data, to_read);
|
| - }
|
| - callback.Run(expected.result);
|
| - }
|
| -}
|
| -
|
| -void MockServiceWorkerResponseReader::ExpectReadInfo(size_t len,
|
| - bool async,
|
| - int result) {
|
| - expected_reads_.push(ExpectedRead(len, async, result));
|
| -}
|
| -
|
| -void MockServiceWorkerResponseReader::ExpectReadInfoOk(size_t len, bool async) {
|
| - expected_reads_.push(ExpectedRead(len, async, len));
|
| -}
|
| -
|
| -void MockServiceWorkerResponseReader::ExpectReadData(const char* data,
|
| - size_t len,
|
| - bool async,
|
| - int result) {
|
| - expected_reads_.push(ExpectedRead(data, len, async, result));
|
| -}
|
| -
|
| -void MockServiceWorkerResponseReader::ExpectReadDataOk(const std::string& data,
|
| - bool async) {
|
| - expected_reads_.push(
|
| - ExpectedRead(data.data(), data.size(), async, data.size()));
|
| -}
|
| -
|
| -void MockServiceWorkerResponseReader::CompletePendingRead() {
|
| - DCHECK(!expected_reads_.empty());
|
| - ExpectedRead expected = expected_reads_.front();
|
| - expected_reads_.pop();
|
| - EXPECT_TRUE(expected.async);
|
| - if (expected.info) {
|
| - pending_info_->response_data_size = expected.len;
|
| - } else {
|
| - size_t to_read = std::min(pending_buffer_len_, expected.len);
|
| - if (to_read > 0)
|
| - memcpy(pending_buffer_->data(), expected.data, to_read);
|
| - }
|
| - pending_info_ = nullptr;
|
| - pending_buffer_ = nullptr;
|
| - net::CompletionCallback callback = pending_callback_;
|
| - pending_callback_.Reset();
|
| - callback.Run(expected.result);
|
| -}
|
| -
|
| -// A test implementation of ServiceWorkerResponseWriter.
|
| -//
|
| -// This class exposes the ability to expect writes (see ExpectWrite*Ok() below).
|
| -// Each write to this class via WriteInfo() or WriteData() consumes another
|
| -// expected write, in the order they were added, so:
|
| -// writer->ExpectWriteInfoOk(5, false);
|
| -// writer->ExpectWriteDataOk(6, false);
|
| -// writer->ExpectWriteDataOk(6, false);
|
| -// Expects these calls, in this order:
|
| -// writer->WriteInfo(...); // checks that |buf->response_data_size| == 5
|
| -// writer->WriteData(...); // checks that 6 bytes are being written
|
| -// writer->WriteData(...); // checks that another 6 bytes are being written
|
| -// If this class receives an unexpected call to WriteInfo() or WriteData(), it
|
| -// DCHECKs.
|
| -// Expected writes marked async do not complete synchronously, but rather return
|
| -// without running their callback and need to be completed with
|
| -// CompletePendingWrite().
|
| -// A convenience method AllExpectedWritesDone() is exposed so tests can ensure
|
| -// that all expected writes have been consumed by matching calls to WriteInfo()
|
| -// or WriteData().
|
| -class MockServiceWorkerResponseWriter : public ServiceWorkerResponseWriter {
|
| - public:
|
| - MockServiceWorkerResponseWriter()
|
| - : ServiceWorkerResponseWriter(0, nullptr),
|
| - info_written_(0),
|
| - data_written_(0) {}
|
| - ~MockServiceWorkerResponseWriter() override {}
|
| -
|
| - // ServiceWorkerResponseWriter overrides
|
| - void WriteInfo(HttpResponseInfoIOBuffer* info_buf,
|
| - const net::CompletionCallback& callback) override;
|
| - void WriteData(net::IOBuffer* buf,
|
| - int buf_len,
|
| - const net::CompletionCallback& callback) override;
|
| -
|
| - // Enqueue expected writes.
|
| - void ExpectWriteInfoOk(size_t len, bool async);
|
| - void ExpectWriteDataOk(size_t len, bool async);
|
| -
|
| - // Complete a pending asynchronous write. This method DCHECKs unless there is
|
| - // a pending write (a write for which WriteInfo() or WriteData() has been
|
| - // called but the callback has not yet been run).
|
| - void CompletePendingWrite();
|
| -
|
| - // Returns whether all expected reads have been consumed.
|
| - bool AllExpectedWritesDone() { return expected_writes_.size() == 0; }
|
| -
|
| - private:
|
| - struct ExpectedWrite {
|
| - ExpectedWrite(bool is_info, size_t length, bool async, int result)
|
| - : is_info(is_info), length(length), async(async), result(result) {}
|
| - bool is_info;
|
| - size_t length;
|
| - bool async;
|
| - int result;
|
| - };
|
| -
|
| - std::queue<ExpectedWrite> expected_writes_;
|
| -
|
| - size_t info_written_;
|
| - size_t data_written_;
|
| -
|
| - net::CompletionCallback pending_callback_;
|
| -};
|
| -
|
| -void MockServiceWorkerResponseWriter::WriteInfo(
|
| - HttpResponseInfoIOBuffer* info_buf,
|
| - const net::CompletionCallback& callback) {
|
| - DCHECK(!expected_writes_.empty());
|
| - ExpectedWrite write = expected_writes_.front();
|
| - EXPECT_TRUE(write.is_info);
|
| - EXPECT_EQ(write.length, static_cast<size_t>(info_buf->response_data_size));
|
| - info_written_ += info_buf->response_data_size;
|
| - if (!write.async) {
|
| - expected_writes_.pop();
|
| - callback.Run(write.result);
|
| - } else {
|
| - pending_callback_ = callback;
|
| - }
|
| -}
|
| -
|
| -void MockServiceWorkerResponseWriter::WriteData(
|
| - net::IOBuffer* buf,
|
| - int buf_len,
|
| - const net::CompletionCallback& callback) {
|
| - DCHECK(!expected_writes_.empty());
|
| - ExpectedWrite write = expected_writes_.front();
|
| - EXPECT_FALSE(write.is_info);
|
| - EXPECT_EQ(write.length, static_cast<size_t>(buf_len));
|
| - data_written_ += buf_len;
|
| - if (!write.async) {
|
| - expected_writes_.pop();
|
| - callback.Run(write.result);
|
| - } else {
|
| - pending_callback_ = callback;
|
| - }
|
| -}
|
| -
|
| -void MockServiceWorkerResponseWriter::ExpectWriteInfoOk(size_t length,
|
| - bool async) {
|
| - ExpectedWrite expected(true, length, async, length);
|
| - expected_writes_.push(expected);
|
| -}
|
| -
|
| -void MockServiceWorkerResponseWriter::ExpectWriteDataOk(size_t length,
|
| - bool async) {
|
| - ExpectedWrite expected(false, length, async, length);
|
| - expected_writes_.push(expected);
|
| -}
|
| -
|
| -void MockServiceWorkerResponseWriter::CompletePendingWrite() {
|
| - DCHECK(!expected_writes_.empty());
|
| - ExpectedWrite write = expected_writes_.front();
|
| - DCHECK(write.async);
|
| - expected_writes_.pop();
|
| - pending_callback_.Run(write.result);
|
| -}
|
| -
|
| -class ServiceWorkerCacheWriterTest : public ::testing::Test {
|
| - public:
|
| - ServiceWorkerCacheWriterTest()
|
| - : readers_deleter_(&readers_), writers_deleter_(&writers_) {}
|
| -
|
| - void SetUp() override {
|
| - ::testing::Test::SetUp();
|
| - cache_writer_.reset(new ServiceWorkerCacheWriter(
|
| - base::Bind(&ServiceWorkerCacheWriterTest::CreateReader,
|
| - base::Unretained(this)),
|
| - base::Bind(&ServiceWorkerCacheWriterTest::CreateWriter,
|
| - base::Unretained(this))));
|
| - write_complete_ = false;
|
| - }
|
| -
|
| - MockServiceWorkerResponseReader* ExpectReader() {
|
| - scoped_ptr<MockServiceWorkerResponseReader> reader(
|
| - new MockServiceWorkerResponseReader);
|
| - MockServiceWorkerResponseReader* borrowed_reader = reader.get();
|
| - readers_.push_back(reader.release()); // give ownership to |readers_|
|
| - return borrowed_reader;
|
| - }
|
| -
|
| - MockServiceWorkerResponseWriter* ExpectWriter() {
|
| - scoped_ptr<MockServiceWorkerResponseWriter> writer(
|
| - new MockServiceWorkerResponseWriter);
|
| - MockServiceWorkerResponseWriter* borrowed_writer = writer.get();
|
| - writers_.push_back(writer.release()); // give ownership to |writers_|
|
| - return borrowed_writer;
|
| - }
|
| -
|
| - protected:
|
| - // TODO(ellyjones): when unique_ptr<> is allowed, make these instead:
|
| - // std::list<unique_ptr<...>>
|
| - // Right now, these cannot use scoped_ptr.
|
| - // Their elements are deleted by the STLElementDeleters below when this object
|
| - // goes out of scope.
|
| - std::list<MockServiceWorkerResponseReader*> readers_;
|
| - std::list<MockServiceWorkerResponseWriter*> writers_;
|
| - STLElementDeleter<std::list<MockServiceWorkerResponseReader*>>
|
| - readers_deleter_;
|
| - STLElementDeleter<std::list<MockServiceWorkerResponseWriter*>>
|
| - writers_deleter_;
|
| - scoped_ptr<ServiceWorkerCacheWriter> cache_writer_;
|
| - bool write_complete_;
|
| - net::Error last_error_;
|
| -
|
| - scoped_ptr<ServiceWorkerResponseReader> CreateReader() {
|
| - if (readers_.empty())
|
| - return make_scoped_ptr<ServiceWorkerResponseReader>(nullptr);
|
| - scoped_ptr<ServiceWorkerResponseReader> reader(readers_.front());
|
| - readers_.pop_front();
|
| - return reader.Pass();
|
| - }
|
| - scoped_ptr<ServiceWorkerResponseWriter> CreateWriter() {
|
| - if (writers_.empty())
|
| - return make_scoped_ptr<ServiceWorkerResponseWriter>(nullptr);
|
| - scoped_ptr<ServiceWorkerResponseWriter> writer(writers_.front());
|
| - writers_.pop_front();
|
| - return writer.Pass();
|
| - }
|
| -
|
| - ServiceWorkerCacheWriter::OnWriteCompleteCallback CreateWriteCallback() {
|
| - return base::Bind(&ServiceWorkerCacheWriterTest::OnWriteComplete,
|
| - base::Unretained(this));
|
| - }
|
| -
|
| - void OnWriteComplete(net::Error error) {
|
| - write_complete_ = true;
|
| - last_error_ = error;
|
| - }
|
| -
|
| - net::Error WriteHeaders(size_t len) {
|
| - scoped_refptr<HttpResponseInfoIOBuffer> buf(new HttpResponseInfoIOBuffer);
|
| - buf->response_data_size = len;
|
| - return cache_writer_->MaybeWriteHeaders(buf.get(), CreateWriteCallback());
|
| - }
|
| -
|
| - net::Error WriteData(const std::string& data) {
|
| - scoped_refptr<net::IOBuffer> buf = new net::StringIOBuffer(data);
|
| - return cache_writer_->MaybeWriteData(buf.get(), data.size(),
|
| - CreateWriteCallback());
|
| - }
|
| -};
|
| -
|
| -// Passthrough tests:
|
| -// In these tests, the ServiceWorkerCacheWriter under test has no existing
|
| -// reader, since no calls to ExpectReader() have been made; this means that
|
| -// there is no existing cached response and the incoming data is written back to
|
| -// the cache directly.
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, PassthroughHeadersSync) {
|
| - const size_t kHeaderSize = 16;
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - writer->ExpectWriteInfoOk(kHeaderSize, false);
|
| -
|
| - net::Error error = WriteHeaders(kHeaderSize);
|
| - EXPECT_EQ(net::OK, error);
|
| - EXPECT_FALSE(write_complete_);
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| - EXPECT_EQ(0U, cache_writer_->bytes_written());
|
| -}
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, PassthroughHeadersAsync) {
|
| - size_t kHeaderSize = 16;
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - writer->ExpectWriteInfoOk(kHeaderSize, true);
|
| -
|
| - net::Error error = WriteHeaders(kHeaderSize);
|
| - EXPECT_EQ(net::ERR_IO_PENDING, error);
|
| - EXPECT_FALSE(write_complete_);
|
| - writer->CompletePendingWrite();
|
| - EXPECT_TRUE(write_complete_);
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| - EXPECT_EQ(0U, cache_writer_->bytes_written());
|
| -}
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, PassthroughDataSync) {
|
| - const std::string data1 = "abcdef";
|
| - const std::string data2 = "ghijklmno";
|
| - size_t response_size = data1.size() + data2.size();
|
| -
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - writer->ExpectWriteInfoOk(response_size, false);
|
| - writer->ExpectWriteDataOk(data1.size(), false);
|
| - writer->ExpectWriteDataOk(data2.size(), false);
|
| -
|
| - net::Error error = WriteHeaders(response_size);
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - error = WriteData(data2);
|
| - EXPECT_EQ(net::OK, error);
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| -}
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, PassthroughDataAsync) {
|
| - const std::string data1 = "abcdef";
|
| - const std::string data2 = "ghijklmno";
|
| - size_t response_size = data1.size() + data2.size();
|
| -
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - writer->ExpectWriteInfoOk(response_size, false);
|
| - writer->ExpectWriteDataOk(data1.size(), true);
|
| - writer->ExpectWriteDataOk(data2.size(), true);
|
| -
|
| - net::Error error = WriteHeaders(response_size);
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::ERR_IO_PENDING, error);
|
| - writer->CompletePendingWrite();
|
| - EXPECT_TRUE(write_complete_);
|
| -
|
| - write_complete_ = false;
|
| - error = WriteData(data2);
|
| - EXPECT_EQ(net::ERR_IO_PENDING, error);
|
| - writer->CompletePendingWrite();
|
| - EXPECT_TRUE(write_complete_);
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| -}
|
| -
|
| -// Comparison tests:
|
| -// For the Compare* tests below, the ServiceWorkerCacheWriter under test has a
|
| -// reader for an existing cached response, so it will compare the response being
|
| -// written to it against the existing cached response.
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareHeadersSync) {
|
| - size_t response_size = 3;
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - MockServiceWorkerResponseReader* reader = ExpectReader();
|
| -
|
| - reader->ExpectReadInfoOk(response_size, false);
|
| -
|
| - net::Error error = WriteHeaders(response_size);
|
| - EXPECT_EQ(net::OK, error);
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| - EXPECT_TRUE(reader->AllExpectedReadsDone());
|
| -}
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareDataOkSync) {
|
| - const std::string data1 = "abcdef";
|
| - size_t response_size = data1.size();
|
| -
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - MockServiceWorkerResponseReader* reader = ExpectReader();
|
| -
|
| - reader->ExpectReadInfoOk(response_size, false);
|
| - reader->ExpectReadDataOk(data1, false);
|
| -
|
| - net::Error error = WriteHeaders(response_size);
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| - EXPECT_TRUE(reader->AllExpectedReadsDone());
|
| - EXPECT_EQ(0U, cache_writer_->bytes_written());
|
| -}
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareShortCacheReads) {
|
| - const size_t kHeaderSize = 16;
|
| - const std::string& data1 = "abcdef";
|
| - const std::string& cache_data2 = "ghi";
|
| - const std::string& cache_data3 = "j";
|
| - const std::string& cache_data4 = "kl";
|
| - const std::string& net_data2 = "ghijkl";
|
| - const std::string& data5 = "mnopqrst";
|
| -
|
| - MockServiceWorkerResponseReader* reader = ExpectReader();
|
| - reader->ExpectReadInfo(kHeaderSize, false, kHeaderSize);
|
| - reader->ExpectReadDataOk(data1, false);
|
| - reader->ExpectReadDataOk(cache_data2, false);
|
| - reader->ExpectReadDataOk(cache_data3, false);
|
| - reader->ExpectReadDataOk(cache_data4, false);
|
| - reader->ExpectReadDataOk(data5, false);
|
| -
|
| - net::Error error = WriteHeaders(kHeaderSize);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(net_data2);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(data5);
|
| - EXPECT_EQ(net::OK, error);
|
| - EXPECT_TRUE(reader->AllExpectedReadsDone());
|
| - EXPECT_EQ(0U, cache_writer_->bytes_written());
|
| -}
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareDataOkAsync) {
|
| - const std::string data1 = "abcdef";
|
| - size_t response_size = data1.size();
|
| -
|
| - MockServiceWorkerResponseReader* reader = ExpectReader();
|
| -
|
| - reader->ExpectReadInfoOk(response_size, true);
|
| - reader->ExpectReadDataOk(data1, true);
|
| -
|
| - net::Error error = WriteHeaders(response_size);
|
| - EXPECT_EQ(net::ERR_IO_PENDING, error);
|
| - reader->CompletePendingRead();
|
| -
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::ERR_IO_PENDING, error);
|
| - reader->CompletePendingRead();
|
| -
|
| - EXPECT_TRUE(reader->AllExpectedReadsDone());
|
| - EXPECT_EQ(0U, cache_writer_->bytes_written());
|
| -}
|
| -
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareDataManyOkAsync) {
|
| - const std::string expected_data[] = {
|
| - "abcdef", "ghijkl", "mnopqr", "stuvwxyz",
|
| - };
|
| - size_t response_size = 0;
|
| - for (size_t i = 0; i < arraysize(expected_data); ++i)
|
| - response_size += expected_data[i].size();
|
| -
|
| - MockServiceWorkerResponseReader* reader = ExpectReader();
|
| -
|
| - reader->ExpectReadInfoOk(response_size, true);
|
| - for (size_t i = 0; i < arraysize(expected_data); ++i) {
|
| - reader->ExpectReadDataOk(expected_data[i], true);
|
| - }
|
| -
|
| - net::Error error = WriteHeaders(response_size);
|
| - EXPECT_EQ(net::ERR_IO_PENDING, error);
|
| - reader->CompletePendingRead();
|
| -
|
| - for (size_t i = 0; i < arraysize(expected_data); ++i) {
|
| - error = WriteData(expected_data[i]);
|
| - EXPECT_EQ(net::ERR_IO_PENDING, error);
|
| - reader->CompletePendingRead();
|
| - EXPECT_EQ(net::OK, last_error_);
|
| - }
|
| -
|
| - EXPECT_TRUE(reader->AllExpectedReadsDone());
|
| - EXPECT_EQ(0U, cache_writer_->bytes_written());
|
| -}
|
| -
|
| -// This test writes headers and three data blocks data1, data2, data3; data2
|
| -// differs in the cached version. The writer should be asked to rewrite the
|
| -// headers and body with the new value, and the copy reader should be asked to
|
| -// read the header and data1.
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareFailedCopySync) {
|
| - std::string data1 = "abcdef";
|
| - std::string cache_data2 = "ghijkl";
|
| - std::string net_data2 = "mnopqr";
|
| - std::string data3 = "stuvwxyz";
|
| - size_t cache_response_size = data1.size() + cache_data2.size() + data3.size();
|
| - size_t net_response_size = data1.size() + net_data2.size() + data3.size();
|
| -
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - MockServiceWorkerResponseReader* compare_reader = ExpectReader();
|
| - MockServiceWorkerResponseReader* copy_reader = ExpectReader();
|
| -
|
| - compare_reader->ExpectReadInfoOk(cache_response_size, false);
|
| - compare_reader->ExpectReadDataOk(data1, false);
|
| - compare_reader->ExpectReadDataOk(cache_data2, false);
|
| -
|
| - copy_reader->ExpectReadInfoOk(cache_response_size, false);
|
| - copy_reader->ExpectReadDataOk(data1, false);
|
| -
|
| - writer->ExpectWriteInfoOk(net_response_size, false);
|
| - writer->ExpectWriteDataOk(data1.size(), false);
|
| - writer->ExpectWriteDataOk(net_data2.size(), false);
|
| - writer->ExpectWriteDataOk(data3.size(), false);
|
| -
|
| - net::Error error = WriteHeaders(net_response_size);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(net_data2);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(data3);
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| - EXPECT_TRUE(compare_reader->AllExpectedReadsDone());
|
| - EXPECT_TRUE(copy_reader->AllExpectedReadsDone());
|
| -}
|
| -
|
| -// Tests behavior when the cached data is shorter than the network data.
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareFailedCopyShort) {
|
| - std::string data1 = "abcdef";
|
| - std::string cache_data2 = "mnop";
|
| - std::string net_data2 = "mnopqr";
|
| - std::string data3 = "stuvwxyz";
|
| - size_t cache_response_size = data1.size() + cache_data2.size() + data3.size();
|
| - size_t net_response_size = data1.size() + net_data2.size() + data3.size();
|
| -
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - MockServiceWorkerResponseReader* compare_reader = ExpectReader();
|
| - MockServiceWorkerResponseReader* copy_reader = ExpectReader();
|
| -
|
| - compare_reader->ExpectReadInfoOk(cache_response_size, false);
|
| - compare_reader->ExpectReadDataOk(data1, false);
|
| - compare_reader->ExpectReadDataOk(cache_data2, false);
|
| - compare_reader->ExpectReadDataOk("", false); // EOF read
|
| -
|
| - copy_reader->ExpectReadInfoOk(cache_response_size, false);
|
| - copy_reader->ExpectReadDataOk(data1, false);
|
| -
|
| - writer->ExpectWriteInfoOk(net_response_size, false);
|
| - writer->ExpectWriteDataOk(data1.size(), false);
|
| - writer->ExpectWriteDataOk(net_data2.size(), false);
|
| - writer->ExpectWriteDataOk(data3.size(), false);
|
| -
|
| - net::Error error = WriteHeaders(net_response_size);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(net_data2);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(data3);
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| - EXPECT_TRUE(compare_reader->AllExpectedReadsDone());
|
| - EXPECT_TRUE(copy_reader->AllExpectedReadsDone());
|
| -}
|
| -
|
| -// Tests behavior when the cached data is longer than the network data.
|
| -TEST_F(ServiceWorkerCacheWriterTest, CompareFailedCopyLong) {
|
| - std::string data1 = "abcdef";
|
| - std::string cache_data2 = "mnop";
|
| - std::string net_data2 = "mnop";
|
| - std::string cache_data3 = "qr";
|
| - size_t cached_size = data1.size() + cache_data2.size() + cache_data3.size();
|
| - size_t net_size = data1.size() + net_data2.size();
|
| -
|
| - MockServiceWorkerResponseWriter* writer = ExpectWriter();
|
| - MockServiceWorkerResponseReader* compare_reader = ExpectReader();
|
| - MockServiceWorkerResponseReader* copy_reader = ExpectReader();
|
| -
|
| - compare_reader->ExpectReadInfoOk(cached_size, false);
|
| - compare_reader->ExpectReadDataOk(data1, false);
|
| - compare_reader->ExpectReadDataOk(cache_data2, false);
|
| -
|
| - // The comparison should fail at the end of |cache_data2|, when the cache
|
| - // writer realizes the two responses are different sizes, and then the network
|
| - // data should be written back starting with |net_data2|.
|
| - copy_reader->ExpectReadInfoOk(cached_size, false);
|
| - copy_reader->ExpectReadDataOk(data1, false);
|
| - copy_reader->ExpectReadDataOk(net_data2, false);
|
| -
|
| - writer->ExpectWriteInfoOk(net_size, false);
|
| - writer->ExpectWriteDataOk(data1.size(), false);
|
| - writer->ExpectWriteDataOk(net_data2.size(), false);
|
| -
|
| - net::Error error = WriteHeaders(net_size);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(data1);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData(net_data2);
|
| - EXPECT_EQ(net::OK, error);
|
| - error = WriteData("");
|
| - EXPECT_EQ(net::OK, error);
|
| -
|
| - EXPECT_TRUE(writer->AllExpectedWritesDone());
|
| - EXPECT_TRUE(compare_reader->AllExpectedReadsDone());
|
| - EXPECT_TRUE(copy_reader->AllExpectedReadsDone());
|
| -}
|
| -
|
| -} // namespace
|
| -} // namespace content
|
|
|