@Override public void reconcileFlow(OFMatchReconcile ofmRcIn,EventPriority priority){
  if (ofmRcIn == null)   return;
  OFMatchReconcile myOfmRc=new OFMatchReconcile(ofmRcIn);
  flowQueue.offer(myOfmRc,priority);
  ctrFlowReconcileRequest.updateCounterWithFlush();
  Date currTime=new Date();
  long delay=0;
  if (currTime.after(new Date(lastReconcileTime.getTime() + 1000))) {
    delay=0;
  }
 else {
    delay=FLOW_RECONCILE_DELAY_MILLISEC;
  }
  flowReconcileTask.reschedule(delay,TimeUnit.MILLISECONDS);
  if (logger.isTraceEnabled()) {
    logger.trace("Reconciling flow: {}, total: {}",myOfmRc.toString(),flowQueue.size());
  }
}

@ Override public void reconcileFlow ( OFMatchReconcile ofmRcIn , EventPriority priority ) { if ( ofmRcIn == null ) return ; OFMatchReconcile myOfmRc = new OFMatchReconcile ( ofmRcIn ) ; flowQueue . offer ( myOfmRc , priority ) ; ctrFlowReconcileRequest . updateCounterWithFlush ( ) ; Date currTime = new Date ( ) ; long delay = 0 ; if ( currTime . after ( new Date ( lastReconcileTime . getTime ( ) + 1000 ) ) ) { delay = 0 ; } else { delay = FLOW_RECONCILE_DELAY_MILLISEC ; } flowReconcileTask . reschedule ( delay , TimeUnit . MILLISECONDS ) ; if ( logger . isTraceEnabled ( ) ) { logger . trace ( "Reconciling flow: {}, total: {}" , myOfmRc . toString ( ) , flowQueue . size ( ) ) ; } }
add to - be - reconciled flow to the queue .
