protected void processBDDPLists(){
  int count=0;
  Set<NodePortTuple> nptList=new HashSet<NodePortTuple>();
  while (count < BDDP_TASK_SIZE && quarantineQueue.peek() != null) {
    NodePortTuple npt;
    npt=quarantineQueue.remove();
    sendDiscoveryMessage(npt.getNodeId(),npt.getPortId(),false,false);
    nptList.add(npt);
    count++;
  }
  count=0;
  while (count < BDDP_TASK_SIZE && maintenanceQueue.peek() != null) {
    NodePortTuple npt;
    npt=maintenanceQueue.remove();
    sendDiscoveryMessage(npt.getNodeId(),npt.getPortId(),false,false);
    count++;
  }
  for (  NodePortTuple npt : nptList) {
    generateSwitchPortStatusUpdate(npt.getNodeId(),npt.getPortId());
  }
}

protected void processBDDPLists ( ) { int count = 0 ; Set < NodePortTuple > nptList = new HashSet < NodePortTuple > ( ) ; while ( count < BDDP_TASK_SIZE && quarantineQueue . peek ( ) != null ) { NodePortTuple npt ; npt = quarantineQueue . remove ( ) ; sendDiscoveryMessage ( npt . getNodeId ( ) , npt . getPortId ( ) , false , false ) ; nptList . add ( npt ) ; count ++ ; } count = 0 ; while ( count < BDDP_TASK_SIZE && maintenanceQueue . peek ( ) != null ) { NodePortTuple npt ; npt = maintenanceQueue . remove ( ) ; sendDiscoveryMessage ( npt . getNodeId ( ) , npt . getPortId ( ) , false , false ) ; count ++ ; } for ( NodePortTuple npt : nptList ) { generateSwitchPortStatusUpdate ( npt . getNodeId ( ) , npt . getPortId ( ) ) ; } }
this method processes the quarantine list in bursts . the task is at most once per bddp_task_interval . one each call , bddp_task_size number of switch ports are processed . once the bddp packets are sent out through the switch ports , the ports are removed from the quarantine list .
