ark::comms::TcpServerStage

Defined in header “ark/comms/stages/tcp_server_stage.hh”.

---

This stage provides a TCP server, binding to the port of your choice. Any incoming packets will be published over the channel as TcpPacketGroups, and any ’egress’ packets will be sent to all clients.

Methods

• TcpServerStage(std::string name)
  Constructor.

• ~TcpServerStage()
  Destructor. Implemented privately to handle cleanup.

• void initialize(pipeline::StageInterface & interface)
  Initializes the stage, starting threads and creating publishers.

• void start()
  Indicates that the system has settled and you should begin any threads or processing.

• void shutdown()
  Stops the stage, shutting down threads.

• SocketStats statistics()
  A function intended for testing; returns the current stage statistics.