X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=server.cpp;h=0cbc453674b75722b19e5f2c6979142cd7551042;hb=9bb20b7dd0bcea9de1daf4cac29263d74924ce5a;hp=266d41809765075caaa750be0fd06809d707481d;hpb=ae994771c0747d43bd1ed422224f4caacb95ca9f;p=cubemap

diff --git a/server.cpp b/server.cpp
index 266d418..0cbc453 100644
--- a/server.cpp
+++ b/server.cpp
@@ -7,7 +7,6 @@
 #include <sys/sendfile.h>
 #include <sys/socket.h>
 #include <sys/types.h>
-#include <time.h>
 #include <unistd.h>
 #include <algorithm>
 #include <map>
@@ -194,6 +193,13 @@ void Server::add_stream_from_serialized(const StreamProto &stream)
 	streams.insert(make_pair(stream.stream_id(), new Stream(stream)));
 }
 	
+void Server::set_backlog_size(const std::string &stream_id, size_t new_size)
+{
+	MutexLock lock(&mutex);
+	assert(streams.count(stream_id) != 0);
+	streams[stream_id]->set_backlog_size(new_size);
+}
+	
 void Server::set_header(const string &stream_id, const string &header)
 {
 	MutexLock lock(&mutex);
@@ -527,6 +533,7 @@ void Server::process_queued_data()
 	     ++queued_it) {
 		Stream *stream = find_stream(queued_it->first);
 		stream->add_data(queued_it->second.data(), queued_it->second.size());
+		stream->wake_up_all_clients();
 	}
 	queued_data.clear();
 }