Lines Matching refs:Status
87 Status PutCF(uint32_t, const Slice&, const Slice&) override { in PutCF()
89 return Status::OK(); in PutCF()
92 Status DeleteCF(uint32_t, const Slice&) override { in DeleteCF()
94 return Status::OK(); in DeleteCF()
97 Status SingleDeleteCF(uint32_t, const Slice&) override { in SingleDeleteCF()
99 return Status::OK(); in SingleDeleteCF()
102 Status DeleteRangeCF(uint32_t, const Slice&, const Slice&) override { in DeleteRangeCF()
104 return Status::OK(); in DeleteRangeCF()
107 Status MergeCF(uint32_t, const Slice&, const Slice&) override { in MergeCF()
109 return Status::OK(); in MergeCF()
112 Status PutBlobIndexCF(uint32_t, const Slice&, const Slice&) override { in PutBlobIndexCF()
114 return Status::OK(); in PutBlobIndexCF()
117 Status MarkBeginPrepare(bool unprepare) override { in MarkBeginPrepare()
122 return Status::OK(); in MarkBeginPrepare()
125 Status MarkEndPrepare(const Slice&) override { in MarkEndPrepare()
127 return Status::OK(); in MarkEndPrepare()
130 Status MarkCommit(const Slice&) override { in MarkCommit()
132 return Status::OK(); in MarkCommit()
135 Status MarkRollback(const Slice&) override { in MarkRollback()
137 return Status::OK(); in MarkRollback()
151 Status PutCF(uint32_t, const Slice& key, const Slice&) override { in PutCF()
154 return Status::OK(); in PutCF()
157 Status DeleteCF(uint32_t, const Slice& key) override { in DeleteCF()
160 return Status::OK(); in DeleteCF()
163 Status SingleDeleteCF(uint32_t, const Slice& key) override { in SingleDeleteCF()
166 return Status::OK(); in SingleDeleteCF()
169 Status DeleteRangeCF(uint32_t, const Slice& begin_key, in DeleteRangeCF()
174 return Status::OK(); in DeleteRangeCF()
177 Status MergeCF(uint32_t, const Slice& key, const Slice&) override { in MergeCF()
180 return Status::OK(); in MergeCF()
183 Status PutBlobIndexCF(uint32_t, const Slice&, const Slice&) override { in PutBlobIndexCF()
185 return Status::OK(); in PutBlobIndexCF()
188 Status MarkBeginPrepare(bool) override { in MarkBeginPrepare()
190 return Status::OK(); in MarkBeginPrepare()
193 Status MarkEndPrepare(const Slice&) override { in MarkEndPrepare()
195 return Status::OK(); in MarkEndPrepare()
198 Status MarkCommit(const Slice&) override { in MarkCommit()
200 return Status::OK(); in MarkCommit()
203 Status MarkRollback(const Slice&) override { in MarkRollback()
205 return Status::OK(); in MarkRollback()
414 Status ReadRecordFromWriteBatch(Slice* input, char* tag, in ReadRecordFromWriteBatch()
424 return Status::Corruption("bad WriteBatch Put"); in ReadRecordFromWriteBatch()
430 return Status::Corruption("bad WriteBatch Put"); in ReadRecordFromWriteBatch()
436 return Status::Corruption("bad WriteBatch Delete"); in ReadRecordFromWriteBatch()
442 return Status::Corruption("bad WriteBatch Delete"); in ReadRecordFromWriteBatch()
447 return Status::Corruption("bad WriteBatch DeleteRange"); in ReadRecordFromWriteBatch()
454 return Status::Corruption("bad WriteBatch DeleteRange"); in ReadRecordFromWriteBatch()
459 return Status::Corruption("bad WriteBatch Merge"); in ReadRecordFromWriteBatch()
465 return Status::Corruption("bad WriteBatch Merge"); in ReadRecordFromWriteBatch()
470 return Status::Corruption("bad WriteBatch BlobIndex"); in ReadRecordFromWriteBatch()
476 return Status::Corruption("bad WriteBatch BlobIndex"); in ReadRecordFromWriteBatch()
482 return Status::Corruption("bad WriteBatch Blob"); in ReadRecordFromWriteBatch()
495 return Status::Corruption("bad EndPrepare XID"); in ReadRecordFromWriteBatch()
500 return Status::Corruption("bad Commit XID"); in ReadRecordFromWriteBatch()
505 return Status::Corruption("bad Rollback XID"); in ReadRecordFromWriteBatch()
509 return Status::Corruption("unknown WriteBatch tag"); in ReadRecordFromWriteBatch()
511 return Status::OK(); in ReadRecordFromWriteBatch()
514 Status WriteBatch::Iterate(Handler* handler) const { in Iterate()
516 return Status::Corruption("malformed WriteBatch (too small)"); in Iterate()
523 Status WriteBatchInternal::Iterate(const WriteBatch* wb, in Iterate()
527 return Status::Corruption("Invalid start/end bounds for Iterate"); in Iterate()
541 Status s; in Iterate()
566 return Status::Corruption( in Iterate()
571 s = Status::OK(); in Iterate()
645 s = Status::NotSupported( in Iterate()
652 s = Status::NotSupported( in Iterate()
664 s = Status::NotSupported( in Iterate()
677 s = Status::NotSupported( in Iterate()
683 s = Status::NotSupported( in Iterate()
713 return Status::Corruption("unknown WriteBatch tag"); in Iterate()
721 return Status::Corruption("WriteBatch has wrong count"); in Iterate()
723 return Status::OK(); in Iterate()
755 Status WriteBatchInternal::Put(WriteBatch* b, uint32_t column_family_id, in Put()
758 return Status::InvalidArgument("key is too large"); in Put()
761 return Status::InvalidArgument("value is too large"); in Put()
787 Status WriteBatch::Put(ColumnFamilyHandle* column_family, const Slice& key, in Put()
793 Status WriteBatchInternal::CheckSlicePartsLength(const SliceParts& key, in CheckSlicePartsLength()
800 return Status::InvalidArgument("key is too large"); in CheckSlicePartsLength()
808 return Status::InvalidArgument("value is too large"); in CheckSlicePartsLength()
810 return Status::OK(); in CheckSlicePartsLength()
813 Status WriteBatchInternal::Put(WriteBatch* b, uint32_t column_family_id, in Put()
815 Status s = CheckSlicePartsLength(key, value); in Put()
840 Status WriteBatch::Put(ColumnFamilyHandle* column_family, const SliceParts& key, in Put()
846 Status WriteBatchInternal::InsertNoop(WriteBatch* b) { in InsertNoop()
848 return Status::OK(); in InsertNoop()
851 Status WriteBatchInternal::MarkEndPrepare(WriteBatch* b, const Slice& xid, in MarkEndPrepare()
880 return Status::OK(); in MarkEndPrepare()
883 Status WriteBatchInternal::MarkCommit(WriteBatch* b, const Slice& xid) { in MarkCommit()
889 return Status::OK(); in MarkCommit()
892 Status WriteBatchInternal::MarkRollback(WriteBatch* b, const Slice& xid) { in MarkRollback()
898 return Status::OK(); in MarkRollback()
901 Status WriteBatchInternal::Delete(WriteBatch* b, uint32_t column_family_id, in Delete()
918 Status WriteBatch::Delete(ColumnFamilyHandle* column_family, const Slice& key) { in Delete()
923 Status WriteBatchInternal::Delete(WriteBatch* b, uint32_t column_family_id, in Delete()
940 Status WriteBatch::Delete(ColumnFamilyHandle* column_family, in Delete()
946 Status WriteBatchInternal::SingleDelete(WriteBatch* b, in SingleDelete()
964 Status WriteBatch::SingleDelete(ColumnFamilyHandle* column_family, in SingleDelete()
970 Status WriteBatchInternal::SingleDelete(WriteBatch* b, in SingleDelete()
988 Status WriteBatch::SingleDelete(ColumnFamilyHandle* column_family, in SingleDelete()
994 Status WriteBatchInternal::DeleteRange(WriteBatch* b, uint32_t column_family_id, in DeleteRange()
1013 Status WriteBatch::DeleteRange(ColumnFamilyHandle* column_family, in DeleteRange()
1019 Status WriteBatchInternal::DeleteRange(WriteBatch* b, uint32_t column_family_id, in DeleteRange()
1038 Status WriteBatch::DeleteRange(ColumnFamilyHandle* column_family, in DeleteRange()
1045 Status WriteBatchInternal::Merge(WriteBatch* b, uint32_t column_family_id, in Merge()
1048 return Status::InvalidArgument("key is too large"); in Merge()
1051 return Status::InvalidArgument("value is too large"); in Merge()
1070 Status WriteBatch::Merge(ColumnFamilyHandle* column_family, const Slice& key, in Merge()
1076 Status WriteBatchInternal::Merge(WriteBatch* b, uint32_t column_family_id, in Merge()
1079 Status s = CheckSlicePartsLength(key, value); in Merge()
1100 Status WriteBatch::Merge(ColumnFamilyHandle* column_family, in Merge()
1106 Status WriteBatchInternal::PutBlobIndex(WriteBatch* b, in PutBlobIndex()
1125 Status WriteBatch::PutLogData(const Slice& blob) { in PutLogData()
1141 Status WriteBatch::RollbackToSavePoint() { in RollbackToSavePoint()
1143 return Status::NotFound(); in RollbackToSavePoint()
1164 return Status::OK(); in RollbackToSavePoint()
1167 Status WriteBatch::PopSavePoint() { in PopSavePoint()
1169 return Status::NotFound(); in PopSavePoint()
1175 return Status::OK(); in PopSavePoint()
1178 Status WriteBatch::AssignTimestamp(const Slice& ts) { in AssignTimestamp()
1183 Status WriteBatch::AssignTimestamps(const std::vector<Slice>& ts_list) { in AssignTimestamps()
1358 bool SeekToColumnFamily(uint32_t column_family_id, Status* s) { in SeekToColumnFamily()
1366 *s = Status::OK(); in SeekToColumnFamily()
1368 *s = Status::InvalidArgument( in SeekToColumnFamily()
1383 *s = Status::OK(); in SeekToColumnFamily()
1398 Status PutCFImpl(uint32_t column_family_id, const Slice& key, in PutCFImpl()
1403 return Status::OK(); in PutCFImpl()
1407 Status seek_status; in PutCFImpl()
1420 Status ret_status; in PutCFImpl()
1434 ret_status = Status::TryAgain("key+seq exists"); in PutCFImpl()
1458 Status s = Status::NotSupported(); in PutCFImpl()
1503 Status PutCF(uint32_t column_family_id, const Slice& key, in PutCF()
1508 Status DeleteImpl(uint32_t /*column_family_id*/, const Slice& key, in DeleteImpl()
1510 Status ret_status; in DeleteImpl()
1518 ret_status = Status::TryAgain("key+seq exists"); in DeleteImpl()
1527 Status DeleteCF(uint32_t column_family_id, const Slice& key) override { in DeleteCF()
1531 return Status::OK(); in DeleteCF()
1535 Status seek_status; in DeleteCF()
1560 Status SingleDeleteCF(uint32_t column_family_id, const Slice& key) override { in SingleDeleteCF()
1564 return Status::OK(); in SingleDeleteCF()
1568 Status seek_status; in SingleDeleteCF()
1595 Status DeleteRangeCF(uint32_t column_family_id, const Slice& begin_key, in DeleteRangeCF()
1601 return Status::OK(); in DeleteRangeCF()
1605 Status seek_status; in DeleteRangeCF()
1628 return Status::NotSupported( in DeleteRangeCF()
1648 Status MergeCF(uint32_t column_family_id, const Slice& key, in MergeCF()
1653 return Status::OK(); in MergeCF()
1657 Status seek_status; in MergeCF()
1672 Status ret_status; in MergeCF()
1721 Status merge_status = MergeHelper::TimedFullMerge( in MergeCF()
1735 ret_status = Status::TryAgain("key+seq exists"); in MergeCF()
1749 ret_status = Status::TryAgain("key+seq exists"); in MergeCF()
1767 Status PutBlobIndexCF(uint32_t column_family_id, const Slice& key, in PutBlobIndexCF()
1815 Status MarkBeginPrepare(bool unprepare) override { in MarkBeginPrepare()
1823 return Status::NotSupported( in MarkBeginPrepare()
1842 return Status::OK(); in MarkBeginPrepare()
1845 Status MarkEndPrepare(const Slice& name) override { in MarkEndPrepare()
1866 return Status::OK(); in MarkEndPrepare()
1869 Status MarkNoop(bool empty_batch) override { in MarkNoop()
1879 return Status::OK(); in MarkNoop()
1882 Status MarkCommit(const Slice& name) override { in MarkCommit()
1885 Status s; in MarkCommit()
1930 Status MarkRollback(const Slice& name) override { in MarkRollback()
1949 return Status::OK(); in MarkRollback()
1967 Status WriteBatchInternal::InsertInto( in InsertInto()
1997 return Status::OK(); in InsertInto()
2000 Status WriteBatchInternal::InsertInto( in InsertInto()
2018 Status s = writer->batch->Iterate(&inserter); in InsertInto()
2027 Status WriteBatchInternal::InsertInto( in InsertInto()
2039 Status s = batch->Iterate(&inserter); in InsertInto()
2049 Status WriteBatchInternal::SetContents(WriteBatch* b, const Slice& contents) { in SetContents()
2053 return Status::OK(); in SetContents()
2056 Status WriteBatchInternal::Append(WriteBatch* dst, const WriteBatch* src, in Append()
2080 return Status::OK(); in Append()