Repository: aurora Updated Branches: refs/heads/master c245b9b76 -> d6c1d7f79
Expose timing stats on PendingTaskProcessor runs Bugs closed: AURORA-1857 Reviewed at https://reviews.apache.org/r/54992/ Project: http://git-wip-us.apache.org/repos/asf/aurora/repo Commit: http://git-wip-us.apache.org/repos/asf/aurora/commit/d6c1d7f7 Tree: http://git-wip-us.apache.org/repos/asf/aurora/tree/d6c1d7f7 Diff: http://git-wip-us.apache.org/repos/asf/aurora/diff/d6c1d7f7 Branch: refs/heads/master Commit: d6c1d7f7999ef54ec51798ad3768db8cb044e591 Parents: c245b9b Author: Mehrdad Nurolahzade <[email protected]> Authored: Tue Dec 27 12:49:58 2016 +0100 Committer: Stephan Erb <[email protected]> Committed: Tue Dec 27 12:49:58 2016 +0100 ---------------------------------------------------------------------- .../apache/aurora/scheduler/preemptor/PendingTaskProcessor.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/aurora/blob/d6c1d7f7/src/main/java/org/apache/aurora/scheduler/preemptor/PendingTaskProcessor.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/aurora/scheduler/preemptor/PendingTaskProcessor.java b/src/main/java/org/apache/aurora/scheduler/preemptor/PendingTaskProcessor.java index 5687bc5..f59f3fd 100644 --- a/src/main/java/org/apache/aurora/scheduler/preemptor/PendingTaskProcessor.java +++ b/src/main/java/org/apache/aurora/scheduler/preemptor/PendingTaskProcessor.java @@ -43,6 +43,7 @@ import com.google.common.collect.Multimap; import com.google.common.collect.Multiset; import com.google.common.collect.Sets; +import org.apache.aurora.common.inject.TimedInterceptor.Timed; import org.apache.aurora.common.quantity.Amount; import org.apache.aurora.common.quantity.Time; import org.apache.aurora.common.util.Clock; @@ -113,6 +114,7 @@ public class PendingTaskProcessor implements Runnable { this.clock = requireNonNull(clock); } + @Timed("pending_task_processor_run") @Override public void run() { metrics.recordTaskProcessorRun();
