import org.openflow.protocol.OFFeaturesRequest; //导入依赖的package包/类
@Override
void processOFFeaturesRequest(final ControllerChannelHandler h,
        final OFFeaturesRequest m) {
    final OFFeaturesReply reply = h.sw.getFeaturesReply();
    if (reply == null) {
        h.log.error("OVXSwitch failed to return a featuresReply message: {}"
                + h.sw.getSwitchName());
        h.channel.disconnect();
    }
    reply.setXid(m.getXid());
    h.channel.write(Collections.singletonList(reply));
    h.log.info("Connected dpid {} to controller {}",
            h.sw.getSwitchName(), h.channel.getRemoteAddress());
    h.sw.setConnected(true);
    h.setState(ACTIVE);
}
 

import org.openflow.protocol.OFFeaturesRequest; //导入依赖的package包/类
@Override
public Future<OFFeaturesReply> getFeaturesReplyFromSwitch()
        throws IOException {
    OFMessage request = new OFFeaturesRequest();
    request.setXid(getNextTransactionId());
    OFFeaturesReplyFuture future =
            new OFFeaturesReplyFuture(threadPool, this, request.getXid());
    this.featuresFutureMap.put(request.getXid(), future);
    List<OFMessage> msglist = new ArrayList<OFMessage>(1);
    msglist.add(request);
    this.channel.write(msglist);
    return future;
}
 

import org.openflow.protocol.OFFeaturesRequest; //导入依赖的package包/类
@Override
void processOFMessage(final ControllerChannelHandler h,
        final OFMessage m) throws IOException {

    switch (m.getType()) {
    case HELLO:
        this.processOFHello(h, (OFHello) m);
        break;
    case ECHO_REPLY:
        break;
    case ECHO_REQUEST:
        this.processOFEchoRequest(h, (OFEchoRequest) m);
        break;

    case FEATURES_REQUEST:
        this.processOFFeaturesRequest(h, (OFFeaturesRequest) m);
        break;
    case BARRIER_REQUEST:
        // TODO: actually implement barrier contract
        final OFBarrierReply breply = new OFBarrierReply();
        breply.setXid(m.getXid());
        h.channel.write(Collections.singletonList(breply));
        break;
    case SET_CONFIG:
    case ERROR:
    case PACKET_OUT:
    case PORT_MOD:
    case QUEUE_GET_CONFIG_REQUEST:
    case STATS_REQUEST:
    case FLOW_MOD:
    case GET_CONFIG_REQUEST:
        h.sw.handleIO(m, h.channel);
        break;
    case VENDOR:
        processOFVendor(h, (OFVendor) m);
        break;
    case FEATURES_REPLY:
    case FLOW_REMOVED:
    case PACKET_IN:
    case PORT_STATUS:
    case BARRIER_REPLY:
    case GET_CONFIG_REPLY:
    case STATS_REPLY:
    case QUEUE_GET_CONFIG_REPLY:
        this.illegalMessageReceived(h, m);
        break;
    default:
        break;
    }
}