Lines Matching refs:ColumnFamilyData

481                                       ColumnFamilyData* cfd,
574   Status RunManualCompaction(ColumnFamilyData* cfd, int input_level,
664   SuperVersion* GetAndRefSuperVersion(ColumnFamilyData* cfd);
678   void ReturnAndCleanupSuperVersion(ColumnFamilyData* cfd, SuperVersion* sv);
711       const ReadOptions&, ColumnFamilyData* cfd, SuperVersion* super_version,
880   Status TEST_SwitchMemtable(ColumnFamilyData* cfd = nullptr);
886   Status TEST_FlushMemTable(ColumnFamilyData* cfd,
893   Status TEST_AtomicFlushMemTables(const autovector<ColumnFamilyData*>& cfds,
1038   void NotifyOnFlushBegin(ColumnFamilyData* cfd, FileMetaData* file_meta,
1043       ColumnFamilyData* cfd, const MutableCFOptions& mutable_cf_options,
1046   void NotifyOnCompactionBegin(ColumnFamilyData* cfd, Compaction* c,
1050   void NotifyOnCompactionCompleted(ColumnFamilyData* cfd, Compaction* c,
1054   void NotifyOnMemTableSealed(ColumnFamilyData* cfd,
1059       ColumnFamilyData* cfd, const ExternalSstFileIngestionJob& ingestion_job);
1062   void NewThreadStatusCfInfo(ColumnFamilyData* cfd) const;
1064   void EraseThreadStatusCfInfo(ColumnFamilyData* cfd) const;
1254     BGFlushArg(ColumnFamilyData* cfd, uint64_t max_memtable_id,  in BGFlushArg()
1261     ColumnFamilyData* cfd_;
1280     ColumnFamilyData* cfd;
1373       ColumnFamilyData* cfd, const MutableCFOptions& mutable_cf_options,
1402   Status WriteLevel0TableForRecovery(int job_id, ColumnFamilyData* cfd,
1421   void MaybeFlushStatsCF(autovector<ColumnFamilyData*>* cfds);
1425   Status SwitchMemtable(ColumnFamilyData* cfd, WriteContext* context);
1427   void SelectColumnFamiliesForAtomicFlush(autovector<ColumnFamilyData*>* cfds);
1430   Status FlushMemTable(ColumnFamilyData* cfd, const FlushOptions& options,
1434       const autovector<ColumnFamilyData*>& column_family_datas,
1439   Status WaitUntilFlushWouldNotStallWrites(ColumnFamilyData* cfd,
1448   Status WaitForFlushMemTable(ColumnFamilyData* cfd,
1456       const autovector<ColumnFamilyData*>& cfds,
1488   void AssignAtomicFlushSeq(const autovector<ColumnFamilyData*>& cfds);
1529                           ColumnFamilyData* cfd, Version* version,
1546   ColumnFamilyData* GetColumnFamilyDataByName(const std::string& cf_name);
1556   typedef std::vector<std::pair<ColumnFamilyData*, uint64_t>> FlushRequest;
1558   void GenerateFlushRequest(const autovector<ColumnFamilyData*>& cfds,
1563   void SchedulePendingCompaction(ColumnFamilyData* cfd);
1586   bool EnoughRoomForCompaction(ColumnFamilyData* cfd,
1592   bool RequestCompactionToken(ColumnFamilyData* cfd, bool force,
1611   int FindMinimumEmptyLevelFitting(ColumnFamilyData* cfd,
1618   Status ReFitLevel(ColumnFamilyData* cfd, int level, int target_level = -1);
1621   void AddToCompactionQueue(ColumnFamilyData* cfd);
1622   ColumnFamilyData* PopFirstFromCompactionQueue();
1626   ColumnFamilyData* PickCompactionFromQueue(
1637   FSDirectory* GetDataDir(ColumnFamilyData* cfd, size_t path_id) const;
1651       ColumnFamilyData* cfd, SuperVersionContext* sv_context,
1654   bool GetIntPropertyInternal(ColumnFamilyData* cfd,
1664   bool HaveManualCompaction(ColumnFamilyData* cfd);
1667   void BuildCompactionJobInfo(const ColumnFamilyData* cfd, Compaction* c,
1676       ColumnFamilyData* cfd, uint64_t num,
1708     ColumnFamilyData* cfd;
1928   std::deque<ColumnFamilyData*> compaction_queue_;
2124     VersionSet* vset, const ColumnFamilyData& cfd_to_flush,
2133     VersionSet* vset, const ColumnFamilyData* cfd_to_flush,