diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-07-03 14:02:27 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-07-03 14:02:27 +0200 |
commit | 55fe06979ceebe67553135b43aa47e70d931304b (patch) | |
tree | 16b10a744879cc1872d6c07624b59ae64469ddbf /common/listener.cpp | |
parent | 56fae95f49a1ca8ca614bd9f89b0ea5f872765e9 (diff) | |
parent | 288946f1694c2abe1d2c5800c87339d1e8780e4b (diff) | |
download | sink-55fe06979ceebe67553135b43aa47e70d931304b.tar.gz sink-55fe06979ceebe67553135b43aa47e70d931304b.zip |
Merge branch 'develop'
Diffstat (limited to 'common/listener.cpp')
-rw-r--r-- | common/listener.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/common/listener.cpp b/common/listener.cpp index 983e438..c9fd9d3 100644 --- a/common/listener.cpp +++ b/common/listener.cpp | |||
@@ -405,6 +405,7 @@ void Listener::updateClientsWithRevision(qint64 revision) | |||
405 | 405 | ||
406 | SinkTrace() << "Sending revision update for " << client.name << revision; | 406 | SinkTrace() << "Sending revision update for " << client.name << revision; |
407 | Sink::Commands::write(client.socket, ++m_messageId, Sink::Commands::RevisionUpdateCommand, m_fbb); | 407 | Sink::Commands::write(client.socket, ++m_messageId, Sink::Commands::RevisionUpdateCommand, m_fbb); |
408 | client.socket->flush(); | ||
408 | } | 409 | } |
409 | m_fbb.Clear(); | 410 | m_fbb.Clear(); |
410 | } | 411 | } |
@@ -420,6 +421,8 @@ void Listener::notify(const Sink::Notification ¬ification) | |||
420 | builder.add_identifier(idString); | 421 | builder.add_identifier(idString); |
421 | builder.add_message(messageString); | 422 | builder.add_message(messageString); |
422 | builder.add_entities(entities); | 423 | builder.add_entities(entities); |
424 | builder.add_progress(notification.progress); | ||
425 | builder.add_total(notification.total); | ||
423 | auto command = builder.Finish(); | 426 | auto command = builder.Finish(); |
424 | Sink::Commands::FinishNotificationBuffer(m_fbb, command); | 427 | Sink::Commands::FinishNotificationBuffer(m_fbb, command); |
425 | for (Client &client : m_connections) { | 428 | for (Client &client : m_connections) { |