Commit 4f271027 authored by Steven Murray's avatar Steven Murray
Browse files

The castor/tape/tapeserver directory now contains a renamed aggregator daemon.

Only the daemon name has been changed.  The underlying tape gateway protocol
still has an aggregatorTransActionId field and the VDQM will still name the
tape server daemon as being an aggregator.
parent e566927c
}; // enum AggregatorDlfMessages
} // namespace aggregator
} // namespace tape
} // namespace castor
#endif // CASTOR_TAPE_AGGREGATOR_AGGREGATORDLFMESSAGECONSTANTS_HPP
/* This file was generated by ./AggregatorDlfMessagesCodeGenerator on Thu Feb 11 09:50:23 CET 2010
*/
/******************************************************************************
* castor/tape/aggregator/AggregatorDlfMessageStrings.cpp
*
* 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 Steven Murray Steven.Murray@cern.ch
*****************************************************************************/
#include "castor/tape/aggregator/AggregatorDlfMessageConstants.hpp"
#include "castor/tape/aggregator/AggregatorDaemon.hpp"
castor::dlf::Message castor::tape::aggregator::AggregatorDaemon::s_dlfMessages[] = {
{AGGREGATOR_NULL, " - "},
{AGGREGATOR_STARTED, "aggregatord started"},
{AGGREGATOR_FAILED_TO_START, "aggregatord failed to start"},
{AGGREGATOR_RECEIVED_VDQM_CONNECTION, "Received a connection from VDQM"},
{AGGREGATOR_HANDLE_VDQM_REQUEST_EXCEPT, "Exception raised when handling a request from the VDQM"},
{AGGREGATOR_FAILED_TO_READ_MESSAGE_HEADER, "Failed to read message header"},
{AGGREGATOR_UNKNOWN_MAGIC, "Unknown magic number"},
{AGGREGATOR_UNKNOWN_REQUEST_TYPE, "Unknown request type"},
{AGGREGATOR_FAILED_TO_READ_MESSAGE_BODY, "Failed to read message body"},
{AGGREGATOR_RECEIVE_RTCOPY_JOB, "Receiving remote-copy job"},
{AGGREGATOR_RECEIVED_RTCOPY_JOB, "Received remote-copy job"},
{AGGREGATOR_SUBMITTING_RTCOPY_JOB_TO_RTCPD, "Submitting remote-copy job to RTCPD"},
{AGGREGATOR_FAILED_TO_SUBMIT_JOB_TO_RTCPD, "Failed to submit remote-copy job to RTCPD"},
{AGGREGATOR_FAILED_TO_MARSHALL_RTCP_ACKN, "Failed to marshall RTCP acknowledge message"},
{AGGREGATOR_FAILED_TO_SEND_RTCOPY_JOB_REPLY_TO_VDQM, "Failed to send remote-copy job reply to VDQM"},
{AGGREGATOR_FAILED_TO_PROCESS_RCOPY_JOB_SUBMISSION, "Failed to process remote-copy job submission message"},
{AGGREGATOR_RTCPD_HANDLER_SOCKET_IS_NULL, "The RtcpdHandlerThread has been passed a NULL socket pointer"},
{AGGREGATOR_INITIAL_RTCPD_CALLBACK, "Received initial callback connection from RTCPD"},
{AGGREGATOR_RTCPD_CALLBACK, "Received a callback connection from RTCPD"},
{AGGREGATOR_GOT_VOLREQID, "Got volume request ID from RTCPD"},
{AGGREGATOR_FAILED_TO_GET_VOLREQID, "Failed to get volume request ID from RTCPD"},
{AGGREGATOR_FAILED_TO_MARSHALL_RTCOPY_JOB_REPLY_MESSAGE, "Failed to marshall remote-copy job reply message"},
{AGGREGATOR_SIGNALLED_NO_MORE_REQUESTS, "Signalled no more requests to RTCPD"},
{AGGREGATOR_FAILED_TO_COORDINATE_REMOTE_COPY, "Failed to coordinate remote-copy"},
{AGGREGATOR_TRANSFER_FAILED, "Transfer failed"},
{AGGREGATOR_GAVE_REQUEST_FOR_MORE_WORK, "Gave request for more work to RTCPD"},
{AGGREGATOR_DATA_ON_INITIAL_RTCPD_CONNECTION, "Data has arrived on the initial RTCPD connection"},
{AGGREGATOR_RECEIVED_RTCP_ENDOF_REQ, "Received RTCP_ENDOF_REQ"},
{AGGREGATOR_TAPE_POSITIONED, "Tape positioned"},
{AGGREGATOR_FILE_TRANSFERED, "File transfered"},
{AGGREGATOR_GET_REQUEST_INFO_FROM_RTCPD, "Getting request information from RTCPD"},
{AGGREGATOR_GOT_REQUEST_INFO_FROM_RTCPD, "Got request information from RTCPD"},
{AGGREGATOR_TOLD_CLIENT_TO_START_TRANSFER, "Told client to start the transfer protocol"},
{AGGREGATOR_GET_VOLUME_FROM_CLIENT, "Getting volume from client"},
{AGGREGATOR_GOT_VOLUME_FROM_CLIENT, "Got volume from client"},
{AGGREGATOR_GOT_NO_MORE_FILES_FROM_CLIENT, "Got no more files from client"},
{AGGREGATOR_GET_FILE_TO_MIGRATE_FROM_CLIENT, "Getting file to migrate from client"},
{AGGREGATOR_GOT_FILE_TO_MIGRATE_FROM_CLIENT, "Got file to migrate from client"},
{AGGREGATOR_GET_FILE_TO_RECALL_FROM_CLIENT, "Getting file to recall from client"},
{AGGREGATOR_GOT_FILE_TO_RECALL_FROM_CLIENT, "Got file to recall from client"},
{AGGREGATOR_GIVE_VOLUME_TO_RTCPD, "Giving volume to RTCPD"},
{AGGREGATOR_GAVE_VOLUME_TO_RTCPD, "Gave volume to RTCPD"},
{AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_RECALL_WORK, "Asking RTCPD to request more recall work"},
{AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_RECALL_WORK, "Asked RTCPD to request more recall work"},
{AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_MIGRATE_WORK, "Asking RTCPD to request more migrate work"},
{AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_MIGRATE_WORK, "Asked RTCPD to request more migrate work"},
{AGGREGATOR_TELL_RTCPD_DUMP_TAPE, "Telling RTCPD to dump tape"},
{AGGREGATOR_TOLD_RTCPD_DUMP_TAPE, "Told RTCPD to dump tape"},
{AGGREGATOR_TELL_RTCPD_END_OF_FILE_LIST, "Telling RTCPD end of file list"},
{AGGREGATOR_TOLD_RTCPD_END_OF_FILE_LIST, "Told RTCPD end of file list"},
{AGGREGATOR_TELL_RTCPD_TO_ABORT, "Telling RTCPD to abort"},
{AGGREGATOR_TOLD_RTCPD_TO_ABORT, "Told RTCPD to abort"},
{AGGREGATOR_GIVE_RECALL_FILE_TO_RTCPD, "Giving recall file to RTCPD"},
{AGGREGATOR_GAVE_RECALL_FILE_TO_RTCPD, "Gave recall file to RTCPD"},
{AGGREGATOR_GIVE_MIGRATE_FILE_TO_RTCPD, "Giving migrate file to RTCPD"},
{AGGREGATOR_GAVE_MIGRATE_FILE_TO_RTCPD, "Gave migrate file to RTCPD"},
{AGGREGATOR_RECEIVE_MSGBODY_FROM_RTCPD, "Receiving message body from RTCPD"},
{AGGREGATOR_RECEIVED_MSGBODY_FROM_RTCPD, "Received message body from RTCPD"},
{AGGREGATOR_RECEIVE_FILERQSTBODY_FROM_RTCPD, "Receiving FileRqstBody from RTCPD"},
{AGGREGATOR_RECEIVED_FILERQSTBODY_FROM_RTCPD, "Received FileRqstBody from RTCPD"},
{AGGREGATOR_RECEIVE_FILERQSTERRBODY_FROM_RTCPD, "Receiving FileRqstErrBody from RTCPD"},
{AGGREGATOR_RECEIVED_FILERQSTERRBODY_FROM_RTCPD, "Received FileRqstErrBody from RTCPD"},
{AGGREGATOR_PROCESSING_TAPE_DISK_RQST, "Processing a tape/disk IO request from RTCPD"},
{AGGREGATOR_PING_RTCPD, "Pinging RTCPD"},
{AGGREGATOR_PINGED_RTCPD, "Pinged RTCPD"},
{AGGREGATOR_SEND_ACK_TO_RTCPD, "Sending acknowledge to RTCPD"},
{AGGREGATOR_SENT_ACK_TO_RTCPD, "Sent acknowledge to RTCPD"},
{AGGREGATOR_SEND_HEADER_TO_RTCPD, "Sending message header to RTCPD"},
{AGGREGATOR_SENT_HEADER_TO_RTCPD, "Sent message header to RTCPD"},
{AGGREGATOR_RECEIVE_TAPERQSTBODY, "Receiving tape request message body"},
{AGGREGATOR_RECEIVED_TAPERQSTBODY, "Received tape request message body"},
{AGGREGATOR_RECEIVE_GIVEOUTPBODY, "Receiving GIVE_OUTP message body"},
{AGGREGATOR_RECEIVED_GIVEOUTPBODY, "Received GIVE_OUTP message body"},
{AGGREGATOR_RECEIVE_TAPERQSTERRBODY, "Receiving tape request message body with error appendix"},
{AGGREGATOR_RECEIVED_TAPERQSTERRBODY, "Received tape request message body with error appendix"},
{AGGREGATOR_SEND_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD, "Sending delayed acknowledge of request for more work to RTCPD"},
{AGGREGATOR_SENT_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD, "Sent delayed acknowledge of request for more work to RTCPD"},
{AGGREGATOR_CREATED_RTCPD_CALLBACK_PORT, "Created TCP/IP port for RTCPD callbacks"},
{AGGREGATOR_CONNECTION_CLOSED_BY_RTCPD, "Connection closed by RTCPD"},
{AGGREGATOR_CLOSED_CONNECTION, "Connection closed by aggregator"},
{AGGREGATOR_NOTIFY_CLIENT_FILE_MIGRATED, "Notifying client file migrated"},
{AGGREGATOR_NOTIFIED_CLIENT_FILE_MIGRATED, "Notified client file migrated"},
{AGGREGATOR_NOTIFY_CLIENT_FILE_RECALLED, "Notifying client file recalled"},
{AGGREGATOR_NOTIFIED_CLIENT_FILE_RECALLED, "Notified client file recalled"},
{AGGREGATOR_NOTIFY_CLIENT_END_OF_SESSION, "Notifying client end of session"},
{AGGREGATOR_NOTIFIED_CLIENT_END_OF_SESSION, "Notified client end of session"},
{AGGREGATOR_GET_DUMP_PARAMETERS_FROM_CLIENT, "Getting dump parameters from client"},
{AGGREGATOR_GOT_DUMP_PARAMETERS_FROM_CLIENT, "Got dump parameters from client"},
{AGGREGATOR_NOTIFY_CLIENT_DUMP_MESSAGE, "Notifying client dump message"},
{AGGREGATOR_NOTIFIED_CLIENT_DUMP_MESSAGE, "Notified client dump message"},
{AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_SESSION, "Failed to notify client end of session"},
{AGGREGATOR_NOTIFY_CLIENT_END_OF_FAILED_SESSION, "Notifying client end of failed session"},
{AGGREGATOR_NOTIFIED_CLIENT_END_OF_FAILED_SESSION, "Notified client end of failed session"},
{AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_FAILED_SESSION, "Failed to notify client end of failed session"},
{AGGREGATOR_SELECT_INTR, "Select interrupted"},
{AGGREGATOR_ENTERING_BRIDGE_MODE, "Entering bridge mode"},
{AGGREGATOR_PING_CLIENT, "Pinging client"},
{AGGREGATOR_PINGED_CLIENT, "Pinged client"},
{AGGREGATOR_CLOSED_INITIAL_CALLBACK_CONNECTION, "Closed initial callback connection"},
{AGGREGATOR_RECEIVED_TAPE_INFO_FROM_VMGR, "Received tape information from VMGR"},
{AGGREGATOR_SENT_FILETOMIGRATEREQUEST, "Sent FileToMigrateRequest to client"},
{AGGREGATOR_RECEIVED_FILETOMIGRATE, "Received FileToMigrate from client"},
{AGGREGATOR_SENT_FILETORECALLREQUEST, "Sent FileToRecallRequest to client"},
{AGGREGATOR_RECEIVED_FILETORECALL, "Received FileToRecall from client"},
{AGGREGATOR_SENT_FILEMIGRATEDNOTIFICATION, "Sent FileMigratedNotification to client"},
{AGGREGATOR_SENT_FILERECALLEDNOTIFICATION, "Sent FileRecalledNotification to client"},
{AGGREGATOR_RECEIVED_NOMOREFILES, "Recieved NoMoreFiles from client"},
{AGGREGATOR_RECEIVED_ACK_OF_NOTIFICATION, "Recieved acknowledge of notification from client"},
{AGGREGATOR_RECEIVED_ENDNOTIFCATIONERRORREPORT, "Received EndNotificationErrorReport from client"},
{AGGREGATOR_RECEIVED_NOTIFCATIONACKNOWLEDGE, "Received NotificationAcknowledge from client"},
{AGGREGATOR_SEND_END_OF_SESSION_TO_RTCPD, "Sending end-of-session to RTCPD"},
{AGGREGATOR_FAILED_TO_PARSE_TPCONFIG, "Failed to parse TPCONFIG file"},
{AGGREGATOR_PARSED_TPCONFIG, "Parsed TPCONFIG"},
{AGGREGATOR_CLOSED_RTCPD_DISK_TAPE_CONNECTION_DUE_TO_PEER, "Closed rtcpd disk/tape IO control connection due to rtcpd closing its end"},
{AGGREGATOR_TOO_MANY_DRIVES_IN_TPCONFIG, "There are more drives in the TPCONFIG file than there were when aggregatord was started. Please restart aggregatord."},
{-1, ""}};
0,AGGREGATOR_NULL," - "
1,AGGREGATOR_STARTED,"aggregatord started"
2,AGGREGATOR_FAILED_TO_START,"aggregatord failed to start"
3,AGGREGATOR_RECEIVED_VDQM_CONNECTION,"Received a connection from VDQM"
4,AGGREGATOR_HANDLE_VDQM_REQUEST_EXCEPT,"Exception raised when handling a request from the VDQM"
5,AGGREGATOR_FAILED_TO_READ_MESSAGE_HEADER,"Failed to read message header"
6,AGGREGATOR_UNKNOWN_MAGIC,"Unknown magic number"
7,AGGREGATOR_UNKNOWN_REQUEST_TYPE,"Unknown request type"
8,AGGREGATOR_FAILED_TO_READ_MESSAGE_BODY,"Failed to read message body"
9,AGGREGATOR_RECEIVE_RTCOPY_JOB,"Receiving remote-copy job"
10,AGGREGATOR_RECEIVED_RTCOPY_JOB,"Received remote-copy job"
11,AGGREGATOR_SUBMITTING_RTCOPY_JOB_TO_RTCPD,"Submitting remote-copy job to RTCPD"
12,AGGREGATOR_FAILED_TO_SUBMIT_JOB_TO_RTCPD,"Failed to submit remote-copy job to RTCPD"
13,AGGREGATOR_FAILED_TO_MARSHALL_RTCP_ACKN,"Failed to marshall RTCP acknowledge message"
14,AGGREGATOR_FAILED_TO_SEND_RTCOPY_JOB_REPLY_TO_VDQM,"Failed to send remote-copy job reply to VDQM"
15,AGGREGATOR_FAILED_TO_PROCESS_RCOPY_JOB_SUBMISSION,"Failed to process remote-copy job submission message"
16,AGGREGATOR_RTCPD_HANDLER_SOCKET_IS_NULL,"The RtcpdHandlerThread has been passed a NULL socket pointer"
17,AGGREGATOR_INITIAL_RTCPD_CALLBACK,"Received initial callback connection from RTCPD"
18,AGGREGATOR_RTCPD_CALLBACK,"Received a callback connection from RTCPD"
19,AGGREGATOR_GOT_VOLREQID,"Got volume request ID from RTCPD"
20,AGGREGATOR_FAILED_TO_GET_VOLREQID,"Failed to get volume request ID from RTCPD"
21,AGGREGATOR_FAILED_TO_MARSHALL_RTCOPY_JOB_REPLY_MESSAGE,"Failed to marshall remote-copy job reply message"
22,AGGREGATOR_SIGNALLED_NO_MORE_REQUESTS,"Signalled no more requests to RTCPD"
23,AGGREGATOR_FAILED_TO_COORDINATE_REMOTE_COPY,"Failed to coordinate remote-copy"
24,AGGREGATOR_TRANSFER_FAILED,"Transfer failed"
25,AGGREGATOR_GAVE_REQUEST_FOR_MORE_WORK,"Gave request for more work to RTCPD"
26,AGGREGATOR_DATA_ON_INITIAL_RTCPD_CONNECTION,"Data has arrived on the initial RTCPD connection"
27,AGGREGATOR_RECEIVED_RTCP_ENDOF_REQ,"Received RTCP_ENDOF_REQ"
28,AGGREGATOR_TAPE_POSITIONED,"Tape positioned"
29,AGGREGATOR_FILE_TRANSFERED,"File transfered"
30,AGGREGATOR_GET_REQUEST_INFO_FROM_RTCPD,"Getting request information from RTCPD"
31,AGGREGATOR_GOT_REQUEST_INFO_FROM_RTCPD,"Got request information from RTCPD"
32,AGGREGATOR_TOLD_CLIENT_TO_START_TRANSFER,"Told client to start the transfer protocol"
33,AGGREGATOR_GET_VOLUME_FROM_CLIENT,"Getting volume from client"
34,AGGREGATOR_GOT_VOLUME_FROM_CLIENT,"Got volume from client"
35,AGGREGATOR_GOT_NO_MORE_FILES_FROM_CLIENT,"Got no more files from client"
36,AGGREGATOR_GET_FILE_TO_MIGRATE_FROM_CLIENT,"Getting file to migrate from client"
37,AGGREGATOR_GOT_FILE_TO_MIGRATE_FROM_CLIENT,"Got file to migrate from client"
38,AGGREGATOR_GET_FILE_TO_RECALL_FROM_CLIENT,"Getting file to recall from client"
39,AGGREGATOR_GOT_FILE_TO_RECALL_FROM_CLIENT,"Got file to recall from client"
40,AGGREGATOR_GIVE_VOLUME_TO_RTCPD,"Giving volume to RTCPD"
41,AGGREGATOR_GAVE_VOLUME_TO_RTCPD,"Gave volume to RTCPD"
42,AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_RECALL_WORK,"Asking RTCPD to request more recall work"
43,AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_RECALL_WORK,"Asked RTCPD to request more recall work"
44,AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_MIGRATE_WORK,"Asking RTCPD to request more migrate work"
45,AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_MIGRATE_WORK,"Asked RTCPD to request more migrate work"
46,AGGREGATOR_TELL_RTCPD_DUMP_TAPE,"Telling RTCPD to dump tape"
47,AGGREGATOR_TOLD_RTCPD_DUMP_TAPE,"Told RTCPD to dump tape"
48,AGGREGATOR_TELL_RTCPD_END_OF_FILE_LIST,"Telling RTCPD end of file list"
49,AGGREGATOR_TOLD_RTCPD_END_OF_FILE_LIST,"Told RTCPD end of file list"
50,AGGREGATOR_TELL_RTCPD_TO_ABORT,"Telling RTCPD to abort"
51,AGGREGATOR_TOLD_RTCPD_TO_ABORT,"Told RTCPD to abort"
52,AGGREGATOR_GIVE_RECALL_FILE_TO_RTCPD,"Giving recall file to RTCPD"
53,AGGREGATOR_GAVE_RECALL_FILE_TO_RTCPD,"Gave recall file to RTCPD"
54,AGGREGATOR_GIVE_MIGRATE_FILE_TO_RTCPD,"Giving migrate file to RTCPD"
55,AGGREGATOR_GAVE_MIGRATE_FILE_TO_RTCPD,"Gave migrate file to RTCPD"
56,AGGREGATOR_RECEIVE_MSGBODY_FROM_RTCPD,"Receiving message body from RTCPD"
57,AGGREGATOR_RECEIVED_MSGBODY_FROM_RTCPD,"Received message body from RTCPD"
58,AGGREGATOR_RECEIVE_FILERQSTBODY_FROM_RTCPD,"Receiving FileRqstBody from RTCPD"
59,AGGREGATOR_RECEIVED_FILERQSTBODY_FROM_RTCPD,"Received FileRqstBody from RTCPD"
60,AGGREGATOR_RECEIVE_FILERQSTERRBODY_FROM_RTCPD,"Receiving FileRqstErrBody from RTCPD"
61,AGGREGATOR_RECEIVED_FILERQSTERRBODY_FROM_RTCPD,"Received FileRqstErrBody from RTCPD"
62,AGGREGATOR_PROCESSING_TAPE_DISK_RQST,"Processing a tape/disk IO request from RTCPD"
63,AGGREGATOR_PING_RTCPD,"Pinging RTCPD"
64,AGGREGATOR_PINGED_RTCPD,"Pinged RTCPD"
65,AGGREGATOR_SEND_ACK_TO_RTCPD,"Sending acknowledge to RTCPD"
66,AGGREGATOR_SENT_ACK_TO_RTCPD,"Sent acknowledge to RTCPD"
67,AGGREGATOR_SEND_HEADER_TO_RTCPD,"Sending message header to RTCPD"
68,AGGREGATOR_SENT_HEADER_TO_RTCPD,"Sent message header to RTCPD"
69,AGGREGATOR_RECEIVE_TAPERQSTBODY,"Receiving tape request message body"
70,AGGREGATOR_RECEIVED_TAPERQSTBODY,"Received tape request message body"
71,AGGREGATOR_RECEIVE_GIVEOUTPBODY,"Receiving GIVE_OUTP message body"
72,AGGREGATOR_RECEIVED_GIVEOUTPBODY,"Received GIVE_OUTP message body"
73,AGGREGATOR_RECEIVE_TAPERQSTERRBODY,"Receiving tape request message body with error appendix"
74,AGGREGATOR_RECEIVED_TAPERQSTERRBODY,"Received tape request message body with error appendix"
75,AGGREGATOR_SEND_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD,"Sending delayed acknowledge of request for more work to RTCPD"
76,AGGREGATOR_SENT_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD,"Sent delayed acknowledge of request for more work to RTCPD"
77,AGGREGATOR_CREATED_RTCPD_CALLBACK_PORT,"Created TCP/IP port for RTCPD callbacks"
78,AGGREGATOR_CONNECTION_CLOSED_BY_RTCPD,"Connection closed by RTCPD"
79,AGGREGATOR_CLOSED_CONNECTION,"Connection closed by aggregator"
80,AGGREGATOR_NOTIFY_CLIENT_FILE_MIGRATED,"Notifying client file migrated"
81,AGGREGATOR_NOTIFIED_CLIENT_FILE_MIGRATED,"Notified client file migrated"
82,AGGREGATOR_NOTIFY_CLIENT_FILE_RECALLED,"Notifying client file recalled"
83,AGGREGATOR_NOTIFIED_CLIENT_FILE_RECALLED,"Notified client file recalled"
84,AGGREGATOR_NOTIFY_CLIENT_END_OF_SESSION,"Notifying client end of session"
85,AGGREGATOR_NOTIFIED_CLIENT_END_OF_SESSION,"Notified client end of session"
86,AGGREGATOR_GET_DUMP_PARAMETERS_FROM_CLIENT,"Getting dump parameters from client"
87,AGGREGATOR_GOT_DUMP_PARAMETERS_FROM_CLIENT,"Got dump parameters from client"
88,AGGREGATOR_NOTIFY_CLIENT_DUMP_MESSAGE,"Notifying client dump message"
89,AGGREGATOR_NOTIFIED_CLIENT_DUMP_MESSAGE,"Notified client dump message"
90,AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_SESSION,"Failed to notify client end of session"
91,AGGREGATOR_NOTIFY_CLIENT_END_OF_FAILED_SESSION,"Notifying client end of failed session"
92,AGGREGATOR_NOTIFIED_CLIENT_END_OF_FAILED_SESSION,"Notified client end of failed session"
93,AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_FAILED_SESSION,"Failed to notify client end of failed session"
94,AGGREGATOR_SELECT_INTR,"Select interrupted"
95,AGGREGATOR_ENTERING_BRIDGE_MODE,"Entering bridge mode"
96,AGGREGATOR_PING_CLIENT,"Pinging client"
97,AGGREGATOR_PINGED_CLIENT,"Pinged client"
98,AGGREGATOR_CLOSED_INITIAL_CALLBACK_CONNECTION,"Closed initial callback connection"
99,AGGREGATOR_RECEIVED_TAPE_INFO_FROM_VMGR,"Received tape information from VMGR"
100,AGGREGATOR_SENT_FILETOMIGRATEREQUEST,"Sent FileToMigrateRequest to client"
101,AGGREGATOR_RECEIVED_FILETOMIGRATE,"Received FileToMigrate from client"
102,AGGREGATOR_SENT_FILETORECALLREQUEST,"Sent FileToRecallRequest to client"
103,AGGREGATOR_RECEIVED_FILETORECALL,"Received FileToRecall from client"
104,AGGREGATOR_SENT_FILEMIGRATEDNOTIFICATION,"Sent FileMigratedNotification to client"
105,AGGREGATOR_SENT_FILERECALLEDNOTIFICATION,"Sent FileRecalledNotification to client"
106,AGGREGATOR_RECEIVED_NOMOREFILES,"Recieved NoMoreFiles from client"
107,AGGREGATOR_RECEIVED_ACK_OF_NOTIFICATION,"Recieved acknowledge of notification from client"
108,AGGREGATOR_RECEIVED_ENDNOTIFCATIONERRORREPORT,"Received EndNotificationErrorReport from client"
109,AGGREGATOR_RECEIVED_NOTIFCATIONACKNOWLEDGE,"Received NotificationAcknowledge from client"
110,AGGREGATOR_SEND_END_OF_SESSION_TO_RTCPD,"Sending end-of-session to RTCPD"
111,AGGREGATOR_FAILED_TO_PARSE_TPCONFIG,"Failed to parse TPCONFIG file"
112,AGGREGATOR_PARSED_TPCONFIG,"Parsed TPCONFIG"
113,AGGREGATOR_CLOSED_RTCPD_DISK_TAPE_CONNECTION_DUE_TO_PEER,"Closed rtcpd disk/tape IO control connection due to rtcpd closing its end"
114,AGGREGATOR_TOO_MANY_DRIVES_IN_TPCONFIG,"There are more drives in the TPCONFIG file than there were when aggregatord was started. Please restart aggregatord."
......@@ -23,12 +23,12 @@
* @author Nicola.Bessone@cern.ch Steven.Murray@cern.ch
*****************************************************************************/
#include "castor/tape/aggregator/BoolFunctor.hpp"
#include "castor/tape/tapeserver/BoolFunctor.hpp"
//-----------------------------------------------------------------------------
// destructor
//-----------------------------------------------------------------------------
castor::tape::aggregator::BoolFunctor::~BoolFunctor() throw() {
castor::tape::tapeserver::BoolFunctor::~BoolFunctor() throw() {
// Do nothing
}
/******************************************************************************
* castor/tape/aggregator/BoolFunctor.hpp
* castor/tape/tapeserver/BoolFunctor.hpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
......@@ -22,12 +22,12 @@
*
* @author Nicola.Bessone@cern.ch Steven.Murray@cern.ch
*****************************************************************************/
#ifndef _CASTOR_TAPE_AGGREGATOR_BOOLFUNCTOR_HPP_
#define _CASTOR_TAPE_AGGREGATOR_BOOLFUNCTOR_HPP_
#ifndef _CASTOR_TAPE_TAPESERVER_BOOLFUNCTOR_HPP_
#define _CASTOR_TAPE_TAPESERVER_BOOLFUNCTOR_HPP_
namespace castor {
namespace tape {
namespace aggregator {
namespace tapeserver {
/**
* Abstract class specifiying the interface to be followed by functors that
......@@ -48,8 +48,8 @@ namespace aggregator {
}; // class BoolFunctor
} // namespace aggregator
} // namespace tapeserver
} // namespace tape
} // namespace castor
#endif // _CASTOR_TAPE_AGGREGATOR_BOOLFUNCTOR_HPP_
#endif // _CASTOR_TAPE_TAPESERVER_BOOLFUNCTOR_HPP_
/******************************************************************************
* castor/tape/aggregator/BridgeProtocolEngine.hpp
* castor/tape/tapeserver/BridgeProtocolEngine.hpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
......@@ -22,14 +22,14 @@
* @author Nicola.Bessone@cern.ch Steven.Murray@cern.ch
*****************************************************************************/
#ifndef CASTOR_TAPE_AGGREGATOR_BRIDGEPROTOCOLENGINE
#define CASTOR_TAPE_AGGREGATOR_BRIDGEPROTOCOLENGINE
#ifndef CASTOR_TAPE_TAPESERVER_BRIDGEPROTOCOLENGINE
#define CASTOR_TAPE_TAPESERVER_BRIDGEPROTOCOLENGINE
#include "castor/exception/Exception.hpp"
#include "castor/tape/aggregator/BoolFunctor.hpp"
#include "castor/tape/aggregator/BridgeSocketCatalogue.hpp"
#include "castor/tape/aggregator/Constants.hpp"
#include "castor/tape/aggregator/Counter.hpp"
#include "castor/tape/tapeserver/BoolFunctor.hpp"
#include "castor/tape/tapeserver/BridgeSocketCatalogue.hpp"
#include "castor/tape/tapeserver/Constants.hpp"
#include "castor/tape/tapeserver/Counter.hpp"
#include "castor/tape/legacymsg/CommonMarshal.hpp"
#include "castor/tape/legacymsg/RtcpMarshal.hpp"
#include "castor/tape/tapegateway/Volume.hpp"
......@@ -43,7 +43,7 @@
namespace castor {
namespace tape {
namespace aggregator {
namespace tapeserver {
/**
* Acts as a bridge between the tape gatway and rtcpd.
......@@ -70,8 +70,8 @@ public:
* this parameter is ignored.
* @param stoppingGracefully Functor that returns true if the daemon is
* stopping gracefully.
* @param aggregatorTransactionCounter The counter used to generate
* aggregator transaction IDs. These are the
* @param tapeserverTransactionCounter The counter used to generate
* tapeserver transaction IDs. These are the
* IDS used in requests to the clients.
*/
BridgeProtocolEngine(
......@@ -82,7 +82,7 @@ public:
tapegateway::Volume &volume,
const uint32_t nbFilesOnDestinationTape,
BoolFunctor &stoppingGracefully,
Counter<uint64_t> &aggregatorTransactionCounter) throw();
Counter<uint64_t> &tapeserverTransactionCounter) throw();
/**
* Run a recall/migration session.
......@@ -135,10 +135,10 @@ private:
BoolFunctor &m_stoppingGracefully;
/**
* The counter used to generate the next aggregator transaction ID to be used
* The counter used to generate the next tapeserver transaction ID to be used
* in a request to the client.
*/
Counter<uint64_t> &m_aggregatorTransactionCounter;
Counter<uint64_t> &m_tapeserverTransactionCounter;
/**
* The number of received RTCP_ENDOF_REQ messages.
......@@ -224,7 +224,7 @@ private:
* rtcpd request. If there is no such tape path,
* then the value of this parameter should be set
* to NULL.
* @param aggregatorTransactionId The aggregator transaction ID associated
* @param aggregatorTransactionId The tapeserver transaction ID associated
* with the request sent to the client. If no
* request was sent then this parameter should be
* set to 0.
......@@ -497,8 +497,8 @@ private:
}; // class BridgeProtocolEngine
} // namespace aggregator
} // namespace tapeserver
} // namespace tape
} // namespace castor
#endif // CASTOR_TAPE_AGGREGATOR_BRIDGEPROTOCOLENGINE
#endif // CASTOR_TAPE_TAPESERVER_BRIDGEPROTOCOLENGINE
/******************************************************************************
* castor/tape/aggregator/BridgeSocketCatalogue.hpp
* castor/tape/tapeserver/BridgeSocketCatalogue.hpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
......@@ -23,8 +23,8 @@
*****************************************************************************/
#include "castor/exception/Internal.hpp"
#include "castor/tape/aggregator/BridgeSocketCatalogue.hpp"
#include "castor/tape/aggregator/Constants.hpp"
#include "castor/tape/tapeserver/BridgeSocketCatalogue.hpp"
#include "castor/tape/tapeserver/Constants.hpp"
#include "castor/tape/utils/utils.hpp"
#include <errno.h>
......@@ -33,7 +33,7 @@
//-----------------------------------------------------------------------------
// constructor
//-----------------------------------------------------------------------------
castor::tape::aggregator::BridgeSocketCatalogue::BridgeSocketCatalogue() :
castor::tape::tapeserver::BridgeSocketCatalogue::BridgeSocketCatalogue() :
m_listenSock(-1), m_initialRtcpdSock(-1) {
}
......@@ -41,7 +41,7 @@ castor::tape::aggregator::BridgeSocketCatalogue::BridgeSocketCatalogue() :
//-----------------------------------------------------------------------------
// destructor
//-----------------------------------------------------------------------------
castor::tape::aggregator::BridgeSocketCatalogue::~BridgeSocketCatalogue() {
castor::tape::tapeserver::BridgeSocketCatalogue::~BridgeSocketCatalogue() {
// Note this destructor does NOT close the listen socket used to accept rtcpd
// connections. This is the responsibility of the VdqmRequestHandler.
......@@ -67,7 +67,7 @@ castor::tape::aggregator::BridgeSocketCatalogue::~BridgeSocketCatalogue() {
//-----------------------------------------------------------------------------
// addListenSock
//-----------------------------------------------------------------------------
void castor::tape::aggregator::BridgeSocketCatalogue::addListenSock(
void castor::tape::tapeserver::BridgeSocketCatalogue::addListenSock(
const int listenSock) throw(castor::exception::Exception) {
if(listenSock < 0) {
......@@ -91,7 +91,7 @@ void castor::tape::aggregator::BridgeSocketCatalogue::addListenSock(
//-----------------------------------------------------------------------------
// addInitialRtcpdConn
//-----------------------------------------------------------------------------
void castor::tape::aggregator::BridgeSocketCatalogue::addInitialRtcpdConn(
void castor::tape::tapeserver::BridgeSocketCatalogue::addInitialRtcpdConn(
const int initialRtcpdSock) throw(castor::exception::Exception) {
if(initialRtcpdSock < 0) {
......@@ -115,7 +115,7 @@ void castor::tape::aggregator::BridgeSocketCatalogue::addInitialRtcpdConn(
//-----------------------------------------------------------------------------
// addRtcpdDiskTapeIOControlConn
//-----------------------------------------------------------------------------
void castor::tape::aggregator::BridgeSocketCatalogue::
void castor::tape::tapeserver::BridgeSocketCatalogue::
addRtcpdDiskTapeIOControlConn(const int rtcpdSock)
throw(castor::exception::Exception) {
......@@ -146,7 +146,7 @@ void castor::tape::aggregator::BridgeSocketCatalogue::
//-----------------------------------------------------------------------------
// addClientConn
//-----------------------------------------------------------------------------
void castor::tape::aggregator::BridgeSocketCatalogue::addClientConn(
void castor::tape::tapeserver::BridgeSocketCatalogue::addClientConn(
const int rtcpdSock,
const uint32_t rtcpdReqMagic,
const uint32_t rtcpdReqType,
......@@ -200,7 +200,7 @@ void castor::tape::aggregator::BridgeSocketCatalogue::addClientConn(
// Store the client-connection
itor->clientSock = clientSock;
// Store the aggregator transaction ID asscoiated with the request sent
// Store the tapeserver transaction ID asscoiated with the request sent
// to the client
itor->aggregatorTransactionId = aggregatorTransactionId;
......@@ -227,7 +227,7 @@ void castor::tape::aggregator::BridgeSocketCatalogue::addClientConn(
//-----------------------------------------------------------------------------
// getListenSock
//-----------------------------------------------------------------------------
int castor::tape::aggregator::BridgeSocketCatalogue::getListenSock()
int castor::tape::tapeserver::BridgeSocketCatalogue::getListenSock()
throw(castor::exception::Exception) {
// Throw an exception if the socket-descriptor of the listen socket does not
......@@ -244,7 +244,7 @@ int castor::tape::aggregator::BridgeSocketCatalogue::getListenSock()
//-----------------------------------------------------------------------------
// getInitialRtcpdConn
//-----------------------------------------------------------------------------
int castor::tape::aggregator::BridgeSocketCatalogue::getInitialRtcpdConn()
int castor::tape::tapeserver::BridgeSocketCatalogue::getInitialRtcpdConn()
throw(castor::exception::Exception) {
// Throw an exception if the socket-descriptor of the initial rtcpd
......@@ -261,7 +261,7 @@ int castor::tape::aggregator::BridgeSocketCatalogue::getInitialRtcpdConn()
//-----------------------------------------------------------------------------
// releaseRtcpdDiskTapeIOControlConn
//-----------------------------------------------------------------------------
int castor::tape::aggregator::BridgeSocketCatalogue::
int castor::tape::tapeserver::BridgeSocketCatalogue::
releaseRtcpdDiskTapeIOControlConn(const int rtcpdSock)
throw(castor::exception::Exception) {
......@@ -304,7 +304,7 @@ int castor::tape::aggregator::BridgeSocketCatalogue::
//-----------------------------------------------------------------------------
// releaseClientConn
//-----------------------------------------------------------------------------
int castor::tape::aggregator::BridgeSocketCatalogue::releaseClientConn(
int castor::tape::tapeserver::BridgeSocketCatalogue::releaseClientConn(
const int rtcpdSock, const int clientSock)
throw(castor::exception::Exception) {
......@@ -378,7 +378,7 @@ int castor::tape::aggregator::BridgeSocketCatalogue::releaseClientConn(
//-----------------------------------------------------------------------------
// getRtcpdConn
//-----------------------------------------------------------------------------
void castor::tape::aggregator::BridgeSocketCatalogue::getRtcpdConn(
void castor::tape::tapeserver::BridgeSocketCatalogue::getRtcpdConn(
const int clientSock,
int &rtcpdSock,
uint32_t &rtcpdReqMagic,
......@@ -426,7 +426,7 @@ void castor::tape::aggregator::BridgeSocketCatalogue::getRtcpdConn(
//-----------------------------------------------------------------------------
// buildReadFdSet
//-----------------------------------------------------------------------------
void castor::tape::aggregator::BridgeSocketCatalogue::buildReadFdSet(
void castor::tape::tapeserver::BridgeSocketCatalogue::buildReadFdSet(
fd_set &readFdSet, int &maxFd) throw() {
// Clear the file-descriptor set
......@@ -474,7 +474,7 @@ void castor::tape::aggregator::BridgeSocketCatalogue::buildReadFdSet(
//-----------------------------------------------------------------------------
// getAPendingSock
//-----------------------------------------------------------------------------
int castor::tape::aggregator::BridgeSocketCatalogue::getAPendingSock(
int castor::tape::tapeserver::BridgeSocketCatalogue::getAPendingSock(
fd_set &readFdSet, SocketType &sockType) throw() {
// If the listen socket is pending, then set the socket type output parameter
......@@ -522,7 +522,7 @@ int castor::tape::aggregator::BridgeSocketCatalogue::getAPendingSock(
//-----------------------------------------------------------------------------
// getNbDiskTapeIOControlConnections
//-----------------------------------------------------------------------------
int castor::tape::aggregator::BridgeSocketCatalogue::
int castor::tape::tapeserver::BridgeSocketCatalogue::
getNbDiskTapeIOControlConns() {
return m_rtcpdConnections.size();
......@@ -532,7 +532,7 @@ int castor::tape::aggregator::BridgeSocketCatalogue::
//-----------------------------------------------------------------------------
// checkForTimeout
//-----------------------------------------------------------------------------
void castor::tape::aggregator::BridgeSocketCatalogue::checkForTimeout()
void castor::tape::tapeserver::BridgeSocketCatalogue::checkForTimeout()
throw(castor::exception::TimeOut) {
if(!m_clientReqHistory.empty()) {
......
/******************************************************************************
* castor/tape/aggregator/BridgeSocketCatalogue.hpp
* castor/tape/tapeserver/BridgeSocketCatalogue.hpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
......@@ -22,8 +22,8 @@
* @author Nicola.Bessone@cern.ch Steven.Murray@cern.ch
*****************************************************************************/
#ifndef CASTOR_TAPE_AGGREGATOR_BRIDGESOCKETCATALOGUE
#define CASTOR_TAPE_AGGREGATOR_BRIDGESOCKETCATALOGUE
#ifndef CASTOR_TAPE_TAPESERVER_BRIDGESOCKETCATALOGUE
#define CASTOR_TAPE_TAPESERVER_BRIDGESOCKETCATALOGUE
#include "castor/exception/Exception.hpp"
#include "castor/exception/TimeOut.hpp"
......@@ -37,7 +37,7 @@
namespace castor {
namespace tape {
namespace aggregator {
namespace tapeserver {
/**
* The BridgeProtocolEngine is implemented as a single thread spinning in a
......@@ -160,7 +160,7 @@ public:
* sent to rtcpd.
* @param clientSock The socket-descriptor of the client connection
* from which a reply is expected.
* @param aggregatorTransactionId The aggregator transaction ID associated
* @param aggregatorTransactionId The tapeserver transaction ID associated
* with the client request.
*/
void addClientConn(
......@@ -258,7 +258,7 @@ public:
* the initiating rtcpd request. If there is no
* such tape path, then this parameter is set to
* NULL.
* @param aggregatorTransactionId Output parameter: The aggregator
* @param aggregatorTransactionId Output parameter: The tapeserver
* transaction ID associated with the request sent
* to the client.