2 * Copyright (c) 2014, 2015 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.controller.config.manager.impl;
11 import java.util.Deque;
12 import java.util.LinkedList;
13 import java.util.concurrent.TimeUnit;
14 import javax.annotation.Nullable;
15 import javax.annotation.concurrent.GuardedBy;
16 import org.opendaylight.controller.config.api.ModuleIdentifier;
17 import org.slf4j.Logger;
18 import org.slf4j.LoggerFactory;
20 public class DeadlockMonitor implements AutoCloseable {
21 private static final Logger LOG = LoggerFactory.getLogger(DeadlockMonitor.class);
23 private static final long WARN_AFTER_MILLIS = 5000;
25 private final TransactionIdentifier transactionIdentifier;
26 private final DeadlockMonitorRunnable thread;
28 private final Deque<ModuleIdentifierWithNanos> moduleIdentifierWithNanosStack = new LinkedList<>();
30 private ModuleIdentifierWithNanos top = ModuleIdentifierWithNanos.empty;
32 public DeadlockMonitor(final TransactionIdentifier transactionIdentifier) {
33 this.transactionIdentifier = transactionIdentifier;
34 thread = new DeadlockMonitorRunnable();
38 public synchronized void setCurrentlyInstantiatedModule(final ModuleIdentifier currentlyInstantiatedModule) {
40 boolean popping = currentlyInstantiatedModule == null;
42 moduleIdentifierWithNanosStack.pop();
43 if (moduleIdentifierWithNanosStack.isEmpty()) {
44 top = ModuleIdentifierWithNanos.empty;
46 top = moduleIdentifierWithNanosStack.peekLast();
49 ModuleIdentifierWithNanos current = new ModuleIdentifierWithNanos(currentlyInstantiatedModule);
50 moduleIdentifierWithNanosStack.push(current);
53 LOG.trace("setCurrentlyInstantiatedModule {}, top {}", currentlyInstantiatedModule, top);
56 public boolean isAlive() {
57 return thread.isAlive();
66 public String toString() {
67 return "DeadlockMonitor{" + transactionIdentifier + '}';
70 private class DeadlockMonitorRunnable extends Thread {
72 private DeadlockMonitorRunnable() {
73 super(DeadlockMonitor.this.toString());
79 ModuleIdentifierWithNanos old = new ModuleIdentifierWithNanos();
80 while (!this.isInterrupted()) {
81 ModuleIdentifierWithNanos copy;
83 copy = new ModuleIdentifierWithNanos(DeadlockMonitor.this.top);
86 if (old.moduleIdentifier == null || !old.equals(copy)) {
90 // is the getInstance() running longer than WARN_AFTER_MILLIS ?
91 long runningTime = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - copy.nanoTime);
92 if (runningTime > WARN_AFTER_MILLIS) {
93 LOG.warn("{} did not finish after {} ms", copy.moduleIdentifier, runningTime);
97 sleep(WARN_AFTER_MILLIS);
98 } catch (final InterruptedException e) {
102 LOG.trace("Exiting {}", this);
106 public String toString() {
107 return "DeadLockMonitorRunnable{" + transactionIdentifier + "}";
111 private static class ModuleIdentifierWithNanos {
112 private static ModuleIdentifierWithNanos empty = new ModuleIdentifierWithNanos();
114 private final ModuleIdentifier moduleIdentifier;
116 private final long nanoTime;
118 private ModuleIdentifierWithNanos() {
119 this((ModuleIdentifier)null);
122 private ModuleIdentifierWithNanos(final ModuleIdentifier moduleIdentifier) {
123 this.moduleIdentifier = moduleIdentifier;
124 nanoTime = System.nanoTime();
127 private ModuleIdentifierWithNanos(final ModuleIdentifierWithNanos copy) {
128 moduleIdentifier = copy.moduleIdentifier;
129 nanoTime = copy.nanoTime;
133 public boolean equals(final Object o) {
137 if (o == null || getClass() != o.getClass()) {
141 ModuleIdentifierWithNanos that = (ModuleIdentifierWithNanos) o;
143 if (nanoTime != that.nanoTime) {
146 if (moduleIdentifier != null ? !moduleIdentifier.equals(that.moduleIdentifier) : that.moduleIdentifier != null) {
154 public int hashCode() {
155 int result = moduleIdentifier != null ? moduleIdentifier.hashCode() : 0;
156 result = 31 * result + (int) (nanoTime ^ (nanoTime >>> 32));
161 public String toString() {
162 return "ModuleIdentifierWithNanos{" +