mirror of https://gitee.com/bigwinds/arangodb
comments
This commit is contained in:
parent
362838ae69
commit
4b568e6069
|
@ -172,14 +172,14 @@ static TRI_datafile_t* CreateCompactor (TRI_document_collection_t* document,
|
||||||
// reserve room for one additional entry
|
// reserve room for one additional entry
|
||||||
if (TRI_ReserveVectorPointer(&collection->_compactors, 1) != TRI_ERROR_NO_ERROR) {
|
if (TRI_ReserveVectorPointer(&collection->_compactors, 1) != TRI_ERROR_NO_ERROR) {
|
||||||
// could not get memory, exit early
|
// could not get memory, exit early
|
||||||
return NULL;
|
return nullptr;
|
||||||
}
|
}
|
||||||
|
|
||||||
TRI_LOCK_JOURNAL_ENTRIES_DOC_COLLECTION(document);
|
TRI_LOCK_JOURNAL_ENTRIES_DOC_COLLECTION(document);
|
||||||
|
|
||||||
compactor = TRI_CreateCompactorPrimaryCollection(document, fid, maximalSize);
|
compactor = TRI_CreateCompactorPrimaryCollection(document, fid, maximalSize);
|
||||||
|
|
||||||
if (compactor != NULL) {
|
if (compactor != nullptr) {
|
||||||
int res TRI_UNUSED = TRI_PushBackVectorPointer(&collection->_compactors, compactor);
|
int res TRI_UNUSED = TRI_PushBackVectorPointer(&collection->_compactors, compactor);
|
||||||
|
|
||||||
// we have reserved space before, so we can be sure the push succeeds
|
// we have reserved space before, so we can be sure the push succeeds
|
||||||
|
|
|
@ -1071,6 +1071,7 @@ void CollectorThread::finishMarker (char* mem,
|
||||||
CollectorCache* cache) {
|
CollectorCache* cache) {
|
||||||
TRI_df_marker_t* marker = reinterpret_cast<TRI_df_marker_t*>(mem);
|
TRI_df_marker_t* marker = reinterpret_cast<TRI_df_marker_t*>(mem);
|
||||||
|
|
||||||
|
// re-use the original WAL marker's tick
|
||||||
marker->_tick = tick;
|
marker->_tick = tick;
|
||||||
|
|
||||||
// calculate the CRC
|
// calculate the CRC
|
||||||
|
|
Loading…
Reference in New Issue