Java 类org.projectfloodlight.openflow.protocol.OFBsnControllerConnectionsReply 实例源码

项目:fresco_floodlight    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:iTAP-controller    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:SDN-Multicast    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:arscheduler    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:floodlight1.2-delay    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:floodlight-hardware    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:ACAMPController    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:fast-failover-demo    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:floodlightLB    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:DSC    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:floodlight    文件:OFSwitch.java   
@Override
public void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply) {

    // Instantiate clean map, can't use a builder here since we need to call temp.get()
    Map<URI,Map<OFAuxId, OFBsnControllerConnection>> temp = new ConcurrentHashMap<URI,Map<OFAuxId, OFBsnControllerConnection>>();

    List<OFBsnControllerConnection> controllerCxnUpdates = controllerCxnsReply.getConnections();
    for(OFBsnControllerConnection update : controllerCxnUpdates) {
        URI uri = URI.create(update.getUri());

        Map<OFAuxId, OFBsnControllerConnection> cxns = temp.get(uri);

        // Add to nested map
        if(cxns != null){
            cxns.put(update.getAuxiliaryId(), update);
        } else{
            cxns = new ConcurrentHashMap<OFAuxId, OFBsnControllerConnection>();
            cxns.put(update.getAuxiliaryId(), update);
            temp.put(uri, cxns);
        }
    }

    this.controllerConnections = ImmutableMap.<URI,Map<OFAuxId, OFBsnControllerConnection>>copyOf(temp);
}
项目:fresco_floodlight    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:iTAP-controller    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
                                        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:SDN-Multicast    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:arscheduler    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:floodlight1.2-delay    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:floodlight-hardware    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:ACAMPController    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:fast-failover-demo    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
                                        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:floodlightLB    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
                                        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:DSC    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
                                        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:floodlight    文件:OFSwitchTest.java   
/**
 * Helper to load controller connection messages into a switch for testing.
 * @param sw the switch to insert the message on
 * @param role the role for the controller connection message
 * @param state the state for the controller connection message
 * @param uri the URI for the controller connection message
 */
public void updateControllerConnections(IOFSwitchBackend sw, OFControllerRole role1, OFBsnControllerConnectionState state1, String uri1
                                        ,  OFControllerRole role2, OFBsnControllerConnectionState state2, String uri2) {
    OFBsnControllerConnection connection1 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role1)
            .setState(state1)
            .setUri(uri1)
            .build();

    OFBsnControllerConnection connection2 = factory.buildBsnControllerConnection()
            .setAuxiliaryId(OFAuxId.MAIN)
            .setRole(role2)
            .setState(state2)
            .setUri(uri2)
            .build();

    List<OFBsnControllerConnection> connections = new ArrayList<OFBsnControllerConnection>();
    connections.add(connection1);
    connections.add(connection2);

    OFBsnControllerConnectionsReply reply = factory.buildBsnControllerConnectionsReply()
            .setConnections(connections)
            .build();

    sw.updateControllerConnections(reply);
}
项目:fresco_floodlight    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:iTAP-controller    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:SDN-Multicast    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:arscheduler    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:floodlight1.2-delay    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:floodlight-hardware    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:ACAMPController    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:fast-failover-demo    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:floodlightLB    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:DSC    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * 更新交换机和控制器连接映射
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);
项目:floodlight    文件:IOFSwitchBackend.java   
/**
 * Updates the switch's mapping of controller connections
 * @param controllerCxnsReply the controller connections message sent from the switch
 */
void updateControllerConnections(OFBsnControllerConnectionsReply controllerCxnsReply);