ynkmr/Sourcetrail
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

logic: add 1MB buffer to pushIntermediateStorge

Browse Source
This commit is contained in:
Andreas Stallinger
2017-06-12 12:05:34 +02:00
parent 19ed6cb372
commit 148588b179
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/lib/data/indexer/interprocess/InterprocessIntermediateStorageManager.cpp
+4 -3
View File
@@ -13,7 +13,7 @@ InterprocessIntermediateStorageManager::InterprocessIntermediateStorageManager(
)
: BaseInterprocessDataManager(
s_sharedMemoryNamePrefix + std::to_string(processId) + "_" + instanceUuid,
1048576 /* 1 MB */,
3 * 1048576 /* 3 MB */,
instanceUuid,
processId,
isOwner)
@@ -27,8 +27,8 @@ InterprocessIntermediateStorageManager::~InterprocessIntermediateStorageManager(
void InterprocessIntermediateStorageManager::pushIntermediateStorage(
const std::shared_ptr<IntermediateStorage>& intermediateStorage)
{
const unsigned int overestimationMultiplier = 3;
size_t size = intermediateStorage->getByteSize() * overestimationMultiplier;
const unsigned int overestimationMultiplier = 3;
size_t size = (intermediateStorage->getByteSize() + sizeof(SharedIntermediateStorage))* overestimationMultiplier + 1048576/* 1 MB */;
SharedMemory::ScopedAccess access(&m_sharedMemory);
@@ -97,6 +97,7 @@ std::shared_ptr<IntermediateStorage> InterprocessIntermediateStorageManager::pop
storage->setNextId(sharedIntermediateStorage.getNextId());
queue->pop_front();
LOG_INFO(access.logString());
return storage;
}