Lines Matching refs:i
727 for (auto i = 0; i < 100; ++i) { in TEST_F() local
728 batch.Put(Key(i), RandomString(&rnd, 1024)); in TEST_F()
740 for (auto i = 100; i < 199; ++i) { in TEST_F() local
741 batch.Put(Key(i), RandomString(&rnd, 1024)); in TEST_F()
761 for (auto i = 0; i < 199; ++i) { in TEST_F() local
762 if (i < 100) { in TEST_F()
763 ASSERT_NE(Get(Key(i)), "NOT_FOUND"); in TEST_F()
765 ASSERT_EQ(Get(Key(i)), "NOT_FOUND"); in TEST_F()
769 for (auto i = 0; i < 199; ++i) { in TEST_F() local
770 if (i < 100) { in TEST_F()
771 ASSERT_NE(Get(Key(i)), "NOT_FOUND"); in TEST_F()
773 ASSERT_EQ(Get(Key(i)), "NOT_FOUND"); in TEST_F()
803 for (auto i = 0; i < 100; ++i) { in TEST_F() local
804 batch.Put(Key(i), RandomString(&rnd, 1024)); in TEST_F()
818 for (auto i = 100; i < 200; ++i) { in TEST_F() local
819 batch.Put(Key(i), RandomString(&rnd, 1024)); in TEST_F()
840 for (auto i = 0; i < 199; ++i) { in TEST_F() local
841 if (i < 100) { in TEST_F()
842 ASSERT_NE(Get(Key(i)), "NOT_FOUND"); in TEST_F()
844 ASSERT_EQ(Get(Key(i)), "NOT_FOUND"); in TEST_F()
854 for (auto i = 200; i < 300; ++i) { in TEST_F() local
855 batch.Put(Key(i), RandomString(&rnd, 1024)); in TEST_F()
864 for (auto i = 0; i < 300; ++i) { in TEST_F() local
865 if (i < 100 || i >= 200) { in TEST_F()
866 ASSERT_NE(Get(Key(i)), "NOT_FOUND"); in TEST_F()
868 ASSERT_EQ(Get(Key(i)), "NOT_FOUND"); in TEST_F()
894 for (auto i = 1; i < 4; ++i) { in TEST_F() local
896 batch.Put(handles_[i], Key(j), RandomString(&rnd, 1024)); in TEST_F()
910 for (auto i = 100; i < 199; ++i) { in TEST_F() local
911 batch.Put(handles_[2], Key(i), RandomString(&rnd, 1024)); in TEST_F()
932 for (auto i = 1; i < 4; ++i) { in TEST_F() local
934 ASSERT_EQ(NumTableFilesAtLevel(0, i), 1); in TEST_F()
937 for (auto i = 1; i < 4; ++i) { in TEST_F() local
940 ASSERT_NE(Get(i, Key(j)), "NOT_FOUND"); in TEST_F()
942 ASSERT_EQ(Get(i, Key(j)), "NOT_FOUND"); in TEST_F()
947 for (auto i = 1; i < 4; ++i) { in TEST_F() local
950 ASSERT_NE(Get(i, Key(j)), "NOT_FOUND"); in TEST_F()
952 ASSERT_EQ(Get(i, Key(j)), "NOT_FOUND"); in TEST_F()
970 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
976 options[i].env = fault_envs.back().get(); in TEST_F()
977 options[i].create_if_missing = true; in TEST_F()
978 options[i].level0_file_num_compaction_trigger = 2; in TEST_F()
979 options[i].writable_file_max_buffer_size = 32768; in TEST_F()
980 options[i].listeners.emplace_back(listener[i]); in TEST_F()
981 options[i].sst_file_manager = sfm; in TEST_F()
985 listener[i]->EnableAutoRecovery(); in TEST_F()
987 listener[i]->InjectFileCreationError(fault_fs[i], 3, in TEST_F()
989 snprintf(buf, sizeof(buf), "_%d", i); in TEST_F()
990 DestroyDB(dbname_ + std::string(buf), options[i]); in TEST_F()
991 ASSERT_EQ(DB::Open(options[i], dbname_ + std::string(buf), &dbptr), in TEST_F()
996 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1005 ASSERT_EQ(db[i]->Write(wopts, &batch), Status::OK()); in TEST_F()
1006 ASSERT_EQ(db[i]->Flush(FlushOptions()), Status::OK()); in TEST_F()
1010 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1020 ASSERT_EQ(db[i]->Write(wopts, &batch), Status::OK()); in TEST_F()
1021 ASSERT_EQ(db[i]->Flush(FlushOptions()), Status::OK()); in TEST_F()
1024 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1025 Status s = static_cast<DBImpl*>(db[i])->TEST_WaitForCompact(true); in TEST_F()
1027 fault_fs[i]->SetFilesystemActive(true); in TEST_F()
1031 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1033 ASSERT_EQ(listener[i]->WaitForRecovery(5000000), true); in TEST_F()
1034 ASSERT_EQ(static_cast<DBImpl*>(db[i])->TEST_WaitForCompact(true), in TEST_F()
1036 EXPECT_TRUE(db[i]->GetProperty( in TEST_F()
1039 EXPECT_TRUE(db[i]->GetProperty( in TEST_F()
1044 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1046 snprintf(buf, sizeof(buf), "_%d", i); in TEST_F()
1047 delete db[i]; in TEST_F()
1048 fault_fs[i]->SetFilesystemActive(true); in TEST_F()
1052 Status s = DestroyDB(dbname_ + std::string(buf), options[i]); in TEST_F()
1071 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1077 options[i].env = fault_envs.back().get(); in TEST_F()
1078 options[i].create_if_missing = true; in TEST_F()
1079 options[i].level0_file_num_compaction_trigger = 2; in TEST_F()
1080 options[i].writable_file_max_buffer_size = 32768; in TEST_F()
1081 options[i].listeners.emplace_back(listener[i]); in TEST_F()
1082 options[i].sst_file_manager = sfm; in TEST_F()
1086 listener[i]->EnableAutoRecovery(); in TEST_F()
1087 switch (i) { in TEST_F()
1090 listener[i]->InjectFileCreationError(fault_fs[i], 3, in TEST_F()
1096 listener[i]->InjectFileCreationError(fault_fs[i], 2, in TEST_F()
1102 snprintf(buf, sizeof(buf), "_%d", i); in TEST_F()
1103 DestroyDB(dbname_ + std::string(buf), options[i]); in TEST_F()
1104 ASSERT_EQ(DB::Open(options[i], dbname_ + std::string(buf), &dbptr), in TEST_F()
1109 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1118 ASSERT_EQ(db[i]->Write(wopts, &batch), Status::OK()); in TEST_F()
1119 ASSERT_EQ(db[i]->Flush(FlushOptions()), Status::OK()); in TEST_F()
1123 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1133 ASSERT_EQ(db[i]->Write(wopts, &batch), Status::OK()); in TEST_F()
1134 if (i != 1) { in TEST_F()
1135 ASSERT_EQ(db[i]->Flush(FlushOptions()), Status::OK()); in TEST_F()
1137 ASSERT_EQ(db[i]->Flush(FlushOptions()), Status::NoSpace()); in TEST_F()
1141 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1142 Status s = static_cast<DBImpl*>(db[i])->TEST_WaitForCompact(true); in TEST_F()
1143 switch (i) { in TEST_F()
1154 fault_fs[i]->SetFilesystemActive(true); in TEST_F()
1158 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1160 if (i < 2) { in TEST_F()
1161 ASSERT_EQ(listener[i]->WaitForRecovery(5000000), true); in TEST_F()
1163 if (i == 1) { in TEST_F()
1164 ASSERT_EQ(static_cast<DBImpl*>(db[i])->TEST_WaitForCompact(true), in TEST_F()
1167 EXPECT_TRUE(db[i]->GetProperty( in TEST_F()
1170 EXPECT_TRUE(db[i]->GetProperty( in TEST_F()
1175 for (auto i = 0; i < kNumDbInstances; ++i) { in TEST_F() local
1177 snprintf(buf, sizeof(buf), "_%d", i); in TEST_F()
1178 fault_fs[i]->SetFilesystemActive(true); in TEST_F()
1179 delete db[i]; in TEST_F()
1183 DestroyDB(dbname_ + std::string(buf), options[i]); in TEST_F()