Commit 19db4a86 authored by Dominik Charousset's avatar Dominik Charousset

Integrate review feedback

parent 4a56c02a
...@@ -161,6 +161,7 @@ public: ...@@ -161,6 +161,7 @@ public:
return queue_.peek(); return queue_.peek();
} }
/// Tries to find an element in the queue that matches the given predicate.
template <class Predicate> template <class Predicate>
pointer find_if(Predicate pred) { pointer find_if(Predicate pred) {
fetch_more(); fetch_more();
......
...@@ -124,6 +124,7 @@ public: ...@@ -124,6 +124,7 @@ public:
f(*i); f(*i);
} }
/// Tries to find an element in the queue that matches the given predicate.
template <class Predicate> template <class Predicate>
pointer find_if(Predicate pred) { pointer find_if(Predicate pred) {
for (auto i = begin(); i != end(); ++i) for (auto i = begin(); i != end(); ++i)
......
...@@ -154,6 +154,7 @@ public: ...@@ -154,6 +154,7 @@ public:
kvp.second.peek_all(f); kvp.second.peek_all(f);
} }
/// Tries to find an element in the queue that matches the given predicate.
template <class Predicate> template <class Predicate>
pointer find_if(Predicate pred) { pointer find_if(Predicate pred) {
for (auto& kvp : qs_) for (auto& kvp : qs_)
......
...@@ -80,6 +80,7 @@ public: ...@@ -80,6 +80,7 @@ public:
return peek_recursion<0>(); return peek_recursion<0>();
} }
/// Tries to find an element in the queue that matches the given predicate.
template <class Predicate> template <class Predicate>
pointer find_if(Predicate pred) { pointer find_if(Predicate pred) {
return find_if_recursion<0>(pred); return find_if_recursion<0>(pred);
......
...@@ -175,6 +175,7 @@ void scheduled_actor::enqueue(mailbox_element_ptr ptr, execution_unit* eu) { ...@@ -175,6 +175,7 @@ void scheduled_actor::enqueue(mailbox_element_ptr ptr, execution_unit* eu) {
break; break;
} }
} }
mailbox_element* scheduled_actor::peek_at_next_mailbox_element() { mailbox_element* scheduled_actor::peek_at_next_mailbox_element() {
if (mailbox().closed() || mailbox().blocked()) { if (mailbox().closed() || mailbox().blocked()) {
return nullptr; return nullptr;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment