[ServiceWorkerCache] Make the cache operations run serially.

content/browser/service_worker/service_worker_cache_unittest.cc

 // Copyright 2014 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.h"
 
 #include "base/files/file_path.h"
 #include "base/files/scoped_temp_dir.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "base/run_loop.h"
@@ skipping 890 matching lines @@
   delayable_backend->OpenEntryContinue();
 
   close_loop->Run();
   // Put failed because the backend was closed while it was running.
   EXPECT_EQ(ServiceWorkerCache::ErrorTypeStorage, callback_error_);
   EXPECT_TRUE(callback_closed_);
 
   VerifyAllOpsFail();
 }
 
+TEST_P(ServiceWorkerCacheTestP, VerifySerialScheduling) {
+  // Start two operations, the first one is delayed but the second isn't. The
+  // second should wait for the first.
+  EXPECT_TRUE(Keys());  // Opens the backend.
+  DelayableBackend* delayable_backend = cache_->UseDelayableBackend();
+  delayable_backend->set_delay_open(true);
+
+  scoped_ptr<ServiceWorkerResponse> response1 =
+      CopyFetchResponse(body_response_);
+  response1->status_code = 1;
+
+  scoped_ptr<base::RunLoop> close_loop1(new base::RunLoop());
+  cache_->Put(CopyFetchRequest(body_request_), response1.Pass(),
+              base::Bind(&ServiceWorkerCacheTest::ResponseAndErrorCallback,
+                         base::Unretained(this), close_loop1.get()));
+
+  // Blocks on opening the cache entry.
+  base::RunLoop().RunUntilIdle();
+
+  delayable_backend->set_delay_open(false);
+  scoped_ptr<ServiceWorkerResponse> response2 =
+      CopyFetchResponse(body_response_);
+  response2->status_code = 2;
+  scoped_ptr<base::RunLoop> close_loop2(new base::RunLoop());
+  cache_->Put(CopyFetchRequest(body_request_), response2.Pass(),
+              base::Bind(&ServiceWorkerCacheTest::ResponseAndErrorCallback,
+                         base::Unretained(this), close_loop2.get()));
+
+  // The second put operation should wait for the first to complete.
+  base::RunLoop().RunUntilIdle();
+  EXPECT_FALSE(callback_response_);
+
+  delayable_backend->OpenEntryContinue();
+  close_loop1->Run();
+  EXPECT_EQ(1, callback_response_->status_code);
+  close_loop2->Run();
+  EXPECT_EQ(2, callback_response_->status_code);
+}
+
 INSTANTIATE_TEST_CASE_P(ServiceWorkerCacheTest,
                         ServiceWorkerCacheTestP,
                         ::testing::Values(false, true));
 
 }  // namespace content