Commit a53be1c9 authored by Jozsef Makai's avatar Jozsef Makai

MGM: increasing WFE threadpool threads

parent 88a8df93
......@@ -65,7 +65,7 @@ WFE::WFE()
mActiveJobs = 0;
eos::common::Mapping::Root(mRootVid);
XrdSysMutexHelper sLock(gSchedulerMutex);
gScheduler = new XrdScheduler(&gMgmOfsEroute, &gMgmOfsTrace, 10, 200, 80);
gScheduler = new XrdScheduler(&gMgmOfsEroute, &gMgmOfsTrace, 10, 500, 100);
gScheduler->Start();
}
......@@ -230,7 +230,6 @@ WFE::WFEr()
queries[3] += "/e/";
}
auto findStarted = std::chrono::steady_clock::now();
for (size_t i = 0; i < 4; ++i) {
eos_static_debug("query-path=%s", queries[i].c_str());
gOFS->_find(queries[i].c_str(),
......@@ -246,13 +245,6 @@ WFE::WFEr()
0
);
}
auto findEnded = std::chrono::steady_clock::now();
auto timespent = std::chrono::duration_cast<std::chrono::milliseconds>(findEnded - findStarted);
auto wfedirsSize = 0ul;
for(const auto& keyval : wfedirs) {
wfedirsSize += keyval.second.size();
}
eos_static_info("findtime=%ld , size=%lu", timespent.count(), wfedirsSize);
{
eos_static_debug("msg=\"finished WFE find\" WFE-dirs=%llu %s",
......@@ -302,11 +294,7 @@ WFE::WFEr()
XrdSysMutexHelper sLock(gSchedulerMutex);
time_t storetime = 0;
// move job into the scheduled queue
auto moveStarted = std::chrono::steady_clock::now();
job->Move(job->mActions[0].mQueue, "s", storetime);
auto moveEnded = std::chrono::steady_clock::now();
auto timeSpent = std::chrono::duration_cast<std::chrono::milliseconds>(moveEnded - moveStarted);
eos_static_info("movetime=%ld", timeSpent.count());
job->mActions[0].mQueue = "s";
job->mActions[0].mTime = storetime;
XrdOucString tst;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment