evd::LandedSocket Class Reference

#include "LandedSocket.h"

Public Member Functions
	LandedSocket (fhicl::ParameterSet const &, art::ActivityRegistry &reg)
bool	connect (void)
void	sendGeometry (std::string)
void	sendEvent (int, int, int, int, int)
void	sendHit (double, double, double, double, double, int)
void	sendVertex (double, double, double, double, int, int)

Private Member Functions
void	postBeginJob ()
void	postBeginJobWorkers (art::InputSource *, std::vector< art::Worker * > const &)
void	preProcessEvent (art::Event const &)
void	postProcessEvent (art::Event const &)

Private Attributes
art::InputSource *	inputSource_
boost::asio::local::stream_protocol::endpoint *	endpoint_
boost::asio::local::stream_protocol::socket *	socket_
boost::asio::io_service	service_
unsigned long	record_

Detailed Description

Definition at line 20 of file LandedSocket.h.

Constructor & Destructor Documentation

evd::LandedSocket::LandedSocket	(	fhicl::ParameterSet const &	pset,
		art::ActivityRegistry &	reg
	)

Definition at line 20 of file LandedSocket_service.cc.

References postBeginJob(), postBeginJobWorkers(), postProcessEvent(), preProcessEvent(), art::ActivityRegistry::sPostBeginJob, art::ActivityRegistry::sPostBeginJobWorkers, art::ActivityRegistry::sPostProcessEvent, and art::ActivityRegistry::sPreProcessEvent.

                                          :
    endpoint_(nullptr),
    socket_(nullptr),
    service_()
  {
   
    reg.sPostBeginJob.watch       (this, &LandedSocket::postBeginJob);
    reg.sPostBeginJobWorkers.watch(this, &LandedSocket::postBeginJobWorkers);
    reg.sPreProcessEvent.watch    (this, &LandedSocket::preProcessEvent);
    reg.sPostProcessEvent.watch   (this, &LandedSocket::postProcessEvent);
    
  }

Member Function Documentation

bool evd::LandedSocket::connect

(

void

)

Definition at line 95 of file LandedSocket_service.cc.

References endpoint_, sendGeometry(), service_, and socket_.

Referenced by postProcessEvent().

  {
    //connect to landed app
    std::ostringstream sockfile;
    sockfile << getenv("HOME") << "/.landed.sock";
    endpoint_=new boost::asio::local::stream_protocol::endpoint(sockfile.str());
    if (!endpoint_)
      {
        mf::LogError("Landed") << "failed to create socket for connection to LANDED app\n";     
        return false;
      }
    socket_=new boost::asio::local::stream_protocol::socket(service_);
    if (socket_!=nullptr)
      socket_->connect(*endpoint_);
    return socket_!=nullptr;
  }

void evd::LandedSocket::postBeginJob ( )

private

Definition at line 35 of file LandedSocket_service.cc.

References postBeginJobWorkers().

Referenced by LandedSocket().

  {

  }

void evd::LandedSocket::postBeginJobWorkers ( art::InputSource *  inputsource, std::vector< art::Worker * > const &  workers  )

private

Definition at line 40 of file LandedSocket_service.cc.

References inputSource_, preProcessEvent(), and record_.

Referenced by LandedSocket(), and postBeginJob().

  {
    inputSource_=inputsource;
    record_=0;
  }

void evd::LandedSocket::postProcessEvent ( art::Event const &  event )

private

Definition at line 52 of file LandedSocket_service.cc.

References connect(), art::Event::id(), inputSource_, LOG_DEBUG, record_, art::RootInput::seekToEvent(), and socket_.

Referenced by LandedSocket(), and preProcessEvent().

  {
    if (socket_!=nullptr)
      {
        art::RootInput* rootinput = dynamic_cast<art::RootInput*>(inputSource_);
        if (!rootinput)
          {
            throw cet::exception("Landed") << "input is not root file, therefore not seekable and therefore unsuitable for EventViewer\n";
          }
        boost::array<char, 128> instr;
        size_t len=socket_->receive(boost::asio::buffer(instr));
        if (len>0)
          {
            long newrec=atol(instr.data());
            long diff=newrec-record_;
            diff--;
            //      std::cout << "seek: " << diff << std::endl;
            if (rootinput->seekToEvent(diff, true))
              {
                LOG_DEBUG("Landed") << "seek succeeded\n";
                socket_->send(boost::asio::buffer("OK\n", 3));
                record_=newrec;
              }
            else
              {
                //              std::cout << "no such event, reloading\n";
                if (!rootinput->seekToEvent(event.id(), true))
                  throw cet::exception("Landed") << "problem performing seek on input, lost track of input event\n";
                socket_->send(boost::asio::buffer("NO\n", 3));
                //              std::cout << "reload performed\n";
              }
            //wait for message confirmation
            boost::array<char, 2> conf; 
            if (socket_->receive(boost::asio::buffer(conf))!=1)
              throw cet::exception("Landed") << "LANDED app did not confirm instruction result\n";      
            
          }
        else
          throw cet::exception("Landed") << "bad instruction from LANDED app\n";
      }
  }

