evd::WebEVDServer< T > Class Template Reference

#include <WebEVDServer.h>

Public Member Functions
	WebEVDServer ()
	~WebEVDServer ()
Result	serve (const T &evt, const geo::GeometryCore *geom, const detinfo::DetectorPropertiesData &detprop)

Protected Types
template<class PROD >
using	HandleT = typename T::template HandleT< std::vector< PROD >>

Protected Member Functions
int	EnsureListen ()

Protected Attributes
int	fSock

Detailed Description

template<class T>
class evd::WebEVDServer< T >

Definition at line 24 of file WebEVDServer.h.

Member Typedef Documentation

template<class T>

template<class PROD >

using evd::WebEVDServer< T >::HandleT = typename T::template HandleT<std::vector<PROD>>

protected

Definition at line 35 of file WebEVDServer.h.

Constructor & Destructor Documentation

template<class T >

evd::WebEVDServer< T >::WebEVDServer

(

)

Definition at line 67 of file WebEVDServer.cxx.

  : fSock(0)
{
}

template<class T >

evd::WebEVDServer< T >::~WebEVDServer

(

)

Definition at line 73 of file WebEVDServer.cxx.

{
  if(fSock) close(fSock);
}

Member Function Documentation

template<class T >

int evd::WebEVDServer< T >::EnsureListen ( )

protected

Definition at line 830 of file WebEVDServer.cxx.

{
  if(fSock != 0) return 0;

  char host[1024];
  gethostname(host, 1024);
  char* user = getlogin();

  std::cout << "\n------------------------------------------------------------\n" << std::endl;

  // E1071 is DUNE :)
  int port = 1071;

  // Search for an open port up-front
  while(system(TString::Format("ss -an | grep -q %d", port).Data()) == 0) ++port;


  fSock = socket(AF_INET, SOCK_STREAM, 0);
  if(fSock == -1) return err("socket");

  // Reuse port immediately even if a previous instance just aborted.
  const int one = 1;
  if(setsockopt(fSock, SOL_SOCKET, SO_REUSEADDR,
                &one, sizeof(one)) != 0) return err("setsockopt");

  sockaddr_in addr;
  addr.sin_family = AF_INET;
  addr.sin_port = swap_byte_order(port);
  addr.sin_addr.s_addr = INADDR_ANY;

  if(bind(fSock, (sockaddr*)&addr, sizeof(addr)) != 0) return err("bind");

  if(listen(fSock, 128/*backlog*/) != 0) return err("listen");


  std::cout << "First run" << std::endl;
  std::cout << "ssh -L "
            << port << ":localhost:" << port << " "
            << user << "@" << host << std::endl << std::endl;
  std::cout << "and then navigate to http://localhost:" << port << "/ in your favorite browser." << std::endl << std::endl;
  //  std::cout << "Press Ctrl-C here when done." << std::endl;

  return 0;
}

template<class T>

Result evd::WebEVDServer< T >::serve	(	const T &	evt,
		const geo::GeometryCore *	geom,
		const detinfo::DetectorPropertiesData &	detprop
	)

Definition at line 1030 of file WebEVDServer.cxx.

{
  // Don't want a sigpipe signal when the browser hangs up on us. This way we
  // will get an error return from the write() call instead.
  signal(SIGPIPE, SIG_IGN);

  if(EnsureListen() != 0) return kERROR;

  LazyDigits<T> digs(evt, geom);
  LazyWires<T> wires(evt, geom);

  std::list<std::thread> threads;

  while(true){
    int sock = accept(fSock, 0, 0);
    if(sock == -1) return err("accept");

    std::string req = read_all(sock);

    std::cout << req << std::endl;

    char* ctx;
    char* verb = strtok_r(&req.front(), " ", &ctx);

    if(verb && std::string(verb) == "GET"){
      char* freq = strtok_r(0, " ", &ctx);
      std::string sreq(freq);

      if(sreq == "/NEXT" ||
         sreq == "/PREV" ||
         sreq == "/NEXT_TRACES" ||
         sreq == "/PREV_TRACES" ||
         sreq == "/QUIT" ||
         sreq.find("/seek/") == 0 ||
         sreq.find("/seek_traces/") == 0){
        for(std::thread& t: threads) t.join();
        return HandleCommand(sreq, sock);
      }
      else{
        threads.emplace_back(_HandleGet<T>, sreq, sock, &evt, &digs, &wires, geom, &detprop);
      }
    }
    else{
      write_unimp501(sock);
      close(sock);
    }
  }

  // unreachable
}

Member Data Documentation

template<class T>

int evd::WebEVDServer< T >::fSock

protected

Definition at line 39 of file WebEVDServer.h.

---

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

• WebEVDServer.h
• WebEVDServer.cxx