X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=serverpool.cpp;h=936bd21293ab074504965dc0f035fbe6a8dc98a0;hp=590e0f53b30a5c095e3b57a7a1a5a470093574fb;hb=22cd7233eabd1d012f29e890ec67c6b70a0d6753;hpb=7b3d494100ef1063578b1ef76818baee4ab53ada diff --git a/serverpool.cpp b/serverpool.cpp index 590e0f5..936bd21 100644 --- a/serverpool.cpp +++ b/serverpool.cpp @@ -1,12 +1,17 @@ #include #include +#include #include "client.h" +#include "log.h" #include "server.h" #include "serverpool.h" #include "state.pb.h" +#include "udpstream.h" #include "util.h" +struct sockaddr_in6; + using namespace std; ServerPool::ServerPool(int size) @@ -142,7 +147,7 @@ void ServerPool::set_header(int stream_index, const string &http_header, const s } } -void ServerPool::add_data(int stream_index, const char *data, size_t bytes) +void ServerPool::add_data(int stream_index, const char *data, size_t bytes, StreamStartSuitability suitable_for_stream_start) { assert(stream_index >= 0 && stream_index < ssize_t(num_http_streams + udp_streams.size())); @@ -154,7 +159,7 @@ void ServerPool::add_data(int stream_index, const char *data, size_t bytes) // HTTP stream. for (int i = 0; i < num_servers; ++i) { - servers[i].add_data_deferred(stream_index, data, bytes); + servers[i].add_data_deferred(stream_index, data, bytes, suitable_for_stream_start); } }