Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added synchronized when iterating over synchronizedList as per Java specification

This commit is contained in:
emopers 2015-12-28 08:59:56 -06:00 committed by Wajihulhassan
parent a0249da8a7
commit 3c6c1d973c
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NNStorage.java
View File

@ -836,8 +836,10 @@ public class NNStorage extends Storage implements Closeable,
* @param sds A list of storage directories to mark as errored.
*/
void reportErrorsOnDirectories(List<StorageDirectory> sds) {
for (StorageDirectory sd : sds) {
reportErrorsOnDirectory(sd);
synchronized(sds) {
for (StorageDirectory sd : sds) {
reportErrorsOnDirectory(sd);
}
}
}