Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Bug 9165: Log config subsystem readiness as INFO
[controller.git]
/
opendaylight
/
config
/
config-persister-impl
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
config
/
persist
/
impl
/
ConfigPusherImpl.java
diff --git
a/opendaylight/config/config-persister-impl/src/main/java/org/opendaylight/controller/config/persist/impl/ConfigPusherImpl.java
b/opendaylight/config/config-persister-impl/src/main/java/org/opendaylight/controller/config/persist/impl/ConfigPusherImpl.java
index ae4fb09ddc232f9411deda1278632031996a5401..08c3330a2731a3d0cb2d9ffd1abdf001359aed71 100644
(file)
--- a/
opendaylight/config/config-persister-impl/src/main/java/org/opendaylight/controller/config/persist/impl/ConfigPusherImpl.java
+++ b/
opendaylight/config/config-persister-impl/src/main/java/org/opendaylight/controller/config/persist/impl/ConfigPusherImpl.java
@@
-9,7
+9,6
@@
package org.opendaylight.controller.config.persist.impl;
import static com.google.common.base.Preconditions.checkNotNull;
package org.opendaylight.controller.config.persist.impl;
import static com.google.common.base.Preconditions.checkNotNull;
-import com.google.common.base.Function;
import com.google.common.base.Stopwatch;
import com.google.common.collect.Collections2;
import java.io.IOException;
import com.google.common.base.Stopwatch;
import com.google.common.collect.Collections2;
import java.io.IOException;
@@
-23,7
+22,6
@@
import java.util.SortedSet;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
-import javax.annotation.Nonnull;
import javax.annotation.concurrent.Immutable;
import javax.management.MBeanServerConnection;
import org.opendaylight.controller.config.api.ConflictingVersionException;
import javax.annotation.concurrent.Immutable;
import javax.management.MBeanServerConnection;
import org.opendaylight.controller.config.api.ConflictingVersionException;
@@
-136,7
+134,7
@@
public class ConfigPusherImpl implements ConfigPusher {
result.put(configSnapshotHolder, pushResult);
}
}
result.put(configSnapshotHolder, pushResult);
}
}
- LOG.
debug
("All configuration snapshots have been pushed successfully.");
+ LOG.
info
("All configuration snapshots have been pushed successfully.");
return result;
}
return result;
}
@@
-212,12
+210,7
@@
public class ConfigPusherImpl implements ConfigPusher {
}
static Set<String> transformCapabilities(final Set<Capability> currentCapabilities) {
}
static Set<String> transformCapabilities(final Set<Capability> currentCapabilities) {
- return new HashSet<>(Collections2.transform(currentCapabilities, new Function<Capability, String>() {
- @Override
- public String apply(@Nonnull final Capability input) {
- return input.getCapabilityUri();
- }
- }));
+ return new HashSet<>(Collections2.transform(currentCapabilities, Capability::getCapabilityUri));
}
static class ConfigPusherException extends Exception {
}
static class ConfigPusherException extends Exception {