Commit d2f1738b authored by Steven Murray's avatar Steven Murray
Browse files

Added the member variable m_vdqmRequestHandlerThreadPool to make the design...

Added the member variable m_vdqmRequestHandlerThreadPool to make the design and structure of the code more explicit
parent 9a8b6394
......@@ -302,13 +302,12 @@ void castor::tape::aggregator::AggregatorDaemon::
new castor::server::TCPListenerThreadPool("VdqmRequestHandlerPool",
new castor::tape::aggregator::VdqmRequestHandler(), vdqmListenPort));
castor::server::BaseThreadPool *const vdqmRequestHandlerThreadPool =
getThreadPool('V');
m_vdqmRequestHandlerThreadPool = getThreadPool('V');
if(vdqmRequestHandlerThreadPool == NULL) {
if(m_vdqmRequestHandlerThreadPool == NULL) {
TAPE_THROW_EX(castor::exception::Internal,
": Failed to get VdqmRequestHandlerPool");
}
vdqmRequestHandlerThreadPool->setNbThreads(0);
m_vdqmRequestHandlerThreadPool->setNbThreads(MAXDRIVES);
}
......@@ -28,6 +28,7 @@
#include "castor/exception/Exception.hpp"
#include "castor/exception/InvalidConfigEntry.hpp"
#include "castor/server/BaseDaemon.hpp"
#include "castor/server/BaseThreadPool.hpp"
#include <iostream>
......@@ -85,6 +86,12 @@ private:
*/
ParsedCommandLine m_parsedCommandLine;
/**
* The VDQM request handler thread pool which should contain as many threads
* as there are drives per tape server.
*/
server::BaseThreadPool *m_vdqmRequestHandlerThreadPool;
/**
* Parses the command-line arguments and sets the daemon options accordingly.
*
......
......@@ -35,6 +35,7 @@ namespace tape {
namespace aggregator {
const size_t HDRBUFSIZ = 3 * sizeof(uint32_t);
const int MAXDRIVES = 4;
const int MAXINITMIGFILES = 2;
const uint32_t MIGRATEUMASK = 022;
const size_t MSGBUFSIZ = 1024;
......
......@@ -1350,7 +1350,6 @@ void castor::tape::aggregator::GatewayTxRx::notifyGatewayEndOfFailedSession(
castor::dlf::Param("volReqId" , volReqId ),
castor::dlf::Param("gatewayHost" , gatewayHost ),
castor::dlf::Param("gatewayPort" , gatewayPort ),
castor::dlf::Param("mountTransactionId", volReqId ),
castor::dlf::Param("errorCode" , ex.code() ),
castor::dlf::Param("errorrMessage" , ex.getMessage().str())};
castor::dlf::dlf_writep(cuuid, DLF_LVL_SYSTEM,
......
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