* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.openflowjava.protocol.it.integration;
+import com.google.common.util.concurrent.SettableFuture;
import java.net.InetAddress;
-import java.util.Arrays;
import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
-
import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter;
+import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter.SystemListener;
import org.opendaylight.openflowjava.protocol.api.connection.ConnectionReadyListener;
import org.opendaylight.openflowjava.protocol.api.connection.SwitchConnectionHandler;
import org.opendaylight.openflowjava.protocol.impl.core.SwitchConnectionProviderImpl;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.DisconnectEvent;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.SslConnectionError;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.SwitchIdleEvent;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.SystemNotificationsListener;
import org.opendaylight.yangtools.yang.common.RpcError;
import org.opendaylight.yangtools.yang.common.RpcResult;
+import org.opendaylight.yangtools.yang.common.Uint32;
+import org.opendaylight.yangtools.yang.common.Uint8;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import com.google.common.util.concurrent.SettableFuture;
-
/**
- * @author michal.polkorab
+ * Mock plugin.
*
+ * @author michal.polkorab
*/
-public class MockPlugin implements OpenflowProtocolListener, SwitchConnectionHandler,
- SystemNotificationsListener, ConnectionReadyListener {
-
+public class MockPlugin implements OpenflowProtocolListener, SwitchConnectionHandler, SystemListener,
+ ConnectionReadyListener {
protected static final Logger LOGGER = LoggerFactory.getLogger(MockPlugin.class);
- protected volatile ConnectionAdapter adapter;
- private SettableFuture<Void> finishedFuture;
+
+ private final SettableFuture<Void> finishedFuture;
+ private final ExecutorService executorService;
+
private int idleCounter = 0;
- /** Creates MockPlugin */
- public MockPlugin() {
+ protected volatile ConnectionAdapter adapter;
+
+ public MockPlugin(final ExecutorService executorService) {
LOGGER.trace("Creating MockPlugin");
finishedFuture = SettableFuture.create();
+ this.executorService = executorService;
LOGGER.debug("mockPlugin: {}", System.identityHashCode(this));
}
@Override
- public void onSwitchConnected(ConnectionAdapter connection) {
+ public void onSwitchConnected(final ConnectionAdapter connection) {
LOGGER.debug("onSwitchConnected: {}", connection);
- this.adapter = connection;
+ adapter = connection;
connection.setMessageListener(this);
connection.setSystemListener(this);
connection.setConnectionReadyListener(this);
+ connection.setExecutorService(executorService);
}
@Override
- public boolean accept(InetAddress switchAddress) {
+ public boolean accept(final InetAddress switchAddress) {
LOGGER.debug("MockPlugin.accept(): {}", switchAddress.toString());
-
return true;
}
+ @Override
+ public void onDisconnect(final DisconnectEvent disconnect) {
+ LOGGER.debug("disconnection occured: {}", disconnect.getInfo());
+ }
+
+ @Override
+ public void onSslConnectionError(final SslConnectionError sslConnectionError) {
+ LOGGER.debug("Ssl error occured: {}", sslConnectionError.getInfo());
+ }
+
+ @Override
+ public void onSwitchIdle(final SwitchIdleEvent switchIdle) {
+ LOGGER.debug("MockPlugin.onSwitchIdleEvent() switch status: {}", switchIdle.getInfo());
+ idleCounter++;
+ }
+
@Override
public void onEchoRequestMessage(final EchoRequestMessage notification) {
LOGGER.debug("MockPlugin.onEchoRequestMessage() adapter: {}", adapter);
- new Thread(new Runnable() {
- @Override
- public void run() {
- LOGGER.debug("MockPlugin.onEchoRequestMessage().run() started adapter: {}", adapter);
- EchoReplyInputBuilder replyBuilder = new EchoReplyInputBuilder();
- replyBuilder.setVersion((short) 4);
- replyBuilder.setXid(notification.getXid());
- EchoReplyInput echoReplyInput = replyBuilder.build();
- adapter.echoReply(echoReplyInput);
- LOGGER.debug("adapter.EchoReply(Input) sent : ", echoReplyInput.toString());
- LOGGER.debug("MockPlugin.onEchoRequestMessage().run() finished adapter: {}", adapter);
- }
+ new Thread(() -> {
+ LOGGER.debug("MockPlugin.onEchoRequestMessage().run() started adapter: {}", adapter);
+ EchoReplyInputBuilder replyBuilder = new EchoReplyInputBuilder();
+ replyBuilder.setVersion(Uint8.valueOf(4));
+ replyBuilder.setXid(notification.getXid());
+ EchoReplyInput echoReplyInput = replyBuilder.build();
+ adapter.echoReply(echoReplyInput);
+ LOGGER.debug("adapter.EchoReply(Input) sent : ", echoReplyInput.toString());
+ LOGGER.debug("MockPlugin.onEchoRequestMessage().run() finished adapter: {}", adapter);
}).start();
}
@Override
- public void onErrorMessage(ErrorMessage notification) {
+ public void onErrorMessage(final ErrorMessage notification) {
LOGGER.debug("Error message received");
-
}
@Override
- public void onExperimenterMessage(ExperimenterMessage notification) {
+ public void onExperimenterMessage(final ExperimenterMessage notification) {
LOGGER.debug("Experimenter message received");
-
}
@Override
- public void onFlowRemovedMessage(FlowRemovedMessage notification) {
+ public void onFlowRemovedMessage(final FlowRemovedMessage notification) {
LOGGER.debug("FlowRemoved message received");
-
}
@Override
- public void onHelloMessage(HelloMessage notification) {
- new Thread(new Runnable() {
- @Override
- public void run() {
- LOGGER.debug("MockPlugin.onHelloMessage().run() Hello message received");
- HelloInputBuilder hib = new HelloInputBuilder();
- hib.setVersion((short) 4);
- hib.setXid(2L);
- HelloInput hi = hib.build();
- adapter.hello(hi);
- LOGGER.debug("hello msg sent");
- new Thread(new Runnable() {
- @Override
- public void run() {
- getSwitchFeatures();
- }
- }).start();
- }
+ public void onHelloMessage(final HelloMessage notification) {
+ new Thread(() -> {
+ LOGGER.debug("MockPlugin.onHelloMessage().run() Hello message received");
+ HelloInputBuilder hib = new HelloInputBuilder();
+ hib.setVersion(Uint8.valueOf(4));
+ hib.setXid(Uint32.TWO);
+ HelloInput hi = hib.build();
+ adapter.hello(hi);
+ LOGGER.debug("hello msg sent");
+ new Thread(this::getSwitchFeatures).start();
}).start();
-
}
protected void getSwitchFeatures() {
GetFeaturesInputBuilder featuresBuilder = new GetFeaturesInputBuilder();
- featuresBuilder.setVersion((short) 4);
- featuresBuilder.setXid(3L);
+ featuresBuilder.setVersion(Uint8.valueOf(4));
+ featuresBuilder.setXid(Uint32.valueOf(3));
GetFeaturesInput featuresInput = featuresBuilder.build();
try {
LOGGER.debug("Requesting features ");
RpcResult<GetFeaturesOutput> rpcResult = adapter.getFeatures(
featuresInput).get(2500, TimeUnit.MILLISECONDS);
if (rpcResult.isSuccessful()) {
- byte[] byteArray = rpcResult.getResult().getDatapathId()
- .toByteArray();
- LOGGER.debug("DatapathId: {}", Arrays.toString(byteArray));
+ LOGGER.debug("DatapathId: {}", rpcResult.getResult().getDatapathId());
} else {
RpcError rpcError = rpcResult.getErrors().iterator().next();
LOGGER.warn("rpcResult failed", rpcError.getCause());
}
}
- protected void shutdown() {
- try {
- LOGGER.debug("MockPlugin.shutdown() sleeping 5... : {}", System.identityHashCode(this));
- Thread.sleep(500);
- if (adapter != null) {
- Future<Boolean> disconnect = adapter.disconnect();
- disconnect.get();
- LOGGER.debug("MockPlugin.shutdown() Disconnected");
- }
- } catch (Exception e) {
- LOGGER.error("MockPlugin.shutdown() exception caught: ", e.getMessage(), e);
+ protected void shutdown() throws InterruptedException, ExecutionException {
+ LOGGER.debug("MockPlugin.shutdown() sleeping 5... : {}", System.identityHashCode(this));
+ Thread.sleep(500);
+ if (adapter != null) {
+ Future<Boolean> disconnect = adapter.disconnect();
+ disconnect.get();
+ LOGGER.debug("MockPlugin.shutdown() Disconnected");
}
+
finishedFuture.set(null);
}
@Override
- public void onMultipartReplyMessage(MultipartReplyMessage notification) {
+ public void onMultipartReplyMessage(final MultipartReplyMessage notification) {
LOGGER.debug("MultipartReply message received");
-
}
@Override
- public void onPacketInMessage(PacketInMessage notification) {
+ public void onPacketInMessage(final PacketInMessage notification) {
LOGGER.debug("PacketIn message received");
LOGGER.debug("BufferId: {}", notification.getBufferId());
LOGGER.debug("TotalLength: {}", notification.getTotalLen());
}
@Override
- public void onPortStatusMessage(PortStatusMessage notification) {
+ public void onPortStatusMessage(final PortStatusMessage notification) {
LOGGER.debug("MockPlugin.onPortStatusMessage() message received");
-
- }
-
- @Override
- public void onDisconnectEvent(DisconnectEvent notification) {
- LOGGER.debug("disconnection occured: {}", notification.getInfo());
}
- /**
- * @return finishedFuture object
- */
public SettableFuture<Void> getFinishedFuture() {
return finishedFuture;
}
- @Override
- public void onSwitchIdleEvent(SwitchIdleEvent notification) {
- LOGGER.debug("MockPlugin.onSwitchIdleEvent() switch status: {}", notification.getInfo());
- idleCounter ++;
- }
-
/**
- * @return number of occured idleEvents
+ * Returns number of occurred idleEvents.
*/
public int getIdleCounter() {
return idleCounter;
}
/**
- * Initiates connection to device
- * @param switchConnectionProvider
- * @param host - host IP
- * @param port - port number
+ * Initiates connection to device.
+ *
+ * @param switchConnectionProvider the SwitchConnectionProviderImpl
+ * @param host - host IP
+ * @param port - port number
*/
- public void initiateConnection(SwitchConnectionProviderImpl switchConnectionProvider, String host, int port) {
+ public void initiateConnection(final SwitchConnectionProviderImpl switchConnectionProvider, final String host,
+ final int port) {
LOGGER.trace("MockPlugin().initiateConnection()");
switchConnectionProvider.initiateConnection(host, port);
}
Code Review / openflowplugin.git / blobdiff