@Test public void testOnHelloMessage1() { messageListener.onHelloMessage(hello); Mockito.verify(handshakeListener).onSwitchHelloMessage(hello.getXid(), hello.getVersion(), switchConnection); }
@Override public void onHelloMessage(HelloMessage arg0) { BigInteger datapathId = this.connectionRegistry.getDatapathID(this.switchConnection); if (datapathId == null) { handshakeListener.onSwitchHelloMessage(arg0.getXid(), arg0.getVersion(), this.switchConnection); } else { shimRelay.sendOpenFlowMessageToCore(coreConnector, arg0, arg0.getVersion(), arg0.getXid(), datapathId.longValue(), 0); } }
ShimMessageListener implements OpenflowProtocolListener, SystemNotificationsListener, ConnectionReadyListener { @Override public void onHelloMessage(HelloMessage arg0) { BigInteger datapathId = this.connectionRegistry.getDatapathID(this.switchConnection); if (datapathId == null) { handshakeListener.onSwitchHelloMessage(arg0.getXid(), arg0.getVersion(), this.switchConnection); } else { shimRelay.sendOpenFlowMessageToCore(coreConnector, arg0, arg0.getVersion(), arg0.getXid(), datapathId.longValue(), 0); } } }
ShimMessageListener implements OpenflowProtocolListener, SystemNotificationsListener, ConnectionReadyListener { @Override public void onHelloMessage(HelloMessage arg0) { BigInteger datapathId = this.connectionRegistry.getDatapathID(this.switchConnection); if (datapathId == null) { handshakeListener.onSwitchHelloMessage(arg0.getXid(), arg0.getVersion(), this.switchConnection); } else { shimRelay.sendOpenFlowMessageToCore(coreConnector, arg0, arg0.getVersion(), arg0.getXid(), datapathId.longValue(), 0); } } ShimMessageListener(ZeroMQBaseConnector connector, ConnectionAdapter switchConnection, ShimRelay _shimRelay,
            ShimSwitchConnectionHandlerImpl handler, NotificationPublishService _notificationProviderService); }
ShimMessageListener implements OpenflowProtocolListener, SystemNotificationsListener, ConnectionReadyListener { @Override public void onHelloMessage(HelloMessage arg0) { BigInteger datapathId = this.connectionRegistry.getDatapathID(this.switchConnection); if (datapathId == null) { handshakeListener.onSwitchHelloMessage(arg0.getXid(), arg0.getVersion(), this.switchConnection); } else { shimRelay.sendOpenFlowMessageToCore(coreConnector, arg0, arg0.getVersion(), arg0.getXid(), datapathId.longValue(), 0); } } ShimMessageListener(ZeroMQBaseConnector connector, ConnectionAdapter switchConnection, ShimRelay _shimRelay,
            ShimSwitchConnectionHandlerImpl handler, NotificationPublishService _notificationProviderService); void initSession(GetFeaturesOutput featuresOutput); void addMessageTranslator(final Class<? extends DataObject> messageType, final int version,
            final IMDMessageTranslator<OfHeader, List<DataObject>> translator); void registerConnectionAdaptersRegistry(ConnectionAdaptersRegistry connectionRegistry); void registerHandshakeListener(IHandshakeListener listener); @Override void onEchoRequestMessage(EchoRequestMessage arg0); @Override void onErrorMessage(ErrorMessage arg0); @Override void onExperimenterMessage(ExperimenterMessage arg0); @Override void onFlowRemovedMessage(FlowRemovedMessage arg0); @Override void onHelloMessage(HelloMessage arg0); @Override void onMultipartReplyMessage(MultipartReplyMessage arg0); @Override void onPacketInMessage(PacketInMessage arg0); @Override void onPortStatusMessage(PortStatusMessage arg0); @Override void onDisconnectEvent(DisconnectEvent arg0); @Override void onSwitchIdleEvent(SwitchIdleEvent arg0); @Override void onConnectionReady(); }
ShimMessageListener implements OpenflowProtocolListener, SystemNotificationsListener, ConnectionReadyListener { @Override public void onHelloMessage(HelloMessage arg0) { BigInteger datapathId = this.connectionRegistry.getDatapathID(this.switchConnection); if (datapathId == null) { handshakeListener.onSwitchHelloMessage(arg0.getXid(), arg0.getVersion(), this.switchConnection); } else { shimRelay.sendOpenFlowMessageToCore(coreConnector, arg0, arg0.getVersion(), arg0.getXid(), datapathId.longValue(), 0); } } ShimMessageListener(ZeroMQBaseConnector connector, ConnectionAdapter switchConnection, ShimRelay _shimRelay,
            ShimSwitchConnectionHandlerImpl handler, NotificationPublishService _notificationProviderService); void initSession(GetFeaturesOutput featuresOutput); void addMessageTranslator(final Class<? extends DataObject> messageType, final int version,
            final IMDMessageTranslator<OfHeader, List<DataObject>> translator); void registerConnectionAdaptersRegistry(ConnectionAdaptersRegistry connectionRegistry); void registerHandshakeListener(IHandshakeListener listener); @Override void onEchoRequestMessage(EchoRequestMessage arg0); @Override void onErrorMessage(ErrorMessage arg0); @Override void onExperimenterMessage(ExperimenterMessage arg0); @Override void onFlowRemovedMessage(FlowRemovedMessage arg0); @Override void onHelloMessage(HelloMessage arg0); @Override void onMultipartReplyMessage(MultipartReplyMessage arg0); @Override void onPacketInMessage(PacketInMessage arg0); @Override void onPortStatusMessage(PortStatusMessage arg0); @Override void onDisconnectEvent(DisconnectEvent arg0); @Override void onSwitchIdleEvent(SwitchIdleEvent arg0); @Override void onConnectionReady(); static final Long DEFAULT_XID; }