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

modified error message so it becomes clear that the mmfiles engine also uses rocksdb internally, but only for persistent indexes (#2545)

This commit is contained in:
Jan 2017-06-12 11:34:13 +02:00 committed by Frank Celler
parent 781b02f7fb
commit 2f04981fe9
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
arangod/MMFiles/MMFilesPersistentIndexFeature.cpp
View File

@ -94,7 +94,7 @@ void MMFilesPersistentIndexFeature::start() {
auto database = ApplicationServer::getFeature<DatabasePathFeature>("DatabasePath"); auto database = ApplicationServer::getFeature<DatabasePathFeature>("DatabasePath");
_path = database->subdirectoryName("rocksdb"); _path = database->subdirectoryName("rocksdb");
LOG_TOPIC(TRACE, arangodb::Logger::FIXME) << "initializing rocksdb, path: " << _path; LOG_TOPIC(TRACE, arangodb::Logger::FIXME) << "initializing rocksdb for persistent indexes, path: " << _path;
_comparator = new MMFilesPersistentIndexKeyComparator(); _comparator = new MMFilesPersistentIndexKeyComparator();
@ -138,7 +138,7 @@ void MMFilesPersistentIndexFeature::start() {
rocksdb::Status status = rocksdb::OptimisticTransactionDB::Open(_options, _path, &_db); rocksdb::Status status = rocksdb::OptimisticTransactionDB::Open(_options, _path, &_db);
if (! status.ok()) { if (! status.ok()) {
LOG_TOPIC(FATAL, arangodb::Logger::FIXME) << "unable to initialize RocksDB: " << status.ToString(); LOG_TOPIC(FATAL, arangodb::Logger::FIXME) << "unable to initialize RocksDB engine for persistent indexes: " << status.ToString();
FATAL_ERROR_EXIT(); FATAL_ERROR_EXIT();
} }
} }
@ -148,7 +148,7 @@ void MMFilesPersistentIndexFeature::unprepare() {
return; return;
} }
LOG_TOPIC(TRACE, arangodb::Logger::FIXME) << "shutting down RocksDB"; LOG_TOPIC(TRACE, arangodb::Logger::FIXME) << "shutting down RocksDB for persistent indexes";
// flush // flush
rocksdb::FlushOptions options; rocksdb::FlushOptions options;
@ -156,7 +156,7 @@ void MMFilesPersistentIndexFeature::unprepare() {
rocksdb::Status status = _db->GetBaseDB()->Flush(options); rocksdb::Status status = _db->GetBaseDB()->Flush(options);
if (! status.ok()) { if (! status.ok()) {
LOG_TOPIC(ERR, arangodb::Logger::FIXME) << "error flushing data to RocksDB: " << status.ToString(); LOG_TOPIC(ERR, arangodb::Logger::FIXME) << "error flushing data to RocksDB for persistent indexes: " << status.ToString();
} }
syncWal(); syncWal();
@ -173,12 +173,12 @@ int MMFilesPersistentIndexFeature::syncWal() {
return TRI_ERROR_NO_ERROR; return TRI_ERROR_NO_ERROR;
} }
LOG_TOPIC(TRACE, arangodb::Logger::FIXME) << "syncing RocksDB WAL"; LOG_TOPIC(TRACE, arangodb::Logger::FIXME) << "syncing RocksDB WAL for persistent indexes";
rocksdb::Status status = Instance->db()->GetBaseDB()->SyncWAL(); rocksdb::Status status = Instance->db()->GetBaseDB()->SyncWAL();
if (! status.ok()) { if (!status.ok()) {
LOG_TOPIC(ERR, arangodb::Logger::FIXME) << "error syncing RocksDB WAL: " << status.ToString(); LOG_TOPIC(ERR, arangodb::Logger::FIXME) << "error syncing RocksDB WAL for persistent indexes: " << status.ToString();
return TRI_ERROR_INTERNAL; return TRI_ERROR_INTERNAL;
} }
#endif #endif