public void startMonitorThread() { crmLock.lock(); try { if (this.monitor == null) { this.monitor = new CacheReplicationMonitor(namesystem, this, scanIntervalMs, crmLock); this.monitor.start(); } } finally { crmLock.unlock(); } }
public void stopMonitorThread() { crmLock.lock(); try { if (this.monitor != null) { CacheReplicationMonitor prevMonitor = this.monitor; this.monitor = null; IOUtils.closeQuietly(prevMonitor); } } finally { crmLock.unlock(); } }
public static void enableHdfsCachingTracing() { LogManager.getLogger(CacheReplicationMonitor.class.getName()).setLevel( Level.TRACE); LogManager.getLogger(CacheManager.class.getName()).setLevel( Level.TRACE); LogManager.getLogger(FsDatasetCache.class.getName()).setLevel( Level.TRACE); }