??????
        
??????????????????????????????????????????????????????????????????????500k??????????????????????????????????FLUSH_SLAVE_TIMEOUT??????????syncFlushTimeout=30000??????????FLUSH_SLAVE_TIMEOUT??????????????


public boolean waitForFlush(long timeout){
??      this.countDownLatch.await(timeout,TimeUnit.MILISECONDS);
return this.flushOK;
??
}


countDownLatch??????HAService#doWaitTransfer??req.wakeupCustomer(transferOK)??????


??????????????????slave??????master????????offset(????5??),????HAService#doWaitTransfer??5??????????????req.getNextOffset()????????transferOK=false??


????????????????????????


??????

Reply via email to