|
@@ -146,10 +146,15 @@ def runUntilCurrentTimer(func):
|
|
|
num_pending += 1
|
|
|
|
|
|
num_pending += len(reactor.threadCallQueue)
|
|
|
-
|
|
|
start = time.time() * 1000
|
|
|
ret = func(*args, **kwargs)
|
|
|
end = time.time() * 1000
|
|
|
+
|
|
|
+ # record the amount of wallclock time spent running pending calls.
|
|
|
+ # This is a proxy for the actual amount of time between reactor polls,
|
|
|
+ # since about 25% of time is actually spent running things triggered by
|
|
|
+ # I/O events, but that is harder to capture without rewriting half the
|
|
|
+ # reactor.
|
|
|
tick_time.inc_by(end - start)
|
|
|
pending_calls_metric.inc_by(num_pending)
|
|
|
|