void evd::LandedSocket::preProcessEvent ( art::Event const &  )

private

Definition at line 47 of file LandedSocket_service.cc.

References postProcessEvent().

Referenced by LandedSocket(), and postBeginJobWorkers().

  {

  }

void evd::LandedSocket::sendEvent	(	int	nhits,
		int	nvertex,
		int	run,
		int	subrun,
		int	event
	)

Definition at line 130 of file LandedSocket_service.cc.

References record_, sendHit(), socket_, and ss.

Referenced by sendGeometry().

  {
    std::ostringstream ss;
    ss << "EVT:" << record_ << "," << nhits << "," << nvertex << ", " << run << "," << subrun << "," << event << "\n";
    //    std::cout << ss.str();
    if (socket_->send(boost::asio::buffer(ss.str().c_str(), ss.str().length()))!=ss.str().length())
       throw cet::exception("Landed") << "failed to send event introduction to LANDED app\n";   
    boost::array<char, 2> conf; 
    if (socket_->receive(boost::asio::buffer(conf))!=1)
      throw cet::exception("Landed") << "LANDED app did not confirm event\n";   
  }

void evd::LandedSocket::sendGeometry

(

std::string

vrml

)

Definition at line 113 of file LandedSocket_service.cc.

References LOG_DEBUG, sendEvent(), socket_, and ss.

Referenced by connect().

  {
    std::ostringstream ss;
    ss << "GEO:"<< vrml.length() << "\n";
    if (socket_->send(boost::asio::buffer(ss.str().c_str(), ss.str().length()))!=ss.str().length() ||
        socket_->send(boost::asio::buffer(vrml.c_str(), vrml.length()))!=vrml.length())
      {
        throw cet::exception("Landed") << "failed to send detector geometry to LANDED app\n";   
      }
    boost::array<char, 2> conf; 
    if (socket_->receive(boost::asio::buffer(conf))!=1)
      throw cet::exception("Landed") << "LANDED app did not confirm detector geometry\n";
    else
      LOG_DEBUG("Landed") << "LANDED app has confirmed detector geometry\n";

  }

void evd::LandedSocket::sendHit	(	double	x,
		double	y,
		double	z,
		double	e,
		double	ne,
		int	track
	)

Definition at line 142 of file LandedSocket_service.cc.

References sendVertex(), socket_, and ss.

Referenced by sendEvent().

  {
    std::ostringstream ss;
    ss << "HIT:" << x << "," << y << "," << z << "," << e << "," << ne << "," << track << "\n";
    //    std::cout << ss.str();
    if (socket_->send(boost::asio::buffer(ss.str().c_str(), ss.str().length()))!=ss.str().length())
      throw cet::exception("Landed") << "failed to send hit to LANDED app\n";   
    boost::array<char, 2> conf; 
    if (socket_->receive(boost::asio::buffer(conf))!=1)
      throw cet::exception("Landed") << "LANDED app did not confirm hit\n";     

  }

void evd::LandedSocket::sendVertex	(	double	x,
		double	y,
		double	z,
		double	e,
		int	id,
		int	pdgcode
	)

Definition at line 155 of file LandedSocket_service.cc.

References DEFINE_ART_SERVICE, socket_, and ss.

Referenced by sendHit().

  {
    std::ostringstream ss;
    ss << "VTX:" << x << "," << y << "," << z << "," << e << "," << id << "," << pdgcode << "\n";
    if (socket_->send(boost::asio::buffer(ss.str().c_str(), ss.str().length()))!=ss.str().length())
        throw cet::exception("Landed") << "failed to send vertex to LANDED app\n";      
    boost::array<char, 2> conf; 
    if (socket_->receive(boost::asio::buffer(conf))!=1)
      throw cet::exception("Landed") << "LANDED app did not confirm vertex\n";  
  }

Member Data Documentation

boost::asio::local::stream_protocol::endpoint* evd::LandedSocket::endpoint_

private

Definition at line 34 of file LandedSocket.h.

Referenced by connect().

art::InputSource* evd::LandedSocket::inputSource_

private

Definition at line 33 of file LandedSocket.h.

Referenced by postBeginJobWorkers(), and postProcessEvent().

unsigned long evd::LandedSocket::record_

private

Definition at line 37 of file LandedSocket.h.

Referenced by postBeginJobWorkers(), postProcessEvent(), and sendEvent().

boost::asio::io_service evd::LandedSocket::service_

private

Definition at line 36 of file LandedSocket.h.

Referenced by connect().

boost::asio::local::stream_protocol::socket* evd::LandedSocket::socket_

private

Definition at line 35 of file LandedSocket.h.

Referenced by connect(), postProcessEvent(), sendEvent(), sendGeometry(), sendHit(), and sendVertex().

---

The documentation for this class was generated from the following files:

• /cvmfs/larsoft.opensciencegrid.org/products/lareventdisplay/v07_02_02/source/lareventdisplay/Landed/LandedSocket.h
• /cvmfs/larsoft.opensciencegrid.org/products/lareventdisplay/v07_02_02/source/lareventdisplay/Landed/LandedSocket_service.cc