Provide API in RequestCoordinator to remove results by client ID.

components/offline_pages/background/request_queue_in_memory_store.cc

 // Copyright 2016 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 "components/offline_pages/background/request_queue_in_memory_store.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "components/offline_pages/background/save_page_request.h"
@@ skipping 21 matching lines @@
     requests_.erase(iter);
   requests_.insert(std::make_pair(request.request_id(), request));
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE, base::Bind(callback, UpdateStatus::UPDATED));
 }
 
 void RequestQueueInMemoryStore::RemoveRequests(
     const std::vector<int64_t>& request_ids,
     const RemoveCallback& callback) {
   // In case the |request_ids| is empty, the result will be true, but the count
-  // of deleted pages will be empty.
+  // of deleted pages will be 0.
   int count = 0;
   RequestsMap::iterator iter;
   for (auto request_id : request_ids) {
     iter = requests_.find(request_id);
     if (iter != requests_.end()) {
       requests_.erase(iter);
       ++count;
     }
   }
 
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE, base::Bind(callback, true, count));
 }
 
+void RequestQueueInMemoryStore::RemoveRequestsByClientId(
+    const std::vector<ClientId>& client_ids,
+    const RemoveCallback& callback) {
+  // In case the |client_ids| is empty, the result will be true, but the count

[Dmitry Titov, 2016/08/01 19:37:31]

If this comment is moved to .h file, it'll be easier to find. It is 'interface'
kind of comment, so probably belongs to .h

[Pete Williamson, 2016/08/01 23:23:07]

Done.

+  // of deleted pages will be 0.
+  int count = 0;
+
+  // Once for each client id in our list
+  for (auto client_id : client_ids) {
+    // Check it against each request in the store.
+    for (auto iter = requests_.begin();
+         iter != requests_.end();
+         ++iter) {
+      // Check against each incoming client ID, and delete if we have a match.
+      if ((*iter).second.client_id() == client_id) {
+        requests_.erase(iter);
+        // This delete will invalidate the iterator, so move on to the next
+        // entry.
+        ++count;
+        break;
+      }
+    }
+  }
+
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(callback, true, count));
+}
+
 void RequestQueueInMemoryStore::Reset(const ResetCallback& callback) {
   requests_.clear();
   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
                                                 base::Bind(callback, true));
 }
 
 }  // namespace offline_pages