protected synchronized void clearBuffers(){
  while (m_firstBuffer.size() > 0 && m_secondBuffer.size() > 0) {
    m_throughput.updateStart();
    Instance newInst=processBuffers();
    m_throughput.updateEnd(m_log);
    if (newInst != null) {
      m_ie.setInstance(newInst);
      m_ie.setStatus(InstanceEvent.INSTANCE_AVAILABLE);
      notifyInstanceListeners(m_ie);
    }
  }
  m_ie.setInstance(null);
  m_ie.setStatus(InstanceEvent.BATCH_FINISHED);
  notifyInstanceListeners(m_ie);
  if (m_log != null) {
    m_log.statusMessage(statusMessagePrefix() + "Finished");
  }
  m_headerOne=null;
  m_headerTwo=null;
  m_mergedHeader=null;
  m_firstBuffer=null;
  m_secondBuffer=null;
  m_firstFinished=false;
  m_secondFinished=false;
  m_busy=false;
}

protected synchronized void clearBuffers ( ) { while ( m_firstBuffer . size ( ) > 0 && m_secondBuffer . size ( ) > 0 ) { m_throughput . updateStart ( ) ; Instance newInst = processBuffers ( ) ; m_throughput . updateEnd ( m_log ) ; if ( newInst != null ) { m_ie . setInstance ( newInst ) ; m_ie . setStatus ( InstanceEvent . INSTANCE_AVAILABLE ) ; notifyInstanceListeners ( m_ie ) ; } } m_ie . setInstance ( null ) ; m_ie . setStatus ( InstanceEvent . BATCH_FINISHED ) ; notifyInstanceListeners ( m_ie ) ; if ( m_log != null ) { m_log . statusMessage ( statusMessagePrefix ( ) + "Finished" ) ; } m_headerOne = null ; m_headerTwo = null ; m_mergedHeader = null ; m_firstBuffer = null ; m_secondBuffer = null ; m_firstFinished = false ; m_secondFinished = false ; m_busy = false ; }
clear remaining instances in the buffers
