public void deletePaths()

in src/main/java/com/netflix/bdp/s3mper/metastore/impl/MetastoreJanitor.java [139:158]

• 14 lines of code
• 2 McCabe index (conditional complexity)

    public void deletePaths(TimeUnit unit, long time) throws Exception {
        log.info("Starting Full Path Delete");
        log.info(format("read_units=%d, write_units=%d, queue_size=%d, scan_threads=%d, delete_threads=%d", scanLimit, deleteLimit, queueSize, scanThreads, deleteThreads));
        
        executor = Executors.newFixedThreadPool(scanThreads+deleteThreads);
        
        log.info(format("Scanning for items older than: %d (ms)", unit.toMillis(time)));
        
        for (int i = 0; i < scanThreads; i++) {
            PathScannerTask scanner = new PathScannerTask(db, scanLimiter, queue, queueSize, unit.toMillis(time));
            
            tasks.add(scanner);
            Future scanFuture = executor.submit(scanner);
            
            futures.add(scanFuture);
            scanFutures.add(scanFuture);
        }
        
        processDelete();
    }