X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=pcep%2Ftesttool%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fprotocol%2Fpcep%2Ftesttool%2FPCCMock.java;fp=pcep%2Ftesttool%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fprotocol%2Fpcep%2Ftesttool%2FPCCMock.java;h=800c692d6bf2c6edf3debff4a3bebbadf4d38323;hb=bc39003df163d3f2f1bcbae240ba3b7bd31aecda;hp=a7a97e438d9620fdccd98ff7245f6c8413b70191;hpb=c3bfa531c37f1e452e7ecf211862e69f4d7f1aa4;p=bgpcep.git diff --git a/pcep/testtool/src/test/java/org/opendaylight/protocol/pcep/testtool/PCCMock.java b/pcep/testtool/src/test/java/org/opendaylight/protocol/pcep/testtool/PCCMock.java index a7a97e438d..800c692d6b 100644 --- a/pcep/testtool/src/test/java/org/opendaylight/protocol/pcep/testtool/PCCMock.java +++ b/pcep/testtool/src/test/java/org/opendaylight/protocol/pcep/testtool/PCCMock.java @@ -7,22 +7,19 @@ */ package org.opendaylight.protocol.pcep.testtool; -import com.google.common.base.Preconditions; +import static com.google.common.base.Preconditions.checkArgument; + import com.google.common.net.HostAndPort; import java.net.InetSocketAddress; -import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutionException; import org.opendaylight.protocol.concepts.KeyMapping; -import org.opendaylight.protocol.pcep.PCEPCapability; -import org.opendaylight.protocol.pcep.PCEPSession; -import org.opendaylight.protocol.pcep.PCEPSessionNegotiatorFactory; -import org.opendaylight.protocol.pcep.PCEPSessionProposalFactory; import org.opendaylight.protocol.pcep.impl.BasePCEPSessionProposalFactory; import org.opendaylight.protocol.pcep.impl.DefaultPCEPSessionNegotiatorFactory; import org.opendaylight.protocol.pcep.pcc.mock.protocol.PCCDispatcherImpl; import org.opendaylight.protocol.pcep.spi.pojo.DefaultPCEPExtensionConsumerContext; import org.opendaylight.protocol.util.InetSocketAddressUtil; +import org.opendaylight.yangtools.yang.common.Uint8; public final class PCCMock { private PCCMock() { @@ -30,17 +27,15 @@ public final class PCCMock { } public static void main(final String[] args) throws InterruptedException, ExecutionException { - Preconditions.checkArgument(args.length > 0, "Host and port of server must be provided."); - final List caps = new ArrayList<>(); - final PCEPSessionProposalFactory proposal = new BasePCEPSessionProposalFactory((short) 120, (short) 30, caps); - final PCEPSessionNegotiatorFactory snf - = new DefaultPCEPSessionNegotiatorFactory(proposal, 0); - final HostAndPort serverHostAndPort = HostAndPort.fromString(args[0]); - final InetSocketAddress serverAddr = new InetSocketAddress(serverHostAndPort.getHost(), serverHostAndPort - .getPortOrDefault(12345)); - final InetSocketAddress clientAddr = InetSocketAddressUtil.getRandomLoopbackInetSocketAddress(0); + checkArgument(args.length > 0, "Host and port of server must be provided."); + final var proposal = new BasePCEPSessionProposalFactory(Uint8.valueOf(120), Uint8.valueOf(30), List.of()); + final var snf = new DefaultPCEPSessionNegotiatorFactory(proposal, 0); + final var serverHostAndPort = HostAndPort.fromString(args[0]); + final var serverAddr = new InetSocketAddress(serverHostAndPort.getHost(), + serverHostAndPort.getPortOrDefault(12345)); + final var clientAddr = InetSocketAddressUtil.getRandomLoopbackInetSocketAddress(0); - try (PCCDispatcherImpl pccDispatcher = new PCCDispatcherImpl( + try (var pccDispatcher = new PCCDispatcherImpl( new DefaultPCEPExtensionConsumerContext().getMessageHandlerRegistry())) { pccDispatcher.createClient(serverAddr, -1, SimpleSessionListener::new, snf, KeyMapping.of(), clientAddr) .get();