Java 类net.floodlightcontroller.core.IOFConnection 实例源码

项目：fresco_floodlight 文件：OFSwitch.java

/**
 * Gets a connection specified by aux Id.
 * @param auxId the specified aux id for the connection desired.
 * @return the aux connection specified by the auxId
 */
public IOFConnection getConnection(OFAuxId auxId) {
    IOFConnection connection = this.connections.get(auxId);
    if (connection == null) {
        throw new IllegalArgumentException("OF Connection for " + this + " with " + auxId + " does not exist.");
    }
    return connection;
}

项目：fresco_floodlight 文件：OFSwitch.java

public IOFConnection getConnection(LogicalOFMessageCategory category) {
    if (switchManager.isCategoryRegistered(category)) {
        return getConnection(category.getAuxId());
    }
    else{
        throw new IllegalArgumentException(category + " is not registered with the floodlight provider service.");
    }
}

项目：fresco_floodlight 文件：OFSwitch.java

@Override
public boolean hasAnotherMaster() {

    //TODO: refactor get connection to not throw illegal arg exceptions
    IOFConnection mainCxn = this.getConnection(OFAuxId.MAIN);

    if(mainCxn != null) {

        // Determine the local URI
        InetSocketAddress address = (InetSocketAddress) mainCxn.getLocalInetAddress();
        URI localURI = URIUtil.createURI(address.getHostName(), address.getPort());

        for(Entry<URI,Map<OFAuxId, OFBsnControllerConnection>> entry : this.controllerConnections.entrySet()) {

            // Don't check our own controller connections
            URI uri = entry.getKey();
            if(!localURI.equals(uri)){

                // We only care for the MAIN connection
                Map<OFAuxId, OFBsnControllerConnection> cxns = this.controllerConnections.get(uri);
                OFBsnControllerConnection controllerCxn = cxns.get(OFAuxId.MAIN);

                if(controllerCxn != null) {
                    // If the controller id disconnected or not master we know it is not connected
                    if(controllerCxn.getState() == OFBsnControllerConnectionState.BSN_CONTROLLER_CONNECTION_STATE_CONNECTED
                            && controllerCxn.getRole() == OFControllerRole.ROLE_MASTER){
                        return true;
                    }
                } else {
                    log.warn("Unable to find controller connection with aux id "
                            + "MAIN for switch {} on controller with URI {}.",
                            this, uri);
                }
            }
        }
    }
    return false;
}

项目：fresco_floodlight 文件：OFSwitchHandshakeHandler.java

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

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

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

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

/**
 * Gets a connection specified by aux Id.
 * @param auxId the specified aux id for the connection desired.
 * @return the aux connection specified by the auxId
 */
public IOFConnection getConnection(OFAuxId auxId) {
    IOFConnection connection = this.connections.get(auxId);
    if (connection == null) {
        throw new IllegalArgumentException("OF Connection for " + this + " with " + auxId + " does not exist.");
    }
    return connection;
}

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

public IOFConnection getConnection(LogicalOFMessageCategory category) {
    if (switchManager.isCategoryRegistered(category)) {
        return getConnection(category.getAuxId());
    }
    else{
        throw new IllegalArgumentException(category + " is not registered with the floodlight provider service.");
    }
}

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

