diff options
| author | Max Kellermann <max@duempel.org> | 2014-01-04 17:42:03 +0100 |
|---|---|---|
| committer | Max Kellermann <max@duempel.org> | 2014-01-04 17:42:03 +0100 |
| commit | 68fcc195657fa31b47bc9504286a9b31feda92dc (patch) | |
| tree | 223c2ef36aebe471b5600b52ed56ea567d007934 /src/output/HttpdOutputPlugin.cxx | |
| parent | 8e4efd071e8eef033d0a68f6cf60f3910599a1a9 (diff) | |
| download | mpd-68fcc195657fa31b47bc9504286a9b31feda92dc.tar.gz mpd-68fcc195657fa31b47bc9504286a9b31feda92dc.tar.xz mpd-68fcc195657fa31b47bc9504286a9b31feda92dc.zip | |
output/httpd: move queue size check to HttpdClient::PushPage()
Don't let the server care for client problems.
Diffstat (limited to 'src/output/HttpdOutputPlugin.cxx')
| -rw-r--r-- | src/output/HttpdOutputPlugin.cxx | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/src/output/HttpdOutputPlugin.cxx b/src/output/HttpdOutputPlugin.cxx index 63131533a..ea75cb87d 100644 --- a/src/output/HttpdOutputPlugin.cxx +++ b/src/output/HttpdOutputPlugin.cxx @@ -401,16 +401,6 @@ HttpdOutput::BroadcastPage(Page *page) void HttpdOutput::BroadcastFromEncoder() { - mutex.lock(); - for (auto &client : clients) { - if (client.GetQueueSize() > 256 * 1024) { - FormatDebug(httpd_output_domain, - "client is too slow, flushing its queue"); - client.CancelQueue(); - } - } - mutex.unlock(); - Page *page; while ((page = ReadPage()) != nullptr) { BroadcastPage(page); |