Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

comment out log spam

This commit is contained in:
jsteemann 2017-03-31 15:37:33 +02:00
parent ff0e1b1a54
commit 6f3e37ac36
3 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
arangod/RocksDBEngine/RocksDBCollection.cpp
View File

@ -360,11 +360,12 @@ int RocksDBCollection::read(transaction::Methods* trx,
ManagedDocumentResult& result, bool) {
TRI_ASSERT(key.isString());
RocksDBToken token = primaryIndex()->lookupKey(trx, StringRef(key));
/*
LOG_TOPIC(ERR, Logger::FIXME)
<< "READ IN COLLECTION '" << _logicalCollection->name()
<< "', KEY: " << key.copyString()
<< ", FOUND REVISION ID: " << token.revisionId();
*/
if (token.revisionId()) {
if (readDocument(trx, token, result)) {
// found
@ -806,10 +807,11 @@ int RocksDBCollection::insertDocument(arangodb::transaction::Methods* trx,
rocksdb::Transaction* rtrx = rocksTransaction(trx);
/*
LOG_TOPIC(ERR, Logger::FIXME)
<< "INSERT DOCUMENT. COLLECTION '" << _logicalCollection->name()
<< "', OBJECTID: " << _objectId << ", REVISIONID: " << revisionId;
*/
rocksdb::Status status = rtrx->Put(key.string(), *value.string());
if (!status.ok()) {
auto converted =
@ -925,11 +927,12 @@ int RocksDBCollection::updateDocument(transaction::Methods* trx,
TRI_ASSERT(trx->state()->isRunning());
TRI_ASSERT(!ServerState::instance()->isCoordinator());
/*
LOG_TOPIC(ERR, Logger::FIXME)
<< "UPDATE DOCUMENT. COLLECTION '" << _logicalCollection->name()
<< "', OBJECTID: " << _objectId << ", OLDREVISIONID: " << oldRevisionId
<< ", NEWREVISIONID: " << newRevisionId;
*/
int res = removeDocument(trx, oldRevisionId, oldDoc, waitForSync);
if (res != TRI_ERROR_NO_ERROR) {
@ -969,16 +972,20 @@ arangodb::Result RocksDBCollection::lookupRevisionVPack(
TRI_ASSERT(value.data());
auto result = convertStatus(status);
if (result.ok()) {
/*
LOG_TOPIC(ERR, Logger::FIXME)
<< "LOOKUPREVISIONVPACK. COLLECTION '" << _logicalCollection->name()
<< "', OBJECTID: " << _objectId << ", REVISIONID: " << revisionId
<< " -> FOUND";
*/
mdr.setManaged(std::move(value), revisionId);
} else {
/*
LOG_TOPIC(ERR, Logger::FIXME)
<< "LOOKUPREVISIONVPACK. COLLECTION '" << _logicalCollection->name()
<< "', OBJECTID: " << _objectId << ", REVISIONID: " << revisionId
<< " -> NOT FOUND";
*/
}
return result;
}

2
arangod/RocksDBEngine/RocksDBEngine.cpp
View File

@ -668,7 +668,7 @@ Result RocksDBEngine::dropDatabase(TRI_voc_tick_t id) {
// TODO: remove documents and index entries of database
rocksdb::WriteOptions options; // TODO: check which options would make sense
auto key = RocksDBKey::Database(vocbase->id());
auto key = RocksDBKey::Database(id);
rocksdb::Status res = _db->Delete(options, key.string());
return rocksutils::convertStatus(res);

3
arangod/RocksDBEngine/RocksDBPrimaryIndex.cpp
View File

@ -273,11 +273,12 @@ int RocksDBPrimaryIndex::insert(transaction::Methods* trx,
RocksDBKey::PrimaryIndexValue(_objectId, slice.get("_key").copyString());
auto value = RocksDBValue::PrimaryIndexValue(revisionId);
/*
LOG_TOPIC(ERR, Logger::FIXME)
<< "PRIMARYINDEX::INSERT. COLLECTION '" << _collection->name()
<< "', OBJECTID: " << _objectId << ", REVISIONID: " << revisionId
<< ", KEY: " << slice.get("_key").copyString();
*/
// aquire rocksdb transaction
RocksDBTransactionState* state = rocksutils::toRocksTransactionState(trx);
rocksdb::Transaction* rtrx = state->rocksTransaction();