@Override
public Collection<OFMessage> write(Iterable<OFMessage> msgList, LogicalOFMessageCategory category) {
    IOFConnection conn = this.getConnection(category); /* do first to check for supported category */
    Collection<OFMessage> validMsgs = new ArrayList<OFMessage>();
    Collection<OFMessage> invalidMsgs = SwitchRoleMessageValidator.pruneInvalidMessages(
            msgList, validMsgs, this.getOFFactory().getVersion(), this.isActive());
    if (log.isDebugEnabled()) {
        log.debug("MESSAGES: {}, VALID: {}, INVALID: {}", new Object[] { msgList, validMsgs, invalidMsgs});
    }
    /* Try to write all valid messages */
    Collection<OFMessage> unsent = conn.write(validMsgs);
    for (OFMessage m : validMsgs) {
        if (!unsent.contains(m)) {
            switchManager.handleOutgoingMessage(this, m);
        }
    }

    /* Collect invalid and unsent messages */
    Collection<OFMessage> ret = null;
    if (!unsent.isEmpty()) {
        log.warn("Could not send messages {} due to channel disconnection on switch {}", unsent, this.getId());
        ret = IterableUtils.toCollection(unsent);
    }
    if (!invalidMsgs.isEmpty()) {
        log.warn("Could not send messages {} while in SLAVE role on switch {}", invalidMsgs, this.getId());
        if (ret == null) {
            ret = IterableUtils.toCollection(invalidMsgs);
        } else {
            ret.addAll(IterableUtils.toCollection(invalidMsgs));
        }
    }
    if (ret == null) {
        return Collections.emptyList();
    } else {
        return ret;
    }
}

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

@Override
public boolean hasAnotherMaster() {

    //TODO: refactor get connection to not throw illegal arg exceptions
    IOFConnection mainCxn = this.getConnection(OFAuxId.MAIN);

    if(mainCxn != null) {

        // Determine the local URI
        InetSocketAddress address = (InetSocketAddress) mainCxn.getLocalInetAddress();
        URI localURI = URIUtil.createURI(address.getHostName(), address.getPort());

        for(Entry<URI,Map<OFAuxId, OFBsnControllerConnection>> entry : this.controllerConnections.entrySet()) {

            // Don't check our own controller connections
            URI uri = entry.getKey();
            if(!localURI.equals(uri)){

                // We only care for the MAIN connection
                Map<OFAuxId, OFBsnControllerConnection> cxns = this.controllerConnections.get(uri);
                OFBsnControllerConnection controllerCxn = cxns.get(OFAuxId.MAIN);

                if(controllerCxn != null) {
                    // If the controller id disconnected or not master we know it is not connected
                    if(controllerCxn.getState() == OFBsnControllerConnectionState.BSN_CONTROLLER_CONNECTION_STATE_CONNECTED
                            && controllerCxn.getRole() == OFControllerRole.ROLE_MASTER){
                        return true;
                    }
                } else {
                    log.warn("Unable to find controller connection with aux id "
                            + "MAIN for switch {} on controller with URI {}.",
                            this, uri);
                }
            }
        }
    }
    return false;
}

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

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

项目：arscheduler 文件：OFSwitch.java

/**
 * Gets a connection specified by aux Id.
 * @param auxId the specified aux id for the connection desired.
 * @return the aux connection specified by the auxId
 */
public IOFConnection getConnection(OFAuxId auxId) {
    IOFConnection connection = this.connections.get(auxId);
    if (connection == null) {
        throw new IllegalArgumentException("OF Connection for " + this + " with " + auxId + " does not exist.");
    }
    return connection;
}

项目：arscheduler 文件：OFSwitch.java

public IOFConnection getConnection(LogicalOFMessageCategory category) {
    if (switchManager.isCategoryRegistered(category)) {
        return getConnection(category.getAuxId());
    }
    else{
        throw new IllegalArgumentException(category + " is not registered with the floodlight provider service.");
    }
}

项目：arscheduler 文件：OFSwitch.java

