summaryrefslogtreecommitdiff
path: root/deps/v8/src/libplatform/task-queue.cc
diff options
context:
space:
mode:
Diffstat (limited to 'deps/v8/src/libplatform/task-queue.cc')
-rw-r--r--deps/v8/src/libplatform/task-queue.cc25
1 files changed, 12 insertions, 13 deletions
diff --git a/deps/v8/src/libplatform/task-queue.cc b/deps/v8/src/libplatform/task-queue.cc
index 37cf1353e..7a9071f36 100644
--- a/deps/v8/src/libplatform/task-queue.cc
+++ b/deps/v8/src/libplatform/task-queue.cc
@@ -2,27 +2,26 @@
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
-#include "task-queue.h"
+#include "src/libplatform/task-queue.h"
-// TODO(jochen): We should have our own version of checks.h.
-#include "../checks.h"
+#include "src/base/logging.h"
namespace v8 {
-namespace internal {
+namespace platform {
TaskQueue::TaskQueue() : process_queue_semaphore_(0), terminated_(false) {}
TaskQueue::~TaskQueue() {
- LockGuard<Mutex> guard(&lock_);
- ASSERT(terminated_);
- ASSERT(task_queue_.empty());
+ base::LockGuard<base::Mutex> guard(&lock_);
+ DCHECK(terminated_);
+ DCHECK(task_queue_.empty());
}
void TaskQueue::Append(Task* task) {
- LockGuard<Mutex> guard(&lock_);
- ASSERT(!terminated_);
+ base::LockGuard<base::Mutex> guard(&lock_);
+ DCHECK(!terminated_);
task_queue_.push(task);
process_queue_semaphore_.Signal();
}
@@ -31,7 +30,7 @@ void TaskQueue::Append(Task* task) {
Task* TaskQueue::GetNext() {
for (;;) {
{
- LockGuard<Mutex> guard(&lock_);
+ base::LockGuard<base::Mutex> guard(&lock_);
if (!task_queue_.empty()) {
Task* result = task_queue_.front();
task_queue_.pop();
@@ -48,10 +47,10 @@ Task* TaskQueue::GetNext() {
void TaskQueue::Terminate() {
- LockGuard<Mutex> guard(&lock_);
- ASSERT(!terminated_);
+ base::LockGuard<base::Mutex> guard(&lock_);
+ DCHECK(!terminated_);
terminated_ = true;
process_queue_semaphore_.Signal();
}
-} } // namespace v8::internal
+} } // namespace v8::platform