X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=server.h;h=523f5c55f376eed2ca9becf25a15c60a9172ba70;hp=e8114cfbdcf516a920cdb1a5690951e0705a1e46;hb=3b8ad87137cff7522ed12f4675d5ff26933bc94a;hpb=488f28bf7070f44469a006ed4a9d4c423788d175 diff --git a/server.h b/server.h index e8114cf..523f5c5 100644 --- a/server.h +++ b/server.h @@ -12,6 +12,7 @@ #include #include "client.h" +#include "stream.h" #include "thread.h" class ClientProto; @@ -34,7 +35,9 @@ public: std::vector get_client_stats() const; // Set header (both HTTP header and any stream headers) for the given stream. - void set_header(const std::string &stream_id, const std::string &header); + void set_header(const std::string &stream_id, + const std::string &http_header, + const std::string &stream_header); // Set that the given stream should use the given mark pool from now on. // NOTE: This should be set before any clients are connected! @@ -51,8 +54,10 @@ public: // at the same time). CubemapStateProto serialize(); void add_client_from_serialized(const ClientProto &client); - void add_stream(const std::string &stream_id, size_t bytes_received); + void add_stream(const std::string &stream_id, size_t bytes_received, Stream::Encoding encoding); void add_stream_from_serialized(const StreamProto &stream); + void set_backlog_size(const std::string &stream_id, size_t new_size); + void set_encoding(const std::string &stream_id, Stream::Encoding encoding); private: // Mutex protecting queued_data only. Note that if you want to hold both this @@ -123,7 +128,6 @@ private: void process_queued_data(); void add_client(int sock); - void add_data(const std::string &stream_id, const char *data, ssize_t bytes); }; #endif // !defined(_SERVER_H)