8000 enable SyncWAL code for WIN32 as well · arangodb/arangodb@0689b6e · GitHub
[go: up one dir, main page]

Skip to content

Commit 0689b6e

Browse files
committed
enable SyncWAL code for WIN32 as well
1 parent 1c85cdf commit 0689b6e

File tree

3 files changed

+0
-28
lines changed

3 files changed

+0
-28
lines changed

arangod/RocksDBEngine/Methods/RocksDBTrxBaseMethods.cpp

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -348,17 +348,6 @@ arangodb::Result RocksDBTrxBaseMethods::doCommit() {
348348
// if we fail during commit, make sure we remove blockers, etc.
349349
auto cleanupCollTrx = scopeGuard([this]() { _state->cleanupCollections(); });
350350

351-
#ifdef _WIN32
352-
// set wait for sync flag if required
353-
// we do this only for Windows here, because all other platforms use the
354-
// RocksDB SyncThread to do the syncing
355-
if (_state->waitForSync()) {
356-
rocksdb::WriteOptions wo;
357-
wo.sync = true;
358-
_rocksTransaction->SetWriteOptions(wo);
359-
}
360-
#endif
361-
362351
// total number of sequence ID consuming records
363352
uint64_t numOps = _rocksTransaction->GetNumPuts() +
364353
_rocksTransaction->GetNumDeletes() +
@@ -387,7 +376,6 @@ arangodb::Result RocksDBTrxBaseMethods::doCommit() {
387376
_state->commitCollections(_lastWrittenOperationTick);
388377
cleanupCollTrx.cancel();
389378

390-
#ifndef _WIN32
391379
// wait for sync if required, for all other platforms but Windows
392380
if (_state->waitForSync()) {
393381
auto& selector = _state->vocbase().server().getFeature<EngineSelectorFeature>();
@@ -402,7 +390,6 @@ arangodb::Result RocksDBTrxBaseMethods::doCommit() {
402390
return RocksDBSyncThread::sync(engine.db()->GetBaseDB());
403391
}
404392
}
405-
#endif
406393

407394
return Result();
408395
}

arangod/RocksDBEngine/RocksDBEngine.cpp

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -184,12 +184,7 @@ RocksDBEngine::RocksDBEngine(application_features::ApplicationServer& server)
184184
_pruneWaitTimeInitial(180.0),
185185
_maxWalArchiveSizeLimit(0),
186186
_releasedTick(0),
187-
#ifdef _WIN32
188-
// background syncing is not supported on Windows
189-
_syncInterval(0),
190-
#else
191187
_syncInterval(100),
192-
#endif
193188
_syncDelayThreshold(5000),
194189
_requiredDiskFreePercentage(0.01),
195190
_requiredDiskFreeBytes(16 * 1024 * 1024),
@@ -410,14 +405,6 @@ void RocksDBEngine::validateOptions(std::shared_ptr<options::ProgramOptions> opt
410405
}
411406
}
412407

413-
#ifdef _WIN32
414-
if (_syncInterval > 0) {
415-
LOG_TOPIC("68301", WARN, arangodb::Logger::CONFIG)
416-
<< "automatic syncing of RocksDB WAL via background thread is not "
417-
<< " supported on this platform";
418-
}
419-
#endif
420-
421408
if (_pruneWaitTimeInitial < 10) {
422409
LOG_TOPIC("a9667", WARN, arangodb::Logger::ENGINES)
423410
<< "consider increasing the value for "

arangod/RocksDBEngine/RocksDBSyncThread.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,6 @@ Result RocksDBSyncThread::syncWal() {
7575
}
7676

7777
Result RocksDBSyncThread::sync(rocksdb::DB* db) {
78-
#ifndef _WIN32
7978
// if called on Windows, we would get the following error from RocksDB:
8079
// > Not implemented: SyncWAL() is not supported for this implementation of
8180
// WAL file
@@ -85,7 +84,6 @@ Result RocksDBSyncThread::sync(rocksdb::DB* db) {
8584
if (!status.ok()) {
8685
return rocksutils::convertStatus(status);
8786
}
88-
#endif
8987
return Result();
9088
}
9189

0 commit comments

Comments
 (0)
0