void add_client_from_serialized(const ClientProto &client);
void add_stream(const std::string &stream_id, size_t bytes_received);
void add_stream_from_serialized(const StreamProto &stream);
+ void set_backlog_size(const std::string &stream_id, size_t new_size);
private:
// Mutex protecting queued_data only. Note that if you want to hold both this
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)