import net.floodlightcontroller.core.internal.OFFeaturesReplyFuture; //导入依赖的package包/类
public OFSwitchBase() {
    this.stringId = null;
    this.attributes = new ConcurrentHashMap<Object, Object>();
    this.connectedSince = new Date();
    this.transactionIdSource = new AtomicInteger();
    this.portLock = new Object();
    this.portsByNumber = new ConcurrentHashMap<Short, OFPhysicalPort>();
    this.portsByName = new ConcurrentHashMap<String, OFPhysicalPort>();
    this.connected = true;
    this.statsFutureMap = new ConcurrentHashMap<Integer,OFStatisticsFuture>();
    this.featuresFutureMap = new ConcurrentHashMap<Integer,OFFeaturesReplyFuture>();
    this.iofMsgListenersMap = new ConcurrentHashMap<Integer,IOFMessageListener>();
    this.role = null;
    this.timedCache = new TimedCache<Long>(100, 5*1000 );  // 5 seconds interval
    this.listenerLock = new ReentrantReadWriteLock();
    this.portBroadcastCacheHitMap = new ConcurrentHashMap<Short, AtomicLong>();

    // Defaults properties for an ideal switch
    this.setAttribute(PROP_FASTWILDCARDS, OFMatch.OFPFW_ALL);
    this.setAttribute(PROP_SUPPORTS_OFPP_FLOOD, new Boolean(true));
    this.setAttribute(PROP_SUPPORTS_OFPP_TABLE, new Boolean(true));
}
 

import net.floodlightcontroller.core.internal.OFFeaturesReplyFuture; //导入依赖的package包/类
public OFSwitchBase() {
    this.stringId = null;
    this.attributes = new ConcurrentHashMap<Object, Object>();
    this.connectedSince = new Date();
    this.transactionIdSource = new AtomicInteger();
    this.portLock = new Object();
    this.portsByNumber = new ConcurrentHashMap<Short, OFPhysicalPort>();
    this.portsByName = new ConcurrentHashMap<String, OFPhysicalPort>();
    this.connected = true;
    this.statsFutureMap = new ConcurrentHashMap<Integer,OFStatisticsFuture>();
    this.featuresFutureMap = new ConcurrentHashMap<Integer,OFFeaturesReplyFuture>();
    this.iofMsgListenersMap = new ConcurrentHashMap<Integer,IOFMessageListener>();
    this.role = null;
    this.timedCache = new TimedCache<Long>(100, 5*1000 );  // 5 seconds interval
    this.listenerLock = new ReentrantReadWriteLock();
    this.portBroadcastCacheHitMap = new ConcurrentHashMap<Short, Long>();
    
    // Defaults properties for an ideal switch
    this.setAttribute(PROP_FASTWILDCARDS, OFMatch.OFPFW_ALL);
    this.setAttribute(PROP_SUPPORTS_OFPP_FLOOD, new Boolean(true));
    this.setAttribute(PROP_SUPPORTS_OFPP_TABLE, new Boolean(true));
}
 

import net.floodlightcontroller.core.internal.OFFeaturesReplyFuture; //导入依赖的package包/类
public OFSwitchBase() {
    this.stringId = null;
    this.attributes = new ConcurrentHashMap<Object, Object>();
    this.connectedSince = null;
    this.transactionIdSource = new AtomicInteger();
    this.connected = false;
    this.statsFutureMap = new ConcurrentHashMap<Integer,OFStatisticsFuture>();
    this.featuresFutureMap = new ConcurrentHashMap<Integer,OFFeaturesReplyFuture>();
    this.iofMsgListenersMap = new ConcurrentHashMap<Integer,IOFMessageListener>();
    this.role = null;
    this.timedCache = new TimedCache<Long>(100, 5*1000 );  // 5 seconds interval
    this.portBroadcastCacheHitMap = new ConcurrentHashMap<Short, AtomicLong>();
    this.description = new OFDescriptionStatistics();
    this.lastMessageTime = System.currentTimeMillis();

    this.portManager = new PortManager();

    // Defaults properties for an ideal switch
    this.setAttribute(PROP_FASTWILDCARDS, OFMatch.OFPFW_ALL);
    this.setAttribute(PROP_SUPPORTS_OFPP_FLOOD, Boolean.valueOf(true));
    this.setAttribute(PROP_SUPPORTS_OFPP_TABLE, Boolean.valueOf(true));
    if (packetInRateThresholdHigh == 0) {
        packetInRateThresholdHigh = Integer.MAX_VALUE;
    } else {
        packetInRateThresholdLow = packetInRateThresholdHigh / 2;
    }
}
 

import net.floodlightcontroller.core.internal.OFFeaturesReplyFuture; //导入依赖的package包/类
@Override
public Future<OFFeaturesReply> querySwitchFeaturesReply()
        throws IOException {
    OFMessage request =
            floodlightProvider.getOFMessageFactory().
                getMessage(OFType.FEATURES_REQUEST);
    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.write(msglist);
    return future;
}
 

import net.floodlightcontroller.core.internal.OFFeaturesReplyFuture; //导入依赖的package包/类
@Override
public void deliverOFFeaturesReply(OFMessage reply) {
    OFFeaturesReplyFuture future = this.featuresFutureMap.get(reply.getXid());
    if (future != null) {
        future.deliverFuture(this, reply);
        // The future will ultimately unregister itself and call
        // cancelFeaturesReply
        return;
    }
    log.error("Switch {}: received unexpected featureReply", this);
}
 

import net.floodlightcontroller.core.internal.OFFeaturesReplyFuture; //导入依赖的package包/类
@Override
public Future<OFFeaturesReply> querySwitchFeaturesReply()
        throws IOException {
    OFMessage request = 
            floodlightProvider.getOFMessageFactory().
                getMessage(OFType.FEATURES_REQUEST);
    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.write(msglist);
    return future;
}
 

import net.floodlightcontroller.core.internal.OFFeaturesReplyFuture; //导入依赖的package包/类
@Override
public Future<OFFeaturesReply> querySwitchFeaturesReply()
        throws IOException {
    OFMessage request = 
            floodlightProvider.getOFMessageFactory().
                getMessage(OFType.FEATURES_REQUEST);
    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;
}