EmergeManager::~EmergeManager()
{
- for (unsigned int i = 0; i != emergethread.size(); i++) {
+ for (u32 i = 0; i != emergethread.size(); i++) {
if (threads_active) {
emergethread[i]->Stop();
emergethread[i]->qevent.signal();
}
// Create the mapgens
- for (size_t i = 0; i != emergethread.size(); i++) {
+ for (u32 i = 0; i != emergethread.size(); i++) {
Mapgen *mg = createMapgen(params.mg_name, i, ¶ms);
assert(mg);
mapgen.push_back(mg);
Mapgen *EmergeManager::getCurrentMapgen()
{
- for (unsigned int i = 0; i != emergethread.size(); i++) {
+ for (u32 i = 0; i != emergethread.size(); i++) {
if (emergethread[i]->IsSameThread())
return emergethread[i]->mapgen;
}
if (threads_active)
return;
- for (unsigned int i = 0; i != emergethread.size(); i++)
+ for (u32 i = 0; i != emergethread.size(); i++)
emergethread[i]->Start();
threads_active = true;
return;
// Request thread stop in parallel
- for (unsigned int i = 0; i != emergethread.size(); i++) {
+ for (u32 i = 0; i != emergethread.size(); i++) {
emergethread[i]->Stop();
emergethread[i]->qevent.signal();
}
// Then do the waiting for each
- for (unsigned int i = 0; i != emergethread.size(); i++)
+ for (u32 i = 0; i != emergethread.size(); i++)
emergethread[i]->Wait();
threads_active = false;
// insert into the EmergeThread queue with the least items
int lowestitems = emergethread[0]->blockqueue.size();
- for (unsigned int i = 1; i != emergethread.size(); i++) {
+ for (u32 i = 1; i != emergethread.size(); i++) {
int nitems = emergethread[i]->blockqueue.size();
if (nitems < lowestitems) {
idx = i;