Fix a queue for FSP API.

chrome/browser/chromeos/file_system_provider/queue.cc

 // 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 "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/single_thread_task_runner.h"
 #include "base/thread_task_runner_handle.h"
 #include "chrome/browser/chromeos/file_system_provider/queue.h"
@@ skipping 57 matching lines @@
   // If not completed, then it must have been aborted.
   const auto aborted_it = aborted_.find(token);
   DCHECK(aborted_it != aborted_.end());
   aborted_.erase(aborted_it);
 
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE, base::Bind(&Queue::MaybeRun, weak_ptr_factory_.GetWeakPtr()));
 }
 
 void Queue::MaybeRun() {
-  if (executed_.size() == max_in_parallel_ || !pending_.size()) {
+  if (executed_.size() + completed_.size() == max_in_parallel_ ||
+      !pending_.size()) {
     return;
   }
 
-  DCHECK_GT(max_in_parallel_, executed_.size());
+  DCHECK_GT(max_in_parallel_, executed_.size() + completed_.size());
   Task task = pending_.front();
   pending_.pop_front();
 
   executed_[task.token] = task;
   AbortCallback abort_callback = task.callback.Run();
 
   // It may happen that the task is completed and removed synchronously. Hence,
   // we need to check if the task is still in the executed collection.
   const auto executed_task_it = executed_.find(task.token);
   if (executed_task_it != executed_.end())
@@ skipping 26 matching lines @@
       return;
     }
   }
 
   // The task is already removed, marked as completed or aborted.
   NOTREACHED();
 }
 
 }  // namespace file_system_provider
 }  // namespace chromeos