From 28b338ed9bafc2017a635848e14a2a25b78d0016 Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Thu, 18 Jan 2018 11:04:41 +0000
Subject: [PATCH] Move definition of paused_producer to __init__

---
 synapse/util/file_consumer.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/synapse/util/file_consumer.py b/synapse/util/file_consumer.py
index 5284c7967..54c9da957 100644
--- a/synapse/util/file_consumer.py
+++ b/synapse/util/file_consumer.py
@@ -43,6 +43,10 @@ class BackgroundFileConsumer(object):
         # True if PushProducer, false if PullProducer
         self.streaming = False
 
+        # For PushProducers, indicates whether we've paused the producer and
+        # need to call resumeProducing before we get more data.
+        self.paused_producer = False
+
         # Queue of slices of bytes to be written. When producer calls
         # unregister a final None is sent.
         self.bytes_queue = Queue.Queue()
@@ -71,8 +75,6 @@ class BackgroundFileConsumer(object):
         if not streaming:
             self.producer.resumeProducing()
 
-        self.paused_producer = False
-
     def unregisterProducer(self):
         """Part of IProducer interface
         """