Home
last modified time | relevance | path

Searched refs:WriteStallCondition (Results 1 – 6 of 6) sorted by relevance

/rocksdb-6.9/db/
Dcolumn_family.cc813 std::pair<WriteStallCondition, ColumnFamilyData::WriteStallCause>
827 return {WriteStallCondition::kStopped, in GetWriteStallConditionAndCause()
842 return {WriteStallCondition::kDelayed, in GetWriteStallConditionAndCause()
845 return {WriteStallCondition::kNormal, WriteStallCause::kNone}; in GetWriteStallConditionAndCause()
848 WriteStallCondition ColumnFamilyData::RecalculateWriteStallConditions( in RecalculateWriteStallConditions()
850 auto write_stall_condition = WriteStallCondition::kNormal; in RecalculateWriteStallConditions()
866 if (write_stall_condition == WriteStallCondition::kStopped && in RecalculateWriteStallConditions()
876 } else if (write_stall_condition == WriteStallCondition::kStopped && in RecalculateWriteStallConditions()
887 } else if (write_stall_condition == WriteStallCondition::kStopped && in RecalculateWriteStallConditions()
897 } else if (write_stall_condition == WriteStallCondition::kDelayed && in RecalculateWriteStallConditions()
[all …]
Djob_context.h61 WriteStallCondition old_cond, WriteStallCondition new_cond, in PushWriteStallNotification()
Dcolumn_family.h208 WriteStallCondition write_stall_condition;
477 static std::pair<WriteStallCondition, WriteStallCause>
487 WriteStallCondition RecalculateWriteStallConditions(
Ddb_test.cc6037 WriteStallListener() : condition_(WriteStallCondition::kNormal) {} in WriteStallListener()
6042 bool CheckCondition(WriteStallCondition expected) { in CheckCondition()
6048 WriteStallCondition condition_;
6144 ASSERT_TRUE(listener->CheckCondition(WriteStallCondition::kDelayed)); in TEST_F()
6155 ASSERT_TRUE(listener->CheckCondition(WriteStallCondition::kNormal)); in TEST_F()
6190 ASSERT_TRUE(listener->CheckCondition(WriteStallCondition::kNormal)); in TEST_F()
6213 ASSERT_TRUE(listener->CheckCondition(WriteStallCondition::kDelayed)); in TEST_F()
6219 ASSERT_TRUE(listener->CheckCondition(WriteStallCondition::kNormal)); in TEST_F()
6229 ASSERT_TRUE(listener->CheckCondition(WriteStallCondition::kDelayed)); in TEST_F()
/rocksdb-6.9/include/rocksdb/
Dlistener.h122 enum class WriteStallCondition { enum
133 WriteStallCondition cur;
134 WriteStallCondition prev;
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc1805 WriteStallCondition write_stall_condition = WriteStallCondition::kNormal; in WaitUntilFlushWouldNotStallWrites()
1807 if (write_stall_condition != WriteStallCondition::kNormal) { in WaitUntilFlushWouldNotStallWrites()
1862 } while (write_stall_condition != WriteStallCondition::kNormal); in WaitUntilFlushWouldNotStallWrites()