Lines Matching refs:kAtomicGroupSize
966 const int kAtomicGroupSize = 3; in TEST_F() local
967 SetupValidAtomicGroup(kAtomicGroupSize); in TEST_F()
968 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
974 EXPECT_EQ(num_initial_edits_ + kAtomicGroupSize, num_recovered_edits_); in TEST_F()
980 const int kAtomicGroupSize = 3; in TEST_F() local
981 SetupValidAtomicGroup(kAtomicGroupSize); in TEST_F()
982 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
996 EXPECT_EQ(num_initial_edits_ + kAtomicGroupSize, num_recovered_edits_); in TEST_F()
1002 const int kAtomicGroupSize = 3; in TEST_F() local
1003 SetupValidAtomicGroup(kAtomicGroupSize); in TEST_F()
1010 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
1023 EXPECT_EQ(kAtomicGroupSize, num_applied_edits_); in TEST_F()
1028 const int kAtomicGroupSize = 4; in TEST_F() local
1029 const int kNumberOfPersistedVersionEdits = kAtomicGroupSize - 1; in TEST_F()
1030 SetupIncompleteTrailingAtomicGroup(kAtomicGroupSize); in TEST_F()
1044 const int kAtomicGroupSize = 4; in TEST_F() local
1045 const int kNumberOfPersistedVersionEdits = kAtomicGroupSize - 1; in TEST_F()
1046 SetupIncompleteTrailingAtomicGroup(kAtomicGroupSize); in TEST_F()
1062 EXPECT_TRUE(reactive_versions_->replay_buffer().size() == kAtomicGroupSize); in TEST_F()
1066 edits_[kAtomicGroupSize - 1].EncodeTo(&last_record); in TEST_F()
1078 EXPECT_EQ(kAtomicGroupSize, num_applied_edits_); in TEST_F()
1083 const int kAtomicGroupSize = 4; in TEST_F() local
1084 const int kNumberOfPersistedVersionEdits = kAtomicGroupSize - 1; in TEST_F()
1085 SetupIncompleteTrailingAtomicGroup(kAtomicGroupSize); in TEST_F()
1109 EXPECT_TRUE(reactive_versions_->replay_buffer().size() == kAtomicGroupSize); in TEST_F()
1116 const int kAtomicGroupSize = 4; in TEST_F() local
1117 SetupCorruptedAtomicGroup(kAtomicGroupSize); in TEST_F()
1118 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
1122 EXPECT_EQ(edits_[kAtomicGroupSize / 2].DebugString(), in TEST_F()
1128 const int kAtomicGroupSize = 4; in TEST_F() local
1129 SetupCorruptedAtomicGroup(kAtomicGroupSize); in TEST_F()
1130 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
1139 EXPECT_EQ(edits_[kAtomicGroupSize / 2].DebugString(), in TEST_F()
1145 const int kAtomicGroupSize = 4; in TEST_F() local
1146 SetupCorruptedAtomicGroup(kAtomicGroupSize); in TEST_F()
1156 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
1161 EXPECT_EQ(edits_[kAtomicGroupSize / 2].DebugString(), in TEST_F()
1167 const int kAtomicGroupSize = 4; in TEST_F() local
1168 SetupIncorrectAtomicGroup(kAtomicGroupSize); in TEST_F()
1169 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
1179 const int kAtomicGroupSize = 4; in TEST_F() local
1180 SetupIncorrectAtomicGroup(kAtomicGroupSize); in TEST_F()
1181 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
1196 const int kAtomicGroupSize = 4; in TEST_F() local
1197 SetupIncorrectAtomicGroup(kAtomicGroupSize); in TEST_F()
1206 AddNewEditsToLog(kAtomicGroupSize); in TEST_F()
1251 const int kAtomicGroupSize = 3; in TEST_P() local
1273 std::vector<VersionEdit> edits(kAtomicGroupSize); in TEST_P()
1274 uint32_t remaining = kAtomicGroupSize; in TEST_P()
1303 EXPECT_EQ(kAtomicGroupSize - 1, tmp_edits->size()); in TEST_P()