Lines Matching refs:ASSERT_OK

75   ASSERT_OK(s);  in OpenSecondary()
87 ASSERT_OK(s); in OpenSecondaryWithColumnFamilies()
115 ASSERT_OK(Put("foo", "foo_value")); in TEST_F()
116 ASSERT_OK(Put("bar", "bar_value")); in TEST_F()
117 ASSERT_OK(dbfull()->Flush(FlushOptions())); in TEST_F()
120 ASSERT_OK(ReopenAsSecondary(options)); in TEST_F()
150 ASSERT_OK(Put("foo", "foo_value" + std::to_string(i))); in TEST_F()
151 ASSERT_OK(Put("bar", "bar_value" + std::to_string(i))); in TEST_F()
152 ASSERT_OK(Flush()); in TEST_F()
158 ASSERT_OK(dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
159 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
166 ASSERT_OK(db_secondary_->Get(ropts, "foo", &value)); in TEST_F()
168 ASSERT_OK(db_secondary_->Get(ropts, "bar", &value)); in TEST_F()
190 ASSERT_OK(Put("foo", "new_foo_value")); in TEST_F()
191 ASSERT_OK(Put("bar", "new_bar_value")); in TEST_F()
192 ASSERT_OK(Flush()); in TEST_F()
194 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
261 ASSERT_OK(Put("a", "value")); in TEST_F()
262 ASSERT_OK(Put("c", "value")); in TEST_F()
263 ASSERT_OK(Flush()); in TEST_F()
264 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
267 ASSERT_OK(Put("b", "value")); in TEST_F()
268 ASSERT_OK(Put("d", "value")); in TEST_F()
269 ASSERT_OK(Flush()); in TEST_F()
270 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
273 ASSERT_OK(dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
274 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
288 ASSERT_OK(Put("foo", "foo_value" + std::to_string(i))); in TEST_F()
289 ASSERT_OK(Put("bar", "bar_value" + std::to_string(i))); in TEST_F()
301 ASSERT_OK(db_secondary_->Get(ropts, "foo", &value)); in TEST_F()
303 ASSERT_OK(db_secondary_->Get(ropts, "bar", &value)); in TEST_F()
325 ASSERT_OK(Put("foo", "new_foo_value")); in TEST_F()
326 ASSERT_OK(Put("bar", "new_bar_value")); in TEST_F()
328 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
331 ASSERT_OK(Flush()); in TEST_F()
332 ASSERT_OK(Put("foo", "new_foo_value_1")); in TEST_F()
333 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
365 ASSERT_OK(Put(0 /*cf*/, "foo", "foo_value")); in TEST_F()
366 ASSERT_OK(Put(1 /*cf*/, "foo", "foo_value")); in TEST_F()
367 ASSERT_OK(Flush(0 /*cf*/)); in TEST_F()
368 ASSERT_OK(Flush(1 /*cf*/)); in TEST_F()
369 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
373 ASSERT_OK(db_secondary_->Get(ropts, "foo", &value)); in TEST_F()
412 ASSERT_OK(Put("foo", "foo_value" + std::to_string(i))); in TEST_F()
413 ASSERT_OK(Put("bar", "bar_value" + std::to_string(i))); in TEST_F()
414 ASSERT_OK(dbfull()->Flush(FlushOptions())); in TEST_F()
416 ASSERT_OK(dbfull()->TEST_WaitForFlushMemTable()); in TEST_F()
417 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
425 ASSERT_OK(db_secondary_->Get(ropts, "foo", &value)); in TEST_F()
429 ASSERT_OK(db_secondary_->Get(ropts, "bar", &value)); in TEST_F()
481 ASSERT_OK(Put("foo", "foo_value" + std::to_string(i))); in TEST_F()
482 ASSERT_OK(Put("bar", "bar_value" + std::to_string(i))); in TEST_F()
483 ASSERT_OK(dbfull()->Flush(FlushOptions())); in TEST_F()
485 ASSERT_OK(dbfull()->TEST_WaitForFlushMemTable()); in TEST_F()
486 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
495 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
497 ASSERT_OK(db_secondary_->Get(ropts, "foo", &value)); in TEST_F()
501 ASSERT_OK(db_secondary_->Get(ropts, "bar", &value)); in TEST_F()
539 ASSERT_OK(Put(1 /*cf*/, "foo", "foo_val_1")); in TEST_F()
540 ASSERT_OK(Flush(1 /*cf*/)); in TEST_F()
542 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
546 ASSERT_OK(db_secondary_->Get(ropts, handles_secondary_[1], "foo", &value)); in TEST_F()
549 ASSERT_OK(dbfull()->DropColumnFamily(handles_[1])); in TEST_F()
552 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
554 ASSERT_OK(db_secondary_->Get(ropts, handles_secondary_[1], "foo", &value)); in TEST_F()
576 ASSERT_OK(Put("key" + std::to_string(j), "value_" + std::to_string(i))); in TEST_F()
578 ASSERT_OK(Flush()); in TEST_F()
581 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
602 ASSERT_OK(dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
603 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
606 ASSERT_OK(dbfull()->SetOptions({{"disable_auto_compactions", "false"}})); in TEST_F()
608 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
626 ASSERT_OK(Put("0", "value0")); in TEST_F()
627 ASSERT_OK(Flush()); in TEST_F()
628 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
632 ASSERT_OK(db_secondary_->Get(ropts, "0", &value)); in TEST_F()
636 ASSERT_OK(dbfull()->SetOptions({{"disable_auto_compactions", "false"}})); in TEST_F()
637 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
673 ASSERT_OK(db2->Get(read_opts, it1->key(), &value)); in TEST_F()
678 ASSERT_OK(db1->Get(read_opts, it2->key(), &value)); in TEST_F()
683 ASSERT_OK(Put("key" + std::to_string(k), "value" + std::to_string(k))); in TEST_F()
684 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
734 ASSERT_OK(db2->Get(read_opts, handles2[i], it1->key(), &value)); in TEST_F()
739 ASSERT_OK(db1->Get(read_opts, handles1[i], it2->key(), &value)); in TEST_F()
745 ASSERT_OK( in TEST_F()
747 ASSERT_OK( in TEST_F()
751 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
776 ASSERT_OK(dbfull()->Write(write_opts, &wb)); in TEST_F()
783 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
800 ASSERT_OK(dbfull()->Write(write_opts, &wb1)); in TEST_F()
807 ASSERT_OK(dbfull()->Write(write_opts, &wb2)); in TEST_F()
810 ASSERT_OK(Flush()); in TEST_F()
812 ASSERT_OK(db_secondary_->TryCatchUpWithPrimary()); in TEST_F()
844 ASSERT_OK(Put("a", "value0")); in TEST_F()
845 ASSERT_OK(Put("c", "value0")); in TEST_F()
846 ASSERT_OK(Flush()); in TEST_F()
847 ASSERT_OK(Put("b", "value1")); in TEST_F()
848 ASSERT_OK(Put("d", "value1")); in TEST_F()
849 ASSERT_OK(Flush()); in TEST_F()
856 ASSERT_OK(dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
857 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()