mirror of https://gitee.com/bigwinds/arangodb
474f0cde31
* added check for empty scheduler * removed log, old is 1 not 0 * require running in this thread * test * added isDirect to callback * signature fixed * added drain * added allowDirectHandling * disabled for testing * Add ExecContextScope object to direct call. * try alternate initialization of ExecContextScope * remove ExecContextScope, no help. try _fifoSize as part of direct decision. * strand management to minimize reuse of same strand per listen socket * blind attempt to address Jenkins shutdown lock up. may remove quickly. * add filename and line to existing error log message * Adjust queueOperation() to stop accepting items once isStopping() becomes true. * revert previous check-in to MMFilesCollectorThread.cpp * big reformat * fixed merge conflicts * Add CHANGELOG entry. |
||
|---|---|---|
| .. | ||
| CMakeLists.txt | ||
| MMFilesAllocatorThread.cpp | ||
| MMFilesAllocatorThread.h | ||
| MMFilesCleanupThread.cpp | ||
| MMFilesCleanupThread.h | ||
| MMFilesCollection.cpp | ||
| MMFilesCollection.h | ||
| MMFilesCollectionExport.cpp | ||
| MMFilesCollectionExport.h | ||
| MMFilesCollectionKeys.cpp | ||
| MMFilesCollectionKeys.h | ||
| MMFilesCollectionWriteLocker.h | ||
| MMFilesCollectorCache.h | ||
| MMFilesCollectorThread.cpp | ||
| MMFilesCollectorThread.h | ||
| MMFilesCompactionFeature.cpp | ||
| MMFilesCompactionFeature.h | ||
| MMFilesCompactionLocker.h | ||
| MMFilesCompactorThread.cpp | ||
| MMFilesCompactorThread.h | ||
| MMFilesDatafile.cpp | ||
| MMFilesDatafile.h | ||
| MMFilesDatafileHelper.h | ||
| MMFilesDatafileStatistics.cpp | ||
| MMFilesDatafileStatistics.h | ||
| MMFilesDatafileStatisticsContainer.cpp | ||
| MMFilesDatafileStatisticsContainer.h | ||
| MMFilesDitch.cpp | ||
| MMFilesDitch.h | ||
| MMFilesDocumentOperation.cpp | ||
| MMFilesDocumentOperation.h | ||
| MMFilesDocumentPosition.h | ||
| MMFilesEdgeIndex.cpp | ||
| MMFilesEdgeIndex.h | ||
| MMFilesEngine.cpp | ||
| MMFilesEngine.h | ||
| MMFilesExportCursor.cpp | ||
| MMFilesExportCursor.h | ||
| MMFilesFulltextIndex.cpp | ||
| MMFilesFulltextIndex.h | ||
| MMFilesGeoIndex.cpp | ||
| MMFilesGeoIndex.h | ||
| MMFilesHashIndex.cpp | ||
| MMFilesHashIndex.h | ||
| MMFilesIncrementalSync.h | ||
| MMFilesIndex.h | ||
| MMFilesIndexElement.cpp | ||
| MMFilesIndexElement.h | ||
| MMFilesIndexFactory.cpp | ||
| MMFilesIndexFactory.h | ||
| MMFilesIndexLookupContext.cpp | ||
| MMFilesIndexLookupContext.h | ||
| MMFilesLogfileManager.cpp | ||
| MMFilesLogfileManager.h | ||
| MMFilesOptimizerRules.cpp | ||
| MMFilesOptimizerRules.h | ||
| MMFilesPathBasedIndex.cpp | ||
| MMFilesPathBasedIndex.h | ||
| MMFilesPersistentIndex.cpp | ||
| MMFilesPersistentIndex.h | ||
| MMFilesPersistentIndexFeature.cpp | ||
| MMFilesPersistentIndexFeature.h | ||
| MMFilesPersistentIndexKeyComparator.cpp | ||
| MMFilesPersistentIndexKeyComparator.h | ||
| MMFilesPrimaryIndex.cpp | ||
| MMFilesPrimaryIndex.h | ||
| MMFilesRemoverThread.cpp | ||
| MMFilesRemoverThread.h | ||
| MMFilesRestCollectionHandler.cpp | ||
| MMFilesRestCollectionHandler.h | ||
| MMFilesRestExportHandler.cpp | ||
| MMFilesRestExportHandler.h | ||
| MMFilesRestHandlers.cpp | ||
| MMFilesRestHandlers.h | ||
| MMFilesRestReplicationHandler.cpp | ||
| MMFilesRestReplicationHandler.h | ||
| MMFilesRestWalHandler.cpp | ||
| MMFilesRestWalHandler.h | ||
| MMFilesRevisionsCache.cpp | ||
| MMFilesRevisionsCache.h | ||
| MMFilesSkiplist.h | ||
| MMFilesSkiplistIndex.cpp | ||
| MMFilesSkiplistIndex.h | ||
| MMFilesSynchronizerThread.cpp | ||
| MMFilesSynchronizerThread.h | ||
| MMFilesTransactionCollection.cpp | ||
| MMFilesTransactionCollection.h | ||
| MMFilesTransactionContextData.cpp | ||
| MMFilesTransactionContextData.h | ||
| MMFilesTransactionManager.cpp | ||
| MMFilesTransactionManager.h | ||
| MMFilesTransactionState.cpp | ||
| MMFilesTransactionState.h | ||
| MMFilesV8Functions.cpp | ||
| MMFilesV8Functions.h | ||
| MMFilesWalAccess.cpp | ||
| MMFilesWalAccess.h | ||
| MMFilesWalLogfile.cpp | ||
| MMFilesWalLogfile.h | ||
| MMFilesWalMarker.h | ||
| MMFilesWalRecoverState.cpp | ||
| MMFilesWalRecoverState.h | ||
| MMFilesWalRecoveryFeature.cpp | ||
| MMFilesWalRecoveryFeature.h | ||
| MMFilesWalSlot.cpp | ||
| MMFilesWalSlot.h | ||
| MMFilesWalSlots.cpp | ||
| MMFilesWalSlots.h | ||
| MMFilesWalSyncRegion.h | ||
| README.md | ||
| mmfiles-fulltext-common.h | ||
| mmfiles-fulltext-index.cpp | ||
| mmfiles-fulltext-index.h | ||
| mmfiles-fulltext-list.cpp | ||
| mmfiles-fulltext-list.h | ||
| mmfiles-fulltext-query.cpp | ||
| mmfiles-fulltext-query.h | ||
| mmfiles-replication-common.cpp | ||
| mmfiles-replication-common.h | ||
| mmfiles-replication-dump.cpp | ||
| mmfiles-replication-dump.h | ||
README.md
MMFilesEngine
How operations are stored - Overview
All operations like insert or remove are written as markers to a write ahead log (WAL). This WAL consists of files of a certain size and if such a file is full (or is manually flushed), all relevant markers are transferred (transferMarkers()) to the journals of the respective collections. During the transfer any obsolete markers will be thrown away: a sequence of insert, remove, insert on the same document will result in the last insert discarding the previous operations. When a journal file of size (journalSize()) is full, it will be sealed and renamed. By applying these operations it will become a datafile that is read-only. Datafiles will eventually be merged by a compactor thread that does about the same work as the transferMarkers function, reducing the size of the stored data.
Ditches
Ditches are used to pin objects in WAL or journal as long as they are used by other operations.