| 28 | OpenRocksDB::OpenRocksDB(RocksDatabase& db, gsl::not_null<std::shared_ptr<rocksdb::DB>> impl) : db_(&db), impl_(std::move(impl)) {} |
| 29 | |
| 30 | rocksdb::Status OpenRocksDB::Put(const rocksdb::WriteOptions& options, const rocksdb::Slice& key, const rocksdb::Slice& value) { |
| 31 | rocksdb::Status result = impl_->Put(options, key, value); |
| 32 | if (result == rocksdb::Status::NoSpace()) { |
| 33 | db_->invalidate(); |
| 34 | } |
| 35 | return result; |
| 36 | } |
| 37 | |
| 38 | rocksdb::Status OpenRocksDB::Get(const rocksdb::ReadOptions& options, const rocksdb::Slice& key, std::string* value) { |
| 39 | rocksdb::Status result = impl_->Get(options, key, value); |