return new AioCompletion(c);
}
+int Rados::blacklist_add(const std::string& client_address,
+ uint32_t expire_seconds) {
+ TestRadosClient *impl = reinterpret_cast<TestRadosClient*>(client);
+ return impl->blacklist_add(client_address, expire_seconds);
+}
+
int Rados::conf_parse_env(const char *env) const {
return rados_conf_parse_env(reinterpret_cast<rados_t>(client), env);
}
return 0;
}
-int librados::Rados::pool_list2(std::list<std::pair<int64_t, std::string> >& v)
+int Rados::pool_list2(std::list<std::pair<int64_t, std::string> >& v)
{
TestRadosClient *impl = reinterpret_cast<TestRadosClient*>(client);
return impl->pool_list(v);
client = NULL;
}
+void Rados::test_blacklist_self(bool set) {
+}
+
int Rados::wait_for_latest_osdmap() {
TestRadosClient *impl = reinterpret_cast<TestRadosClient*>(client);
return impl->wait_for_latest_osdmap();
virtual int pool_reverse_lookup(int64_t id, std::string *name);
virtual int watch_flush();
+
+ virtual int blacklist_add(const std::string& client_address,
+ uint32_t expire_seconds);
protected:
~TestMemRadosClient();
virtual int watch_flush() = 0;
+ virtual int blacklist_add(const std::string& client_address,
+ uint32_t expire_seconds) = 0;
+
TestWatchNotify &get_watch_notify() {
return m_watch_notify;
}