@Override
public Collection<OFMessage> write(Iterable<OFMessage> msgList, LogicalOFMessageCategory category) {
    IOFConnection conn = this.getConnection(category); /* do first to check for supported category */
    Collection<OFMessage> validMsgs = new ArrayList<OFMessage>();
    Collection<OFMessage> invalidMsgs = SwitchRoleMessageValidator.pruneInvalidMessages(
            msgList, validMsgs, this.getOFFactory().getVersion(), this.isActive());
    if (log.isDebugEnabled()) {
        log.debug("MESSAGES: {}, VALID: {}, INVALID: {}", new Object[] { msgList, validMsgs, invalidMsgs});
    }
    /* Try to write all valid messages */
    Collection<OFMessage> unsent = conn.write(validMsgs);
    for (OFMessage m : validMsgs) {
        if (!unsent.contains(m)) {
            switchManager.handleOutgoingMessage(this, m);
        }
    }

    /* Collect invalid and unsent messages */
    Collection<OFMessage> ret = null;
    if (!unsent.isEmpty()) {
        log.warn("Could not send messages {} due to channel disconnection on switch {}", unsent, this.getId());
        ret = IterableUtils.toCollection(unsent);
    }
    if (!invalidMsgs.isEmpty()) {
        log.warn("Could not send messages {} while in SLAVE role on switch {}", invalidMsgs, this.getId());
        if (ret == null) {
            ret = IterableUtils.toCollection(invalidMsgs);
        } else {
            ret.addAll(IterableUtils.toCollection(invalidMsgs));
        }
    }
    if (ret == null) {
        return Collections.emptyList();
    } else {
        return ret;
    }
}

项目：arscheduler 文件：OFSwitch.java

@Override
public boolean hasAnotherMaster() {

    //TODO: refactor get connection to not throw illegal arg exceptions
    IOFConnection mainCxn = this.getConnection(OFAuxId.MAIN);

    if(mainCxn != null) {

        // Determine the local URI
        InetSocketAddress address = (InetSocketAddress) mainCxn.getLocalInetAddress();
        URI localURI = URIUtil.createURI(address.getHostName(), address.getPort());

        for(Entry<URI,Map<OFAuxId, OFBsnControllerConnection>> entry : this.controllerConnections.entrySet()) {

            // Don't check our own controller connections
            URI uri = entry.getKey();
            if(!localURI.equals(uri)){

                // We only care for the MAIN connection
                Map<OFAuxId, OFBsnControllerConnection> cxns = this.controllerConnections.get(uri);
                OFBsnControllerConnection controllerCxn = cxns.get(OFAuxId.MAIN);

                if(controllerCxn != null) {
                    // If the controller id disconnected or not master we know it is not connected
                    if(controllerCxn.getState() == OFBsnControllerConnectionState.BSN_CONTROLLER_CONNECTION_STATE_CONNECTED
                            && controllerCxn.getRole() == OFControllerRole.ROLE_MASTER){
                        return true;
                    }
                } else {
                    log.warn("Unable to find controller connection with aux id "
                            + "MAIN for switch {} on controller with URI {}.",
                            this, uri);
                }
            }
        }
    }
    return false;
}

项目：arscheduler 文件：OFSwitchHandshakeHandler.java

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

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

/**
 * Gets a connection specified by aux Id.
 * @param auxId the specified aux id for the connection desired.
 * @return the aux connection specified by the auxId
 */
public IOFConnection getConnection(OFAuxId auxId) {
    IOFConnection connection = this.connections.get(auxId);
    if (connection == null) {
        throw new IllegalArgumentException("OF Connection for " + this + " with " + auxId + " does not exist.");
    }
    return connection;
}

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

public IOFConnection getConnection(LogicalOFMessageCategory category) {
    if (switchManager.isCategoryRegistered(category)) {
        return getConnection(category.getAuxId());
    }
    else{
        throw new IllegalArgumentException(category + " is not registered with the floodlight provider service.");
    }
}

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

