X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=serverpool.cpp;h=a2035943d429a53e1c621ab6c773b08fdac56994;hp=f8fece60a43c0a17d303c74dbd48e9e5a986d695;hb=e8740ea38fa1b54672a83744549fcd1463403d98;hpb=61bac622cc696a98c9dcec8a78771c742232958e diff --git a/serverpool.cpp b/serverpool.cpp index f8fece6..a203594 100644 --- a/serverpool.cpp +++ b/serverpool.cpp @@ -16,7 +16,7 @@ ServerPool::~ServerPool() void ServerPool::add_client(int sock) { - servers[clients_added++ % num_servers].add_client(sock); + servers[clients_added++ % num_servers].add_client_deferred(sock); } void ServerPool::add_client_from_serialized(const ClientProto &client) @@ -48,7 +48,7 @@ void ServerPool::set_header(const std::string &stream_id, const std::string &hea void ServerPool::add_data(const std::string &stream_id, const char *data, size_t bytes) { for (int i = 0; i < num_servers; ++i) { - servers[i].add_data(stream_id, data, bytes); + servers[i].add_data_deferred(stream_id, data, bytes); } }