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

Removed the tapserver/castor/acs directory

parent c4a68c4f
/******************************************************************************
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
*
* Copyright (C) 2003 CERN
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* @author Castor Dev team, castor-dev@cern.ch
*****************************************************************************/
#pragma once
namespace castor {
namespace acs {
/**
* The default TCP/IP port on which the CASTOR ACS daemon listens for incoming Zmq
* connections from the tape server.
*/
const unsigned short ACS_PORT = 54521;
/**
* Default time to wait in seconds between queries to ACS Library for responses.
*/
const int ACS_QUERY_INTERVAL = 10;
/**
* Default time to wait in seconds for the tape-library command to conclude.
*/
const int ACS_CMD_TIMEOUT = 610;
/**
* The maximum ACS sequence number value to be used.
*/
const unsigned short ACS_MAX_SEQ = 65535;
/**
* Default timeout for the response command to the ACS library.
*/
const int ACS_RESPONSE_TIMEOUT = 5;
/**
* Enumeration of the states of an ACS request.
*/
enum RequestState {
ACS_REQUEST_TO_EXECUTE,
ACS_REQUEST_IS_RUNNING,
ACS_REQUEST_COMPLETED,
ACS_REQUEST_FAILED,
ACS_REQUEST_TO_DELETE};
} // namespace acs
} // namespace castor
......@@ -32,7 +32,6 @@
#include "objectstore/BackendPopulator.hpp"
#include "rdbms/Login.hpp"
#include "scheduler/OStoreDB/OStoreDBWithAgent.hpp"
#include "tapeserver/castor/acs/Constants.hpp"
#include "tapeserver/castor/tape/tapeserver/daemon/CleanerSession.hpp"
#include "tapeserver/castor/tape/tapeserver/daemon/DataTransferSession.hpp"
#include "tapeserver/castor/tape/tapeserver/daemon/Session.hpp"
......@@ -920,7 +919,7 @@ int DriveHandler::runChild() {
const int sizeOfIOThreadPoolForZMQ = 1;
mediachanger::SmartZmqContext zmqContext(
mediachanger::SmartZmqContext::instantiateZmqContext(sizeOfIOThreadPoolForZMQ));
mediachanger::AcsProxyZmq acs(castor::acs::ACS_PORT, zmqContext.get());
mediachanger::AcsProxyZmq acs(mediachanger::ACS_PORT, zmqContext.get());
cta::mediachanger::MmcProxyLog mmc(m_processManager.logContext().logger());
// The network timeout of rmc communications should be several minutes due
......@@ -963,7 +962,7 @@ int DriveHandler::runChild() {
const int sizeOfIOThreadPoolForZMQ = 1;
mediachanger::SmartZmqContext zmqContext(
mediachanger::SmartZmqContext::instantiateZmqContext(sizeOfIOThreadPoolForZMQ));
mediachanger::AcsProxyZmq acs(castor::acs::ACS_PORT, zmqContext.get());
mediachanger::AcsProxyZmq acs(mediachanger::ACS_PORT, zmqContext.get());
cta::mediachanger::MmcProxyLog mmc(m_processManager.logContext().logger());
// The network timeout of rmc communications should be several minutes due
......
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