#include "rocksdb/memtablerep.h" #include "db/memtable.h" #include "db/skiplist.h" namespace rocksdb { namespace { class SkipListRep : public MemTableRep { SkipList skip_list_; public: explicit SkipListRep(MemTableRep::KeyComparator& compare, Arena* arena) : skip_list_(compare, arena) { } // Insert key into the list. // REQUIRES: nothing that compares equal to key is currently in the list. virtual void Insert(const char* key) override { skip_list_.Insert(key); } // Returns true iff an entry that compares equal to key is in the list. virtual bool Contains(const char* key) const override { return skip_list_.Contains(key); } virtual size_t ApproximateMemoryUsage() override { // All memory is allocated through arena; nothing to report here return 0; } virtual ~SkipListRep() override { } // Iteration over the contents of a skip list class Iterator : public MemTableRep::Iterator { SkipList::Iterator iter_; public: // Initialize an iterator over the specified list. // The returned iterator is not valid. explicit Iterator( const SkipList* list ) : iter_(list) { } virtual ~Iterator() override { } // Returns true iff the iterator is positioned at a valid node. virtual bool Valid() const override { return iter_.Valid(); } // Returns the key at the current position. // REQUIRES: Valid() virtual const char* key() const override { return iter_.key(); } // Advances to the next position. // REQUIRES: Valid() virtual void Next() override { iter_.Next(); } // Advances to the previous position. // REQUIRES: Valid() virtual void Prev() override { iter_.Prev(); } // Advance to the first entry with a key >= target virtual void Seek(const char* target) override { iter_.Seek(target); } // Position at the first entry in list. // Final state of iterator is Valid() iff list is not empty. virtual void SeekToFirst() override { iter_.SeekToFirst(); } // Position at the last entry in list. // Final state of iterator is Valid() iff list is not empty. virtual void SeekToLast() override { iter_.SeekToLast(); } }; // Unhide default implementations of GetIterator using MemTableRep::GetIterator; virtual std::shared_ptr GetIterator() override { return std::make_shared(&skip_list_); } }; } std::shared_ptr SkipListFactory::CreateMemTableRep ( MemTableRep::KeyComparator& compare, Arena* arena) { return std::shared_ptr(new SkipListRep(compare, arena)); } } // namespace rocksdb