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 pool_create(const std::string &pool_name) override;
  36   int pool_delete(const std::string &pool_name) override;
  37   int pool_get_base_tier(int64_t pool_id, int64_t* base_tier) override;
  38   int pool_list(std::list<std::pair<int64_t, std::string> >& v) override;
  39   int64_t pool_lookup(const std::string &name) override;
  40   int pool_reverse_lookup(int64_t id, std::string *name) override;
  41
  42   int watch_flush() override;
  43
  44   bool is_blacklisted() const override;
  45   int blacklist_add(const std::string& client_address,
  46                     uint32_t expire_seconds) override;
  47 protected:
  48   TestMemCluster *get_mem_cluster() {
  49     return m_mem_cluster;
  50   }
  51
  52 protected:
  53   void transaction_start(const std::string &oid) override;
  54   void transaction_finish(const std::string &oid) override;
  55
  56 private:
  57   TestMemCluster *m_mem_cluster;
  58   uint32_t m_nonce;
  59   uint64_t m_global_id;
  60
  61 };
  62
  63 } // namespace librados
  64
  65 #endif // CEPH_TEST_MEM_RADOS_CLIENT_H