mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

SERVER-17223 Disable updateWithDamages support for RocksDB

Browse Source 
Signed-off-by: Benety Goh <benety@mongodb.com>
This commit is contained in:
Igor Canadi 2015-02-08 16:12:49 -08:00 committed by Benety Goh
parent e095f8979c
commit c9e43db56a
1 changed files with 2 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/mongo/db/storage/rocks/rocks_record_store.cpp
View File

@ -439,7 +439,7 @@ namespace mongo {
}
bool RocksRecordStore::updateWithDamagesSupported() const {
return true;
return false;
}
Status RocksRecordStore::updateWithDamages( OperationContext* txn,
@ -447,39 +447,7 @@ namespace mongo {
const RecordData& oldRec,
const char* damageSource,
const mutablebson::DamageVector& damages ) {
RocksRecoveryUnit* ru = RocksRecoveryUnit::getRocksRecoveryUnit( txn );
if (!ru->transaction()->registerWrite(_getTransactionID(loc))) {
throw WriteConflictException();
}
int64_t locStorage;
rocksdb::Slice key = _makeKey(loc, &locStorage);
// get original value
std::string value;
rocksdb::Status status;
status = ru->Get(_columnFamily.get(), key, &value);
if ( !status.ok() ) {
if ( status.IsNotFound() )
return Status( ErrorCodes::InternalError, "doc not found for in-place update" );
log() << "rocks Get failed, blowing up: " << status.ToString();
invariant( false );
}
// apply changes to our copy
for( size_t i = 0; i < damages.size(); i++ ) {
mutablebson::DamageEvent event = damages[i];
const char* sourcePtr = damageSource + event.sourceOffset;
invariant( event.targetOffset + event.size < value.length() );
value.replace( event.targetOffset, event.size, sourcePtr, event.size );
}
// write back
ru->writeBatch()->Put(_columnFamily.get(), key, value);
invariant(false);
return Status::OK();
}