Skip to content
GitLab
Commit 3bdc501c authored by Steven Murray's avatar Steven Murray
Browse files

Within the castor/tape directory I have merged in all the changes made in the 

tape_exp_v1 branch except for those made to castor/tape/tapegateway directory.

The Imakefile in castor/tape has been modified so that it does not generate a
Makefile that tries to build the contents of the castor/tape/tapegateway
directory.
parent 5b7ec102
Expand all Hide whitespace changes
Inline Side-by-side
castor/tape/Constants.hpp
View file @ 3bdc501c
......@@ -34,12 +34,6 @@
namespace castor {
namespace tape {
/**
* The timeout in seconds used when sending and receiving RTCPD network
* messages.
*/
const size_t RTCPDNETRWTIMEOUT = 5;
/**
* The size in bytes of the error string buffer to be used with the strerror
* family of commands.
......
castor/tape/Imakefile
View file @ 3bdc501c
......@@ -23,5 +23,6 @@
#
SUBDIRS = aggregator format fsm tapegateway tpcp
#SUBDIRS = aggregator format fsm tapegateway tpcp
SUBDIRS = aggregator format fsm tpcp
castor/tape/aggregator/AggregatorDlfMessageConstants.hpp
View file @ 3bdc501c
/* This file was generated by ./AggregatorDlfMessagesCodeGenerator on Tue Aug 11 19:03:32 CEST 2009
/* This file was generated by ./AggregatorDlfMessagesCodeGenerator on Tue Sep 29 17:34:08 CEST 2009
*/
/******************************************************************************
......@@ -37,108 +37,105 @@ AGGREGATOR_NULL=0, /* " - " */
AGGREGATOR_STARTED=1, /* "aggregatord started" */
AGGREGATOR_FAILED_TO_PARSE_COMMAND_LINE=2, /* "Failed to parse the command line" */
AGGREGATOR_FAILED_TO_INIT_DB_SERVICE=3, /* "Failed to initialise database service" */
AGGREGATOR_VDQM_REQUEST_HANDLER_SOCKET_IS_NULL=4, /* "The VdqmRequestHandlerThread has been passed a NULL socket pointer" */
AGGREGATOR_VDQM_CONNECTION_WITH_INFO=5, /* "Received a connection from VDQM" */
AGGREGATOR_VDQM_CONNECTION_WITHOUT_INFO=6, /* "Received a connection from VDQM without peer information" */
AGGREGATOR_HANDLE_VDQM_REQUEST_EXCEPT=7, /* "Exception raised when handling a request from the VDQM" */
AGGREGATOR_FAILED_TO_READ_MESSAGE_HEADER=8, /* "Failed to read message header" */
AGGREGATOR_UNKNOWN_MAGIC=9, /* "Unknown magic number" */
AGGREGATOR_UNKNOWN_REQUEST_TYPE=10, /* "Unknown request type" */
AGGREGATOR_FAILED_TO_READ_MESSAGE_BODY=11, /* "Failed to read message body" */
AGGREGATOR_RECEIVE_RCP_JOB_RQST=12, /* "Receiving RCP job request" */
AGGREGATOR_RECEIVED_RCP_JOB_RQST=13, /* "Received RCP job request" */
AGGREGATOR_SUBMITTING_JOB_TO_RTCPD=14, /* "Submitting remote copy job to RTCPD" */
AGGREGATOR_FAILED_TO_SUBMIT_JOB_TO_RTCPD=15, /* "Failed to submit remote copy job to RTCPD" */
AGGREGATOR_FAILED_TO_MARSHALL_RTCP_ACKN=16, /* "Failed to marshall RTCP acknowledge message" */
AGGREGATOR_FAILED_TO_SEND_RCP_JOB_REPLY_TO_VDQM=17, /* "Failed to send RCP job reply to VDQM" */
AGGREGATOR_FAILED_TO_PROCESS_RCP_JOB_SUBMISSION=18, /* "Failed to process RCP job submission message" */
AGGREGATOR_RECEIVED_RTCPD_ERROR_MESSAGE=19, /* "Received error message from RTCPD" */
AGGREGATOR_RTCPD_HANDLER_SOCKET_IS_NULL=20, /* "The RtcpdHandlerThread has been passed a NULL socket pointer" */
AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITH_INFO=21, /* "Received initial callback connection from RTCPD" */
AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITHOUT_INFO=22, /* "Received initial callback connection from RTCPD without peer information" */
AGGREGATOR_RTCPD_CALLBACK_WITH_INFO=23, /* "Received a callback connection from RTCPD" */
AGGREGATOR_RTCPD_CALLBACK_WITHOUT_INFO=24, /* "Received a callback connection from RTCPD without peer information" */
AGGREGATOR_GOT_VOLREQID=25, /* "Got volume request ID from RTCPD" */
AGGREGATOR_FAILED_TO_GET_VOLREQID=26, /* "Failed to get volume request ID from RTCPD" */
AGGREGATOR_FAILED_TO_MARSHALL_RCP_JOB_REPLY_MESSAGE=27, /* "Failed to marshall RCP job reply message" */
AGGREGATOR_SIGNALLED_NO_MORE_REQUESTS=28, /* "Signalled no more requests to RTCPD" */
AGGREGATOR_FAILED_TO_COORDINATE_REMOTE_COPY=29, /* "Failed to coordinate remote copy" */
AGGREGATOR_TRANSFER_FAILED=30, /* "Transfer failed" */
AGGREGATOR_GAVE_REQUEST_FOR_MORE_WORK=31, /* "Gave request for more work to RTCPD" */
AGGREGATOR_DATA_ON_INITIAL_RTCPD_CONNECTION=32, /* "Data has arrived on the initial RTCPD connection" */
AGGREGATOR_RECEIVED_RTCP_ENDOF_REQ=33, /* "Received RTCP_ENDOF_REQ" */
AGGREGATOR_TAPE_POSITIONED=34, /* "Tape positioned" */
AGGREGATOR_FILE_TRANSFERED=35, /* "File transfered" */
AGGREGATOR_GET_REQUEST_INFO_FROM_RTCPD=36, /* "Getting request information from RTCPD" */
AGGREGATOR_GOT_REQUEST_INFO_FROM_RTCPD=37, /* "Got request information from RTCPD" */
AGGREGATOR_TOLD_CLIENT_TO_START_TRANSFER=38, /* "Told client to start the transfer protocol" */
AGGREGATOR_GET_VOLUME_FROM_CLIENT=39, /* "Getting volume from client" */
AGGREGATOR_GOT_VOLUME_FROM_CLIENT=40, /* "Got volume from client" */
AGGREGATOR_GOT_NO_MORE_FILES_FROM_CLIENT=41, /* "Got no more files from client" */
AGGREGATOR_GET_FILE_TO_MIGRATE_FROM_CLIENT=42, /* "Getting file to migrate from client" */
AGGREGATOR_GOT_FILE_TO_MIGRATE_FROM_CLIENT=43, /* "Got file to migrate from client" */
AGGREGATOR_GET_FILE_TO_RECALL_FROM_CLIENT=44, /* "Getting file to recall from client" */
AGGREGATOR_GOT_FILE_TO_RECALL_FROM_CLIENT=45, /* "Got file to recall from client" */
AGGREGATOR_GIVE_VOLUME_TO_RTCPD=46, /* "Giving volume to RTCPD" */
AGGREGATOR_GAVE_VOLUME_TO_RTCPD=47, /* "Gave volume to RTCPD" */
AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_RECALL_WORK=48, /* "Asking RTCPD to request more recall work" */
AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_RECALL_WORK=49, /* "Asked RTCPD to request more recall work" */
AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_MIGRATE_WORK=50, /* "Asking RTCPD to request more migrate work" */
AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_MIGRATE_WORK=51, /* "Asked RTCPD to request more migrate work" */
AGGREGATOR_TELL_RTCPD_DUMP_TAPE=52, /* "Telling RTCPD to dump tape" */
AGGREGATOR_TOLD_RTCPD_DUMP_TAPE=53, /* "Told RTCPD to dump tape" */
AGGREGATOR_TELL_RTCPD_END_OF_FILE_LIST=54, /* "Telling RTCPD end of file list" */
AGGREGATOR_TOLD_RTCPD_END_OF_FILE_LIST=55, /* "Told RTCPD end of file list" */
AGGREGATOR_TELL_RTCPD_TO_ABORT=56, /* "Telling RTCPD to abort" */
AGGREGATOR_TOLD_RTCPD_TO_ABORT=57, /* "Told RTCPD to abort" */
AGGREGATOR_GIVE_RECALL_FILE_TO_RTCPD=58, /* "Giving recall file to RTCPD" */
AGGREGATOR_GAVE_RECALL_FILE_TO_RTCPD=59, /* "Gave recall file to RTCPD" */
AGGREGATOR_GIVE_MIGRATE_FILE_TO_RTCPD=60, /* "Giving migrate file to RTCPD" */
AGGREGATOR_GAVE_MIGRATE_FILE_TO_RTCPD=61, /* "Gave migrate file to RTCPD" */
AGGREGATOR_RECEIVE_MSGBODY_FROM_RTCPD=62, /* "Receiving message body from RTCPD" */
AGGREGATOR_RECEIVED_MSGBODY_FROM_RTCPD=63, /* "Received message body from RTCPD" */
AGGREGATOR_RECEIVE_FILERQSTBODY_FROM_RTCPD=64, /* "Receiving FileRqstBody from RTCPD" */
AGGREGATOR_RECEIVED_FILERQSTBODY_FROM_RTCPD=65, /* "Received FileRqstBody from RTCPD" */
AGGREGATOR_RECEIVE_FILERQSTERRBODY_FROM_RTCPD=66, /* "Receiving FileRqstErrBody from RTCPD" */
AGGREGATOR_RECEIVED_FILERQSTERRBODY_FROM_RTCPD=67, /* "Received FileRqstErrBody from RTCPD" */
AGGREGATOR_PROCESSING_TAPE_DISK_RQST=68, /* "Processing a tape/disk IO request from RTCPD" */
AGGREGATOR_PING_RTCPD=69, /* "Pinging RTCPD" */
AGGREGATOR_PINGED_RTCPD=70, /* "Pinged RTCPD" */
AGGREGATOR_SEND_ACK_TO_RTCPD=71, /* "Sending acknowledge to RTCPD" */
AGGREGATOR_SENT_ACK_TO_RTCPD=72, /* "Sent acknowledge to RTCPD" */
AGGREGATOR_SEND_HEADER_TO_RTCPD=73, /* "Sending message header to RTCPD" */
AGGREGATOR_SENT_HEADER_TO_RTCPD=74, /* "Sent message header to RTCPD" */
AGGREGATOR_RECEIVE_TAPERQSTBODY=75, /* "Receiving tape request message body" */
AGGREGATOR_RECEIVED_TAPERQSTBODY=76, /* "Received tape request message body" */
AGGREGATOR_RECEIVE_GIVEOUTPBODY=77, /* "Receiving GIVE_OUTP message body" */
AGGREGATOR_RECEIVED_GIVEOUTPBODY=78, /* "Received GIVE_OUTP message body" */
AGGREGATOR_RECEIVE_TAPERQSTERRBODY=79, /* "Receiving tape request message body with error appendix" */
AGGREGATOR_RECEIVED_TAPERQSTERRBODY=80, /* "Received tape request message body with error appendix" */
AGGREGATOR_SEND_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD=81, /* "Sending delayed acknowledge of request for more work to RTCPD" */
AGGREGATOR_SENT_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD=82, /* "Sent delayed acknowledge of request for more work to RTCPD" */
AGGREGATOR_CREATED_RTCPD_CALLBACK_PORT=83, /* "Created TCP/IP port for RTCPD callbacks" */
AGGREGATOR_CONNECTION_CLOSED_BY_RTCPD=84, /* "Connection closed by RTCPD" */
AGGREGATOR_CLOSED_CONNECTION=85, /* "Connection closed by aggregator" */
AGGREGATOR_NOTIFY_CLIENT_FILE_MIGRATED=86, /* "Notifying client file migrated" */
AGGREGATOR_NOTIFIED_CLIENT_FILE_MIGRATED=87, /* "Notified client file migrated" */
AGGREGATOR_NOTIFY_CLIENT_FILE_RECALLED=88, /* "Notifying client file recalled" */
AGGREGATOR_NOTIFIED_CLIENT_FILE_RECALLED=89, /* "Notified client file recalled" */
AGGREGATOR_NOTIFY_CLIENT_END_OF_SESSION=90, /* "Notifying client end of session" */
AGGREGATOR_NOTIFIED_CLIENT_END_OF_SESSION=91, /* "Notified client end of session" */
AGGREGATOR_GET_DUMP_PARAMETERS_FROM_CLIENT=92, /* "Getting dump parameters from client" */
AGGREGATOR_GOT_DUMP_PARAMETERS_FROM_CLIENT=93, /* "Got dump parameters from client" */
AGGREGATOR_NOTIFY_CLIENT_DUMP_MESSAGE=94, /* "Notifying client dump message" */
AGGREGATOR_NOTIFIED_CLIENT_DUMP_MESSAGE=95, /* "Notified client dump message" */
AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_SESSION=96, /* "Failed to notify gateway end of session" */
AGGREGATOR_NOTIFY_CLIENT_END_OF_FAILED_SESSION=97, /* "Notifying client end of failed session" */
AGGREGATOR_NOTIFIED_CLIENT_END_OF_FAILED_SESSION=98, /* "Notified client end of failed session" */
AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_FAILED_SESSION=99, /* "Failed to notify gateway end of failed session" */
AGGREGATOR_FAILED_TO_PROCESS_RTCPD_SOCKETS=100, /* "Failed to process RTCPD sockets" */
AGGREGATOR_SELECT_INTR=101, /* "Select interrupted" */
AGGREGATOR_ENTERING_BRIDGE_MODE=102, /* "Entering bridge mode" */
AGGREGATOR_PING_CLIENT=103, /* "Pinging client" */
AGGREGATOR_PINGED_CLIENT=104, /* "Pinged client" */
AGGREGATOR_CLOSED_INITIAL_CALLBACK_CONNECTION=105 /* "Closed initial callback connection" */
AGGREGATOR_VDQM_CONNECTION_WITH_INFO=4, /* "Received a connection from VDQM" */
AGGREGATOR_HANDLE_VDQM_REQUEST_EXCEPT=5, /* "Exception raised when handling a request from the VDQM" */
AGGREGATOR_FAILED_TO_READ_MESSAGE_HEADER=6, /* "Failed to read message header" */
AGGREGATOR_UNKNOWN_MAGIC=7, /* "Unknown magic number" */
AGGREGATOR_UNKNOWN_REQUEST_TYPE=8, /* "Unknown request type" */
AGGREGATOR_FAILED_TO_READ_MESSAGE_BODY=9, /* "Failed to read message body" */
AGGREGATOR_RECEIVE_RCP_JOB_RQST=10, /* "Receiving RCP job request" */
AGGREGATOR_RECEIVED_RCP_JOB_RQST=11, /* "Received RCP job request" */
AGGREGATOR_SUBMITTING_JOB_TO_RTCPD=12, /* "Submitting remote copy job to RTCPD" */
AGGREGATOR_FAILED_TO_SUBMIT_JOB_TO_RTCPD=13, /* "Failed to submit remote copy job to RTCPD" */
AGGREGATOR_FAILED_TO_MARSHALL_RTCP_ACKN=14, /* "Failed to marshall RTCP acknowledge message" */
AGGREGATOR_FAILED_TO_SEND_RCP_JOB_REPLY_TO_VDQM=15, /* "Failed to send RCP job reply to VDQM" */
AGGREGATOR_FAILED_TO_PROCESS_RCP_JOB_SUBMISSION=16, /* "Failed to process RCP job submission message" */
AGGREGATOR_RTCPD_HANDLER_SOCKET_IS_NULL=17, /* "The RtcpdHandlerThread has been passed a NULL socket pointer" */
AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITH_INFO=18, /* "Received initial callback connection from RTCPD" */
AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITHOUT_INFO=19, /* "Received initial callback connection from RTCPD without peer information" */
AGGREGATOR_RTCPD_CALLBACK_WITH_INFO=20, /* "Received a callback connection from RTCPD" */
AGGREGATOR_RTCPD_CALLBACK_WITHOUT_INFO=21, /* "Received a callback connection from RTCPD without peer information" */
AGGREGATOR_GOT_VOLREQID=22, /* "Got volume request ID from RTCPD" */
AGGREGATOR_FAILED_TO_GET_VOLREQID=23, /* "Failed to get volume request ID from RTCPD" */
AGGREGATOR_FAILED_TO_MARSHALL_RCP_JOB_REPLY_MESSAGE=24, /* "Failed to marshall RCP job reply message" */
AGGREGATOR_SIGNALLED_NO_MORE_REQUESTS=25, /* "Signalled no more requests to RTCPD" */
AGGREGATOR_FAILED_TO_COORDINATE_REMOTE_COPY=26, /* "Failed to coordinate remote copy" */
AGGREGATOR_TRANSFER_FAILED=27, /* "Transfer failed" */
AGGREGATOR_GAVE_REQUEST_FOR_MORE_WORK=28, /* "Gave request for more work to RTCPD" */
AGGREGATOR_DATA_ON_INITIAL_RTCPD_CONNECTION=29, /* "Data has arrived on the initial RTCPD connection" */
AGGREGATOR_RECEIVED_RTCP_ENDOF_REQ=30, /* "Received RTCP_ENDOF_REQ" */
AGGREGATOR_TAPE_POSITIONED=31, /* "Tape positioned" */
AGGREGATOR_FILE_TRANSFERED=32, /* "File transfered" */
AGGREGATOR_GET_REQUEST_INFO_FROM_RTCPD=33, /* "Getting request information from RTCPD" */
AGGREGATOR_GOT_REQUEST_INFO_FROM_RTCPD=34, /* "Got request information from RTCPD" */
AGGREGATOR_TOLD_CLIENT_TO_START_TRANSFER=35, /* "Told client to start the transfer protocol" */
AGGREGATOR_GET_VOLUME_FROM_CLIENT=36, /* "Getting volume from client" */
AGGREGATOR_GOT_VOLUME_FROM_CLIENT=37, /* "Got volume from client" */
AGGREGATOR_GOT_NO_MORE_FILES_FROM_CLIENT=38, /* "Got no more files from client" */
AGGREGATOR_GET_FILE_TO_MIGRATE_FROM_CLIENT=39, /* "Getting file to migrate from client" */
AGGREGATOR_GOT_FILE_TO_MIGRATE_FROM_CLIENT=40, /* "Got file to migrate from client" */
AGGREGATOR_GET_FILE_TO_RECALL_FROM_CLIENT=41, /* "Getting file to recall from client" */
AGGREGATOR_GOT_FILE_TO_RECALL_FROM_CLIENT=42, /* "Got file to recall from client" */
AGGREGATOR_GIVE_VOLUME_TO_RTCPD=43, /* "Giving volume to RTCPD" */
AGGREGATOR_GAVE_VOLUME_TO_RTCPD=44, /* "Gave volume to RTCPD" */
AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_RECALL_WORK=45, /* "Asking RTCPD to request more recall work" */
AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_RECALL_WORK=46, /* "Asked RTCPD to request more recall work" */
AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_MIGRATE_WORK=47, /* "Asking RTCPD to request more migrate work" */
AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_MIGRATE_WORK=48, /* "Asked RTCPD to request more migrate work" */
AGGREGATOR_TELL_RTCPD_DUMP_TAPE=49, /* "Telling RTCPD to dump tape" */
AGGREGATOR_TOLD_RTCPD_DUMP_TAPE=50, /* "Told RTCPD to dump tape" */
AGGREGATOR_TELL_RTCPD_END_OF_FILE_LIST=51, /* "Telling RTCPD end of file list" */
AGGREGATOR_TOLD_RTCPD_END_OF_FILE_LIST=52, /* "Told RTCPD end of file list" */
AGGREGATOR_TELL_RTCPD_TO_ABORT=53, /* "Telling RTCPD to abort" */
AGGREGATOR_TOLD_RTCPD_TO_ABORT=54, /* "Told RTCPD to abort" */
AGGREGATOR_GIVE_RECALL_FILE_TO_RTCPD=55, /* "Giving recall file to RTCPD" */
AGGREGATOR_GAVE_RECALL_FILE_TO_RTCPD=56, /* "Gave recall file to RTCPD" */
AGGREGATOR_GIVE_MIGRATE_FILE_TO_RTCPD=57, /* "Giving migrate file to RTCPD" */
AGGREGATOR_GAVE_MIGRATE_FILE_TO_RTCPD=58, /* "Gave migrate file to RTCPD" */
AGGREGATOR_RECEIVE_MSGBODY_FROM_RTCPD=59, /* "Receiving message body from RTCPD" */
AGGREGATOR_RECEIVED_MSGBODY_FROM_RTCPD=60, /* "Received message body from RTCPD" */
AGGREGATOR_RECEIVE_FILERQSTBODY_FROM_RTCPD=61, /* "Receiving FileRqstBody from RTCPD" */
AGGREGATOR_RECEIVED_FILERQSTBODY_FROM_RTCPD=62, /* "Received FileRqstBody from RTCPD" */
AGGREGATOR_RECEIVE_FILERQSTERRBODY_FROM_RTCPD=63, /* "Receiving FileRqstErrBody from RTCPD" */
AGGREGATOR_RECEIVED_FILERQSTERRBODY_FROM_RTCPD=64, /* "Received FileRqstErrBody from RTCPD" */
AGGREGATOR_PROCESSING_TAPE_DISK_RQST=65, /* "Processing a tape/disk IO request from RTCPD" */
AGGREGATOR_PING_RTCPD=66, /* "Pinging RTCPD" */
AGGREGATOR_PINGED_RTCPD=67, /* "Pinged RTCPD" */
AGGREGATOR_SEND_ACK_TO_RTCPD=68, /* "Sending acknowledge to RTCPD" */
AGGREGATOR_SENT_ACK_TO_RTCPD=69, /* "Sent acknowledge to RTCPD" */
AGGREGATOR_SEND_HEADER_TO_RTCPD=70, /* "Sending message header to RTCPD" */
AGGREGATOR_SENT_HEADER_TO_RTCPD=71, /* "Sent message header to RTCPD" */
AGGREGATOR_RECEIVE_TAPERQSTBODY=72, /* "Receiving tape request message body" */
AGGREGATOR_RECEIVED_TAPERQSTBODY=73, /* "Received tape request message body" */
AGGREGATOR_RECEIVE_GIVEOUTPBODY=74, /* "Receiving GIVE_OUTP message body" */
AGGREGATOR_RECEIVED_GIVEOUTPBODY=75, /* "Received GIVE_OUTP message body" */
AGGREGATOR_RECEIVE_TAPERQSTERRBODY=76, /* "Receiving tape request message body with error appendix" */
AGGREGATOR_RECEIVED_TAPERQSTERRBODY=77, /* "Received tape request message body with error appendix" */
AGGREGATOR_SEND_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD=78, /* "Sending delayed acknowledge of request for more work to RTCPD" */
AGGREGATOR_SENT_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD=79, /* "Sent delayed acknowledge of request for more work to RTCPD" */
AGGREGATOR_CREATED_RTCPD_CALLBACK_PORT=80, /* "Created TCP/IP port for RTCPD callbacks" */
AGGREGATOR_CONNECTION_CLOSED_BY_RTCPD=81, /* "Connection closed by RTCPD" */
AGGREGATOR_CLOSED_CONNECTION=82, /* "Connection closed by aggregator" */
AGGREGATOR_NOTIFY_CLIENT_FILE_MIGRATED=83, /* "Notifying client file migrated" */
AGGREGATOR_NOTIFIED_CLIENT_FILE_MIGRATED=84, /* "Notified client file migrated" */
AGGREGATOR_NOTIFY_CLIENT_FILE_RECALLED=85, /* "Notifying client file recalled" */
AGGREGATOR_NOTIFIED_CLIENT_FILE_RECALLED=86, /* "Notified client file recalled" */
AGGREGATOR_NOTIFY_CLIENT_END_OF_SESSION=87, /* "Notifying client end of session" */
AGGREGATOR_NOTIFIED_CLIENT_END_OF_SESSION=88, /* "Notified client end of session" */
AGGREGATOR_GET_DUMP_PARAMETERS_FROM_CLIENT=89, /* "Getting dump parameters from client" */
AGGREGATOR_GOT_DUMP_PARAMETERS_FROM_CLIENT=90, /* "Got dump parameters from client" */
AGGREGATOR_NOTIFY_CLIENT_DUMP_MESSAGE=91, /* "Notifying client dump message" */
AGGREGATOR_NOTIFIED_CLIENT_DUMP_MESSAGE=92, /* "Notified client dump message" */
AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_SESSION=93, /* "Failed to notify gateway end of session" */
AGGREGATOR_NOTIFY_CLIENT_END_OF_FAILED_SESSION=94, /* "Notifying client end of failed session" */
AGGREGATOR_NOTIFIED_CLIENT_END_OF_FAILED_SESSION=95, /* "Notified client end of failed session" */
AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_FAILED_SESSION=96, /* "Failed to notify gateway end of failed session" */
AGGREGATOR_SELECT_INTR=97, /* "Select interrupted" */
AGGREGATOR_ENTERING_BRIDGE_MODE=98, /* "Entering bridge mode" */
AGGREGATOR_PING_CLIENT=99, /* "Pinging client" */
AGGREGATOR_PINGED_CLIENT=100, /* "Pinged client" */
AGGREGATOR_CLOSED_INITIAL_CALLBACK_CONNECTION=101, /* "Closed initial callback connection" */
AGGREGATOR_RECEIVED_TAPE_INFO_FROM_VMGR=102 /* "Received tape information from VMGR" */
}; // enum AggregatorDlfMessages
} // namespace aggregator
} // namespace tape
......
castor/tape/aggregator/AggregatorDlfMessageStrings.cpp
View file @ 3bdc501c
/* This file was generated by ./AggregatorDlfMessagesCodeGenerator on Tue Aug 11 19:03:32 CEST 2009
/* This file was generated by ./AggregatorDlfMessagesCodeGenerator on Tue Sep 29 17:34:08 CEST 2009
*/
/******************************************************************************
......@@ -33,9 +33,7 @@ castor::dlf::Message castor::tape::aggregator::AggregatorDaemon::s_dlfMessages[]
{AGGREGATOR_STARTED, "aggregatord started"},
{AGGREGATOR_FAILED_TO_PARSE_COMMAND_LINE, "Failed to parse the command line"},
{AGGREGATOR_FAILED_TO_INIT_DB_SERVICE, "Failed to initialise database service"},
{AGGREGATOR_VDQM_REQUEST_HANDLER_SOCKET_IS_NULL, "The VdqmRequestHandlerThread has been passed a NULL socket pointer"},
{AGGREGATOR_VDQM_CONNECTION_WITH_INFO, "Received a connection from VDQM"},
{AGGREGATOR_VDQM_CONNECTION_WITHOUT_INFO, "Received a connection from VDQM without peer information"},
{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"},
......@@ -48,7 +46,6 @@ castor::dlf::Message castor::tape::aggregator::AggregatorDaemon::s_dlfMessages[]
{AGGREGATOR_FAILED_TO_MARSHALL_RTCP_ACKN, "Failed to marshall RTCP acknowledge message"},
{AGGREGATOR_FAILED_TO_SEND_RCP_JOB_REPLY_TO_VDQM, "Failed to send RCP job reply to VDQM"},
{AGGREGATOR_FAILED_TO_PROCESS_RCP_JOB_SUBMISSION, "Failed to process RCP job submission message"},
{AGGREGATOR_RECEIVED_RTCPD_ERROR_MESSAGE, "Received error message from RTCPD"},
{AGGREGATOR_RTCPD_HANDLER_SOCKET_IS_NULL, "The RtcpdHandlerThread has been passed a NULL socket pointer"},
{AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITH_INFO, "Received initial callback connection from RTCPD"},
{AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITHOUT_INFO, "Received initial callback connection from RTCPD without peer information"},
......@@ -129,10 +126,10 @@ castor::dlf::Message castor::tape::aggregator::AggregatorDaemon::s_dlfMessages[]
{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 gateway end of failed session"},
{AGGREGATOR_FAILED_TO_PROCESS_RTCPD_SOCKETS, "Failed to process RTCPD sockets"},
{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"},
{-1, ""}};
castor/tape/aggregator/AggregatorDlfMessages.csv
View file @ 3bdc501c
......@@ -2,105 +2,102 @@
1,AGGREGATOR_STARTED,"aggregatord started"
2,AGGREGATOR_FAILED_TO_PARSE_COMMAND_LINE,"Failed to parse the command line"
3,AGGREGATOR_FAILED_TO_INIT_DB_SERVICE,"Failed to initialise database service"
4,AGGREGATOR_VDQM_REQUEST_HANDLER_SOCKET_IS_NULL,"The VdqmRequestHandlerThread has been passed a NULL socket pointer"
5,AGGREGATOR_VDQM_CONNECTION_WITH_INFO,"Received a connection from VDQM"
6,AGGREGATOR_VDQM_CONNECTION_WITHOUT_INFO,"Received a connection from VDQM without peer information"
7,AGGREGATOR_HANDLE_VDQM_REQUEST_EXCEPT,"Exception raised when handling a request from the VDQM"
8,AGGREGATOR_FAILED_TO_READ_MESSAGE_HEADER,"Failed to read message header"
9,AGGREGATOR_UNKNOWN_MAGIC,"Unknown magic number"
10,AGGREGATOR_UNKNOWN_REQUEST_TYPE,"Unknown request type"
11,AGGREGATOR_FAILED_TO_READ_MESSAGE_BODY,"Failed to read message body"
12,AGGREGATOR_RECEIVE_RCP_JOB_RQST,"Receiving RCP job request"
13,AGGREGATOR_RECEIVED_RCP_JOB_RQST,"Received RCP job request"
14,AGGREGATOR_SUBMITTING_JOB_TO_RTCPD,"Submitting remote copy job to RTCPD"
15,AGGREGATOR_FAILED_TO_SUBMIT_JOB_TO_RTCPD,"Failed to submit remote copy job to RTCPD"
16,AGGREGATOR_FAILED_TO_MARSHALL_RTCP_ACKN,"Failed to marshall RTCP acknowledge message"
17,AGGREGATOR_FAILED_TO_SEND_RCP_JOB_REPLY_TO_VDQM,"Failed to send RCP job reply to VDQM"
18,AGGREGATOR_FAILED_TO_PROCESS_RCP_JOB_SUBMISSION,"Failed to process RCP job submission message"
19,AGGREGATOR_RECEIVED_RTCPD_ERROR_MESSAGE,"Received error message from RTCPD"
20,AGGREGATOR_RTCPD_HANDLER_SOCKET_IS_NULL,"The RtcpdHandlerThread has been passed a NULL socket pointer"
21,AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITH_INFO,"Received initial callback connection from RTCPD"
22,AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITHOUT_INFO,"Received initial callback connection from RTCPD without peer information"
23,AGGREGATOR_RTCPD_CALLBACK_WITH_INFO,"Received a callback connection from RTCPD"
24,AGGREGATOR_RTCPD_CALLBACK_WITHOUT_INFO,"Received a callback connection from RTCPD without peer information"
25,AGGREGATOR_GOT_VOLREQID,"Got volume request ID from RTCPD"
26,AGGREGATOR_FAILED_TO_GET_VOLREQID,"Failed to get volume request ID from RTCPD"
27,AGGREGATOR_FAILED_TO_MARSHALL_RCP_JOB_REPLY_MESSAGE,"Failed to marshall RCP job reply message"
28,AGGREGATOR_SIGNALLED_NO_MORE_REQUESTS,"Signalled no more requests to RTCPD"
29,AGGREGATOR_FAILED_TO_COORDINATE_REMOTE_COPY,"Failed to coordinate remote copy"
30,AGGREGATOR_TRANSFER_FAILED,"Transfer failed"
31,AGGREGATOR_GAVE_REQUEST_FOR_MORE_WORK,"Gave request for more work to RTCPD"
32,AGGREGATOR_DATA_ON_INITIAL_RTCPD_CONNECTION,"Data has arrived on the initial RTCPD connection"
33,AGGREGATOR_RECEIVED_RTCP_ENDOF_REQ,"Received RTCP_ENDOF_REQ"
34,AGGREGATOR_TAPE_POSITIONED,"Tape positioned"
35,AGGREGATOR_FILE_TRANSFERED,"File transfered"
36,AGGREGATOR_GET_REQUEST_INFO_FROM_RTCPD,"Getting request information from RTCPD"
37,AGGREGATOR_GOT_REQUEST_INFO_FROM_RTCPD,"Got request information from RTCPD"
38,AGGREGATOR_TOLD_CLIENT_TO_START_TRANSFER,"Told client to start the transfer protocol"
39,AGGREGATOR_GET_VOLUME_FROM_CLIENT,"Getting volume from client"
40,AGGREGATOR_GOT_VOLUME_FROM_CLIENT,"Got volume from client"
41,AGGREGATOR_GOT_NO_MORE_FILES_FROM_CLIENT,"Got no more files from client"
42,AGGREGATOR_GET_FILE_TO_MIGRATE_FROM_CLIENT,"Getting file to migrate from client"
43,AGGREGATOR_GOT_FILE_TO_MIGRATE_FROM_CLIENT,"Got file to migrate from client"
44,AGGREGATOR_GET_FILE_TO_RECALL_FROM_CLIENT,"Getting file to recall from client"
45,AGGREGATOR_GOT_FILE_TO_RECALL_FROM_CLIENT,"Got file to recall from client"
46,AGGREGATOR_GIVE_VOLUME_TO_RTCPD,"Giving volume to RTCPD"
47,AGGREGATOR_GAVE_VOLUME_TO_RTCPD,"Gave volume to RTCPD"
48,AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_RECALL_WORK,"Asking RTCPD to request more recall work"
49,AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_RECALL_WORK,"Asked RTCPD to request more recall work"
50,AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_MIGRATE_WORK,"Asking RTCPD to request more migrate work"
51,AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_MIGRATE_WORK,"Asked RTCPD to request more migrate work"
52,AGGREGATOR_TELL_RTCPD_DUMP_TAPE,"Telling RTCPD to dump tape"
53,AGGREGATOR_TOLD_RTCPD_DUMP_TAPE,"Told RTCPD to dump tape"
54,AGGREGATOR_TELL_RTCPD_END_OF_FILE_LIST,"Telling RTCPD end of file list"
55,AGGREGATOR_TOLD_RTCPD_END_OF_FILE_LIST,"Told RTCPD end of file list"
56,AGGREGATOR_TELL_RTCPD_TO_ABORT,"Telling RTCPD to abort"
57,AGGREGATOR_TOLD_RTCPD_TO_ABORT,"Told RTCPD to abort"
58,AGGREGATOR_GIVE_RECALL_FILE_TO_RTCPD,"Giving recall file to RTCPD"
59,AGGREGATOR_GAVE_RECALL_FILE_TO_RTCPD,"Gave recall file to RTCPD"
60,AGGREGATOR_GIVE_MIGRATE_FILE_TO_RTCPD,"Giving migrate file to RTCPD"
61,AGGREGATOR_GAVE_MIGRATE_FILE_TO_RTCPD,"Gave migrate file to RTCPD"
62,AGGREGATOR_RECEIVE_MSGBODY_FROM_RTCPD,"Receiving message body from RTCPD"
63,AGGREGATOR_RECEIVED_MSGBODY_FROM_RTCPD,"Received message body from RTCPD"
64,AGGREGATOR_RECEIVE_FILERQSTBODY_FROM_RTCPD,"Receiving FileRqstBody from RTCPD"
65,AGGREGATOR_RECEIVED_FILERQSTBODY_FROM_RTCPD,"Received FileRqstBody from RTCPD"
66,AGGREGATOR_RECEIVE_FILERQSTERRBODY_FROM_RTCPD,"Receiving FileRqstErrBody from RTCPD"
67,AGGREGATOR_RECEIVED_FILERQSTERRBODY_FROM_RTCPD,"Received FileRqstErrBody from RTCPD"
68,AGGREGATOR_PROCESSING_TAPE_DISK_RQST,"Processing a tape/disk IO request from RTCPD"
69,AGGREGATOR_PING_RTCPD,"Pinging RTCPD"
70,AGGREGATOR_PINGED_RTCPD,"Pinged RTCPD"
71,AGGREGATOR_SEND_ACK_TO_RTCPD,"Sending acknowledge to RTCPD"
72,AGGREGATOR_SENT_ACK_TO_RTCPD,"Sent acknowledge to RTCPD"
73,AGGREGATOR_SEND_HEADER_TO_RTCPD,"Sending message header to RTCPD"
74,AGGREGATOR_SENT_HEADER_TO_RTCPD,"Sent message header to RTCPD"
75,AGGREGATOR_RECEIVE_TAPERQSTBODY,"Receiving tape request message body"
76,AGGREGATOR_RECEIVED_TAPERQSTBODY,"Received tape request message body"
77,AGGREGATOR_RECEIVE_GIVEOUTPBODY,"Receiving GIVE_OUTP message body"
78,AGGREGATOR_RECEIVED_GIVEOUTPBODY,"Received GIVE_OUTP message body"
79,AGGREGATOR_RECEIVE_TAPERQSTERRBODY,"Receiving tape request message body with error appendix"
80,AGGREGATOR_RECEIVED_TAPERQSTERRBODY,"Received tape request message body with error appendix"
81,AGGREGATOR_SEND_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD,"Sending delayed acknowledge of request for more work to RTCPD"
82,AGGREGATOR_SENT_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD,"Sent delayed acknowledge of request for more work to RTCPD"
83,AGGREGATOR_CREATED_RTCPD_CALLBACK_PORT,"Created TCP/IP port for RTCPD callbacks"
84,AGGREGATOR_CONNECTION_CLOSED_BY_RTCPD,"Connection closed by RTCPD"
85,AGGREGATOR_CLOSED_CONNECTION,"Connection closed by aggregator"
86,AGGREGATOR_NOTIFY_CLIENT_FILE_MIGRATED,"Notifying client file migrated"
87,AGGREGATOR_NOTIFIED_CLIENT_FILE_MIGRATED,"Notified client file migrated"
88,AGGREGATOR_NOTIFY_CLIENT_FILE_RECALLED,"Notifying client file recalled"
89,AGGREGATOR_NOTIFIED_CLIENT_FILE_RECALLED,"Notified client file recalled"
90,AGGREGATOR_NOTIFY_CLIENT_END_OF_SESSION,"Notifying client end of session"
91,AGGREGATOR_NOTIFIED_CLIENT_END_OF_SESSION,"Notified client end of session"
92,AGGREGATOR_GET_DUMP_PARAMETERS_FROM_CLIENT,"Getting dump parameters from client"
93,AGGREGATOR_GOT_DUMP_PARAMETERS_FROM_CLIENT,"Got dump parameters from client"
94,AGGREGATOR_NOTIFY_CLIENT_DUMP_MESSAGE,"Notifying client dump message"
95,AGGREGATOR_NOTIFIED_CLIENT_DUMP_MESSAGE,"Notified client dump message"
96,AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_SESSION,"Failed to notify gateway end of session"
97,AGGREGATOR_NOTIFY_CLIENT_END_OF_FAILED_SESSION,"Notifying client end of failed session"
98,AGGREGATOR_NOTIFIED_CLIENT_END_OF_FAILED_SESSION,"Notified client end of failed session"
99,AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_FAILED_SESSION,"Failed to notify gateway end of failed session"
100,AGGREGATOR_FAILED_TO_PROCESS_RTCPD_SOCKETS,"Failed to process RTCPD sockets"
101,AGGREGATOR_SELECT_INTR,"Select interrupted"
102,AGGREGATOR_ENTERING_BRIDGE_MODE,"Entering bridge mode"
103,AGGREGATOR_PING_CLIENT,"Pinging client"
104,AGGREGATOR_PINGED_CLIENT,"Pinged client"
105,AGGREGATOR_CLOSED_INITIAL_CALLBACK_CONNECTION,"Closed initial callback connection"
4,AGGREGATOR_VDQM_CONNECTION_WITH_INFO,"Received a connection from VDQM"
5,AGGREGATOR_HANDLE_VDQM_REQUEST_EXCEPT,"Exception raised when handling a request from the VDQM"
6,AGGREGATOR_FAILED_TO_READ_MESSAGE_HEADER,"Failed to read message header"
7,AGGREGATOR_UNKNOWN_MAGIC,"Unknown magic number"
8,AGGREGATOR_UNKNOWN_REQUEST_TYPE,"Unknown request type"
9,AGGREGATOR_FAILED_TO_READ_MESSAGE_BODY,"Failed to read message body"
10,AGGREGATOR_RECEIVE_RCP_JOB_RQST,"Receiving RCP job request"
11,AGGREGATOR_RECEIVED_RCP_JOB_RQST,"Received RCP job request"
12,AGGREGATOR_SUBMITTING_JOB_TO_RTCPD,"Submitting remote copy job to RTCPD"
13,AGGREGATOR_FAILED_TO_SUBMIT_JOB_TO_RTCPD,"Failed to submit remote copy job to RTCPD"
14,AGGREGATOR_FAILED_TO_MARSHALL_RTCP_ACKN,"Failed to marshall RTCP acknowledge message"
15,AGGREGATOR_FAILED_TO_SEND_RCP_JOB_REPLY_TO_VDQM,"Failed to send RCP job reply to VDQM"
16,AGGREGATOR_FAILED_TO_PROCESS_RCP_JOB_SUBMISSION,"Failed to process RCP job submission message"
17,AGGREGATOR_RTCPD_HANDLER_SOCKET_IS_NULL,"The RtcpdHandlerThread has been passed a NULL socket pointer"
18,AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITH_INFO,"Received initial callback connection from RTCPD"
19,AGGREGATOR_INITIAL_RTCPD_CALLBACK_WITHOUT_INFO,"Received initial callback connection from RTCPD without peer information"
20,AGGREGATOR_RTCPD_CALLBACK_WITH_INFO,"Received a callback connection from RTCPD"
21,AGGREGATOR_RTCPD_CALLBACK_WITHOUT_INFO,"Received a callback connection from RTCPD without peer information"
22,AGGREGATOR_GOT_VOLREQID,"Got volume request ID from RTCPD"
23,AGGREGATOR_FAILED_TO_GET_VOLREQID,"Failed to get volume request ID from RTCPD"
24,AGGREGATOR_FAILED_TO_MARSHALL_RCP_JOB_REPLY_MESSAGE,"Failed to marshall RCP job reply message"
25,AGGREGATOR_SIGNALLED_NO_MORE_REQUESTS,"Signalled no more requests to RTCPD"
26,AGGREGATOR_FAILED_TO_COORDINATE_REMOTE_COPY,"Failed to coordinate remote copy"
27,AGGREGATOR_TRANSFER_FAILED,"Transfer failed"
28,AGGREGATOR_GAVE_REQUEST_FOR_MORE_WORK,"Gave request for more work to RTCPD"
29,AGGREGATOR_DATA_ON_INITIAL_RTCPD_CONNECTION,"Data has arrived on the initial RTCPD connection"
30,AGGREGATOR_RECEIVED_RTCP_ENDOF_REQ,"Received RTCP_ENDOF_REQ"
31,AGGREGATOR_TAPE_POSITIONED,"Tape positioned"
32,AGGREGATOR_FILE_TRANSFERED,"File transfered"
33,AGGREGATOR_GET_REQUEST_INFO_FROM_RTCPD,"Getting request information from RTCPD"
34,AGGREGATOR_GOT_REQUEST_INFO_FROM_RTCPD,"Got request information from RTCPD"
35,AGGREGATOR_TOLD_CLIENT_TO_START_TRANSFER,"Told client to start the transfer protocol"
36,AGGREGATOR_GET_VOLUME_FROM_CLIENT,"Getting volume from client"
37,AGGREGATOR_GOT_VOLUME_FROM_CLIENT,"Got volume from client"
38,AGGREGATOR_GOT_NO_MORE_FILES_FROM_CLIENT,"Got no more files from client"
39,AGGREGATOR_GET_FILE_TO_MIGRATE_FROM_CLIENT,"Getting file to migrate from client"
40,AGGREGATOR_GOT_FILE_TO_MIGRATE_FROM_CLIENT,"Got file to migrate from client"
41,AGGREGATOR_GET_FILE_TO_RECALL_FROM_CLIENT,"Getting file to recall from client"
42,AGGREGATOR_GOT_FILE_TO_RECALL_FROM_CLIENT,"Got file to recall from client"
43,AGGREGATOR_GIVE_VOLUME_TO_RTCPD,"Giving volume to RTCPD"
44,AGGREGATOR_GAVE_VOLUME_TO_RTCPD,"Gave volume to RTCPD"
45,AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_RECALL_WORK,"Asking RTCPD to request more recall work"
46,AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_RECALL_WORK,"Asked RTCPD to request more recall work"
47,AGGREGATOR_ASK_RTCPD_TO_RQST_MORE_MIGRATE_WORK,"Asking RTCPD to request more migrate work"
48,AGGREGATOR_ASKED_RTCPD_TO_RQST_MORE_MIGRATE_WORK,"Asked RTCPD to request more migrate work"
49,AGGREGATOR_TELL_RTCPD_DUMP_TAPE,"Telling RTCPD to dump tape"
50,AGGREGATOR_TOLD_RTCPD_DUMP_TAPE,"Told RTCPD to dump tape"
51,AGGREGATOR_TELL_RTCPD_END_OF_FILE_LIST,"Telling RTCPD end of file list"
52,AGGREGATOR_TOLD_RTCPD_END_OF_FILE_LIST,"Told RTCPD end of file list"
53,AGGREGATOR_TELL_RTCPD_TO_ABORT,"Telling RTCPD to abort"
54,AGGREGATOR_TOLD_RTCPD_TO_ABORT,"Told RTCPD to abort"
55,AGGREGATOR_GIVE_RECALL_FILE_TO_RTCPD,"Giving recall file to RTCPD"
56,AGGREGATOR_GAVE_RECALL_FILE_TO_RTCPD,"Gave recall file to RTCPD"
57,AGGREGATOR_GIVE_MIGRATE_FILE_TO_RTCPD,"Giving migrate file to RTCPD"
58,AGGREGATOR_GAVE_MIGRATE_FILE_TO_RTCPD,"Gave migrate file to RTCPD"
59,AGGREGATOR_RECEIVE_MSGBODY_FROM_RTCPD,"Receiving message body from RTCPD"
60,AGGREGATOR_RECEIVED_MSGBODY_FROM_RTCPD,"Received message body from RTCPD"
61,AGGREGATOR_RECEIVE_FILERQSTBODY_FROM_RTCPD,"Receiving FileRqstBody from RTCPD"
62,AGGREGATOR_RECEIVED_FILERQSTBODY_FROM_RTCPD,"Received FileRqstBody from RTCPD"
63,AGGREGATOR_RECEIVE_FILERQSTERRBODY_FROM_RTCPD,"Receiving FileRqstErrBody from RTCPD"
64,AGGREGATOR_RECEIVED_FILERQSTERRBODY_FROM_RTCPD,"Received FileRqstErrBody from RTCPD"
65,AGGREGATOR_PROCESSING_TAPE_DISK_RQST,"Processing a tape/disk IO request from RTCPD"
66,AGGREGATOR_PING_RTCPD,"Pinging RTCPD"
67,AGGREGATOR_PINGED_RTCPD,"Pinged RTCPD"
68,AGGREGATOR_SEND_ACK_TO_RTCPD,"Sending acknowledge to RTCPD"
69,AGGREGATOR_SENT_ACK_TO_RTCPD,"Sent acknowledge to RTCPD"
70,AGGREGATOR_SEND_HEADER_TO_RTCPD,"Sending message header to RTCPD"
71,AGGREGATOR_SENT_HEADER_TO_RTCPD,"Sent message header to RTCPD"
72,AGGREGATOR_RECEIVE_TAPERQSTBODY,"Receiving tape request message body"
73,AGGREGATOR_RECEIVED_TAPERQSTBODY,"Received tape request message body"
74,AGGREGATOR_RECEIVE_GIVEOUTPBODY,"Receiving GIVE_OUTP message body"
75,AGGREGATOR_RECEIVED_GIVEOUTPBODY,"Received GIVE_OUTP message body"
76,AGGREGATOR_RECEIVE_TAPERQSTERRBODY,"Receiving tape request message body with error appendix"
77,AGGREGATOR_RECEIVED_TAPERQSTERRBODY,"Received tape request message body with error appendix"
78,AGGREGATOR_SEND_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD,"Sending delayed acknowledge of request for more work to RTCPD"
79,AGGREGATOR_SENT_DELAYED_REQUEST_MORE_WORK_ACK_TO_RTCPD,"Sent delayed acknowledge of request for more work to RTCPD"
80,AGGREGATOR_CREATED_RTCPD_CALLBACK_PORT,"Created TCP/IP port for RTCPD callbacks"
81,AGGREGATOR_CONNECTION_CLOSED_BY_RTCPD,"Connection closed by RTCPD"
82,AGGREGATOR_CLOSED_CONNECTION,"Connection closed by aggregator"
83,AGGREGATOR_NOTIFY_CLIENT_FILE_MIGRATED,"Notifying client file migrated"
84,AGGREGATOR_NOTIFIED_CLIENT_FILE_MIGRATED,"Notified client file migrated"
85,AGGREGATOR_NOTIFY_CLIENT_FILE_RECALLED,"Notifying client file recalled"
86,AGGREGATOR_NOTIFIED_CLIENT_FILE_RECALLED,"Notified client file recalled"
87,AGGREGATOR_NOTIFY_CLIENT_END_OF_SESSION,"Notifying client end of session"
88,AGGREGATOR_NOTIFIED_CLIENT_END_OF_SESSION,"Notified client end of session"
89,AGGREGATOR_GET_DUMP_PARAMETERS_FROM_CLIENT,"Getting dump parameters from client"
90,AGGREGATOR_GOT_DUMP_PARAMETERS_FROM_CLIENT,"Got dump parameters from client"
91,AGGREGATOR_NOTIFY_CLIENT_DUMP_MESSAGE,"Notifying client dump message"
92,AGGREGATOR_NOTIFIED_CLIENT_DUMP_MESSAGE,"Notified client dump message"
93,AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_SESSION,"Failed to notify gateway end of session"
94,AGGREGATOR_NOTIFY_CLIENT_END_OF_FAILED_SESSION,"Notifying client end of failed session"
95,AGGREGATOR_NOTIFIED_CLIENT_END_OF_FAILED_SESSION,"Notified client end of failed session"
96,AGGREGATOR_FAILED_TO_NOTIFY_CLIENT_END_OF_FAILED_SESSION,"Failed to notify gateway end of failed session"
97,AGGREGATOR_SELECT_INTR,"Select interrupted"
98,AGGREGATOR_ENTERING_BRIDGE_MODE,"Entering bridge mode"
99,AGGREGATOR_PING_CLIENT,"Pinging client"
100,AGGREGATOR_PINGED_CLIENT,"Pinged client"
101,AGGREGATOR_CLOSED_INITIAL_CALLBACK_CONNECTION,"Closed initial callback connection"
102,AGGREGATOR_RECEIVED_TAPE_INFO_FROM_VMGR,"Received tape information from VMGR"
castor/tape/aggregator/BridgeProtocolEngine.hpp
View file @ 3bdc501c
......@@ -28,11 +28,9 @@
#include "castor/exception/Exception.hpp"
#include "castor/tape/aggregator/BoolFunctor.hpp"
#include "castor/tape/aggregator/Constants.hpp"
#include "castor/tape/aggregator/MessageHeader.hpp"
#include "castor/tape/aggregator/RcpJobRqstMsgBody.hpp"
#include "castor/tape/aggregator/RtcpFileRqstMsgBody.hpp"
#include "castor/tape/aggregator/RtcpTapeRqstMsgBody.hpp"
#include "castor/tape/aggregator/SmartFdList.hpp"
#include "castor/tape/legacymsg/CommonMarshal.hpp"
#include "castor/tape/legacymsg/RtcpMarshal.hpp"
#include "castor/tape/tapegateway/Volume.hpp"
#include "castor/tape/utils/IndexedContainer.hpp"
#include "h/Castor_limits.h"
......@@ -55,27 +53,31 @@ public:
/**
* Constructor.
*
* @param cuuid The ccuid to be used for logging.
* @param rtcpdCallbackSockFd The file descriptor of the listener socket to
* be used to accept callback connections from
* RTCPD.
* @param rtcpdInitialSockFd The socket file descriptor of initial RTCPD
* connection.
* @param jobRequest The RTCOPY job request from the VDQM.
* @param volume The volume message received from the tape
* gateway.
* @param vsn The volume serial number.
* @param stoppingGracefully Functor that returns true if the daemon is
* stopping gracefully.
* @param cuuid The ccuid to be used for logging.
* @param rtcpdCallbackSockFd The file descriptor of the listener socket
* to be used to accept callback connections
* from RTCPD.
* @param rtcpdInitialSockFd The socket file descriptor of initial
* RTCPD connection.
* @param jobRequest The RTCOPY job request from the VDQM.
* @param volume The volume message received from the
* client.
* @param nbFilesOnDestinationTape If migrating and the client is the tape
* gateway then this must be set to the
* current number of files on the tape, else
* this parameter is ignored.
* @param stoppingGracefully Functor that returns true if the daemon is
* stopping gracefully.
*/
BridgeProtocolEngine(
const Cuuid_t &cuuid,
const int rtcpdCallbackSockFd,
const int rtcpdInitialSockFd,
const RcpJobRqstMsgBody &jobRequest,
tapegateway::Volume &volume,
char (&vsn)[CA_MAXVSNLEN+1],
BoolFunctor &stoppingGracefully) throw();
const Cuuid_t &cuuid,
const int rtcpdCallbackSockFd,
const int rtcpdInitialSockFd,
const legacymsg::RtcpJobRqstMsgBody &jobRequest,
tapegateway::Volume &volume,
const uint32_t nbFilesOnDestinationTape,
BoolFunctor &stoppingGracefully)
throw();
/**
* Run a recall/migration session.
......@@ -105,7 +107,7 @@ private:
/**
* The RTCOPY job request from the VDQM.
*/
const RcpJobRqstMsgBody &m_jobRequest;
const legacymsg::RtcpJobRqstMsgBody &m_jobRequest;
/**
* The volume message received from the tape gateway.
......@@ -113,9 +115,10 @@ private:
tapegateway::Volume &m_volume;
/**
* The volume serial number.
* If migrating and the client is the tape gateway, then this is the next
* expected tape file sequence, else this member is ignored.
*/
const char (&m_vsn)[CA_MAXVSNLEN+1];
uint32_t m_nextDestinationFseq;
/**
* Functor that returns true if the daemon is stopping gracefully.
......@@ -143,7 +146,8 @@ private:
* if the end of the recall/migration session has been reached.
*/
typedef void (BridgeProtocolEngine::*MsgBodyCallback)(
const MessageHeader &header, const int socketFd, bool &endOfSession);
const legacymsg::MessageHeader &header, const int socketFd,
bool &endOfSession);
/**
* Datatype for the map of magic+reqType to message body handler.
......@@ -159,7 +163,7 @@ private:
* Indexed container of the file transaction IDs of all the files currently
* being transfered either for recall or migration.
*/
utils::IndexedContainer<uint64_t, MAXPENDINGTRANSFERS> m_pendingTransferIds;
utils::IndexedContainer<uint64_t> m_pendingTransferIds;
/**
* In-line helper function that returns a 64-bit message body handler key to
......@@ -255,8 +259,9 @@ private:
* @param receivedENDOF_REQ Out parameter: Will be set to true by this
* function of an RTCP_ENDOF_REQ was received.
*/
void processRtcpdRequest(const MessageHeader &header, const int socketFd,
bool &receivedENDOF_REQ) throw(castor::exception::Exception);
void processRtcpdRequest(const legacymsg::MessageHeader &header,
const int socketFd, bool &receivedENDOF_REQ)
throw(castor::exception::Exception);
/**
* Closes the specified RTCPD socket. After closing the connection this
......@@ -272,7 +277,7 @@ private: