|
@@ -132,7 +132,9 @@ class PendingReconstructionBlocks {
|
|
public void clear() {
|
|
public void clear() {
|
|
synchronized (pendingReconstructions) {
|
|
synchronized (pendingReconstructions) {
|
|
pendingReconstructions.clear();
|
|
pendingReconstructions.clear();
|
|
- timedOutItems.clear();
|
|
|
|
|
|
+ synchronized (timedOutItems) {
|
|
|
|
+ timedOutItems.clear();
|
|
|
|
+ }
|
|
timedOutCount = 0L;
|
|
timedOutCount = 0L;
|
|
}
|
|
}
|
|
}
|
|
}
|