Lines Matching refs:rep_
247 : content_flags_(0), max_bytes_(max_bytes), rep_(), timestamp_size_(0) { in WriteBatch()
248 rep_.reserve((reserved_bytes > WriteBatchInternal::kHeader) in WriteBatch()
251 rep_.resize(WriteBatchInternal::kHeader); in WriteBatch()
255 : content_flags_(0), max_bytes_(max_bytes), rep_(), timestamp_size_(ts_sz) { in WriteBatch()
256 rep_.reserve((reserved_bytes > WriteBatchInternal::kHeader) ? in WriteBatch()
258 rep_.resize(WriteBatchInternal::kHeader); in WriteBatch()
264 rep_(rep), in WriteBatch()
270 rep_(std::move(rep)), in WriteBatch()
277 rep_(src.rep_), in WriteBatch()
290 rep_(std::move(src.rep_)), in WriteBatch()
323 rep_.clear(); in Clear()
324 rep_.resize(WriteBatchInternal::kHeader); in Clear()
515 if (rep_.size() < WriteBatchInternal::kHeader) { in Iterate()
520 rep_.size()); in Iterate()
526 if (begin > wb->rep_.size() || end > wb->rep_.size() || end < begin) { in Iterate()
530 Slice input(wb->rep_.data() + begin, static_cast<size_t>(end - begin)); in Iterate()
532 (begin == WriteBatchInternal::kHeader) && (end == wb->rep_.size()); in Iterate()
736 return DecodeFixed32(b->rep_.data() + 8); in Count()
740 EncodeFixed32(&b->rep_[8], n); in SetCount()
744 return SequenceNumber(DecodeFixed64(b->rep_.data())); in Sequence()
748 EncodeFixed64(&b->rep_[0], seq); in SetSequence()
767 b->rep_.push_back(static_cast<char>(kTypeValue)); in Put()
769 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyValue)); in Put()
770 PutVarint32(&b->rep_, column_family_id); in Put()
773 PutLengthPrefixedSlice(&b->rep_, key); in Put()
775 PutVarint32(&b->rep_, in Put()
777 b->rep_.append(key.data(), key.size()); in Put()
778 b->rep_.append(b->timestamp_size_, '\0'); in Put()
780 PutLengthPrefixedSlice(&b->rep_, value); in Put()
823 b->rep_.push_back(static_cast<char>(kTypeValue)); in Put()
825 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyValue)); in Put()
826 PutVarint32(&b->rep_, column_family_id); in Put()
829 PutLengthPrefixedSliceParts(&b->rep_, key); in Put()
831 PutLengthPrefixedSlicePartsWithPadding(&b->rep_, key, b->timestamp_size_); in Put()
833 PutLengthPrefixedSliceParts(&b->rep_, value); in Put()
847 b->rep_.push_back(static_cast<char>(kTypeNoop)); in InsertNoop()
855 assert(b->rep_[12] == static_cast<char>(kTypeNoop)); in MarkEndPrepare()
865 b->rep_[12] = static_cast<char>( in MarkEndPrepare()
869 b->rep_.push_back(static_cast<char>(kTypeEndPrepareXID)); in MarkEndPrepare()
870 PutLengthPrefixedSlice(&b->rep_, xid); in MarkEndPrepare()
884 b->rep_.push_back(static_cast<char>(kTypeCommitXID)); in MarkCommit()
885 PutLengthPrefixedSlice(&b->rep_, xid); in MarkCommit()
893 b->rep_.push_back(static_cast<char>(kTypeRollbackXID)); in MarkRollback()
894 PutLengthPrefixedSlice(&b->rep_, xid); in MarkRollback()
906 b->rep_.push_back(static_cast<char>(kTypeDeletion)); in Delete()
908 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyDeletion)); in Delete()
909 PutVarint32(&b->rep_, column_family_id); in Delete()
911 PutLengthPrefixedSlice(&b->rep_, key); in Delete()
928 b->rep_.push_back(static_cast<char>(kTypeDeletion)); in Delete()
930 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyDeletion)); in Delete()
931 PutVarint32(&b->rep_, column_family_id); in Delete()
933 PutLengthPrefixedSliceParts(&b->rep_, key); in Delete()
952 b->rep_.push_back(static_cast<char>(kTypeSingleDeletion)); in SingleDelete()
954 b->rep_.push_back(static_cast<char>(kTypeColumnFamilySingleDeletion)); in SingleDelete()
955 PutVarint32(&b->rep_, column_family_id); in SingleDelete()
957 PutLengthPrefixedSlice(&b->rep_, key); in SingleDelete()
976 b->rep_.push_back(static_cast<char>(kTypeSingleDeletion)); in SingleDelete()
978 b->rep_.push_back(static_cast<char>(kTypeColumnFamilySingleDeletion)); in SingleDelete()
979 PutVarint32(&b->rep_, column_family_id); in SingleDelete()
981 PutLengthPrefixedSliceParts(&b->rep_, key); in SingleDelete()
1000 b->rep_.push_back(static_cast<char>(kTypeRangeDeletion)); in DeleteRange()
1002 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyRangeDeletion)); in DeleteRange()
1003 PutVarint32(&b->rep_, column_family_id); in DeleteRange()
1005 PutLengthPrefixedSlice(&b->rep_, begin_key); in DeleteRange()
1006 PutLengthPrefixedSlice(&b->rep_, end_key); in DeleteRange()
1025 b->rep_.push_back(static_cast<char>(kTypeRangeDeletion)); in DeleteRange()
1027 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyRangeDeletion)); in DeleteRange()
1028 PutVarint32(&b->rep_, column_family_id); in DeleteRange()
1030 PutLengthPrefixedSliceParts(&b->rep_, begin_key); in DeleteRange()
1031 PutLengthPrefixedSliceParts(&b->rep_, end_key); in DeleteRange()
1057 b->rep_.push_back(static_cast<char>(kTypeMerge)); in Merge()
1059 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyMerge)); in Merge()
1060 PutVarint32(&b->rep_, column_family_id); in Merge()
1062 PutLengthPrefixedSlice(&b->rep_, key); in Merge()
1063 PutLengthPrefixedSlice(&b->rep_, value); in Merge()
1087 b->rep_.push_back(static_cast<char>(kTypeMerge)); in Merge()
1089 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyMerge)); in Merge()
1090 PutVarint32(&b->rep_, column_family_id); in Merge()
1092 PutLengthPrefixedSliceParts(&b->rep_, key); in Merge()
1093 PutLengthPrefixedSliceParts(&b->rep_, value); in Merge()
1112 b->rep_.push_back(static_cast<char>(kTypeBlobIndex)); in PutBlobIndex()
1114 b->rep_.push_back(static_cast<char>(kTypeColumnFamilyBlobIndex)); in PutBlobIndex()
1115 PutVarint32(&b->rep_, column_family_id); in PutBlobIndex()
1117 PutLengthPrefixedSlice(&b->rep_, key); in PutBlobIndex()
1118 PutLengthPrefixedSlice(&b->rep_, value); in PutBlobIndex()
1127 rep_.push_back(static_cast<char>(kTypeLogData)); in PutLogData()
1128 PutLengthPrefixedSlice(&rep_, blob); in PutLogData()
1150 assert(savepoint.size <= rep_.size()); in RollbackToSavePoint()
1153 if (savepoint.size == rep_.size()) { in RollbackToSavePoint()
1159 rep_.resize(savepoint.size); in RollbackToSavePoint()
2051 b->rep_.assign(contents.data(), contents.size()); in SetContents()
2069 src_len = src->rep_.size() - WriteBatchInternal::kHeader; in Append()
2075 assert(src->rep_.size() >= WriteBatchInternal::kHeader); in Append()
2076 dst->rep_.append(src->rep_.data() + WriteBatchInternal::kHeader, src_len); in Append()