mAvailableSpaceBytes = 0L;
mExecutorService =
Executors.newFixedThreadPool(2, ThreadFactoryUtils.daemon("client-heartbeat-%d"));
mMasterClient =
mCloser.register(new MasterClient(mMasterAddress, mZookeeperMode, mExecutorService));
<BUG>mWorkerClient = mCloser.register(new WorkerClient(mMasterClient, mExecutorService));
}</BUG>
synchronized void accessLocalBlock(long blockId) throws IOException {
if (mWorkerClient.isLocal()) {
mWorkerClient.accessBlock(blockId);

mAvailableSpaceBytes = 0L;
mExecutorService =
Executors.newFixedThreadPool(2, ThreadFactoryUtils.daemon("client-heartbeat-%d"));
mMasterClient =
mCloser.register(new MasterClient(mMasterAddress, mZookeeperMode, mExecutorService));
mWorkerClient = mCloser.register(new WorkerClient(mMasterClient, mExecutorService));
String scheme = mZookeeperMode ? Constants.SCHEME_FT : Constants.SCHEME;
String authority = mMasterAddress.getHostName() + ":" + mMasterAddress.getPort();
mRootUri = new TachyonURI(scheme, authority, TachyonURI.SEPARATOR);
}
synchronized void accessLocalBlock(long blockId) throws IOException {
if (mWorkerClient.isLocal()) {
mWorkerClient.accessBlock(blockId);
