File tree Expand file tree Collapse file tree 3 files changed +0
-28
lines changed Expand file tree Collapse file tree 3 files changed +0
-28
lines changed Original file line number Diff line number Diff 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
F440
code>- _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}
Original file line number Diff line number Diff 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 "
Original file line number Diff line number Diff line change @@ -75,7 +75,6 @@ Result RocksDBSyncThread::syncWal() {
7575}
7676
7777Result 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
You can’t perform that action at this time.
0 commit comments