X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=serverpool.h;fp=serverpool.h;h=a70d5429221af06f82049e8c098d93e52c33cbc9;hp=61676281840f070bd2c70a722dd92f2a92b9d327;hb=20e85bd6901355cc40a6cfb4c0deb7232d9aa63f;hpb=061988af511f42da3cd584b4d983177504ddc177 diff --git a/serverpool.h b/serverpool.h index 6167628..a70d542 100644 --- a/serverpool.h +++ b/serverpool.h @@ -30,7 +30,15 @@ public: void add_client_from_serialized(const ClientProto &client, const std::vector> &short_responses); // Adds the given stream to all the servers. Returns the stream index. - int add_stream(const std::string &url, size_t backlog_size, size_t prebuffering_bytes, Stream::Encoding encoding, Stream::Encoding src_encoding); + int add_stream(const std::string &url, + const std::string &hls_url, + size_t backlog_size, + size_t prebuffering_bytes, + Stream::Encoding encoding, + Stream::Encoding src_encoding, + unsigned hls_frag_duration, + size_t hls_backlog_margin, + const std::string &allow_origin); int add_stream_from_serialized(const StreamProto &stream, const std::vector &data_fds); void delete_stream(const std::string &url); int add_udpstream(const sockaddr_in6 &dst, int pacing_rate, int ttl, int multicast_iface_index); @@ -42,7 +50,7 @@ public: void set_header(int stream_index, const std::string &http_header, const std::string &stream_header); - void add_data(int stream_index, const char *data, size_t bytes, uint16_t metacube_flags); + void add_data(int stream_index, const char *data, size_t bytes, uint16_t metacube_flags, const RationalPTS &pts); // Sets the max pacing rate for all the servers. void set_pacing_rate(int stream_index, uint32_t pacing_rate); @@ -59,6 +67,20 @@ public: // Changes the given stream's input encoding type on all the servers. void set_src_encoding(int stream_index, Stream::Encoding encoding); + // Changes the given stream's maximum HLS fragment duration (in seconds) on all the servers. + void set_hls_frag_duration(int stream_index, unsigned hls_frag_duration); + + // Changes the given stream's backlog margin for HLS fragments (in bytes) on all the servers. + void set_hls_backlog_margin(int stream_index, size_t hls_backlog_margin); + + // Changes the given stream's CORS header on all the servers. + void set_allow_origin(int stream_index, const std::string &allow_origin); + + // Register the given stream under the given URL on all the servers. + // Used only for deserialized streams (for new ones, we do this registration + // in add_stream()). + void register_hls_url(int stream_index, const std::string &hls_url); + // Adds the given gen204 endpoint to all the servers. void add_gen204(const std::string &url, const std::string &allow_origin);