diff options
author | Amber Brown <hawkowl@atleastfornow.net> | 2018-09-14 03:11:25 +1000 |
---|---|---|
committer | Amber Brown <hawkowl@atleastfornow.net> | 2018-09-14 03:11:25 +1000 |
commit | 73884ebac59f091ac44cf81b7fb8854cdd4a3785 (patch) | |
tree | 63890fa9d273b69a19fa581e1dce83eb4ab55b38 /synapse/push/httppusher.py | |
parent | buffer? (diff) | |
parent | merge (#3576) (diff) | |
download | synapse-73884ebac59f091ac44cf81b7fb8854cdd4a3785.tar.xz |
Merge remote-tracking branch 'origin/develop' into hawkowl/timeouts-2
Diffstat (limited to 'synapse/push/httppusher.py')
-rw-r--r-- | synapse/push/httppusher.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/synapse/push/httppusher.py b/synapse/push/httppusher.py index 81e18bcf7d..48abd5e4d6 100644 --- a/synapse/push/httppusher.py +++ b/synapse/push/httppusher.py @@ -15,6 +15,8 @@ # limitations under the License. import logging +import six + from prometheus_client import Counter from twisted.internet import defer @@ -26,6 +28,9 @@ from synapse.util.metrics import Measure from . import push_rule_evaluator, push_tools +if six.PY3: + long = int + logger = logging.getLogger(__name__) http_push_processed_counter = Counter("synapse_http_httppusher_http_pushes_processed", "") @@ -96,7 +101,7 @@ class HttpPusher(object): @defer.inlineCallbacks def on_new_notifications(self, min_stream_ordering, max_stream_ordering): - self.max_stream_ordering = max(max_stream_ordering, self.max_stream_ordering) + self.max_stream_ordering = max(max_stream_ordering, self.max_stream_ordering or 0) yield self._process() @defer.inlineCallbacks |