summary refs log tree commit diff
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2018-01-18 11:05:34 +0000
committerErik Johnston <erik@matrix.org>2018-01-18 11:05:34 +0000
commit17b54389feb3855a33406149a8a59f0327bb3ad1 (patch)
tree8d1b7040a273ac8d0601635fc6bc0657b4f2eece
parentMove definition of paused_producer to __init__ (diff)
downloadsynapse-17b54389feb3855a33406149a8a59f0327bb3ad1.tar.xz
Fix _notify_empty typo
-rw-r--r--synapse/util/file_consumer.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/util/file_consumer.py b/synapse/util/file_consumer.py
index 54c9da9573..479e480614 100644
--- a/synapse/util/file_consumer.py
+++ b/synapse/util/file_consumer.py
@@ -110,7 +110,7 @@ class BackgroundFileConsumer(object):
                     if self.bytes_queue.qsize() <= self._RESUME_ON_QUEUE_SIZE:
                         reactor.callFromThread(self._resume_paused_producer)
 
-                if self._notify_empty and self.bytes_queue.empty():
+                if self._notify_empty_deferred and self.bytes_queue.empty():
                     reactor.callFromThread(self._notify_empty)
 
                 bytes = self.bytes_queue.get()