X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=stream.h;h=6c757a19ff29224f1049c2fc8554d4c24f36af0a;hp=057a48cbe08e516be02f756ce4aeac3701672ee2;hb=f0621e41fdb96ce1bd58e7561e0aa76345072ba3;hpb=6544fa0ec3f3a501bcb89ea977756911bd7f3ebd diff --git a/stream.h b/stream.h index 057a48c..6c757a1 100644 --- a/stream.h +++ b/stream.h @@ -15,11 +15,6 @@ class StreamProto; struct Client; -enum StreamStartSuitability { - NOT_SUITABLE_FOR_STREAM_START, - SUITABLE_FOR_STREAM_START, -}; - struct Stream { // Must be in sync with StreamConfig::Encoding. enum Encoding { STREAM_ENCODING_RAW = 0, STREAM_ENCODING_METACUBE }; @@ -77,7 +72,7 @@ struct Stream { // How many bytes this stream have received. Can very well be larger // than , since the buffer wraps. - size_t bytes_received; + size_t bytes_received = 0; // A list of points in the stream that is suitable to start new clients at // (after having sent the header). Empty if no such point exists yet. @@ -93,13 +88,13 @@ struct Stream { std::vector to_process; // Maximum pacing rate for the stream. - uint32_t pacing_rate; + uint32_t pacing_rate = ~0U; // Queued data, if any. Protected by . // The data pointers in the iovec are owned by us. struct DataElement { iovec data; - StreamStartSuitability suitable_for_stream_start; + uint16_t metacube_flags; }; std::vector queued_data; @@ -110,7 +105,7 @@ struct Stream { // Add more data to , adding Metacube headers if needed. // Does not take ownership of . - void add_data_deferred(const char *data, size_t bytes, StreamStartSuitability suitable_for_stream_start); + void add_data_deferred(const char *data, size_t bytes, uint16_t metacube_flags); // Add queued data to the stream, if any. // You should hold the owning Server's .