X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=stream.h;h=7fabd193d1249016af37a821a5d67b3fce33ef91;hp=a57c6d88e7ff0955a68e0d02fceeb0910bd7491f;hb=40ed7df894c8645c132a5bea2bfb12a9be2b82ef;hpb=ae994771c0747d43bd1ed422224f4caacb95ca9f diff --git a/stream.h b/stream.h index a57c6d8..7fabd19 100644 --- a/stream.h +++ b/stream.h @@ -21,6 +21,9 @@ struct Stream { Stream(const StreamProto &serialized); StreamProto serialize(); + // Changes the backlog size, restructuring the data as needed. + void set_backlog_size(size_t new_size); + std::string stream_id; // The HTTP response header, plus the video stream header (if any). @@ -60,14 +63,15 @@ struct Stream { // in the list of clients to wake up when we do. void put_client_to_sleep(Client *client); - // Add more input data to the stream, and wake up all clients that are sleeping. + // Add more input data to the stream. You should probably call wake_up_all_clients() + // after that. void add_data(const char *data, ssize_t bytes); -private: - Stream(const Stream& other); - // We have more data, so mark all clients that are sleeping as ready to go. void wake_up_all_clients(); + +private: + Stream(const Stream& other); }; #endif // !defined(_STREAM_H)