}
void TestMemCluster::blocklist(uint32_t nonce) {
- m_watch_notify.blocklist(nonce);
+ {
+ std::lock_guard locker{m_lock};
+ m_blocklist.insert(nonce);
+ }
- std::lock_guard locker{m_lock};
- m_blocklist.insert(nonce);
+ // after blocklisting the client, disconnect and drop its watches
+ m_watch_notify.blocklist(nonce);
}
void TestMemCluster::transaction_start(const ObjectLocator& locator) {