Lines Matching refs:b
727 bool WriteBatchInternal::IsLatestPersistentState(const WriteBatch* b) { in IsLatestPersistentState() argument
728 return b->is_latest_persistent_state_; in IsLatestPersistentState()
731 void WriteBatchInternal::SetAsLastestPersistentState(WriteBatch* b) { in SetAsLastestPersistentState() argument
732 b->is_latest_persistent_state_ = true; in SetAsLastestPersistentState()
735 uint32_t WriteBatchInternal::Count(const WriteBatch* b) { in Count() argument
736 return DecodeFixed32(b->rep_.data() + 8); in Count()
739 void WriteBatchInternal::SetCount(WriteBatch* b, uint32_t n) { in SetCount() argument
740 EncodeFixed32(&b->rep_[8], n); in SetCount()
743 SequenceNumber WriteBatchInternal::Sequence(const WriteBatch* b) { in Sequence() argument
744 return SequenceNumber(DecodeFixed64(b->rep_.data())); in Sequence()
747 void WriteBatchInternal::SetSequence(WriteBatch* b, SequenceNumber seq) { in SetSequence() argument
748 EncodeFixed64(&b->rep_[0], seq); in SetSequence()
755 Status WriteBatchInternal::Put(WriteBatch* b, uint32_t column_family_id, in Put() argument
764 LocalSavePoint save(b); in Put()
765 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Put()
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()
772 if (0 == b->timestamp_size_) { in Put()
773 PutLengthPrefixedSlice(&b->rep_, key); in Put()
775 PutVarint32(&b->rep_, in Put()
776 static_cast<uint32_t>(key.size() + b->timestamp_size_)); 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()
781 b->content_flags_.store( in Put()
782 b->content_flags_.load(std::memory_order_relaxed) | ContentFlags::HAS_PUT, in Put()
813 Status WriteBatchInternal::Put(WriteBatch* b, uint32_t column_family_id, in Put() argument
820 LocalSavePoint save(b); in Put()
821 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); 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()
828 if (0 == b->timestamp_size_) { 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()
834 b->content_flags_.store( in Put()
835 b->content_flags_.load(std::memory_order_relaxed) | ContentFlags::HAS_PUT, in Put()
846 Status WriteBatchInternal::InsertNoop(WriteBatch* b) { in InsertNoop() argument
847 b->rep_.push_back(static_cast<char>(kTypeNoop)); in InsertNoop()
851 Status WriteBatchInternal::MarkEndPrepare(WriteBatch* b, const Slice& xid, in MarkEndPrepare() argument
855 assert(b->rep_[12] == static_cast<char>(kTypeNoop)); in MarkEndPrepare()
858 if (b->save_points_ != nullptr) { in MarkEndPrepare()
859 while (!b->save_points_->stack.empty()) { in MarkEndPrepare()
860 b->save_points_->stack.pop(); 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()
871 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in MarkEndPrepare()
876 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in MarkEndPrepare()
883 Status WriteBatchInternal::MarkCommit(WriteBatch* b, const Slice& xid) { in MarkCommit() argument
884 b->rep_.push_back(static_cast<char>(kTypeCommitXID)); in MarkCommit()
885 PutLengthPrefixedSlice(&b->rep_, xid); in MarkCommit()
886 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in MarkCommit()
892 Status WriteBatchInternal::MarkRollback(WriteBatch* b, const Slice& xid) { in MarkRollback() argument
893 b->rep_.push_back(static_cast<char>(kTypeRollbackXID)); in MarkRollback()
894 PutLengthPrefixedSlice(&b->rep_, xid); in MarkRollback()
895 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in MarkRollback()
901 Status WriteBatchInternal::Delete(WriteBatch* b, uint32_t column_family_id, in Delete() argument
903 LocalSavePoint save(b); in Delete()
904 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Delete()
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()
912 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in Delete()
923 Status WriteBatchInternal::Delete(WriteBatch* b, uint32_t column_family_id, in Delete() argument
925 LocalSavePoint save(b); in Delete()
926 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); 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()
934 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in Delete()
946 Status WriteBatchInternal::SingleDelete(WriteBatch* b, in SingleDelete() argument
949 LocalSavePoint save(b); in SingleDelete()
950 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in SingleDelete()
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()
958 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in SingleDelete()
970 Status WriteBatchInternal::SingleDelete(WriteBatch* b, in SingleDelete() argument
973 LocalSavePoint save(b); in SingleDelete()
974 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); 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()
982 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in SingleDelete()
994 Status WriteBatchInternal::DeleteRange(WriteBatch* b, uint32_t column_family_id, in DeleteRange() argument
997 LocalSavePoint save(b); in DeleteRange()
998 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in DeleteRange()
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()
1007 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in DeleteRange()
1019 Status WriteBatchInternal::DeleteRange(WriteBatch* b, uint32_t column_family_id, in DeleteRange() argument
1022 LocalSavePoint save(b); in DeleteRange()
1023 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); 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()
1032 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in DeleteRange()
1045 Status WriteBatchInternal::Merge(WriteBatch* b, uint32_t column_family_id, in Merge() argument
1054 LocalSavePoint save(b); in Merge()
1055 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Merge()
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()
1064 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in Merge()
1076 Status WriteBatchInternal::Merge(WriteBatch* b, uint32_t column_family_id, in Merge() argument
1084 LocalSavePoint save(b); in Merge()
1085 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); 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()
1094 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in Merge()
1106 Status WriteBatchInternal::PutBlobIndex(WriteBatch* b, in PutBlobIndex() argument
1109 LocalSavePoint save(b); in PutBlobIndex()
1110 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in PutBlobIndex()
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()
1119 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in PutBlobIndex()
2049 Status WriteBatchInternal::SetContents(WriteBatch* b, const Slice& contents) { in SetContents() argument
2051 b->rep_.assign(contents.data(), contents.size()); in SetContents()
2052 b->content_flags_.store(ContentFlags::DEFERRED, std::memory_order_relaxed); in SetContents()