Commit 17def710 authored by Jakob Otto's avatar Jakob Otto

Cleanup transport_worker_dispatcher

parent d9d2971c
...@@ -98,11 +98,11 @@ public: ...@@ -98,11 +98,11 @@ public:
template <class Parent> template <class Parent>
void resolve(Parent& parent, const uri& locator, const actor& listener) { void resolve(Parent& parent, const uri& locator, const actor& listener) {
auto worker = find_worker(make_node_id(locator)); if (auto worker = find_worker(make_node_id(locator)))
if (worker == nullptr) worker->resolve(parent, locator.path(), listener);
else
anon_send(listener, anon_send(listener,
make_error(sec::runtime_error, "could not resolve node")); make_error(sec::runtime_error, "could not resolve node"));
worker->resolve(parent, locator.path(), listener);
} }
template <class Parent> template <class Parent>
...@@ -125,9 +125,10 @@ public: ...@@ -125,9 +125,10 @@ public:
template <class Parent> template <class Parent>
void timeout(Parent& parent, atom_value value, uint64_t id) { void timeout(Parent& parent, atom_value value, uint64_t id) {
auto worker = workers_by_timeout_id_.at(id); if (auto worker = workers_by_timeout_id_.at(id)) {
worker->timeout(parent, value, id); worker->timeout(parent, value, id);
workers_by_timeout_id_.erase(id); workers_by_timeout_id_.erase(id);
}
} }
void handle_error(sec error) { void handle_error(sec error) {
...@@ -176,7 +177,7 @@ private: ...@@ -176,7 +177,7 @@ private:
factory_type factory_; factory_type factory_;
transport_type* transport_; transport_type* transport_;
}; // namespace net };
} // namespace net } // namespace net
} // namespace caf } // namespace caf
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