int lsps = 1;
boolean pcError = false;
final LoggerContext lc = (LoggerContext) LoggerFactory.getILoggerFactory();
+ short ka = DEFAULT_KEEP_ALIVE;
+ short dt = DEFAULT_DEAD_TIMER;
getRootLogger(lc).setLevel(ch.qos.logback.classic.Level.INFO);
int argIdx = 0;
pcError = true;
} else if (args[argIdx].equals("--log-level")) {
getRootLogger(lc).setLevel(Level.toLevel(args[++argIdx], ch.qos.logback.classic.Level.INFO));
+ } else if (args[argIdx].equals("--keepalive") || args[argIdx].equals("-ka")) {
+ ka = Short.valueOf(args[++argIdx]);
+ } else if (args[argIdx].equals("--deadtimer") || args[argIdx].equals("-d")) {
+ dt = Short.valueOf(args[++argIdx]);
} else {
LOG.warn("WARNING: Unrecognized argument: {}", args[argIdx]);
}
argIdx++;
}
- createPCCs(lsps, pcError, pccCount, localAddress, remoteAddress);
+ createPCCs(lsps, pcError, pccCount, localAddress, remoteAddress, ka, dt);
}
public static void createPCCs(final int lspsPerPcc, final boolean pcerr, final int pccCount,
- final InetAddress localAddress, final List<InetAddress> remoteAddress) throws InterruptedException, ExecutionException {
+ final InetAddress localAddress, final List<InetAddress> remoteAddress, final short keepalive, final short deadtimer) throws InterruptedException, ExecutionException {
final SessionNegotiatorFactory<Message, PCEPSessionImpl, PCEPSessionListener> snf = new DefaultPCEPSessionNegotiatorFactory(
- new OpenBuilder().setKeepalive(DEFAULT_KEEP_ALIVE).setDeadTimer(DEFAULT_DEAD_TIMER).setSessionId((short) 0).build(), 0);
+ new OpenBuilder().setKeepalive(keepalive).setDeadTimer(deadtimer).setSessionId((short) 0).build(), 0);
final StatefulActivator activator07 = new StatefulActivator();
activator07.start(ServiceLoaderPCEPExtensionProviderContext.getSingletonInstance());
public void testSessionEstablishment() {
try {
org.opendaylight.protocol.pcep.testtool.Main.main(new String[]{"-a", "127.0.1.0:4189", "-ka", "10", "-d", "0", "--stateful", "--active"});
- Main.main(new String[] {"--local-address", "127.0.0.1", "--remote-address", "127.0.1.0", "--pcc", "2", "--lsp", "1", "--log-level", "DEBUG"});
+ Main.main(new String[] {"--local-address", "127.0.0.1", "--remote-address", "127.0.1.0", "--pcc", "2", "--lsp", "1", "--log-level", "DEBUG", "-ka", "10", "-d", "0",});
} catch (Exception e) {
Assert.fail(e.getMessage());
}