@Override
public Collection<OFMessage> write(Iterable<OFMessage> msgList, LogicalOFMessageCategory category) {
    IOFConnection conn = this.getConnection(category); /* do first to check for supported category */
    Collection<OFMessage> validMsgs = new ArrayList<OFMessage>();
    Collection<OFMessage> invalidMsgs = SwitchRoleMessageValidator.pruneInvalidMessages(
            msgList, validMsgs, this.getOFFactory().getVersion(), this.isActive());
    if (log.isDebugEnabled()) {
        log.debug("MESSAGES: {}, VALID: {}, INVALID: {}", new Object[] { msgList, validMsgs, invalidMsgs});
    }
    /* Try to write all valid messages */
    Collection<OFMessage> unsent = conn.write(validMsgs);
    for (OFMessage m : validMsgs) {
        if (!unsent.contains(m)) {
            switchManager.handleOutgoingMessage(this, m);
        }
    }

    /* Collect invalid and unsent messages */
    Collection<OFMessage> ret = null;
    if (!unsent.isEmpty()) {
        log.warn("Could not send messages {} due to channel disconnection on switch {}", unsent, this.getId());
        ret = IterableUtils.toCollection(unsent);
    }
    if (!invalidMsgs.isEmpty()) {
        log.warn("Could not send messages {} while in SLAVE role on switch {}", invalidMsgs, this.getId());
        if (ret == null) {
            ret = IterableUtils.toCollection(invalidMsgs);
        } else {
            ret.addAll(IterableUtils.toCollection(invalidMsgs));
        }
    }
    if (ret == null) {
        return Collections.emptyList();
    } else {
        return ret;
    }
}

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

@Override
public boolean hasAnotherMaster() {

    //TODO: refactor get connection to not throw illegal arg exceptions
    IOFConnection mainCxn = this.getConnection(OFAuxId.MAIN);

    if(mainCxn != null) {

        // Determine the local URI
        InetSocketAddress address = (InetSocketAddress) mainCxn.getLocalInetAddress();
        URI localURI = URIUtil.createURI(address.getHostName(), address.getPort());

        for(Entry<URI,Map<OFAuxId, OFBsnControllerConnection>> entry : this.controllerConnections.entrySet()) {

            // Don't check our own controller connections
            URI uri = entry.getKey();
            if(!localURI.equals(uri)){

                // We only care for the MAIN connection
                Map<OFAuxId, OFBsnControllerConnection> cxns = this.controllerConnections.get(uri);
                OFBsnControllerConnection controllerCxn = cxns.get(OFAuxId.MAIN);

                if(controllerCxn != null) {
                    // If the controller id disconnected or not master we know it is not connected
                    if(controllerCxn.getState() == OFBsnControllerConnectionState.BSN_CONTROLLER_CONNECTION_STATE_CONNECTED
                            && controllerCxn.getRole() == OFControllerRole.ROLE_MASTER){
                        return true;
                    }
                } else {
                    log.warn("Unable to find controller connection with aux id "
                            + "MAIN for switch {} on controller with URI {}.",
                            this, uri);
                }
            }
        }
    }
    return false;
}

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

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

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

/**
 * Gets a connection specified by aux Id.
 * @param auxId the specified aux id for the connection desired.
 * @return the aux connection specified by the auxId
 */
public IOFConnection getConnection(OFAuxId auxId) {
    IOFConnection connection = this.connections.get(auxId);
    if (connection == null) {
        throw new IllegalArgumentException("OF Connection for " + this + " with " + auxId + " does not exist.");
    }
    return connection;
}

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

public IOFConnection getConnection(LogicalOFMessageCategory category) {
    if (switchManager.isCategoryRegistered(category)) {
        return getConnection(category.getAuxId());
    }
    else{
        throw new IllegalArgumentException(category + " is not registered with the floodlight provider service.");
    }
}

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

