ceph/src/test/librados_test_stub/TestMemRadosClient.h

   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
  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
  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