diff --git a/xroot_plugins/XrdSsiCtaRequestMessage.cpp b/xroot_plugins/XrdSsiCtaRequestMessage.cpp index 7d25f603492cf920be293fbc6ec26a77a5f798b5..5c07860eb19778b33789cf7c974b93fcf9437fa9 100644 --- a/xroot_plugins/XrdSsiCtaRequestMessage.cpp +++ b/xroot_plugins/XrdSsiCtaRequestMessage.cpp @@ -292,6 +292,9 @@ void RequestMessage::process(const cta::xrd::Request &request, cta::xrd::Respons case Workflow::OPENW: processOPENW (request.notification(), response); break; + case Workflow::CREATE: + processCREATE (request.notification(), response); + break; case Workflow::CLOSEW: processCLOSEW (request.notification(), response); break; @@ -334,6 +337,18 @@ void RequestMessage::processOPENW(const cta::eos::Notification ¬ification, ct response.set_type(cta::xrd::Response::RSP_SUCCESS); } +void RequestMessage::processCREATE(const cta::eos::Notification ¬ification, cta::xrd::Response &response) +{ + // Create a log entry + + cta::log::ScopedParamContainer params(m_lc); + m_lc.log(cta::log::INFO, "In processCREATE(): ignoring CREATE event."); + + // Set response type + + response.set_type(cta::xrd::Response::RSP_SUCCESS); +} + void RequestMessage::processCLOSEW(const cta::eos::Notification ¬ification, cta::xrd::Response &response) { // Unpack message diff --git a/xroot_plugins/XrdSsiCtaRequestMessage.hpp b/xroot_plugins/XrdSsiCtaRequestMessage.hpp index 33c2ee9f2acb41516369dbf6c9226a8f75ce2f42..55d19cfe4728fb933ea009804ec9a018e1723811 100644 --- a/xroot_plugins/XrdSsiCtaRequestMessage.hpp +++ b/xroot_plugins/XrdSsiCtaRequestMessage.hpp @@ -64,6 +64,7 @@ private: typedef void notification_event_t(const cta::eos::Notification ¬ification, cta::xrd::Response &response); notification_event_t processOPENW; //!< Ignore OPENW event + notification_event_t processCREATE; //!< Ignore CREATE event notification_event_t processCLOSEW; //!< Archive file event notification_event_t processPREPARE; //!< Retrieve file event notification_event_t processDELETE; //!< Delete file event