Lines Matching refs:rep
636 : rep(new Rep(default_index_comparator, reserved_bytes, max_bytes, in WriteBatchWithIndex()
646 WriteBatch* WriteBatchWithIndex::GetWriteBatch() { return &rep->write_batch; } in GetWriteBatch()
648 size_t WriteBatchWithIndex::SubBatchCnt() { return rep->sub_batch_cnt; } in SubBatchCnt()
651 return new WBWIIteratorImpl(0, &(rep->skip_list), &rep->write_batch); in NewIterator()
657 &(rep->skip_list), &rep->write_batch); in NewIterator()
663 if (rep->overwrite_key == false) { in NewIteratorWithBase()
673 if (rep->overwrite_key == false) { in NewIteratorWithBase()
679 rep->comparator.default_comparator()); in NewIteratorWithBase()
684 rep->SetLastEntryOffset(); in Put()
685 auto s = rep->write_batch.Put(column_family, key, value); in Put()
687 rep->AddOrUpdateIndex(column_family, key); in Put()
693 rep->SetLastEntryOffset(); in Put()
694 auto s = rep->write_batch.Put(key, value); in Put()
696 rep->AddOrUpdateIndex(key); in Put()
703 rep->SetLastEntryOffset(); in Delete()
704 auto s = rep->write_batch.Delete(column_family, key); in Delete()
706 rep->AddOrUpdateIndex(column_family, key); in Delete()
712 rep->SetLastEntryOffset(); in Delete()
713 auto s = rep->write_batch.Delete(key); in Delete()
715 rep->AddOrUpdateIndex(key); in Delete()
722 rep->SetLastEntryOffset(); in SingleDelete()
723 auto s = rep->write_batch.SingleDelete(column_family, key); in SingleDelete()
725 rep->AddOrUpdateIndex(column_family, key); in SingleDelete()
731 rep->SetLastEntryOffset(); in SingleDelete()
732 auto s = rep->write_batch.SingleDelete(key); in SingleDelete()
734 rep->AddOrUpdateIndex(key); in SingleDelete()
741 rep->SetLastEntryOffset(); in Merge()
742 auto s = rep->write_batch.Merge(column_family, key, value); in Merge()
744 rep->AddOrUpdateIndex(column_family, key); in Merge()
750 rep->SetLastEntryOffset(); in Merge()
751 auto s = rep->write_batch.Merge(key, value); in Merge()
753 rep->AddOrUpdateIndex(key); in Merge()
759 return rep->write_batch.PutLogData(blob); in PutLogData()
762 void WriteBatchWithIndex::Clear() { rep->Clear(); } in Clear()
774 &rep->comparator, value, rep->overwrite_key, &s); in GetFromBatch()
859 &rep->comparator, &batch_value, rep->overwrite_key, &s); in GetFromBatchAndDB()
872 rep->overwrite_key == true) { in GetFromBatchAndDB()
961 &rep->comparator, &batch_value, rep->overwrite_key, s); in MultiGetFromBatchAndDB()
975 rep->overwrite_key == true) { in MultiGetFromBatchAndDB()
1039 void WriteBatchWithIndex::SetSavePoint() { rep->write_batch.SetSavePoint(); } in SetSavePoint()
1042 Status s = rep->write_batch.RollbackToSavePoint(); in RollbackToSavePoint()
1045 rep->sub_batch_cnt = 1; in RollbackToSavePoint()
1046 rep->last_sub_batch_offset = 0; in RollbackToSavePoint()
1047 s = rep->ReBuildIndex(); in RollbackToSavePoint()
1054 return rep->write_batch.PopSavePoint(); in PopSavePoint()
1058 rep->write_batch.SetMaxBytes(max_bytes); in SetMaxBytes()
1062 return rep->write_batch.GetDataSize(); in GetDataSize()