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

Implement demonitor

parent f676aa81
...@@ -86,13 +86,13 @@ void local_actor::monitor(abstract_actor* ptr) { ...@@ -86,13 +86,13 @@ void local_actor::monitor(abstract_actor* ptr) {
} }
void local_actor::demonitor(const actor_addr& whom) { void local_actor::demonitor(const actor_addr& whom) {
/* if (! whom)
if (whom == invalid_actor_addr) return;
auto ptr = actor_cast<strong_actor_ptr>(whom);
if (! ptr)
return; return;
auto ptr = actor_cast<abstract_actor_ptr>(whom);
default_attachable::observe_token tk{address(), default_attachable::monitor}; default_attachable::observe_token tk{address(), default_attachable::monitor};
ptr->detach(tk); ptr->get()->detach(tk);
*/
} }
void local_actor::join(const group& what) { void local_actor::join(const group& what) {
......
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