@Override
public Collection<OFMessage> write(Iterable<OFMessage> msgList, LogicalOFMessageCategory category) {
    IOFConnection conn = this.getConnection(category); /* do first to check for supported category */
    Collection<OFMessage> validMsgs = new ArrayList<OFMessage>();
    Collection<OFMessage> invalidMsgs = SwitchRoleMessageValidator.pruneInvalidMessages(
            msgList, validMsgs, this.getOFFactory().getVersion(), this.isActive());
    if (log.isDebugEnabled()) {
        log.debug("MESSAGES: {}, VALID: {}, INVALID: {}", new Object[] { msgList, validMsgs, invalidMsgs});
    }
    /* Try to write all valid messages */
    Collection<OFMessage> unsent = conn.write(validMsgs);
    for (OFMessage m : validMsgs) {
        if (!unsent.contains(m)) {
            switchManager.handleOutgoingMessage(this, m);
        }
    }

    /* Collect invalid and unsent messages */
    Collection<OFMessage> ret = null;
    if (!unsent.isEmpty()) {
        log.warn("Could not send messages {} due to channel disconnection on switch {}", unsent, this.getId());
        ret = IterableUtils.toCollection(unsent);
    }
    if (!invalidMsgs.isEmpty()) {
        log.warn("Could not send messages {} while in SLAVE role on switch {}", invalidMsgs, this.getId());
        if (ret == null) {
            ret = IterableUtils.toCollection(invalidMsgs);
        } else {
            ret.addAll(IterableUtils.toCollection(invalidMsgs));
        }
    }
    if (ret == null) {
        return Collections.emptyList();
    } else {
        return ret;
    }
}

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

@Override
public boolean hasAnotherMaster() {

    //TODO: refactor get connection to not throw illegal arg exceptions
    IOFConnection mainCxn = this.getConnection(OFAuxId.MAIN);

    if(mainCxn != null) {

        // Determine the local URI
        InetSocketAddress address = (InetSocketAddress) mainCxn.getLocalInetAddress();
        URI localURI = URIUtil.createURI(address.getHostName(), address.getPort());

        for(Entry<URI,Map<OFAuxId, OFBsnControllerConnection>> entry : this.controllerConnections.entrySet()) {

            // Don't check our own controller connections
            URI uri = entry.getKey();
            if(!localURI.equals(uri)){

                // We only care for the MAIN connection
                Map<OFAuxId, OFBsnControllerConnection> cxns = this.controllerConnections.get(uri);
                OFBsnControllerConnection controllerCxn = cxns.get(OFAuxId.MAIN);

                if(controllerCxn != null) {
                    // If the controller id disconnected or not master we know it is not connected
                    if(controllerCxn.getState() == OFBsnControllerConnectionState.BSN_CONTROLLER_CONNECTION_STATE_CONNECTED
                            && controllerCxn.getRole() == OFControllerRole.ROLE_MASTER){
                        return true;
                    }
                } else {
                    log.warn("Unable to find controller connection with aux id "
                            + "MAIN for switch {} on controller with URI {}.",
                            this, uri);
                }
            }
        }
    }
    return false;
}

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

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

项目：ACAMPController 文件：OFSwitch.java

/**
 * Gets a connection specified by aux Id.
 * @param auxId the specified aux id for the connection desired.
 * @return the aux connection specified by the auxId
 */
public IOFConnection getConnection(OFAuxId auxId) {
    IOFConnection connection = this.connections.get(auxId);
    if (connection == null) {
        throw new IllegalArgumentException("OF Connection for " + this + " with " + auxId + " does not exist.");
    }
    return connection;
}

项目：ACAMPController 文件：OFSwitch.java

public IOFConnection getConnection(LogicalOFMessageCategory category) {
    if (switchManager.isCategoryRegistered(category)) {
        return getConnection(category.getAuxId());
    }
    else{
        throw new IllegalArgumentException(category + " is not registered with the floodlight provider service.");
    }
}

项目：ACAMPController 文件：OFSwitch.java

