Sender Class Reference

Public Member Functions
	Sender (int port, EvtBuffer *buf)
void	run ()

Private Attributes
int	m_port
EvtBuffer *	m_buf

Detailed Description

Definition at line 115 of file stevtserver.cc.

Constructor & Destructor Documentation

Sender()

Sender ( int port, EvtBuffer * buf )

inline

Definition at line 117 of file stevtserver.cc.

      : m_port(port), m_buf(buf) {}

Member Function Documentation

run()

void run ( )

inline

Definition at line 121 of file stevtserver.cc.

    {
      TCPServerSocket server("0.0.0.0", m_port);
      server.open();
      while (true) {
        TCPSocket socket;
        try {
          socket = server.accept();
          socket.setBufferSize(32 * 1024 * 1024);
          TCPSocketWriter writer(socket);
          while (true) {
            m_buf->read(writer);
          }
        } catch (const IOException& e) {
          socket.close();
        }
      }
    }

Member Data Documentation

m_buf

EvtBuffer* m_buf

private

Definition at line 142 of file stevtserver.cc.

m_port

int m_port

private

Definition at line 141 of file stevtserver.cc.

---

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

• daq/storage/tools/stevtserver.cc