StreamToServerTool.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
#include <JiveXML/StreamToServerTool.h>
 
namespace JiveXML {

  StreamToServerTool::StreamToServerTool( const std::string& type , const std::string& name, const IInterface* p):
    AthAlgTool(type,name,p),
    m_ServerSvc("JiveXML::ONCRPCServerSvc",name){
 
    //Provide interface
    declareInterface<IStreamTool>(this);

    declareProperty("StreamName", m_StreamName = "default");
    declareProperty("ServerService", m_ServerSvc );
  }

  StatusCode StreamToServerTool::initialize(){
 
    //Make sure we can get hold of the server and the online event displays service
    if (m_ServerSvc.retrieve().isFailure()){
      ATH_MSG_ERROR("Unable to initialize server service with name " << m_ServerSvc.name());
      return StatusCode::FAILURE;
    }
 
    if( m_onlineEDsvc.retrieve().isFailure()){
      ATH_MSG_ERROR("Could not locate the online event displays service");
      return StatusCode::FAILURE;
    }
 
    return StatusCode::SUCCESS;
  }

  StatusCode StreamToServerTool::finalize(){
    return StatusCode::SUCCESS;
  }

   StatusCode StreamToServerTool::StreamEvent( const unsigned long EventNumber,
                                               const unsigned int RunNumber,
                                               const std::ostringstream* const EventBuffer ) {
     m_StreamName = m_onlineEDsvc->getStreamName();
     ATH_MSG_VERBOSE("Streaming event Number " << EventNumber
                     << " from run Number " << RunNumber
                     << " to stream " << m_StreamName
                     << " on " << m_ServerSvc.name() << " service");

     EventStreamID evtStreamID(EventNumber,RunNumber,m_StreamName);

     return m_ServerSvc->UpdateEventForStream(evtStreamID,EventBuffer->str());
   }
 
} //namespace