1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #ifndef CEPH_TEST_MEM_RADOS_CLIENT_H
5 #define CEPH_TEST_MEM_RADOS_CLIENT_H
7 #include "test/librados_test_stub/TestRadosClient.h"
8 #include "include/assert.h"
14 class AioCompletionImpl;
17 class TestMemRadosClient : public TestRadosClient {
19 TestMemRadosClient(CephContext *cct, TestMemCluster *test_mem_cluster);
20 ~TestMemRadosClient() override;
22 TestIoCtxImpl *create_ioctx(int64_t pool_id,
23 const std::string &pool_name) override;
25 uint32_t get_nonce() override {
28 uint64_t get_instance_id() override {
32 void object_list(int64_t pool_id,
33 std::list<librados::TestRadosClient::Object> *list) override;
35 int service_daemon_register(const std::string& service,
36 const std::string& name,
37 const std::map<std::string,std::string>& metadata) override {
40 int service_daemon_update_status(const std::map<std::string,std::string>& status) override {
44 int pool_create(const std::string &pool_name) override;
45 int pool_delete(const std::string &pool_name) override;
46 int pool_get_base_tier(int64_t pool_id, int64_t* base_tier) override;
47 int pool_list(std::list<std::pair<int64_t, std::string> >& v) override;
48 int64_t pool_lookup(const std::string &name) override;
49 int pool_reverse_lookup(int64_t id, std::string *name) override;
51 int watch_flush() override;
53 bool is_blacklisted() const override;
54 int blacklist_add(const std::string& client_address,
55 uint32_t expire_seconds) override;
57 TestMemCluster *get_mem_cluster() {
62 void transaction_start(const std::string &oid) override;
63 void transaction_finish(const std::string &oid) override;
66 TestMemCluster *m_mem_cluster;
72 } // namespace librados
74 #endif // CEPH_TEST_MEM_RADOS_CLIENT_H