TransactionalRegionServer.java 文件源码

/**
 * {@inheritDoc}
 */
@Override
protected void handleReportForDutyResponse(final MapWritable c)
        throws IOException {
    super.handleReportForDutyResponse(c);
    initializeTHLog();
    String n = Thread.currentThread().getName();
    UncaughtExceptionHandler handler = new UncaughtExceptionHandler() {

        public void uncaughtException(final Thread t, final Throwable e) {
            abort("Set stop flag in " + t.getName(), e);
            LOG.fatal("Set stop flag in " + t.getName(), e);
        }
    };
    setDaemonThreadRunning(this.cleanOldTransactionsThread, n
            + ".oldTransactionCleaner", handler);
    setDaemonThreadRunning(this.transactionLeases,
            "Transactional leases");
}