Doom and create new entry when validation is not a match

net/http/http_cache.cc

 // Copyright (c) 2012 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 "net/http/http_cache.h"
 
 #include <algorithm>
 #include <utility>
 
 #include "base/bind.h"
@@ skipping 930 matching lines @@
 void HttpCache::DoneReadingFromEntry(ActiveEntry* entry,
                                      Transaction* transaction) {
   DCHECK(!entry->writer);
   auto it = entry->readers.find(transaction);
   DCHECK(it != entry->readers.end());
   entry->readers.erase(it);
 
   ProcessQueuedTransactions(entry);
 }
 
+void HttpCache::DoomEntryValidationNoMatch(ActiveEntry* entry,
+                                           Transaction* transaction) {

[jkarlin, 2017/06/16 18:28:01]

transaction is unused except for a dcheck, let's remove it.

[shivanisha, 2017/06/27 15:31:14]

done

+  // Validating transaction received a non-matching response.
+
+  DCHECK(transaction == entry->headers_transaction);
+
+  entry->headers_transaction = nullptr;
+  if (entry->HasNoTransactions() && !entry->will_process_queued_transactions) {
+    entry->disk_entry->Doom();
+    DestroyEntry(entry);
+    return;
+  }
+
+  // Restart only add_to_entry_queue transactions.

[jkarlin, 2017/06/16 18:28:01]

Seems like this comment should be the first line of the large comment below.

[shivanisha, 2017/06/27 15:31:14]

done

+
+  DoomActiveEntry(entry->disk_entry->GetKey());
+  // Post task here to avoid a race in creating the entry between |transaction|
+  // and the add_to_entry_queue transactions. Reset the queued transactions'
+  // cache pending state so that in case their destructor is invoked, it's ok

[jkarlin, 2017/06/16 18:28:01]

s/their/its/

[shivanisha, 2017/06/27 15:31:14]

done

+  // for them to not be found in this entry.
+  for (auto* transaction : entry->add_to_entry_queue) {
+    transaction->ResetCachePendingState();
+    base::ThreadTaskRunnerHandle::Get()->PostTask(
+        FROM_HERE, base::Bind(transaction->io_callback(), net::ERR_CACHE_RACE));
+  }
+  entry->add_to_entry_queue.clear();
+}
+
 void HttpCache::RemoveAllQueuedTransactions(ActiveEntry* entry,
                                             TransactionList* list) {
   // Process done_headers_queue before add_to_entry_queue to maintain FIFO
   // order.
 
   for (auto* transaction : entry->done_headers_queue)
     list->push_back(transaction);
   entry->done_headers_queue.clear();
 
   for (auto* pending_transaction : entry->add_to_entry_queue)
     list->push_back(pending_transaction);
   entry->add_to_entry_queue.clear();
 }
 
 void HttpCache::ProcessEntryFailure(ActiveEntry* entry,
                                     Transaction* transaction) {
-  // Failure case is either writer failing to completely write the response to
-  // the cache or validating transaction received a non-304 response.
+  // Writer failed to completely write the response to

[jkarlin, 2017/06/16 18:28:01]

The writer failed ...

[shivanisha, 2017/06/27 15:31:14]

done

+  // the cache.
 
   if (entry->headers_transaction && transaction != entry->headers_transaction)
     RestartHeadersTransaction(entry, transaction);
 
   TransactionList list;
   RemoveAllQueuedTransactions(entry, &list);
 
   if (entry->HasNoTransactions() && !entry->will_process_queued_transactions) {
     entry->disk_entry->Doom();
     DestroyEntry(entry);
@@ skipping 385 matching lines @@
     building_backend_ = false;
     DeletePendingOp(pending_op);
   }
 
   // The cache may be gone when we return from the callback.
   if (!item->DoCallback(result, disk_cache_.get()))
     item->NotifyTransaction(result, NULL);
 }
 
 }  // namespace net