diff options
| author | Jorik Schellekens <joriks@matrix.org> | 2019-07-17 16:53:08 +0100 |
|---|---|---|
| committer | Jorik Schellekens <joriks@matrix.org> | 2019-07-17 16:53:08 +0100 |
| commit | 33789fc83e6615cacbca8eef8be7e0981ffd13c8 (patch) | |
| tree | 0c8e6c4c6ea5f91118f929b243a23d4a5f0fa0d7 | |
| parent | Use better decorator names. (diff) | |
| download | synapse-github/joriks/opentracing_span_conscription.tar.xz | |
I wish python had a good type system. github/joriks/opentracing_span_conscription joriks/opentracing_span_conscription
| -rw-r--r-- | synapse/storage/devices.py | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/synapse/storage/devices.py b/synapse/storage/devices.py index 85e7ef3591..96828d6827 100644 --- a/synapse/storage/devices.py +++ b/synapse/storage/devices.py @@ -140,7 +140,17 @@ class DeviceWorkerStore(SQLBaseStore): break key = (update[0], update[1]) - query_map[key] = (max(query_map.get(key, 0), update[2]), update[3]) + logger.info("++++++++++++++++++++++++ update-0 %s", update[0]) + logger.info("++++++++++++++++++++++++ update-1 %s", update[1]) + logger.info("++++++++++++++++++++++++ update-2 %s", update[2]) + logger.info("++++++++++++++++++++++++ update-3 %s", update[3]) + logger.info( + "+++++++++++++++++++++++++++ %s", (query_map.get(key, 0), update[2]) + ) + query_map[key] = ( + max(query_map.get(key, (0, None))[0], update[2]), + update[3], + ) # If we didn't find any updates with a stream_id lower than the cutoff, it # means that there are more than limit updates all of which have the same |