srtserver.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_SRT
#include <promeki/function.h>
#include <promeki/objectbase.h>
#include <promeki/error.h>
#include <promeki/socketaddress.h>
#include <promeki/string.h>
#include <promeki/srtsocket.h>
 
#include <functional>
 
PROMEKI_NAMESPACE_BEGIN
 
class SrtServer : public ObjectBase {
                PROMEKI_OBJECT(SrtServer, ObjectBase)
        public:
                static constexpr int DefaultBacklog = 50;
 
                SrtServer(ObjectBase *parent = nullptr);
 
                ~SrtServer() override;
 
                Error listen(const SocketAddress &address, int backlog = DefaultBacklog);
 
                void close();
 
                bool isListening() const { return _listening; }
 
                SocketAddress serverAddress() const { return _address; }
 
                SrtSocket::UPtr accept(unsigned int timeoutMs = 0);
 
                int handle() const { return _sock; }
 
                Error setNonBlocking(bool enable);
 
                // ---- Pre-listen configuration ----
 
                Error setLatency(int ms);
 
                Error setPassphrase(const String &passphrase);
 
                Error setEncryptionKeyLength(int bytes);
 
                Error setMaxBandwidth(int64_t bytesPerSec);
 
                Error setPayloadSize(int bytes);
 
                Error setReuseAddress(bool enable);
 
                using ListenCallback = Function<bool(const String &streamId, const SocketAddress &peer)>;
 
                Error setListenCallback(ListenCallback cb);
 
                String lastError() const { return _lastError; }
 
                PROMEKI_SIGNAL(newConnection);
 
                static bool dispatchListenCallback(SrtServer *server, const String &streamId,
                                                   const SocketAddress &peer);
 
        private:
                int            _sock = SrtSocket::InvalidHandle;
                bool           _listening = false;
                SocketAddress  _address;
                String         _passphrase;
                String         _lastError;
                int            _latencyMs = 120;
                int            _payloadSize = 0;
                int            _pbKeyLen = 0;
                int64_t        _maxBw = 0;
                bool           _reuseAddr = true;
                ListenCallback _listenCb;
 
                Error openAndConfigure();
 
                void captureLastError();
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_SRT