|
@@ -19,10 +19,10 @@ package org.apache.hadoop.hdfs.server.datanode.fsdataset.impl;
|
|
|
|
|
|
import java.io.File;
|
|
|
import java.io.IOException;
|
|
|
-import java.util.HashMap;
|
|
|
import java.util.Map;
|
|
|
import java.util.Map.Entry;
|
|
|
import java.util.Set;
|
|
|
+import java.util.concurrent.ConcurrentHashMap;
|
|
|
import java.util.concurrent.Executor;
|
|
|
import java.util.concurrent.LinkedBlockingQueue;
|
|
|
import java.util.concurrent.ThreadFactory;
|
|
@@ -54,7 +54,7 @@ class FsVolumeImpl implements FsVolumeSpi {
|
|
|
private final String storageID;
|
|
|
private final StorageType storageType;
|
|
|
private final Map<String, BlockPoolSlice> bpSlices
|
|
|
- = new HashMap<String, BlockPoolSlice>();
|
|
|
+ = new ConcurrentHashMap<String, BlockPoolSlice>();
|
|
|
private final File currentDir; // <StorageDirectory>/current
|
|
|
private final DF usage;
|
|
|
private final long reserved;
|