X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=serverpool.cpp;h=9f1a7280662a68f35fb40cb8230af9cb75384978;hp=cf6933ccda181e23f4f7f7d85e353ec11b7d805a;hb=ce95fbe3011d2e5be2da737b05bca9af8db8a646;hpb=2c6cd9718a5baf5a2ed5be73ec3c525d4873f45a 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) {