![]() |
Fledge
An open source edge computing platform for industrial users
|
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... | |
StreamHandler::~StreamHandler | ( | ) |
Destructor for the StreamHandler.
Close down the epoll system and wait for the handler thread to terminate.
uint32_t StreamHandler::createStream | ( | uint32_t * | token | ) |
Create a new stream and add it to the epoll mechanism for the stream handler.
token | The single use connection token the client should send |
The | port on which this stream is listening |
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