]>
Commit | Line | Data |
---|---|---|
7c673cae FG |
1 | // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- |
2 | // vim: ts=8 sw=2 smarttab | |
3 | ||
4 | #ifndef CEPH_TEST_MEM_RADOS_CLIENT_H | |
5 | #define CEPH_TEST_MEM_RADOS_CLIENT_H | |
6 | ||
7 | #include "test/librados_test_stub/TestRadosClient.h" | |
8 | #include "include/assert.h" | |
9 | #include <list> | |
10 | #include <string> | |
11 | ||
12 | namespace librados { | |
13 | ||
14 | class AioCompletionImpl; | |
15 | class TestMemCluster; | |
16 | ||
17 | class TestMemRadosClient : public TestRadosClient { | |
18 | public: | |
19 | TestMemRadosClient(CephContext *cct, TestMemCluster *test_mem_cluster); | |
20 | ~TestMemRadosClient() override; | |
21 | ||
22 | TestIoCtxImpl *create_ioctx(int64_t pool_id, | |
23 | const std::string &pool_name) override; | |
24 | ||
25 | uint32_t get_nonce() override { | |
26 | return m_nonce; | |
27 | } | |
28 | uint64_t get_instance_id() override { | |
29 | return m_global_id; | |
30 | } | |
31 | ||
32 | void object_list(int64_t pool_id, | |
33 | std::list<librados::TestRadosClient::Object> *list) override; | |
34 | ||
c07f9fc5 FG |
35 | int service_daemon_register(const std::string& service, |
36 | const std::string& name, | |
37 | const std::map<std::string,std::string>& metadata) override { | |
38 | return 0; | |
39 | } | |
40 | int service_daemon_update_status(const std::map<std::string,std::string>& status) override { | |
41 | return 0; | |
42 | } | |
43 | ||
7c673cae FG |
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; | |
50 | ||
51 | int watch_flush() override; | |
52 | ||
53 | bool is_blacklisted() const override; | |
54 | int blacklist_add(const std::string& client_address, | |
55 | uint32_t expire_seconds) override; | |
56 | protected: | |
57 | TestMemCluster *get_mem_cluster() { | |
58 | return m_mem_cluster; | |
59 | } | |
60 | ||
61 | protected: | |
62 | void transaction_start(const std::string &oid) override; | |
63 | void transaction_finish(const std::string &oid) override; | |
64 | ||
65 | private: | |
66 | TestMemCluster *m_mem_cluster; | |
67 | uint32_t m_nonce; | |
68 | uint64_t m_global_id; | |
69 | ||
70 | }; | |
71 | ||
72 | } // namespace librados | |
73 | ||
74 | #endif // CEPH_TEST_MEM_RADOS_CLIENT_H |