X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=serverpool.cpp;h=9f1a7280662a68f35fb40cb8230af9cb75384978;hp=cf6933ccda181e23f4f7f7d85e353ec11b7d805a;hb=7ddd07eb95bb3216fad47aa6d3eb76a8b2648579;hpb=d9b0536b128e10447a986f7b6ea2b5c93252c80f diff --git a/serverpool.cpp b/serverpool.cpp index cf6933c..9f1a728 100644 --- a/serverpool.cpp +++ b/serverpool.cpp @@ -1,4 +1,5 @@ #include "serverpool.h" +#include "state.pb.h" using namespace std; @@ -13,6 +14,25 @@ ServerPool::~ServerPool() { delete[] servers; } + +CubemapStateProto ServerPool::serialize() +{ + CubemapStateProto state; + + for (int i = 0; i < num_servers; ++i) { + CubemapStateProto local_state = servers[i].serialize(); + + // The stream state should be identical between the servers, so we only store it once. + if (i == 0) { + state.mutable_streams()->MergeFrom(local_state.streams()); + } + for (int j = 0; j < local_state.clients_size(); ++j) { + state.add_clients()->MergeFrom(local_state.clients(j)); + } + } + + return state; +} void ServerPool::add_client(int sock) {