X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;ds=sidebyside;f=serverpool.cpp;h=c77c30ef85c262084a0d92ad862da38a4717ceb5;hb=68b85737b49ff00ab7c16defcf6e3dfab45ca0e3;hp=310a0a7f8fe894ffbfded8fd36bb348ed9b1babb;hpb=0e96bbf9ee0fbebd5fe3fba4d186c0e0d73c9a32;p=cubemap diff --git a/serverpool.cpp b/serverpool.cpp index 310a0a7..c77c30e 100644 --- a/serverpool.cpp +++ b/serverpool.cpp @@ -67,7 +67,7 @@ void ServerPool::add_client_from_serialized(const ClientProto &client) servers[clients_added++ % num_servers].add_client_from_serialized(client); } -int ServerPool::lookup_stream_by_url(const std::string &url) const +int ServerPool::lookup_stream_by_url(const string &url) const { assert(servers != NULL); return servers[0].lookup_stream_by_url(url); @@ -163,6 +163,13 @@ void ServerPool::add_data(int stream_index, const char *data, size_t bytes, Stre } } +void ServerPool::add_gen204(const std::string &url, const std::string &allow_origin) +{ + for (int i = 0; i < num_servers; ++i) { + servers[i].add_gen204(url, allow_origin); + } +} + void ServerPool::run() { for (int i = 0; i < num_servers; ++i) { @@ -201,6 +208,13 @@ void ServerPool::set_backlog_size(int stream_index, size_t new_size) } } +void ServerPool::set_prebuffering_bytes(int stream_index, size_t new_amount) +{ + for (int i = 0; i < num_servers; ++i) { + servers[i].set_prebuffering_bytes(stream_index, new_amount); + } +} + void ServerPool::set_encoding(int stream_index, Stream::Encoding encoding) { for (int i = 0; i < num_servers; ++i) {