X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=stream.h;h=9995765b2db95042fbe1c6369e9d3c2114896400;hp=c98feb46e3bb2e09f5913c1ea31a018e02680075;hb=a0629a862bbac969ff858d8b4c3e78bd299aa721;hpb=2fbbdf3c4a4ffd2d90c102a37c7a02b5b6f80216 diff --git a/stream.h b/stream.h index c98feb4..9995765 100644 --- a/stream.h +++ b/stream.h @@ -15,16 +15,11 @@ 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 }; - Stream(const std::string &stream_id, size_t backlog_size, size_t prebuffering_bytes, Encoding encoding); + Stream(const std::string &stream_id, size_t backlog_size, size_t prebuffering_bytes, Encoding encoding, Encoding src_encoding); ~Stream(); // Serialization/deserialization. @@ -51,6 +46,9 @@ struct Stream { // be Metacube, for reflecting to another Cubemap instance). Encoding encoding; + // What encoding we expect the incoming data to be in (usually Metacube). + Encoding src_encoding; + // The stream data itself, stored in a circular buffer. // // We store our data in a file, so that we can send the data to the @@ -96,7 +94,7 @@ struct Stream { // 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; @@ -107,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 .