void function ( File arg0 ) { if ( executors == null ) { throw new RuntimeException ( "srini_string" ) ; } ThreadPoolExecutor loc0 = executors . get ( arg0 ) ; if ( loc0 != null ) { throw new RuntimeException ( "srini_string" + arg0 + "srini_string" ) ; } addExecutorForVolume ( arg0 ) ; }
starts asyncdiskservice for a new volume concode_field_sep FsDatasetImpl fsdatasetImpl concode_elem_sep DataNode datanode concode_elem_sep Map<String,Set<Long>> deletedBlockIds concode_elem_sep int numDeletedBlocks concode_elem_sep Map<File,ThreadPoolExecutor> executors concode_elem_sep int MAXIMUM_THREADS_PER_VOLUME concode_elem_sep FsVolumeImpl volume concode_elem_sep ThreadGroup threadGroup concode_elem_sep File blockFile concode_elem_sep Log LOG concode_elem_sep String trashDirectory concode_elem_sep long THREADS_KEEP_ALIVE_SECONDS concode_elem_sep ExtendedBlock block concode_elem_sep int MAX_DELETED_BLOCKS concode_elem_sep FsVolumeReference volumeRef concode_elem_sep File metaFile concode_elem_sep int CORE_THREADS_PER_VOLUME concode_field_sep boolean deleteFiles concode_elem_sep void updateDeletedBlockId concode_elem_sep void addExecutorForVolume concode_elem_sep long countPendingDeletions concode_elem_sep void removeVolume concode_elem_sep void deleteAsync concode_elem_sep void run concode_elem_sep String toString concode_elem_sep boolean moveFiles concode_elem_sep void execute concode_elem_sep void submitSyncFileRangeRequest concode_elem_sep void shutdown