Unverified Commit 8f2cd321 authored by Dominik Charousset's avatar Dominik Charousset Committed by GitHub

Merge pull request #691

Fix update message in config server
parents caf27589 5bff8b37
...@@ -86,13 +86,13 @@ behavior config_serv_impl(stateful_actor<kvstate>* self) { ...@@ -86,13 +86,13 @@ behavior config_serv_impl(stateful_actor<kvstate>* self) {
// we never put a nullptr in our map // we never put a nullptr in our map
auto subscriber = actor_cast<actor>(subscriber_ptr); auto subscriber = actor_cast<actor>(subscriber_ptr);
if (subscriber != self->current_sender()) if (subscriber != self->current_sender())
self->send(subscriber, update_atom::value, key, vp.second); self->send(subscriber, update_atom::value, key, vp.first);
} }
// also iterate all subscribers for '*' // also iterate all subscribers for '*'
for (auto& subscriber : self->state.data[wildcard].second) for (auto& subscriber : self->state.data[wildcard].second)
if (subscriber != self->current_sender()) if (subscriber != self->current_sender())
self->send(actor_cast<actor>(subscriber), update_atom::value, self->send(actor_cast<actor>(subscriber), update_atom::value,
key, vp.second); key, vp.first);
}, },
// get a key/value pair // get a key/value pair
[=](get_atom, std::string& key) -> message { [=](get_atom, std::string& key) -> message {
......
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