package org.opendaylight.protocol.bmp.mock;
-import ch.qos.logback.classic.LoggerContext;
-import com.google.common.base.Predicate;
-import com.google.common.collect.Iterables;
import com.google.common.net.InetAddresses;
import io.netty.channel.Channel;
import java.net.InetAddress;
import org.opendaylight.protocol.bmp.spi.registry.BmpExtensionProviderActivator;
import org.opendaylight.protocol.bmp.spi.registry.BmpExtensionProviderContext;
import org.opendaylight.protocol.bmp.spi.registry.SimpleBmpExtensionProviderContext;
+import org.opendaylight.protocol.util.LoggerUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private BmpMock() {
throw new UnsupportedOperationException();
}
+
public static void main(final String[] args) {
LOG.info("Starting BMP test tool.");
final BmpMockArguments arguments = BmpMockArguments.parseArguments(args);
- initiateLogger(arguments);
+ LoggerUtil.initiateLogger(arguments);
+
final BmpMockDispatcher dispatcher = initiateMock(arguments);
// now start the server / client
if (arguments.isOnPassiveMode()) {
}
}
- private static void initiateLogger(final BmpMockArguments arguments) {
- getRootLogger((LoggerContext) LoggerFactory.getILoggerFactory()).setLevel(arguments.getLogLevel());
- }
private static BmpMockDispatcher initiateMock(final BmpMockArguments arguments) {
final BmpExtensionProviderContext ctx = new SimpleBmpExtensionProviderContext();
final BmpExtensionProviderActivator bmpActivator = new BmpActivator(
- ServiceLoaderBGPExtensionProviderContext.getSingletonInstance());
+ ServiceLoaderBGPExtensionProviderContext.getSingletonInstance());
bmpActivator.start(ctx);
return new BmpMockDispatcher(ctx.getBmpMessageRegistry(),
- new BmpSessionFactory() {
- @Override
- public BmpSession getSession(final Channel channel,
- final BmpSessionListenerFactory sessionListenerFactory) {
- return new BmpMockSession(arguments.getPeersCount(), arguments.getPrePolicyRoutesCount(), arguments.getPostPolicyRoutesCount());
- }
- });
+ new BmpSessionFactory() {
+ @Override
+ public BmpSession getSession(final Channel channel,
+ final BmpSessionListenerFactory sessionListenerFactory) {
+ return new BmpMockSession(arguments.getPeersCount(), arguments.getPrePolicyRoutesCount(), arguments.getPostPolicyRoutesCount());
+ }
+ });
}
private static void deployClients(final BmpMockDispatcher dispatcher, final BmpMockArguments arguments) {
currentLocal = InetAddresses.increment(currentLocal);
}
}
-
- private static ch.qos.logback.classic.Logger getRootLogger(final LoggerContext lc) {
- return Iterables.find(lc.getLoggerList(), new Predicate<Logger>() {
- @Override
- public boolean apply(final Logger input) {
- return (input != null) ? input.getName().equals(Logger.ROOT_LOGGER_NAME) : false;
- }
- });
- }
}