Commit 3fc3b630 authored by Dominik Charousset's avatar Dominik Charousset

Integrate review feedback

parent 18aa5318
...@@ -38,8 +38,6 @@ class simple_actor_clock : public actor_clock { ...@@ -38,8 +38,6 @@ class simple_actor_clock : public actor_clock {
public: public:
// -- member types ----------------------------------------------------------- // -- member types -----------------------------------------------------------
using super = simple_actor_clock;
struct event; struct event;
struct delayed_event; struct delayed_event;
...@@ -136,7 +134,7 @@ public: ...@@ -136,7 +134,7 @@ public:
/// A delayed `sec::request_timeout` error that gets cancelled when the /// A delayed `sec::request_timeout` error that gets cancelled when the
/// request arrives in time. /// request arrives in time.
struct request_timeout final: delayed_event { struct request_timeout final : delayed_event {
static constexpr bool cancellable = true; static constexpr bool cancellable = true;
request_timeout(time_point due, strong_actor_ptr self, message_id id) request_timeout(time_point due, strong_actor_ptr self, message_id id)
......
...@@ -94,7 +94,7 @@ void simple_actor_clock::ship(delayed_event& x) { ...@@ -94,7 +94,7 @@ void simple_actor_clock::ship(delayed_event& x) {
break; break;
} }
case multi_timeout_type: { case multi_timeout_type: {
auto& dref = static_cast<ordinary_timeout&>(x); auto& dref = static_cast<multi_timeout&>(x);
auto& self = dref.self; auto& self = dref.self;
self->get()->eq_impl(make_message_id(), self, nullptr, self->get()->eq_impl(make_message_id(), self, nullptr,
timeout_msg{dref.type, dref.id}); timeout_msg{dref.type, dref.id});
...@@ -134,7 +134,7 @@ void simple_actor_clock::handle(const ordinary_timeout_cancellation& x) { ...@@ -134,7 +134,7 @@ void simple_actor_clock::handle(const ordinary_timeout_cancellation& x) {
void simple_actor_clock::handle(const multi_timeout_cancellation& x) { void simple_actor_clock::handle(const multi_timeout_cancellation& x) {
auto pred = [&](const actor_lookup_map::value_type& kvp) { auto pred = [&](const actor_lookup_map::value_type& kvp) {
auto& y = *kvp.second->second; auto& y = *kvp.second->second;
if (y.subtype != ordinary_timeout_type) if (y.subtype != multi_timeout_type)
return false; return false;
auto& dref = static_cast<const multi_timeout&>(y); auto& dref = static_cast<const multi_timeout&>(y);
return x.type == dref.type && x.id == dref.id; return x.type == dref.type && x.id == dref.id;
......
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