Java 类net.floodlightcontroller.core.internal.Controller.IUpdate 实例源码

项目：Multipath-Hedera-system-in-Floodlight-controller 文件：ControllerTest.java

@Test 
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class); 
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0, 
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE);
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate", 
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(null, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：smartenit 文件：ControllerTest.java

@Test 
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class); 
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0, 
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE);
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate", 
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(null, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：floodlight-qosmanager 文件：ControllerTest.java

@Test 
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class); 
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0, 
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE);
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate", 
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(null, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：floodlight-nfv 文件：ControllerTest.java

@Test
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class);
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0,
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE, "Testing");
    controller.doSetRole(); // avoid wait
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate",
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(Role.MASTER, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：HederaInFloodlight 文件：ControllerTest.java

@Test 
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class); 
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0, 
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE);
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate", 
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(null, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：floodlight-oss 文件：ControllerTest.java

@Test
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class);
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0,
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE, "Testing");
    controller.doSetRole(); // avoid wait
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate",
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(Role.MASTER, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：my-floodlight 文件：ControllerTest.java

@Test 
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class); 
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0, 
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE);
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate", 
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(null, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：FL_HAND 文件：ControllerTest.java

@Test 
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class); 
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0, 
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE);
    controller.doSetRole(); // avoid wait
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate", 
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(Role.MASTER, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：sdn-project 文件：ControllerTest.java

@Test 
public void testSetRole() {
    controller.connectedSwitches.add(new OFSwitchImpl());
    RoleChanger roleChanger = createMock(RoleChanger.class); 
    roleChanger.submitRequest(controller.connectedSwitches, Role.SLAVE);
    controller.roleChanger = roleChanger;

    assertEquals("Check that update queue is empty", 0, 
                controller.updates.size());

    replay(roleChanger);
    controller.setRole(Role.SLAVE);
    verify(roleChanger);

    Controller.IUpdate upd = controller.updates.poll();
    assertNotNull("Check that update queue has an update", upd);
    assertTrue("Check that update is HARoleUpdate", 
               upd instanceof Controller.HARoleUpdate);
    Controller.HARoleUpdate roleUpd = (Controller.HARoleUpdate)upd;
    assertSame(null, roleUpd.oldRole);
    assertSame(Role.SLAVE, roleUpd.newRole);
}

项目：open-kilda 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：open-kilda 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：fresco_floodlight 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：fresco_floodlight 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：fresco_floodlight 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：iTAP-controller 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：iTAP-controller 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：iTAP-controller 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：SDN-Multicast 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：SDN-Multicast 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：SDN-Multicast 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：arscheduler 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：arscheduler 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：arscheduler 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：floodlight1.2-delay 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：floodlight1.2-delay 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：floodlight1.2-delay 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：floodlight-hardware 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：floodlight-hardware 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：floodlight-hardware 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：ACAMPController 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：ACAMPController 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：ACAMPController 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：fast-failover-demo 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：fast-failover-demo 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：fast-failover-demo 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：floodlightLB 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：floodlightLB 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}

项目：floodlightLB 文件：MockFloodlightProvider.java

/**
 * Dispatches a new role change notification
 * @param oldRole
 * @param newRole
 */
public void transitionToActive() {
    IUpdate update = new IUpdate() {
        @Override
        public void dispatch() {
            for (IHAListener rl : haListeners.getOrderedListeners()) {
                rl.transitionToActive();
            }
        }
    };
    addUpdateToQueue(update);
}

项目：DSC 文件：RoleManagerTest.java

/**
 * Helper method that mocks up the controller and sets the supplied role
 * @param role the desired role to pass to setRole
 */
private void setRoleAndMockController(HARole role) {
    reset(controller);
    controller.addUpdateToQueue(anyObject(IUpdate.class));
    expectLastCall().anyTimes();
    replay(controller);

    roleManager.setRole(role, "test");
}

项目：DSC 文件：MockFloodlightProvider.java

@Override
public void addUpdateToQueue(final IUpdate update) {
    if (useAsyncUpdates) {
        mostRecentUpdateFuture = executorService.submit(new Runnable() {
            @Override
            public void run() {
                update.dispatch();
            }
        });
    } else {
        update.dispatch();
    }
}