diff options
author | Erik Johnston <erik@matrix.org> | 2018-09-14 18:25:55 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2018-09-14 18:25:55 +0100 |
commit | b5eef203f4dbfd020ef56677581d361aacda4c1a (patch) | |
tree | 91aacdf174700cc42a764631195952b62247ddd0 /synapse/push/httppusher.py | |
parent | Merge branch 'develop' of github.com:matrix-org/synapse into matrix-org-hotfixes (diff) | |
parent | don't filter membership events based on history visibility (#3874) (diff) | |
download | synapse-b5eef203f4dbfd020ef56677581d361aacda4c1a.tar.xz |
Merge branch 'develop' of github.com:matrix-org/synapse into matrix-org-hotfixes
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 a4e8cafdc9..ab5d76e032 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 |