Lines Matching refs:batch
133 WriteBatch batch; in TEST_F() local
134 ASSERT_EQ("", PrintContents(&batch)); in TEST_F()
135 ASSERT_EQ(0u, WriteBatchInternal::Count(&batch)); in TEST_F()
136 ASSERT_EQ(0u, batch.Count()); in TEST_F()
140 WriteBatch batch; in TEST_F() local
141 batch.Put(Slice("foo"), Slice("bar")); in TEST_F()
142 batch.Delete(Slice("box")); in TEST_F()
143 batch.DeleteRange(Slice("bar"), Slice("foo")); in TEST_F()
144 batch.Put(Slice("baz"), Slice("boo")); in TEST_F()
145 WriteBatchInternal::SetSequence(&batch, 100); in TEST_F()
146 ASSERT_EQ(100U, WriteBatchInternal::Sequence(&batch)); in TEST_F()
147 ASSERT_EQ(4u, WriteBatchInternal::Count(&batch)); in TEST_F()
153 PrintContents(&batch)); in TEST_F()
154 ASSERT_EQ(4u, batch.Count()); in TEST_F()
158 WriteBatch batch; in TEST_F() local
159 batch.Put(Slice("foo"), Slice("bar")); in TEST_F()
160 batch.Delete(Slice("box")); in TEST_F()
161 WriteBatchInternal::SetSequence(&batch, 200); in TEST_F()
162 Slice contents = WriteBatchInternal::Contents(&batch); in TEST_F()
163 WriteBatchInternal::SetContents(&batch, in TEST_F()
167 PrintContents(&batch)); in TEST_F()
222 WriteBatch batch; in TEST_F() local
223 WriteBatchInternal::SetSequence(&batch, 100); in TEST_F()
224 ASSERT_EQ("", PrintContents(&batch)); in TEST_F()
225 ASSERT_EQ(0u, batch.Count()); in TEST_F()
226 batch.Put("a", "va"); in TEST_F()
227 ASSERT_EQ("Put(a, va)@100", PrintContents(&batch)); in TEST_F()
228 ASSERT_EQ(1u, batch.Count()); in TEST_F()
229 batch.SingleDelete("a"); in TEST_F()
233 PrintContents(&batch)); in TEST_F()
234 ASSERT_EQ(2u, batch.Count()); in TEST_F()
318 WriteBatch batch; in TEST_F() local
319 batch.Put(Slice("k1"), Slice("v1")); in TEST_F()
320 ASSERT_EQ(1u, batch.Count()); in TEST_F()
321 ASSERT_EQ("Put(k1, v1)@0", PrintContents(&batch)); in TEST_F()
324 ASSERT_OK(batch.Iterate(&handler)); in TEST_F()
328 WriteBatch batch; in TEST_F() local
329 batch.Delete(Slice("k2")); in TEST_F()
330 ASSERT_EQ(1u, batch.Count()); in TEST_F()
331 ASSERT_EQ("Delete(k2)@0", PrintContents(&batch)); in TEST_F()
334 ASSERT_OK(batch.Iterate(&handler)); in TEST_F()
338 WriteBatch batch; in TEST_F() local
339 batch.SingleDelete(Slice("k2")); in TEST_F()
340 ASSERT_EQ(1u, batch.Count()); in TEST_F()
341 ASSERT_EQ("SingleDelete(k2)@0", PrintContents(&batch)); in TEST_F()
344 ASSERT_OK(batch.Iterate(&handler)); in TEST_F()
348 WriteBatch batch; in TEST_F() local
349 batch.Merge(Slice("foo"), Slice("bar")); in TEST_F()
350 ASSERT_EQ(1u, batch.Count()); in TEST_F()
351 ASSERT_EQ("Merge(foo, bar)@0", PrintContents(&batch)); in TEST_F()
354 ASSERT_OK(batch.Iterate(&handler)); in TEST_F()
358 WriteBatch batch; in TEST_F() local
359 batch.Put(Slice("k1"), Slice("v1")); in TEST_F()
360 batch.Put(Slice("k2"), Slice("v2")); in TEST_F()
361 batch.Put(Slice("k3"), Slice("v3")); in TEST_F()
362 batch.PutLogData(Slice("blob1")); in TEST_F()
363 batch.Delete(Slice("k2")); in TEST_F()
364 batch.SingleDelete(Slice("k3")); in TEST_F()
365 batch.PutLogData(Slice("blob2")); in TEST_F()
366 batch.Merge(Slice("foo"), Slice("bar")); in TEST_F()
367 ASSERT_EQ(6u, batch.Count()); in TEST_F()
375 PrintContents(&batch)); in TEST_F()
378 batch.Iterate(&handler); in TEST_F()
392 WriteBatch batch; in TEST_F() local
393 WriteBatchInternal::InsertNoop(&batch); in TEST_F()
394 batch.Put(Slice("k1"), Slice("v1")); in TEST_F()
395 batch.Put(Slice("k2"), Slice("v2")); in TEST_F()
396 batch.SetSavePoint(); in TEST_F()
397 WriteBatchInternal::MarkEndPrepare(&batch, Slice("xid1")); in TEST_F()
398 Status s = batch.RollbackToSavePoint(); in TEST_F()
400 WriteBatchInternal::MarkCommit(&batch, Slice("xid1")); in TEST_F()
401 WriteBatchInternal::MarkRollback(&batch, Slice("xid1")); in TEST_F()
402 ASSERT_EQ(2u, batch.Count()); in TEST_F()
405 batch.Iterate(&handler); in TEST_F()
424 WriteBatch batch(kNumUpdates * (4 + kKeyValueSize * 2) + 1024u); in TEST_F() local
433 batch.Put(raw, raw); in TEST_F()
436 ASSERT_EQ(kNumUpdates, batch.Count()); in TEST_F()
475 batch.Iterate(&handler); in TEST_F()
485 WriteBatch batch(size_t(12884901888ull + 1024u)); in TEST_F() local
489 batch.Put(raw, raw); in TEST_F()
492 ASSERT_EQ(2u, batch.Count()); in TEST_F()
526 batch.Iterate(&handler); in TEST_F()
531 WriteBatch batch; in TEST_F() local
561 batch.Put(Slice("k1"), Slice("v1")); in TEST_F()
562 batch.Put(Slice("k2"), Slice("v2")); in TEST_F()
563 batch.PutLogData(Slice("blob1")); in TEST_F()
564 batch.Delete(Slice("k1")); in TEST_F()
565 batch.SingleDelete(Slice("k2")); in TEST_F()
566 batch.PutLogData(Slice("blob2")); in TEST_F()
567 batch.Merge(Slice("foo"), Slice("bar")); in TEST_F()
568 batch.Iterate(&handler); in TEST_F()
579 WriteBatch batch; in TEST_F() local
580 batch.Put(Slice("foo"), Slice("bar")); in TEST_F()
586 batch.Put(SliceParts(&key_slice, 1), in TEST_F()
594 batch.Put(SliceParts(key_slices, 3), in TEST_F()
598 WriteBatchInternal::SetSequence(&batch, 100); in TEST_F()
602 PrintContents(&batch)); in TEST_F()
603 ASSERT_EQ(3u, batch.Count()); in TEST_F()
622 WriteBatch batch; in TEST_F() local
624 batch.Put(&zero, Slice("foo"), Slice("bar")); in TEST_F()
625 batch.Put(&two, Slice("twofoo"), Slice("bar2")); in TEST_F()
626 batch.Put(&eight, Slice("eightfoo"), Slice("bar8")); in TEST_F()
627 batch.Delete(&eight, Slice("eightfoo")); in TEST_F()
628 batch.SingleDelete(&two, Slice("twofoo")); in TEST_F()
629 batch.DeleteRange(&two, Slice("3foo"), Slice("4foo")); in TEST_F()
630 batch.Merge(&three, Slice("threethree"), Slice("3three")); in TEST_F()
631 batch.Put(&zero, Slice("foo"), Slice("bar")); in TEST_F()
632 batch.Merge(Slice("omom"), Slice("nom")); in TEST_F()
635 batch.Iterate(&handler); in TEST_F()
651 WriteBatchWithIndex batch; in TEST_F() local
653 batch.Put(&zero, Slice("foo"), Slice("bar")); in TEST_F()
654 batch.Put(&two, Slice("twofoo"), Slice("bar2")); in TEST_F()
655 batch.Put(&eight, Slice("eightfoo"), Slice("bar8")); in TEST_F()
656 batch.Delete(&eight, Slice("eightfoo")); in TEST_F()
657 batch.SingleDelete(&two, Slice("twofoo")); in TEST_F()
658 batch.Merge(&three, Slice("threethree"), Slice("3three")); in TEST_F()
659 batch.Put(&zero, Slice("foo"), Slice("bar")); in TEST_F()
660 batch.Merge(Slice("omom"), Slice("nom")); in TEST_F()
664 iter.reset(batch.NewIterator(&eight)); in TEST_F()
682 iter.reset(batch.NewIterator(&two)); in TEST_F()
700 iter.reset(batch.NewIterator()); in TEST_F()
712 iter.reset(batch.NewIterator(&zero)); in TEST_F()
739 batch.GetWriteBatch()->Iterate(&handler); in TEST_F()
755 WriteBatch batch; in TEST_F() local
756 batch.SetSavePoint(); in TEST_F()
758 batch.Put("A", "a"); in TEST_F()
759 batch.Put("B", "b"); in TEST_F()
760 batch.SetSavePoint(); in TEST_F()
762 batch.Put("C", "c"); in TEST_F()
763 batch.Delete("A"); in TEST_F()
764 batch.SetSavePoint(); in TEST_F()
765 batch.SetSavePoint(); in TEST_F()
767 ASSERT_OK(batch.RollbackToSavePoint()); in TEST_F()
773 PrintContents(&batch)); in TEST_F()
775 ASSERT_OK(batch.RollbackToSavePoint()); in TEST_F()
776 ASSERT_OK(batch.RollbackToSavePoint()); in TEST_F()
780 PrintContents(&batch)); in TEST_F()
782 batch.Delete("A"); in TEST_F()
783 batch.Put("B", "bb"); in TEST_F()
785 ASSERT_OK(batch.RollbackToSavePoint()); in TEST_F()
786 ASSERT_EQ("", PrintContents(&batch)); in TEST_F()
788 s = batch.RollbackToSavePoint(); in TEST_F()
790 ASSERT_EQ("", PrintContents(&batch)); in TEST_F()
792 batch.Put("D", "d"); in TEST_F()
793 batch.Delete("A"); in TEST_F()
795 batch.SetSavePoint(); in TEST_F()
797 batch.Put("A", "aaa"); in TEST_F()
799 ASSERT_OK(batch.RollbackToSavePoint()); in TEST_F()
803 PrintContents(&batch)); in TEST_F()
805 batch.SetSavePoint(); in TEST_F()
807 batch.Put("D", "d"); in TEST_F()
808 batch.Delete("A"); in TEST_F()
810 ASSERT_OK(batch.RollbackToSavePoint()); in TEST_F()
814 PrintContents(&batch)); in TEST_F()
816 s = batch.RollbackToSavePoint(); in TEST_F()
821 PrintContents(&batch)); in TEST_F()
875 WriteBatch batch(0, 28); in TEST_F() local
877 ASSERT_OK(batch.Put("a", "....")); in TEST_F()
878 ASSERT_OK(batch.Put("b", "....")); in TEST_F()
879 s = batch.Put("c", "...."); in TEST_F()