Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Merge "Cleanup RpcRoutingStrategy definition"
[controller.git]
/
opendaylight
/
config
/
config-persister-feature-adapter
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
configpusherfeature
/
internal
/
ConfigPushingRunnable.java
diff --git
a/opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java
b/opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java
index 06c5c920f4ebb4da149e591c14d3c944cd4ccd5b..b0e64b84d2adf4433fd378b8fca5d35eb97c4e19 100644
(file)
--- a/
opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java
+++ b/
opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java
@@
-23,7
+23,7
@@
import org.slf4j.LoggerFactory;
import com.google.common.collect.LinkedHashMultimap;
public class ConfigPushingRunnable implements Runnable {
import com.google.common.collect.LinkedHashMultimap;
public class ConfigPushingRunnable implements Runnable {
- private static final Logger
logger
= LoggerFactory.getLogger(ConfigPushingRunnable.class);
+ private static final Logger
LOGGER
= LoggerFactory.getLogger(ConfigPushingRunnable.class);
private static final int POLL_TIME = 1;
private BlockingQueue<FeatureEvent> queue;
private FeatureConfigPusher configPusher;
private static final int POLL_TIME = 1;
private BlockingQueue<FeatureEvent> queue;
private FeatureConfigPusher configPusher;
@@
-49,14
+49,14
@@
public class ConfigPushingRunnable implements Runnable {
processFeatureEvent(event,toInstall);
}
} else if(toInstall.isEmpty()) {
processFeatureEvent(event,toInstall);
}
} else if(toInstall.isEmpty()) {
-
logger
.error("ConfigPushingRunnable - exiting");
+
LOGGER
.error("ConfigPushingRunnable - exiting");
return;
}
} catch (InterruptedException e) {
return;
}
} catch (InterruptedException e) {
-
logger
.error("ConfigPushingRunnable - interupted");
+
LOGGER
.error("ConfigPushingRunnable - interupted");
interuppted = true;
} catch (Exception e) {
interuppted = true;
} catch (Exception e) {
-
logger
.error("Exception while processing features {}", e);
+
LOGGER
.error("Exception while processing features {}", e);
}
}
}
}
}
}
@@
-73,7
+73,7
@@
public class ConfigPushingRunnable implements Runnable {
protected void logPushResult(LinkedHashMultimap<Feature,FeatureConfigSnapshotHolder> results) {
for(Feature f:results.keySet()) {
protected void logPushResult(LinkedHashMultimap<Feature,FeatureConfigSnapshotHolder> results) {
for(Feature f:results.keySet()) {
-
logger
.info("Pushed configs for feature {} {}",f,results.get(f));
+
LOGGER
.info("Pushed configs for feature {} {}",f,results.get(f));
}
}
}
}
}
}