maxmustermann/synapse
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

track this a bit better

Browse source
This commit is contained in:
Amber H. Brown 2019-06-24 08:19:30 +10:00
parent 1241094993
commit ca3eca49d8
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
synapse/federation/sender/transaction_manager.py
View file

@ -42,7 +42,7 @@ class TransactionManager(object):
# HACK to get unique tx id
self._next_txn_id = int(self.clock.time_msec())
self.limiter = defer.DeferredSemaphore(10)
self.limiter = defer.DeferredSemaphore(25)
LaterGauge(
"synapse_federation_transaction_client_concurrency",
@ -50,6 +50,12 @@ class TransactionManager(object):
[],
lambda: self.limiter.limit - self.limiter.tokens,
)
LaterGauge(
"synapse_federation_transaction_client_concurrency_queue",
"",
[],
lambda: len(self.limiter.waiting),
)
@measure_func("_send_new_transaction")
@defer.inlineCallbacks