Commit a3af47e3 authored by Eric Cano's avatar Eric Cano
Browse files

Fixed wrong function being called to configure max queue size.

parent 08700d23
......@@ -112,7 +112,10 @@ void OStoreDB::setThreadNumber(uint64_t threadNumber) {
}
}
void OStoreDB::setBootomHalfQueueSize(uint64_t tasksNumber) {
//------------------------------------------------------------------------------
// OStoreDB::setBottomHalfQueueSize()
//------------------------------------------------------------------------------
void OStoreDB::setBottomHalfQueueSize(uint64_t tasksNumber) {
// 5 is the default queue size.
m_taskPostingSemaphore.release(tasksNumber - 5);
}
......
......@@ -82,7 +82,7 @@ private:
public:
void waitSubthreadsComplete() override;
void setThreadNumber(uint64_t threadNumber);
void setBootomHalfQueueSize(uint64_t tasksNumber);
void setBottomHalfQueueSize(uint64_t tasksNumber);
/*============ Basic IO check: validate object store access ===============*/
void ping() override;
......
......@@ -110,7 +110,7 @@ bool XrdSsiCtaServiceProvider::Init(XrdSsiLogger *logP, XrdSsiCluster *clsP, con
if (threadPoolSize.first) {
m_scheddb->setThreadNumber(threadPoolSize.second);
}
m_scheddb->setThreadNumber(25000);
m_scheddb->setBottomHalfQueueSize(25000);
// Initialise the Scheduler
m_scheduler = cta::make_unique<cta::Scheduler>(*m_catalogue, *m_scheddb, 5, 2*1000*1000);
......
Supports Markdown
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