X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;ds=sidebyside;f=serverpool.h;h=a02798135b12eabe56b9516193831979ab40fec7;hb=534764f026b82b144e974882c8e53c4cd8d21b68;hp=ba60d7c0d9b0705e01c372ed9f4d71d9db99e35d;hpb=40ed7df894c8645c132a5bea2bfb12a9be2b82ef;p=cubemap diff --git a/serverpool.h b/serverpool.h index ba60d7c..a027981 100644 --- a/serverpool.h +++ b/serverpool.h @@ -26,11 +26,13 @@ public: void add_client_from_serialized(const ClientProto &client); // Adds the given stream to all the servers. - void add_stream(const std::string &stream_id, size_t backlog_size); - void add_stream_from_serialized(const StreamProto &stream); + void add_stream(const std::string &stream_id, size_t backlog_size, Stream::Encoding encoding); + void add_stream_from_serialized(const StreamProto &stream, const std::vector &data_fds); // Adds the given data to all the servers. - void set_header(const std::string &stream_id, const std::string &header); + void set_header(const std::string &stream_id, + const std::string &http_header, + const std::string &stream_header); void add_data(const std::string &stream_id, const char *data, size_t bytes); // Connects the given stream to the given mark pool for all the servers. @@ -39,6 +41,9 @@ public: // Changes the given stream's backlog size on all the servers. void set_backlog_size(const std::string &stream_id, size_t new_size); + // Changes the given stream's encoding type on all the servers. + void set_encoding(const std::string &stream_id, Stream::Encoding encoding); + // Starts all the servers. void run();