Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
elega committed Oct 8, 2022
1 parent f3b2c60 commit b01cbe4
Showing 1 changed file with 1 addition and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -64,8 +64,6 @@
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import javax.annotation.Nullable;
import javax.annotation.concurrent.GuardedBy;
import javax.annotation.concurrent.ThreadSafe;
Expand Down Expand Up @@ -161,14 +159,12 @@ public class FileSystemContext implements Closeable {
/** Whether to do URI scheme validation for file systems using this context. */
private boolean mUriValidationEnabled = true;

private final Lock mWorkerInfoListLock = new ReentrantLock();

/** Cached map for workers. */
@GuardedBy("mWorkerInfoList")
private final AtomicReference<List<BlockWorkerInfo>> mWorkerInfoList = new AtomicReference<>();

/** The policy to refresh workers list. */
@GuardedBy("this")
@GuardedBy("mWorkerInfoList")
private final RefreshPolicy mWorkerRefreshPolicy;

private final Map<Class, BlockLocationPolicy> mBlockLocationPolicyMap;
Expand Down

0 comments on commit b01cbe4

Please sign in to comment.