Commit 6e9c0819 authored by Georgios Bitzes's avatar Georgios Bitzes
Browse files

Use __vhash@<key> channel for internally-generated vhash updates

parent ace16b37
......@@ -40,7 +40,7 @@ void Publisher::asyncPublisher(ThreadAssistant &assistant) {
if(!nextItem) continue;
for(auto it = nextItem->begin(); it != nextItem->end(); it++) {
publish(it->first, it->second.serialize());
publish(SSTR("__vhash@" << it->first), it->second.serialize());
}
frontier.next();
......
......@@ -2067,7 +2067,7 @@ TEST_F(Raft_e2e, vhset) {
opts.handshake = makeQClientHandshake();
qclient::Subscriber subscriber(members(), std::move(opts));
std::unique_ptr<Subscription> subscription = subscriber.subscribe("key-1");
std::unique_ptr<Subscription> subscription = subscriber.subscribe(SSTR("__vhash@" << "key-1"));
ASSERT_TRUE(subscription->empty());
RETRY_ASSERT_TRUE(subscription->acknowledged());
......
Supports Markdown
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