1. 包列表
  2. 类列表
  3. org.projectfloodlight.openflow.protocol.OFCircuitPortStatus

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

项目：onos    文件：OplinkEdfaHandshaker.java    
@Override
public void processDriverHandshakeMessage(OFMessage m) {

    if (!startDriverHandshakeCalled) {
        throw new SwitchDriverSubHandshakeNotStarted();
    }

    if (driverHandshakeComplete.get()) {
        throw new SwitchDriverSubHandshakeCompleted(m);
    }

    switch (m.getType()) {
        case BARRIER_REPLY:
            log.debug("OPLK EDFA Received barrier response");
            break;
        case ERROR:
            log.error("Switch {} Error {}", getStringId(), m);
            break;
        case PORT_STATUS:
            processOFPortStatus((OFCircuitPortStatus) m);
            break;
        case STATS_REPLY:
            OFStatsReply stats = (OFStatsReply) m;
            if (stats.getStatsType() == OFStatsType.EXPERIMENTER) {
                log.debug("OPLK EDFA : Received multipart (port desc) reply message {}", m);
                //OTN Optical extension 1.0 port-desc
                createOpticalPortList((OFCircuitPortsReply) m);
                driverHandshakeComplete.set(true);
            }
            break;
        default:
            log.warn("Received message {} during switch-driver " +
                             "subhandshake from switch {} ... " +
                             "Ignoring message", m, getStringId());
    }
}
项目：athena    文件：OplinkRoadmHandshaker.java    
@Override
public void processDriverHandshakeMessage(OFMessage m) {

    if (!startDriverHandshakeCalled) {
        throw new SwitchDriverSubHandshakeNotStarted();
    }

    if (driverHandshakeComplete.get()) {
        throw new SwitchDriverSubHandshakeCompleted(m);
    }

    switch (m.getType()) {
        case BARRIER_REPLY:
            log.debug("OPLK ROADM Received barrier response");
            break;
        case ERROR:
            log.error("Switch {} Error {}", getStringId(), m);
            break;
        case FEATURES_REPLY:
            break;
        case FLOW_REMOVED:
            break;
        case GET_ASYNC_REPLY:
            break;
        case PACKET_IN:
            break;
        case PORT_STATUS:
            processOFPortStatus((OFCircuitPortStatus) m);
            break;
        case QUEUE_GET_CONFIG_REPLY:
            break;
        case ROLE_REPLY:
            break;
        case STATS_REPLY:
            OFStatsReply stats = (OFStatsReply) m;
            if (stats.getStatsType() == OFStatsType.EXPERIMENTER) {
                log.warn("OPLK ROADM : Received multipart (port desc) reply message {}", m);
                //OTN Optical extension 1.0 port-desc
                createOpticalPortList((OFCircuitPortsReply) m);
                driverHandshakeComplete.set(true);
            }
            break;
        default:
            log.warn("Received message {} during switch-driver " +
                             "subhandshake " + "from switch {} ... " +
                             "Ignoring message", m,
                     getStringId());

    }
}
项目：athena    文件：OplinkRoadmHandshaker.java    
private void processOFPortStatus(OFCircuitPortStatus ps) {
    log.debug("OPLK ROADM ..OF Port Status :", ps);
}
项目：athena    文件：OfOpticalSwitchImplLinc13.java    
@Override
public void processDriverHandshakeMessage(OFMessage m) {
    if (!startDriverHandshakeCalled) {
        throw new SwitchDriverSubHandshakeNotStarted();
    }
    if (driverHandshakeComplete.get()) {
        throw new SwitchDriverSubHandshakeCompleted(m);
    }

    switch (m.getType()) {
        case BARRIER_REPLY:
            if (m.getXid() == barrierXidToWaitFor) {
                log.debug("LINC-OE Received barrier response");
            }
            break;
        case ERROR:
            log.error("Switch {} Error {}", getStringId(), m);
            break;
        case FEATURES_REPLY:
            break;
        case FLOW_REMOVED:
            break;
        case GET_ASYNC_REPLY:
            break;
        case PACKET_IN:
            break;
        case PORT_STATUS:
            log.warn("****LINC-OE Port Status {} {}", getStringId(), m);
            processOFPortStatus((OFCircuitPortStatus) m);
            break;
        case QUEUE_GET_CONFIG_REPLY:
            break;
        case ROLE_REPLY:
            break;
        case STATS_REPLY:
            OFStatsReply stats = (OFStatsReply) m;
            if (stats.getStatsType() == OFStatsType.EXPERIMENTER) {
                log.warn("LINC-OE : Received stats reply message {}", m);
                createOpticalPortList((OFCircuitPortsReply) m);
                driverHandshakeComplete.set(true);
            }
            break;
        default:
            log.warn("Received message {} during switch-driver " +
                             "subhandshake " + "from switch {} ... " +
                             "Ignoring message", m,
                     getStringId());

    }
}
项目：athena    文件：OfOpticalSwitchImplLinc13.java    
public void processOFPortStatus(OFCircuitPortStatus ps) {
    log.debug("LINC-OE ..OF Port Status :", ps);
}
项目：ravikumaran201504    文件：OFOpticalSwitchImplLINC13.java    
@Override
public void processDriverHandshakeMessage(OFMessage m) {
    if (!startDriverHandshakeCalled) {
        throw new SwitchDriverSubHandshakeNotStarted();
    }
    if (driverHandshakeComplete.get()) {
        throw new SwitchDriverSubHandshakeCompleted(m);
    }

    switch (m.getType()) {
        case BARRIER_REPLY:
            if (m.getXid() == barrierXidToWaitFor) {
                log.debug("LINC-OE Received barrier response");
            }
            break;
        case ERROR:
            log.error("Switch {} Error {}", getStringId(), m);
            break;
        case FEATURES_REPLY:
            break;
        case FLOW_REMOVED:
            break;
        case GET_ASYNC_REPLY:
            break;
        case PACKET_IN:
            break;
        case PORT_STATUS:
            log.warn("****LINC-OE Port Status {} {}", getStringId(), m);
            processOFPortStatus((OFCircuitPortStatus) m);
            break;
        case QUEUE_GET_CONFIG_REPLY:
            break;
        case ROLE_REPLY:
            break;
        case STATS_REPLY:
            OFStatsReply stats = (OFStatsReply) m;
            if (stats.getStatsType() == OFStatsType.EXPERIMENTER) {
                log.warn("LINC-OE : Received stats reply message {}", m);
                processHandshakeOFExperimenterPortDescRequest(
                        (OFCircuitPortsReply) m);
                driverHandshakeComplete.set(true);
            }
            break;
        default:
            log.warn("Received message {} during switch-driver " +
                             "subhandshake " + "from switch {} ... " +
                             "Ignoring message", m,
                     getStringId());

    }
}
项目：onos    文件：OplinkRoadmHandshaker.java    
@Override
public void processDriverHandshakeMessage(OFMessage m) {

    if (!startDriverHandshakeCalled) {
        throw new SwitchDriverSubHandshakeNotStarted();
    }

    if (driverHandshakeComplete.get()) {
        throw new SwitchDriverSubHandshakeCompleted(m);
    }

    switch (m.getType()) {
        case BARRIER_REPLY:
            log.debug("OPLK ROADM Received barrier response");
            break;
        case ERROR:
            log.error("Switch {} Error {}", getStringId(), m);
            break;
        case FEATURES_REPLY:
            break;
        case FLOW_REMOVED:
            break;
        case GET_ASYNC_REPLY:
            break;
        case PACKET_IN:
            break;
        case PORT_STATUS:
            processOFPortStatus((OFCircuitPortStatus) m);
            break;
        case QUEUE_GET_CONFIG_REPLY:
            break;
        case ROLE_REPLY:
            break;
        case STATS_REPLY:
            OFStatsReply stats = (OFStatsReply) m;
            if (stats.getStatsType() == OFStatsType.EXPERIMENTER) {
                log.debug("OPLK ROADM : Received multipart (port desc) reply message {}", m);
                //OTN Optical extension 1.0 port-desc
                createOpticalPortList((OFCircuitPortsReply) m);
                driverHandshakeComplete.set(true);
            }
            break;
        default:
            log.warn("Received message {} during switch-driver " +
                    "subhandshake from switch {} ... " +
                    "Ignoring message", m, getStringId());

    }
}
项目：onos    文件：OplinkRoadmHandshaker.java    
private void processOFPortStatus(OFCircuitPortStatus ps) {
    log.debug("OPLK ROADM ..OF Port Status :", ps);
}
项目：onos    文件：OfOpticalSwitchImplLinc13.java    
@Override
public void processDriverHandshakeMessage(OFMessage m) {
    if (!startDriverHandshakeCalled) {
        throw new SwitchDriverSubHandshakeNotStarted();
    }
    if (driverHandshakeComplete.get()) {
        throw new SwitchDriverSubHandshakeCompleted(m);
    }

    switch (m.getType()) {
        case BARRIER_REPLY:
            if (m.getXid() == barrierXidToWaitFor) {
                log.debug("LINC-OE Received barrier response");
            }
            break;
        case ERROR:
            log.error("Switch {} Error {}", getStringId(), m);
            break;
        case FEATURES_REPLY:
            break;
        case FLOW_REMOVED:
            break;
        case GET_ASYNC_REPLY:
            break;
        case PACKET_IN:
            break;
        case PORT_STATUS:
            log.debug("****LINC-OE Port Status {} {}", getStringId(), m);
            processOFPortStatus((OFCircuitPortStatus) m);
            break;
        case QUEUE_GET_CONFIG_REPLY:
            break;
        case ROLE_REPLY:
            break;
        case STATS_REPLY:
            OFStatsReply stats = (OFStatsReply) m;
            if (stats.getStatsType() == OFStatsType.EXPERIMENTER) {
                log.debug("LINC-OE : Received stats reply message {}", m);
                createOpticalPortList((OFCircuitPortsReply) m);
                driverHandshakeComplete.set(true);
            }
            break;
        default:
            log.warn("Received message {} during switch-driver " +
                             "subhandshake " + "from switch {} ... " +
                             "Ignoring message", m,
                     getStringId());

    }
}
项目：onos    文件：OfOpticalSwitchImplLinc13.java    
public void processOFPortStatus(OFCircuitPortStatus ps) {
    log.debug("LINC-OE ..OF Port Status :", ps);
}
项目：onos    文件：OplinkEdfaHandshaker.java    
private void processOFPortStatus(OFCircuitPortStatus ps) {
    log.debug("OPLK EDFA ..OF Port Status :", ps);
}
项目：ravikumaran201504    文件：OFOpticalSwitchImplLINC13.java    
public void processOFPortStatus(OFCircuitPortStatus ps) {
    log.debug("LINC-OE ..OF Port Status :", ps);

}