X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=serverpool.h;h=61676281840f070bd2c70a722dd92f2a92b9d327;hp=d257a86c48f7dc1186c12f3e285cce3371f5af28;hb=061988af511f42da3cd584b4d983177504ddc177;hpb=16a03b9858752fae9e81af261821a2a22855fde3 diff --git a/serverpool.h b/serverpool.h index d257a86..6167628 100644 --- a/serverpool.h +++ b/serverpool.h @@ -2,6 +2,7 @@ #define _SERVERPOOL_H 1 #include +#include #include #include @@ -20,14 +21,13 @@ struct sockaddr_in6; class ServerPool { public: ServerPool(int num_servers); - ~ServerPool(); // Fills streams() and clients(). CubemapStateProto serialize(); // Picks a server (round-robin) and allocates the given client to it. void add_client(int sock, Acceptor *acceptor); - void add_client_from_serialized(const ClientProto &client); + 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); @@ -75,15 +75,15 @@ public: std::vector get_client_stats() const; private: - Server *servers; - int num_servers, clients_added; + std::unique_ptr servers; + int num_servers, clients_added = 0; // Our indexing is currently rather primitive; every stream_index in // [0, num_http_streams) maps to a HTTP stream (of which every Server // has exactly one copy), and after that, it's mapping directly into // . - int num_http_streams; - std::vector udp_streams; + int num_http_streams = 0; + std::vector> udp_streams; ServerPool(const ServerPool &); };