return state;
}
-void ServerPool::add_client(int sock)
+void ServerPool::add_client(int sock, Acceptor *acceptor)
{
- servers[clients_added++ % num_servers].add_client_deferred(sock);
+ servers[clients_added++ % num_servers].add_client_deferred(sock, acceptor);
}
void ServerPool::add_client_from_serialized(const ClientProto &client)
}
}
+void ServerPool::create_tls_context_for_acceptor(const Acceptor *acceptor)
+{
+ for (int i = 0; i < num_servers; ++i) {
+ servers[i].create_tls_context_for_acceptor(acceptor);
+ }
+}
+
void ServerPool::run()
{
for (int i = 0; i < num_servers; ++i) {