srtepoll.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_SRT
#include <promeki/atomic.h>
#include <promeki/function.h>
#include <promeki/namespace.h>
#include <promeki/error.h>
#include <promeki/list.h>
#include <promeki/map.h>
#include <promeki/uniqueptr.h>
 
#include <functional>
 
PROMEKI_NAMESPACE_BEGIN
 
class SrtSocket;
class SrtServer;
 
class SrtEpoll {
        public:
                using UPtr = UniquePtr<SrtEpoll>;
 
                static constexpr int InvalidId = -1;
 
                enum Event {
                        ReadReady  = 0x01, 
                        WriteReady = 0x02, 
                        ErrorEvent = 0x04  
                };
 
                struct Ready {
                                int handle = 0;
                                int events = 0;
                };
 
                using ReadyList = ::promeki::List<Ready>;
 
                using ReadyCallback = Function<void(int events)>;
 
                SrtEpoll();
 
                ~SrtEpoll();
 
                SrtEpoll(const SrtEpoll &) = delete;
                SrtEpoll &operator=(const SrtEpoll &) = delete;
 
                Error open();
 
                void close();
 
                bool isOpen() const { return _eid != InvalidId; }
 
                Error add(SrtSocket &sock, int events);
 
                Error add(SrtServer &server, int events);
 
                Error modify(SrtSocket &sock, int events);
 
                Error remove(SrtSocket &sock);
 
                Error remove(SrtServer &server);
 
                int wait(ReadyList &ready, int timeoutMs);
 
                int handle() const { return _eid; }
 
                Error setCallback(SrtSocket &sock, ReadyCallback cb);
 
                Error setCallback(SrtServer &server, ReadyCallback cb);
 
                int dispatchOnce(int timeoutMs);
 
                int run();
 
                void stop();
 
        private:
                int                     _eid = InvalidId;
                Map<int, ReadyCallback> _callbacks;
                Atomic<bool>            _stopRequested{false};
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_SRT