X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Flibrados_test_stub%2FTestMemCluster.h;fp=src%2Fceph%2Fsrc%2Ftest%2Flibrados_test_stub%2FTestMemCluster.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=f256b5b724fdd68f5a7cdd086bbeb4f07c142375;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/test/librados_test_stub/TestMemCluster.h b/src/ceph/src/test/librados_test_stub/TestMemCluster.h deleted file mode 100644 index f256b5b..0000000 --- a/src/ceph/src/test/librados_test_stub/TestMemCluster.h +++ /dev/null @@ -1,112 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#ifndef CEPH_TEST_MEM_CLUSTER_H -#define CEPH_TEST_MEM_CLUSTER_H - -#include "test/librados_test_stub/TestCluster.h" -#include "include/buffer.h" -#include "include/interval_set.h" -#include "include/int_types.h" -#include "common/Cond.h" -#include "common/Mutex.h" -#include "common/RefCountedObj.h" -#include "common/RWLock.h" -#include -#include -#include -#include -#include - -namespace librados { - -class TestMemCluster : public TestCluster { -public: - typedef std::map OMap; - typedef std::map FileOMaps; - typedef std::map FileTMaps; - typedef std::map XAttrs; - typedef std::map FileXAttrs; - - struct File { - File(); - File(const File &rhs); - - bufferlist data; - time_t mtime; - - uint64_t snap_id; - std::vector snaps; - interval_set snap_overlap; - - bool exists; - RWLock lock; - }; - typedef boost::shared_ptr SharedFile; - - typedef std::list FileSnapshots; - typedef std::map Files; - - typedef std::set SnapSeqs; - struct Pool : public RefCountedObject { - Pool(); - - int64_t pool_id = 0; - - SnapSeqs snap_seqs; - uint64_t snap_id = 1; - - RWLock file_lock; - Files files; - FileOMaps file_omaps; - FileTMaps file_tmaps; - FileXAttrs file_xattrs; - }; - - TestMemCluster(); - ~TestMemCluster() override; - - TestRadosClient *create_rados_client(CephContext *cct) override; - - int pool_create(const std::string &pool_name); - int pool_delete(const std::string &pool_name); - int pool_get_base_tier(int64_t pool_id, int64_t* base_tier); - int pool_list(std::list >& v); - int64_t pool_lookup(const std::string &name); - int pool_reverse_lookup(int64_t id, std::string *name); - - Pool *get_pool(int64_t pool_id); - Pool *get_pool(const std::string &pool_name); - - void allocate_client(uint32_t *nonce, uint64_t *global_id); - void deallocate_client(uint32_t nonce); - - bool is_blacklisted(uint32_t nonce) const; - void blacklist(uint32_t nonce); - - void transaction_start(const std::string &oid); - void transaction_finish(const std::string &oid); - -private: - - typedef std::map Pools; - typedef std::set Blacklist; - - mutable Mutex m_lock; - - Pools m_pools; - int64_t m_pool_id = 0; - - uint32_t m_next_nonce; - uint64_t m_next_global_id = 1234; - - Blacklist m_blacklist; - - Cond m_transaction_cond; - std::set m_transactions; - -}; - -} // namespace librados - -#endif // CEPH_TEST_MEM_CLUSTER_H