diff options
| author | Max Kellermann <max@duempel.org> | 2013-01-15 01:12:08 +0100 |
|---|---|---|
| committer | Max Kellermann <max@duempel.org> | 2013-01-15 10:59:28 +0100 |
| commit | 3e035279300d1ac238f2f063e5ca5f478923d7cb (patch) | |
| tree | ac49f4cbcf26317ac6836c1d77966287815eaf1f /src/ClientEvent.cxx | |
| parent | 4fa724461e558561402b05bd4eadf8c7b6874556 (diff) | |
| download | mpd-3e035279300d1ac238f2f063e5ca5f478923d7cb.tar.gz mpd-3e035279300d1ac238f2f063e5ca5f478923d7cb.tar.xz mpd-3e035279300d1ac238f2f063e5ca5f478923d7cb.zip | |
Client: move output buffer code to new class PeakBuffer
Diffstat (limited to '')
| -rw-r--r-- | src/ClientEvent.cxx | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/ClientEvent.cxx b/src/ClientEvent.cxx index 1e06ad48a..201709c76 100644 --- a/src/ClientEvent.cxx +++ b/src/ClientEvent.cxx @@ -46,7 +46,7 @@ client_out_event(G_GNUC_UNUSED GIOChannel *source, GIOCondition condition, g_timer_start(client->last_activity); - if (g_queue_is_empty(client->deferred_send)) { + if (client->output_buffer.IsEmpty()) { /* done sending deferred buffers exist: schedule read */ client->source_id = g_io_add_watch(client->channel, @@ -97,7 +97,7 @@ client_in_event(G_GNUC_UNUSED GIOChannel *source, GIOCondition condition, return false; } - if (!g_queue_is_empty(client->deferred_send)) { + if (!client->output_buffer.IsEmpty()) { /* deferred buffers exist: schedule write */ client->source_id = g_io_add_watch(client->channel, GIOCondition(G_IO_OUT|G_IO_ERR|G_IO_HUP), |