本文整理汇总了Java中net.floodlightcontroller.debugcounter.DebugCounterServiceImpl类的典型用法代码示例。如果您正苦于以下问题:Java DebugCounterServiceImpl类的具体用法?Java DebugCounterServiceImpl怎么用?Java DebugCounterServiceImpl使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DebugCounterServiceImpl类属于net.floodlightcontroller.debugcounter包,在下文中一共展示了DebugCounterServiceImpl类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
switchManager = createMock(IOFSwitchManager.class);
roleManager = createMock(RoleManager.class);
sw = createMock(IOFSwitchBackend.class);
timer = createMock(Timer.class);
expect(timer.newTimeout(anyObject(TimerTask.class), anyLong(), anyObject(TimeUnit.class))).andReturn(EasyMock.createNiceMock(Timeout.class));
replay(timer);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
connection = new MockOFConnection(featuresReply.getDatapathId(), OFAuxId.MAIN);
switchHandler = new OFSwitchHandshakeHandler(connection, featuresReply, switchManager, roleManager, timer);
// replay sw. Reset it if you need more specific behavior
replay(sw);
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:24,代码来源:OFSwitchHandlerTestBase.java
示例2: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
switchManager = createMock(IOFSwitchManager.class);
roleManager = createMock(RoleManager.class);
sw = createMock(IOFSwitchBackend.class);
timer = createMock(Timer.class);
expect(timer.newTimeout(anyObject(TimerTask.class), anyLong(), anyObject(TimeUnit.class))).andReturn(EasyMock.createNiceMock(Timeout.class));
replay(timer);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
connection = new MockOFConnection(featuresReply.getDatapathId(), OFAuxId.MAIN);
switchHandler = new OFSwitchHandshakeHandler(connection, featuresReply, switchManager, roleManager, timer);
// replay sw. Reset it if you need more specific behavior
replay(sw);
}
开发者ID:rizard,项目名称:fast-failover-demo,代码行数:24,代码来源:OFSwitchHandlerTestBase.java
示例3: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
switchManager = createMock(IOFSwitchManager.class);
roleManager = createMock(RoleManager.class);
sw = createMock(IOFSwitchBackend.class);
timer = createMock(Timer.class);
expect(timer.newTimeout(anyObject(TimerTask.class), anyLong(), anyObject(TimeUnit.class))).andReturn(EasyMock.createNiceMock(Timeout.class));
replay(timer);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
connection = new MockOFConnection(featuresReply.getDatapathId(), OFAuxId.MAIN);
switchHandler = new OFSwitchHandshakeHandler(connection, featuresReply, switchManager, roleManager, timer,null);
// replay sw. Reset it if you need more specific behavior
replay(sw);
}
开发者ID:DaiDongLiang,项目名称:DSC,代码行数:24,代码来源:OFSwitchHandlerTestBase.java
示例4: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
factory = OFFactories.getFactory(OFVersion.OF_13);
switchId = DatapathId.of(1);
timer = new HashedWheelTimer();
channel = EasyMock.createMock(Channel.class);
IDebugCounterService debugCounterService = new DebugCounterServiceImpl();
debugCounterService.registerModule(OFConnectionCounters.COUNTER_MODULE);
conn = new OFConnection(switchId, factory, channel, OFAuxId.MAIN,
debugCounterService, timer);
eventLoop = new TestEventLoop();
expect(channel.eventLoop()).andReturn(eventLoop).anyTimes();
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:15,代码来源:OFConnectionTest.java
示例5: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
/*
* This needs to be called explicitly to ensure the featuresReply is not null.
* Otherwise, there is no guarantee @Before will for setUpFeaturesReply() will
* call that function before our @Before setUp() here.
*/
setUpFeaturesReply();
switchManager = createMock(IOFSwitchManager.class);
roleManager = createMock(RoleManager.class);
sw = createMock(IOFSwitchBackend.class);
timer = createMock(Timer.class);
expect(timer.newTimeout(anyObject(TimerTask.class), anyLong(), anyObject(TimeUnit.class))).andReturn(EasyMock.createNiceMock(Timeout.class));
replay(timer);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
connection = new MockOFConnection(featuresReply.getDatapathId(), OFAuxId.MAIN);
switchHandler = new OFSwitchHandshakeHandler(connection, featuresReply, switchManager, roleManager, timer);
// replay sw. Reset it if you need more specific behavior
replay(sw);
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:30,代码来源:OFSwitchHandlerTestBase.java
示例6: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
// Build our test packet
IDebugCounterService debugCounter = new DebugCounterServiceImpl();
switchManager = createMock(IOFSwitchManager.class);
SwitchManagerCounters counters = new SwitchManagerCounters(debugCounter);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
factory = OFFactories.getFactory(OFVersion.OF_13);
testMessage = factory.buildRoleReply()
.setXid(1)
.setRole(OFControllerRole.ROLE_MASTER)
.build();
IOFConnectionBackend conn = EasyMock.createNiceMock(IOFConnectionBackend.class);
capturedMessage = new Capture<OFMessage>();
conn.write(EasyMock.capture(capturedMessage));
expectLastCall().anyTimes();
expect(conn.getOFFactory()).andReturn(factory).anyTimes();
expect(conn.getAuxId()).andReturn(OFAuxId.MAIN).anyTimes();
EasyMock.replay(conn);
IOFConnectionBackend auxConn = EasyMock.createNiceMock(IOFConnectionBackend.class);
expect(auxConn.getOFFactory()).andReturn(factory).anyTimes();
expect(auxConn.getAuxId()).andReturn(OFAuxId.of(1)).anyTimes();
EasyMock.replay(auxConn);
sw = new OFSwitchTest(conn, switchManager);
sw.registerConnection(auxConn);
sw.setControllerRole(OFControllerRole.ROLE_MASTER); /* must supply role now, otherwise write() will be blocked if not master/equal/other */
switches = new ConcurrentHashMap<DatapathId, IOFSwitchBackend>();
switches.put(sw.getId(), sw);
reset(switchManager);
//expect(switchManager.getSwitch(sw.getId())).andReturn(sw).anyTimes();
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:41,代码来源:OFSwitchBaseTest.java
示例7: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
factory = OFFactories.getFactory(OFVersion.OF_13);
switchId = DatapathId.of(1);
timer = new HashedWheelTimer();
channel = EasyMock.createNiceMock(Channel.class);
IDebugCounterService debugCounterService = new DebugCounterServiceImpl();
debugCounterService.registerModule(OFConnectionCounters.COUNTER_MODULE);
conn = new OFConnection(switchId, factory, channel, OFAuxId.MAIN,
debugCounterService, timer);
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:12,代码来源:OFConnectionTest.java
示例8: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
// Build our test packet
IDebugCounterService debugCounter = new DebugCounterServiceImpl();
switchManager = createMock(IOFSwitchManager.class);
SwitchManagerCounters counters = new SwitchManagerCounters(debugCounter);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
factory = OFFactories.getFactory(OFVersion.OF_13);
testMessage = factory.buildRoleReply()
.setXid(1)
.setRole(OFControllerRole.ROLE_MASTER)
.build();
IOFConnectionBackend conn = EasyMock.createNiceMock(IOFConnectionBackend.class);
capturedMessage = new Capture<OFMessage>();
conn.write(EasyMock.capture(capturedMessage));
expectLastCall().anyTimes();
expect(conn.getOFFactory()).andReturn(factory).anyTimes();
expect(conn.getAuxId()).andReturn(OFAuxId.MAIN).anyTimes();
EasyMock.replay(conn);
IOFConnectionBackend auxConn = EasyMock.createNiceMock(IOFConnectionBackend.class);
expect(auxConn.getOFFactory()).andReturn(factory).anyTimes();
expect(auxConn.getAuxId()).andReturn(OFAuxId.of(1)).anyTimes();
EasyMock.replay(auxConn);
sw = new OFSwitchTest(conn, switchManager);
sw.registerConnection(auxConn);
switches = new ConcurrentHashMap<DatapathId, IOFSwitchBackend>();
switches.put(sw.getId(), sw);
reset(switchManager);
//expect(switchManager.getSwitch(sw.getId())).andReturn(sw).anyTimes();
}
开发者ID:pixuan,项目名称:floodlight,代码行数:40,代码来源:OFSwitchBaseTest.java
示例9: MockSwitchManager
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
public MockSwitchManager(){
switchHandlers = new ConcurrentHashMap<DatapathId, OFSwitchHandshakeHandler>();
switches = new ConcurrentHashMap<DatapathId, IOFSwitch>();
counters = new SwitchManagerCounters(new DebugCounterServiceImpl());
//switchListeners = new CopyOnWriteArrayList<IOFSwitchListener>();
}
开发者ID:telstra,项目名称:open-kilda,代码行数:7,代码来源:MockSwitchManager.java
示例10: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
setUpFeaturesReply();
switchManager = createMock(IOFSwitchManager.class);
connectionListener = createMock(IOFConnectionListener.class);
newConnectionListener = createMock(INewOFConnectionListener.class);
newConnection = new Capture<IOFConnectionBackend>();
newFeaturesReply = new Capture<OFFeaturesReply>();
eventLoop = new TestEventLoop();
ctx = createMock(ChannelHandlerContext.class);
channel = createMock(Channel.class);
timer = new HashedWheelTimer();
exceptionEventCapture = new Capture<Throwable>(CaptureType.ALL);
pipeline = createMock(ChannelPipeline.class);
writeCapture = new Capture<List<OFMessage>>(CaptureType.ALL);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
debugCounterService.registerModule(OFConnectionCounters.COUNTER_MODULE);
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
handler = new OFChannelHandler(switchManager, newConnectionListener,
pipeline, debugCounterService, /* 62 is OF versions 1.0 thru 1.4 in decimal */
timer, Collections.singletonList(U32.of(62)), OFFactories.getFactory(OFVersion.OF_14));
verify(switchManager);
reset(switchManager);
resetChannel();
// replay controller. Reset it if you need more specific behavior
replay(switchManager);
// Mock ctx and channelStateEvent
expect(ctx.channel()).andReturn(channel).anyTimes();
expect(ctx.fireExceptionCaught(capture(exceptionEventCapture))).andReturn(ctx).anyTimes();
replay(ctx);
/* Setup an exception event capture on the channel. Right now
* we only expect exception events to be send up the channel.
* However, it's easy to extend to other events if we need it
*/
expect(pipeline.get(OFMessageDecoder.class)).andReturn(new OFMessageDecoder()).anyTimes();
replay(pipeline);
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:52,代码来源:OFChannelHandlerVer13Test.java
示例11: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
// Build our test packet
IDebugCounterService debugCounter = new DebugCounterServiceImpl();
switchManager = createMock(IOFSwitchManager.class);
SwitchManagerCounters counters = new SwitchManagerCounters(debugCounter);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
factory = OFFactories.getFactory(OFVersion.OF_13);
testMessage = factory.buildRoleReply()
.setXid(1)
.setRole(OFControllerRole.ROLE_MASTER)
.build();
IOFConnectionBackend conn = EasyMock.createNiceMock(IOFConnectionBackend.class);
capturedMessage = new Capture<Iterable<OFMessage>>();
expect(conn.write(EasyMock.capture(capturedMessage))).andReturn(Collections.<OFMessage>emptyList()).atLeastOnce();
expect(conn.getOFFactory()).andReturn(factory).anyTimes();
expect(conn.getAuxId()).andReturn(OFAuxId.MAIN).anyTimes();
EasyMock.replay(conn);
IOFConnectionBackend auxConn = EasyMock.createNiceMock(IOFConnectionBackend.class);
expect(auxConn.getOFFactory()).andReturn(factory).anyTimes();
expect(auxConn.getAuxId()).andReturn(OFAuxId.of(1)).anyTimes();
expect(auxConn.write(EasyMock.capture(capturedMessage))).andReturn(Collections.<OFMessage>emptyList()).once();
EasyMock.replay(auxConn);
sw = new OFSwitchTest(conn, switchManager);
sw.registerConnection(auxConn);
sw.setControllerRole(OFControllerRole.ROLE_MASTER); /* must supply role now, otherwise write() will be blocked if not master/equal/other */
switches = new ConcurrentHashMap<DatapathId, IOFSwitchBackend>();
switches.put(sw.getId(), sw);
reset(switchManager);
//expect(switchManager.getSwitch(sw.getId())).andReturn(sw).anyTimes();
setUpPorts();
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:42,代码来源:OFSwitchBaseTest.java
示例12: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
setUpFeaturesReply();
switchManager = createMock(IOFSwitchManager.class);
connectionListener = createMock(IOFConnectionListener.class);
newConnectionListener = createMock(INewOFConnectionListener.class);
newConnection = new Capture<IOFConnectionBackend>();
newFeaturesReply = new Capture<OFFeaturesReply>();
eventLoop = new TestEventLoop();
ctx = createMock(ChannelHandlerContext.class);
channel = createMock(Channel.class);
timer = new HashedWheelTimer();
exceptionEventCapture = new Capture<Throwable>(CaptureType.ALL);
pipeline = createMock(ChannelPipeline.class);
writeCapture = new Capture<List<OFMessage>>(CaptureType.ALL);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
debugCounterService.registerModule(OFConnectionCounters.COUNTER_MODULE);
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
handler = new OFChannelHandler(switchManager, newConnectionListener,
pipeline, debugCounterService,
timer, Collections.singletonList(U32.of(0)), OFFactories.getFactory(OFVersion.OF_14));
verify(switchManager);
reset(switchManager);
resetChannel();
// replay controller. Reset it if you need more specific behavior
replay(switchManager);
// Mock ctx and channelStateEvent
expect(ctx.channel()).andReturn(channel).anyTimes();
expect(ctx.fireExceptionCaught(capture(exceptionEventCapture))).andReturn(ctx).anyTimes();
replay(ctx);
/* Setup an exception event capture on the channel. Right now
* we only expect exception events to be send up the channel.
* However, it's easy to extend to other events if we need it
*/
expect(pipeline.get(OFMessageDecoder.class)).andReturn(new OFMessageDecoder()).anyTimes();
replay(pipeline);
}
开发者ID:xuraylei,项目名称:fresco_floodlight,代码行数:50,代码来源:OFChannelHandlerVer10Test.java
示例13: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
switchManager = createMock(IOFSwitchManager.class);
connectionListener = createMock(IOFConnectionListener.class);
newConnectionListener = createMock(INewOFConnectionListener.class);
newConnection = new Capture<IOFConnectionBackend>();
newFeaturesReply = new Capture<OFFeaturesReply>();
ctx = createMock(ChannelHandlerContext.class);
channelStateEvent = createMock(ChannelStateEvent.class);
channel = createMock(Channel.class);
timer = new HashedWheelTimer();
messageEvent = createMock(MessageEvent.class);
exceptionEventCapture = new Capture<ExceptionEvent>(CaptureType.ALL);
pipeline = createMock(ChannelPipeline.class);
writeCapture = new Capture<List<OFMessage>>(CaptureType.ALL);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
debugCounterService.registerModule(OFConnectionCounters.COUNTER_MODULE);
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
handler = new OFChannelHandler(switchManager, newConnectionListener,
pipeline, debugCounterService, timer);
verify(switchManager);
reset(switchManager);
resetChannel();
// replay controller. Reset it if you need more specific behavior
replay(switchManager);
// Mock ctx and channelStateEvent
expect(ctx.getChannel()).andReturn(channel).anyTimes();
expect(channelStateEvent.getChannel()).andReturn(channel).anyTimes();
replay(ctx, channelStateEvent);
/* Setup an exception event capture on the channel. Right now
* we only expect exception events to be send up the channel.
* However, it's easy to extend to other events if we need it
*/
pipeline.sendUpstream(capture(exceptionEventCapture));
expectLastCall().anyTimes();
expect(pipeline.get(OFMessageDecoder.class)).andReturn(new OFMessageDecoder()).anyTimes();
replay(pipeline);
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:52,代码来源:OFChannelHandlerVer13Test.java
示例14: setUp
import net.floodlightcontroller.debugcounter.DebugCounterServiceImpl; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
switchManager = createMock(IOFSwitchManager.class);
connectionListener = createMock(IOFConnectionListener.class);
newConnectionListener = createMock(INewOFConnectionListener.class);
newConnection = new Capture<IOFConnectionBackend>();
newFeaturesReply = new Capture<OFFeaturesReply>();
ctx = createMock(ChannelHandlerContext.class);
channelStateEvent = createMock(ChannelStateEvent.class);
channel = createMock(Channel.class);
timer = new HashedWheelTimer();
messageEvent = createMock(MessageEvent.class);
exceptionEventCapture = new Capture<ExceptionEvent>(CaptureType.ALL);
pipeline = createMock(ChannelPipeline.class);
writeCapture = new Capture<List<OFMessage>>(CaptureType.ALL);
seenXids = null;
// TODO: should mock IDebugCounterService and make sure
// the expected counters are updated.
debugCounterService = new DebugCounterServiceImpl();
debugCounterService.registerModule(OFConnectionCounters.COUNTER_MODULE);
SwitchManagerCounters counters =
new SwitchManagerCounters(debugCounterService);
expect(switchManager.getCounters()).andReturn(counters).anyTimes();
replay(switchManager);
handler = new OFChannelHandler(switchManager, newConnectionListener,
pipeline, debugCounterService,
timer);
verify(switchManager);
reset(switchManager);
resetChannel();
// replay controller. Reset it if you need more specific behavior
replay(switchManager);
// Mock ctx and channelStateEvent
expect(ctx.getChannel()).andReturn(channel).anyTimes();
expect(channelStateEvent.getChannel()).andReturn(channel).anyTimes();
replay(ctx, channelStateEvent);
/* Setup an exception event capture on the channel. Right now
* we only expect exception events to be send up the channel.
* However, it's easy to extend to other events if we need it
*/
pipeline.sendUpstream(capture(exceptionEventCapture));
expectLastCall().anyTimes();
expect(pipeline.get(OFMessageDecoder.class)).andReturn(new OFMessageDecoder()).anyTimes();
replay(pipeline);
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:52,代码来源:OFChannelHandlerVer10Test.java
注:本文中的net.floodlightcontroller.debugcounter.DebugCounterServiceImpl类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论