File tree Expand file tree Collapse file tree 1 file changed +1
-5
lines changed
core/client/fs/src/main/java/alluxio/client/file Expand file tree Collapse file tree 1 file changed +1
-5
lines changed Original file line number Diff line number Diff line change 6464import java .util .concurrent .ConcurrentHashMap ;
6565import java .util .concurrent .atomic .AtomicBoolean ;
6666import java .util .concurrent .atomic .AtomicReference ;
67- import java .util .concurrent .locks .Lock ;
68- import java .util .concurrent .locks .ReentrantLock ;
6967import javax .annotation .Nullable ;
7068import javax .annotation .concurrent .GuardedBy ;
7169import javax .annotation .concurrent .ThreadSafe ;
@@ -161,14 +159,12 @@ public class FileSystemContext implements Closeable {
161159 /** Whether to do URI scheme validation for file systems using this context. */
162160 private boolean mUriValidationEnabled = true ;
163161
164- private final Lock mWorkerInfoListLock = new ReentrantLock ();
165-
166162 /** Cached map for workers. */
167163 @ GuardedBy ("mWorkerInfoList" )
168164 private final AtomicReference <List <BlockWorkerInfo >> mWorkerInfoList = new AtomicReference <>();
169165
170166 /** The policy to refresh workers list. */
171- @ GuardedBy ("this " )
167+ @ GuardedBy ("mWorkerInfoList " )
172168 private final RefreshPolicy mWorkerRefreshPolicy ;
173169
174170 private final Map <Class , BlockLocationPolicy > mBlockLocationPolicyMap ;
You can’t perform that action at this time.
0 commit comments