public void run()

in src/main/java/com/microsoft/azure/datalake/store/ContentSummaryProcessor.java [64:85]

• 21 lines of code
• 6 McCabe index (conditional complexity)

        public void run() {
            try {
                DirectoryEntry de;
                while ((de = queue.poll()) != null) {
                    try {
                        if (de.type == DirectoryEntryType.DIRECTORY) {  // we should only ever get directories here
                            processDirectoryTree(de.fullName);
                        }
                    } catch (ADLException ex) {
                        if (ex.httpResponseCode == 404) {
                            // swallow - the file or directory got deleted after we enumerated it
                        } else {
                            throw ex;
                        }
                    } finally {
                        queue.unregister();
                    }
                }
            } catch (IOException ex) {
                throw new RuntimeException("IOException processing Directory tree", ex);
            }
        }