mirror of
https://github.com/OpenMW/openmw.git
synced 2025-11-04 13:26:44 +00:00
137 lines
3.5 KiB
C++
137 lines
3.5 KiB
C++
|
|
#include "loader.hpp"
|
|
|
|
#include <QTimer>
|
|
|
|
#include "../tools/reportmodel.hpp"
|
|
|
|
#include "document.hpp"
|
|
#include "state.hpp"
|
|
|
|
CSMDoc::Loader::Stage::Stage() : mFile (0), mRecordsLoaded (0), mRecordsLeft (false) {}
|
|
|
|
|
|
CSMDoc::Loader::Loader()
|
|
{
|
|
QTimer *timer = new QTimer (this);
|
|
|
|
connect (timer, SIGNAL (timeout()), this, SLOT (load()));
|
|
timer->start();
|
|
}
|
|
|
|
QWaitCondition& CSMDoc::Loader::hasThingsToDo()
|
|
{
|
|
return mThingsToDo;
|
|
}
|
|
|
|
void CSMDoc::Loader::load()
|
|
{
|
|
if (mDocuments.empty())
|
|
{
|
|
mMutex.lock();
|
|
mThingsToDo.wait (&mMutex);
|
|
mMutex.unlock();
|
|
return;
|
|
}
|
|
|
|
std::vector<std::pair<Document *, Stage> >::iterator iter = mDocuments.begin();
|
|
|
|
Document *document = iter->first;
|
|
|
|
int size = static_cast<int> (document->getContentFiles().size());
|
|
int editedIndex = size-1; // index of the file to be edited/created
|
|
|
|
if (document->isNew())
|
|
--size;
|
|
|
|
bool done = false;
|
|
|
|
const int batchingSize = 50;
|
|
|
|
try
|
|
{
|
|
if (iter->second.mRecordsLeft)
|
|
{
|
|
CSMDoc::Messages messages;
|
|
for (int i=0; i<batchingSize; ++i) // do not flood the system with update signals
|
|
if (document->getData().continueLoading (messages))
|
|
{
|
|
iter->second.mRecordsLeft = false;
|
|
break;
|
|
}
|
|
else
|
|
++(iter->second.mRecordsLoaded);
|
|
|
|
CSMWorld::UniversalId log (CSMWorld::UniversalId::Type_LoadErrorLog, 0);
|
|
|
|
{ // silence a g++ warning
|
|
for (CSMDoc::Messages::Iterator iter (messages.begin());
|
|
iter!=messages.end(); ++iter)
|
|
{
|
|
document->getReport (log)->add (iter->mId, iter->mMessage);
|
|
emit loadMessage (document, iter->mMessage);
|
|
}
|
|
}
|
|
|
|
emit nextRecord (document, iter->second.mRecordsLoaded);
|
|
|
|
return;
|
|
}
|
|
|
|
if (iter->second.mFile<size)
|
|
{
|
|
boost::filesystem::path path = document->getContentFiles()[iter->second.mFile];
|
|
|
|
int steps = document->getData().startLoading (path, iter->second.mFile!=editedIndex, false);
|
|
iter->second.mRecordsLeft = true;
|
|
iter->second.mRecordsLoaded = 0;
|
|
|
|
emit nextStage (document, path.filename().string(), steps);
|
|
}
|
|
else if (iter->second.mFile==size)
|
|
{
|
|
int steps = document->getData().startLoading (document->getProjectPath(), false, true);
|
|
iter->second.mRecordsLeft = true;
|
|
iter->second.mRecordsLoaded = 0;
|
|
|
|
emit nextStage (document, "Project File", steps);
|
|
}
|
|
else
|
|
{
|
|
done = true;
|
|
}
|
|
|
|
++(iter->second.mFile);
|
|
}
|
|
catch (const std::exception& e)
|
|
{
|
|
mDocuments.erase (iter);
|
|
emit documentNotLoaded (document, e.what());
|
|
return;
|
|
}
|
|
|
|
if (done)
|
|
{
|
|
mDocuments.erase (iter);
|
|
emit documentLoaded (document);
|
|
}
|
|
}
|
|
|
|
void CSMDoc::Loader::loadDocument (CSMDoc::Document *document)
|
|
{
|
|
mDocuments.push_back (std::make_pair (document, Stage()));
|
|
}
|
|
|
|
void CSMDoc::Loader::abortLoading (CSMDoc::Document *document)
|
|
{
|
|
for (std::vector<std::pair<Document *, Stage> >::iterator iter = mDocuments.begin();
|
|
iter!=mDocuments.end(); ++iter)
|
|
{
|
|
if (iter->first==document)
|
|
{
|
|
mDocuments.erase (iter);
|
|
emit documentNotLoaded (document, "");
|
|
break;
|
|
}
|
|
}
|
|
}
|