Fledge
An open source edge computing platform for industrial users
StreamHandler Class Reference

Public Member Functions

 StreamHandler (StorageApi *)
 Constructor for the StreamHandler class.
 
 ~StreamHandler ()
 Destructor for the StreamHandler. More...
 
void handler ()
 The handler method for the stream handler. More...
 
uint32_t createStream (uint32_t *token)
 Create a new stream and add it to the epoll mechanism for the stream handler. More...
 

Constructor & Destructor Documentation

◆ ~StreamHandler()

StreamHandler::~StreamHandler ( )

Destructor for the StreamHandler.

Close down the epoll system and wait for the handler thread to terminate.

Member Function Documentation

◆ createStream()

uint32_t StreamHandler::createStream ( uint32_t *  token)

Create a new stream and add it to the epoll mechanism for the stream handler.

Parameters
tokenThe single use connection token the client should send
Theport on which this stream is listening

◆ handler()

void StreamHandler::handler ( )

The handler method for the stream handler.

This is run in its own thread and is responsible for using epoll to gather events on the descriptors and to dispatch them to the individual streams


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