5f6510825a
This CL fixes all occurences that don't require special OWNER reviews, or can be reviewed by Michi. After this one, we should be able to reenable the readability/check cpplint check. R=mstarzinger@chromium.org Bug: v8:6837, v8:6921 Cq-Include-Trybots: master.tryserver.chromium.linux:linux_chromium_rel_ng;master.tryserver.v8:v8_linux_noi18n_rel_ng Change-Id: Ic81d68d5534eaa795b7197fed5c41ed158361d62 Reviewed-on: https://chromium-review.googlesource.com/721120 Commit-Queue: Clemens Hammacher <clemensh@chromium.org> Reviewed-by: Michael Starzinger <mstarzinger@chromium.org> Cr-Commit-Position: refs/heads/master@{#48670}
92 lines
2.1 KiB
C++
92 lines
2.1 KiB
C++
// Copyright 2015 the V8 project authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
// found in the LICENSE file.
|
|
|
|
#ifndef V8_LOCKED_QUEUE_INL_
|
|
#define V8_LOCKED_QUEUE_INL_
|
|
|
|
#include "src/base/atomic-utils.h"
|
|
#include "src/locked-queue.h"
|
|
|
|
namespace v8 {
|
|
namespace internal {
|
|
|
|
template <typename Record>
|
|
struct LockedQueue<Record>::Node : Malloced {
|
|
Node() : next(nullptr) {}
|
|
Record value;
|
|
base::AtomicValue<Node*> next;
|
|
};
|
|
|
|
|
|
template <typename Record>
|
|
inline LockedQueue<Record>::LockedQueue() {
|
|
head_ = new Node();
|
|
CHECK_NOT_NULL(head_);
|
|
tail_ = head_;
|
|
}
|
|
|
|
|
|
template <typename Record>
|
|
inline LockedQueue<Record>::~LockedQueue() {
|
|
// Destroy all remaining nodes. Note that we do not destroy the actual values.
|
|
Node* old_node = nullptr;
|
|
Node* cur_node = head_;
|
|
while (cur_node != nullptr) {
|
|
old_node = cur_node;
|
|
cur_node = cur_node->next.Value();
|
|
delete old_node;
|
|
}
|
|
}
|
|
|
|
|
|
template <typename Record>
|
|
inline void LockedQueue<Record>::Enqueue(const Record& record) {
|
|
Node* n = new Node();
|
|
CHECK_NOT_NULL(n);
|
|
n->value = record;
|
|
{
|
|
base::LockGuard<base::Mutex> guard(&tail_mutex_);
|
|
tail_->next.SetValue(n);
|
|
tail_ = n;
|
|
}
|
|
}
|
|
|
|
|
|
template <typename Record>
|
|
inline bool LockedQueue<Record>::Dequeue(Record* record) {
|
|
Node* old_head = nullptr;
|
|
{
|
|
base::LockGuard<base::Mutex> guard(&head_mutex_);
|
|
old_head = head_;
|
|
Node* const next_node = head_->next.Value();
|
|
if (next_node == nullptr) return false;
|
|
*record = next_node->value;
|
|
head_ = next_node;
|
|
}
|
|
delete old_head;
|
|
return true;
|
|
}
|
|
|
|
|
|
template <typename Record>
|
|
inline bool LockedQueue<Record>::IsEmpty() const {
|
|
base::LockGuard<base::Mutex> guard(&head_mutex_);
|
|
return head_->next.Value() == nullptr;
|
|
}
|
|
|
|
|
|
template <typename Record>
|
|
inline bool LockedQueue<Record>::Peek(Record* record) const {
|
|
base::LockGuard<base::Mutex> guard(&head_mutex_);
|
|
Node* const next_node = head_->next.Value();
|
|
if (next_node == nullptr) return false;
|
|
*record = next_node->value;
|
|
return true;
|
|
}
|
|
|
|
} // namespace internal
|
|
} // namespace v8
|
|
|
|
#endif // V8_LOCKED_QUEUE_INL_
|