@Override
public Collection<OFMessage> write(Iterable<OFMessage> msgList, LogicalOFMessageCategory category) {
    IOFConnection conn = this.getConnection(category); /* do first to check for supported category */
    Collection<OFMessage> validMsgs = new ArrayList<OFMessage>();
    Collection<OFMessage> invalidMsgs = SwitchRoleMessageValidator.pruneInvalidMessages(
            msgList, validMsgs, this.getOFFactory().getVersion(), this.isActive());
    if (log.isDebugEnabled()) {
        log.debug("MESSAGES: {}, VALID: {}, INVALID: {}", new Object[] { msgList, validMsgs, invalidMsgs});
    }
    /* Try to write all valid messages */
    Collection<OFMessage> unsent = conn.write(validMsgs);
    for (OFMessage m : validMsgs) {
        if (!unsent.contains(m)) {
            switchManager.handleOutgoingMessage(this, m);
        }
    }

    /* Collect invalid and unsent messages */
    Collection<OFMessage> ret = null;
    if (!unsent.isEmpty()) {
        log.warn("Could not send messages {} due to channel disconnection on switch {}", unsent, this.getId());
        ret = IterableUtils.toCollection(unsent);
    }
    if (!invalidMsgs.isEmpty()) {
        log.warn("Could not send messages {} while in SLAVE role on switch {}", invalidMsgs, this.getId());
        if (ret == null) {
            ret = IterableUtils.toCollection(invalidMsgs);
        } else {
            ret.addAll(IterableUtils.toCollection(invalidMsgs));
        }
    }
    if (ret == null) {
        return Collections.emptyList();
    } else {
        return ret;
    }
}

项目：ACAMPController 文件：OFSwitch.java

@Override
public boolean hasAnotherMaster() {

    //TODO: refactor get connection to not throw illegal arg exceptions
    IOFConnection mainCxn = this.getConnection(OFAuxId.MAIN);

    if(mainCxn != null) {

        // Determine the local URI
        InetSocketAddress address = (InetSocketAddress) mainCxn.getLocalInetAddress();
        URI localURI = URIUtil.createURI(address.getHostName(), address.getPort());

        for(Entry<URI,Map<OFAuxId, OFBsnControllerConnection>> entry : this.controllerConnections.entrySet()) {

            // Don't check our own controller connections
            URI uri = entry.getKey();
            if(!localURI.equals(uri)){

                // We only care for the MAIN connection
                Map<OFAuxId, OFBsnControllerConnection> cxns = this.controllerConnections.get(uri);
                OFBsnControllerConnection controllerCxn = cxns.get(OFAuxId.MAIN);

                if(controllerCxn != null) {
                    // If the controller id disconnected or not master we know it is not connected
                    if(controllerCxn.getState() == OFBsnControllerConnectionState.BSN_CONTROLLER_CONNECTION_STATE_CONNECTED
                            && controllerCxn.getRole() == OFControllerRole.ROLE_MASTER){
                        return true;
                    }
                } else {
                    log.warn("Unable to find controller connection with aux id "
                            + "MAIN for switch {} on controller with URI {}.",
                            this, uri);
                }
            }
        }
    }
    return false;
}

项目：ACAMPController 文件：OFSwitchHandshakeHandler.java

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

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

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

项目：floodlightLB 文件：OFSwitchHandshakeHandler.java

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

项目：DSC 文件：OFSwitchHandshakeHandler.java

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

项目：floodlight 文件：OFSwitchHandshakeHandler.java

/**
 * Gets the current connections that this switch handshake handler is
 * responsible for. Used primarily by the REST API.
 * @return an immutable list of IOFConnections
 */
public ImmutableList<IOFConnection> getConnections() {
    ImmutableList.Builder<IOFConnection> builder = ImmutableList.builder();

    builder.add(mainConnection);
    builder.addAll(auxConnections.values());

    return builder.build();
}

项目：fresco_floodlight 文件：SwitchRepresentation.java

public Collection<IOFConnection> getConnections() {
    return this.connections;
}

项目：fresco_floodlight 文件：OFSwitch.java

@Override
public ImmutableList<IOFConnection> getConnections() {
    return ImmutableList.<IOFConnection> copyOf(this.connections.values());
}

项目：fresco_floodlight 文件：OFMessageDamperMockSwitch.java

@Override
public ImmutableList<IOFConnection> getConnections() {
    // TODO Auto-generated method stub
    return null;
}

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

public Collection<IOFConnection> getConnections() {
    return this.connections;
}

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

@Override
public ImmutableList<IOFConnection> getConnections() {
    // TODO Auto-generated method stub
    return null;
}

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

public Collection<IOFConnection> getConnections() {
    return this.connections;
}