本文整理汇总了Java中net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState类的典型用法代码示例。如果您正苦于以下问题:Java WaitAppHandshakeState类的具体用法?Java WaitAppHandshakeState怎么用?Java WaitAppHandshakeState使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
WaitAppHandshakeState类属于net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler包,在下文中一共展示了WaitAppHandshakeState类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: moveToWaitInitialRole
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
@Override
@Test
public void moveToWaitInitialRole() throws Exception {
moveToWaitAppHandshakeState();
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(WaitAppHandshakeState.class));
reset(sw);
expect(sw.getAttribute(IOFSwitchBackend.SWITCH_SUPPORTS_NX_ROLE)).andReturn(true).anyTimes();
replay(sw);
reset(roleManager);
expect(roleManager.getOFControllerRole()).andReturn(OFControllerRole.ROLE_MASTER).anyTimes();
roleManager.notifyControllerConnectionUpdate();
expectLastCall().once();
replay(roleManager);
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
state.enterNextPlugin();
// Expect wait initial role's enterState message to be written
OFMessage msg = connection.retrieveMessage();
assertThat(msg, CoreMatchers.instanceOf(OFRoleRequest.class));
verifyUniqueXids(msg);
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(OFSwitchHandshakeHandler.WaitInitialRoleState.class));
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:27,代码来源:OFSwitchHandshakeHandlerVer13Test.java
示例2: failedAppHandshake
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
/**
* Tests a situation where a plugin returns a DISCONNECT result. This means
* we should disconnect the connection and the state should not change.
*
* @throws Exception
*/
@Test
public void failedAppHandshake() throws Exception {
moveToWaitAppHandshakeState();
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(WaitAppHandshakeState.class));
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
assertThat(state.getCurrentPlugin(), CoreMatchers.<OFSwitchAppHandshakePlugin>equalTo(handshakePlugin));
PluginResult result = new PluginResult(PluginResultType.DISCONNECT);
handshakePlugin.exitPlugin(result);
assertThat(connection.isConnected(), equalTo(false));
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:22,代码来源:OFSwitchHandlerTestBase.java
示例3: moveToWaitInitialRole
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
@Override
@Test
public void moveToWaitInitialRole()
throws Exception {
moveToWaitAppHandshakeState();
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(WaitAppHandshakeState.class));
reset(sw);
expect(sw.getAttribute(IOFSwitchBackend.SWITCH_SUPPORTS_NX_ROLE)).andReturn(true).anyTimes();
replay(sw);
reset(roleManager);
expect(roleManager.getOFControllerRole()).andReturn(OFControllerRole.ROLE_MASTER).anyTimes();
replay(roleManager);
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
PluginResult result = new PluginResult(PluginResultType.CONTINUE);
state.exitPlugin(result);
assertThat(connection.retrieveMessage(), instanceOf(getRoleRequestClass()));
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(OFSwitchHandshakeHandler.WaitInitialRoleState.class));
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:25,代码来源:OFSwitchHandshakeHandlerVer10Test.java
示例4: failedAppHandshake
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
/**
* Tests a situation where a plugin returns a DISCONNECT result. This means
* we should disconnect the connection and the state should not change.
*
* @throws Exception
*/
@Test
public void failedAppHandshake() throws Exception {
moveToWaitAppHandshakeState();
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(WaitAppHandshakeState.class));
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
assertThat(state.getCurrentPlugin(), CoreMatchers.<OFSwitchAppHandshakePlugin>equalTo(handshakePlugin));
PluginResult result = new PluginResult(PluginResultType.DISCONNECT);
handshakePlugin.exitPlugin(result);
assertThat(connection.isConnected(), equalTo(false));
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:22,代码来源:OFSwitchHandlerTestBase.java
示例5: moveToWaitInitialRole
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
@Override
@Test
public void moveToWaitInitialRole() throws Exception {
moveToWaitAppHandshakeState();
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(WaitAppHandshakeState.class));
reset(sw);
expect(sw.getAttribute(IOFSwitchBackend.SWITCH_SUPPORTS_NX_ROLE)).andReturn(true).anyTimes();
replay(sw);
reset(roleManager);
expect(roleManager.getOFControllerRole(null)).andReturn(OFControllerRole.ROLE_MASTER).anyTimes();
roleManager.notifyControllerConnectionUpdate();
expectLastCall().once();
replay(roleManager);
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
state.enterNextPlugin();
// Expect wait initial role's enterState message to be written
OFMessage msg = connection.retrieveMessage();
assertThat(msg, CoreMatchers.instanceOf(OFRoleRequest.class));
verifyUniqueXids(msg);
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(OFSwitchHandshakeHandler.WaitInitialRoleState.class));
}
开发者ID:DaiDongLiang,项目名称:DSC,代码行数:27,代码来源:OFSwitchHandshakeHandlerVer13Test.java
示例6: moveToWaitInitialRole
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
@Override
@Test
public void moveToWaitInitialRole()
throws Exception {
moveToWaitAppHandshakeState();
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(WaitAppHandshakeState.class));
reset(sw);
expect(sw.getAttribute(IOFSwitchBackend.SWITCH_SUPPORTS_NX_ROLE)).andReturn(true).anyTimes();
replay(sw);
reset(roleManager);
expect(roleManager.getOFControllerRole(null)).andReturn(OFControllerRole.ROLE_MASTER).anyTimes();
replay(roleManager);
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
PluginResult result = new PluginResult(PluginResultType.CONTINUE);
state.exitPlugin(result);
assertThat(connection.retrieveMessage(), instanceOf(getRoleRequestClass()));
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(OFSwitchHandshakeHandler.WaitInitialRoleState.class));
}
开发者ID:DaiDongLiang,项目名称:DSC,代码行数:25,代码来源:OFSwitchHandshakeHandlerVer10Test.java
示例7: moveToWaitAppHandshakeState
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
@Test
@Override
public void moveToWaitAppHandshakeState() throws Exception {
moveToWaitTableFeaturesReplyState();
handleTableFeatures(true);
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(WaitAppHandshakeState.class));
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:10,代码来源:OFSwitchHandshakeHandlerVer13Test.java
示例8: moveQuarantine
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
/**
* Tests a situation where a switch returns a QUARANTINE result. This means
* we should move the handshake handler to a quarantine state and also
* quarantine the switch in the controller.
*
* @throws Exception
*/
@Test
public void moveQuarantine() throws Exception {
moveToWaitAppHandshakeState();
reset(switchManager);
switchManager.switchStatusChanged(sw, SwitchStatus.HANDSHAKE, SwitchStatus.QUARANTINED);
expectLastCall().once();
replay(switchManager);
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(WaitAppHandshakeState.class));
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
assertThat(state.getCurrentPlugin(), CoreMatchers.<OFSwitchAppHandshakePlugin>equalTo(handshakePlugin));
reset(sw);
expect(sw.getStatus()).andReturn(SwitchStatus.HANDSHAKE);
sw.setStatus(SwitchStatus.QUARANTINED);
expectLastCall().once();
replay(sw);
PluginResult result = new PluginResult(PluginResultType.QUARANTINE, "test quarantine");
handshakePlugin.exitPlugin(result);
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(QuarantineState.class));
verify(switchManager);
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:34,代码来源:OFSwitchHandlerTestBase.java
示例9: testSwitchDriverSubHandshake
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
/**
* Move the channel from scratch to WAIT_INITIAL_ROLE state via
* WAIT_SWITCH_DRIVER_SUB_HANDSHAKE
* Does extensive testing for the WAIT_SWITCH_DRIVER_SUB_HANDSHAKE state
*
*/
@Test
public void testSwitchDriverSubHandshake()
throws Exception {
moveToWaitSwitchDriverSubHandshake();
//-------------------------------------------------
//-------------------------------------------------
// Send a message to the handler, it should be passed to the
// switch's sub-handshake handling. After this message the
// sub-handshake will be complete
// FIXME:LOJI: With Andi's fix for a default Match object we won't
// need to build/set this match object
Match match = factory.buildMatch().build();
OFMessage m = factory.buildFlowRemoved().setMatch(match).build();
resetToStrict(sw);
sw.processDriverHandshakeMessage(m);
expectLastCall().once();
expect(sw.isDriverHandshakeComplete()).andReturn(true).once();
replay(sw);
switchHandler.processOFMessage(m);
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(OFSwitchHandshakeHandler.WaitAppHandshakeState.class));
assertThat("Unexpected message captured", connection.getMessages(), Matchers.empty());
verify(sw);
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:35,代码来源:OFSwitchHandlerTestBase.java
示例10: moveToWaitAppHandshakeState
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
@Test
@Override
public void moveToWaitAppHandshakeState() throws Exception {
moveToWaitDescriptionStatReply();
handleDescStatsAndCreateSwitch(true);
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(WaitAppHandshakeState.class));
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:9,代码来源:OFSwitchHandshakeHandlerVer10Test.java
示例11: moveToWaitAppHandshakeState
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
@Test
@Override
public void moveToWaitAppHandshakeState() throws Exception {
moveToWaitDescriptionStatReply();
handleDescStatsAndCreateSwitch(true);
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(WaitAppHandshakeState.class));
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:10,代码来源:OFSwitchHandshakeHandlerVer13Test.java
示例12: moveQuarantine
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
/**
* Tests a situation where a switch returns a QUARANTINE result. This means
* we should move the handshake handler to a quarantine state and also
* quarantine the switch in the controller.
*
* @throws Exception
*/
@Test
public void moveQuarantine() throws Exception {
moveToWaitAppHandshakeState();
reset(switchManager);
switchManager.switchStatusChanged(sw, SwitchStatus.HANDSHAKE, SwitchStatus.QUARANTINED);
expectLastCall().once();
replay(switchManager);
assertThat(switchHandler.getStateForTesting(), CoreMatchers.instanceOf(WaitAppHandshakeState.class));
WaitAppHandshakeState state = (WaitAppHandshakeState) switchHandler.getStateForTesting();
assertThat(state.getCurrentPlugin(), CoreMatchers.<OFSwitchAppHandshakePlugin>equalTo(handshakePlugin));
reset(sw);
expect(sw.getStatus()).andReturn(SwitchStatus.HANDSHAKE);
sw.setStatus(SwitchStatus.QUARANTINED);
expectLastCall().once();
replay(sw);
PluginResult result = new PluginResult(PluginResultType.QUARANTINE, "test quarantine");
handshakePlugin.exitPlugin(result);
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(QuarantineState.class));
verify(switchManager);
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:34,代码来源:OFSwitchHandlerTestBase.java
示例13: testSwitchDriverSubHandshake
import net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState; //导入依赖的package包/类
/**
* Move the channel from scratch to WAIT_INITIAL_ROLE state via
* WAIT_SWITCH_DRIVER_SUB_HANDSHAKE
* Does extensive testing for the WAIT_SWITCH_DRIVER_SUB_HANDSHAKE state
*
*/
@Test
public void testSwitchDriverSubHandshake()
throws Exception {
moveToWaitSwitchDriverSubHandshake();
//-------------------------------------------------
//-------------------------------------------------
// Send a message to the handler, it should be passed to the
// switch's sub-handshake handling. After this message the
// sub-handshake will be complete
// FIXME:LOJI: With Andi's fix for a default Match object we won't
// need to build/set this match object
Match match = factory.buildMatch().build();
OFMessage m = factory.buildFlowRemoved().setMatch(match).build();
resetToStrict(sw);
sw.processDriverHandshakeMessage(m);
expectLastCall().once();
expect(sw.isDriverHandshakeComplete()).andReturn(true).once();
replay(sw);
switchHandler.processOFMessage(m);
assertThat(switchHandler.getStateForTesting(),
CoreMatchers.instanceOf(OFSwitchHandshakeHandler.WaitAppHandshakeState.class));
assertThat("Unexpected message captured", connection.getMessages(), Matchers.empty());
verify(sw);
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:35,代码来源:OFSwitchHandlerTestBase.java
注:本文中的net.floodlightcontroller.core.internal.OFSwitchHandshakeHandler.WaitAppHandshakeState类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论