Fix a typo in FileSystemContext.

Alluxio · Mar 16, 2016 · efc2e13 · efc2e13
1 parent 68e7ac0
commit efc2e13
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 11 deletions.
diff --git a/core/client/src/main/java/alluxio/client/file/FileInStream.java b/core/client/src/main/java/alluxio/client/file/FileInStream.java
@@ -231,9 +231,9 @@ private void checkAndAdvanceBlockInStream() throws IOException {
         try {
           long blockSize = getCurrentBlockSize();
           WorkerNetAddress address = mLocationPolicy.getWorkerForNextBlock(
-              mContext.getAluxioBlockStore().getWorkerInfoList(), blockSize);
+              mContext.getAlluxioBlockStore().getWorkerInfoList(), blockSize);
           mCurrentCacheStream =
-              mContext.getAluxioBlockStore().getOutStream(currentBlockId, blockSize, address);
+              mContext.getAlluxioBlockStore().getOutStream(currentBlockId, blockSize, address);
         } catch (IOException e) {
           LOG.warn(BLOCK_ID_NOT_CACHED, currentBlockId, e);
           mShouldCacheCurrentBlock = false;
@@ -311,9 +311,9 @@ private void seekBlockInStream(long newPos) throws IOException {
         try {
           long blockSize = getCurrentBlockSize();
           WorkerNetAddress address = mLocationPolicy.getWorkerForNextBlock(
-              mContext.getAluxioBlockStore().getWorkerInfoList(), blockSize);
+              mContext.getAlluxioBlockStore().getWorkerInfoList(), blockSize);
           mCurrentCacheStream =
-              mContext.getAluxioBlockStore().getOutStream(currentBlockId, blockSize, address);
+              mContext.getAlluxioBlockStore().getOutStream(currentBlockId, blockSize, address);
         } catch (IOException e) {
           LOG.warn(BLOCK_ID_NOT_CACHED, getCurrentBlockId(), e);
           mShouldCacheCurrentBlock = false;
@@ -342,13 +342,13 @@ private void updateBlockInStream(long blockId) throws IOException {
     try {
       if (mAlluxioStorageType.isPromote()) {
         try {
-          mContext.getAluxioBlockStore().promote(blockId);
+          mContext.getAlluxioBlockStore().promote(blockId);
         } catch (IOException e) {
           // Failed to promote
           LOG.warn("Promotion of block with ID {} failed.", blockId, e);
         }
       }
-      mCurrentBlockInStream = mContext.getAluxioBlockStore().getInStream(blockId);
+      mCurrentBlockInStream = mContext.getAlluxioBlockStore().getInStream(blockId);
       mShouldCacheCurrentBlock =
           !(mCurrentBlockInStream instanceof LocalBlockInStream) && mAlluxioStorageType.isStore();
     } catch (IOException e) {

diff --git a/core/client/src/main/java/alluxio/client/file/FileOutStream.java b/core/client/src/main/java/alluxio/client/file/FileOutStream.java
@@ -262,9 +262,9 @@ private void getNextBlock() throws IOException {
     if (mAlluxioStorageType.isStore()) {
       try {
         WorkerNetAddress address = mLocationPolicy
-            .getWorkerForNextBlock(mContext.getAluxioBlockStore().getWorkerInfoList(), mBlockSize);
+            .getWorkerForNextBlock(mContext.getAlluxioBlockStore().getWorkerInfoList(), mBlockSize);
         mCurrentBlockOutStream =
-            mContext.getAluxioBlockStore().getOutStream(getNextBlockId(), mBlockSize, address);
+            mContext.getAlluxioBlockStore().getOutStream(getNextBlockId(), mBlockSize, address);
         mShouldCacheCurrentBlock = true;
       } catch (AlluxioException e) {
         throw new IOException(e);

diff --git a/core/client/src/main/java/alluxio/client/file/FileSystemContext.java b/core/client/src/main/java/alluxio/client/file/FileSystemContext.java
@@ -63,7 +63,7 @@ public void releaseMasterClient(FileSystemMasterClient masterClient) {
   /**
    * @return the Alluxio block store
    */
-  public AlluxioBlockStore getAluxioBlockStore() {
+  public AlluxioBlockStore getAlluxioBlockStore() {
     return mAlluxioBlockStore;
   }
 

diff --git a/core/client/src/test/java/alluxio/client/file/FileInStreamTest.java b/core/client/src/test/java/alluxio/client/file/FileInStreamTest.java
@@ -81,7 +81,7 @@ public void before() throws IOException {
 
     mContext = PowerMockito.mock(FileSystemContext.class);
     mBlockStore = PowerMockito.mock(AlluxioBlockStore.class);
-    Mockito.when(mContext.getAluxioBlockStore()).thenReturn(mBlockStore);
+    Mockito.when(mContext.getAlluxioBlockStore()).thenReturn(mBlockStore);
 
     // Set up BufferedBlockInStreams and caching streams
     mCacheStreams = Lists.newArrayList();

diff --git a/core/client/src/test/java/alluxio/client/file/FileOutStreamTest.java b/core/client/src/test/java/alluxio/client/file/FileOutStreamTest.java
@@ -95,7 +95,7 @@ public void before() throws Exception {
     mFileSystemMasterClient = PowerMockito.mock(FileSystemMasterClient.class);
     mBlockWorkerClient = PowerMockito.mock(BlockWorkerClient.class);
 
-    Mockito.when(mFileSystemContext.getAluxioBlockStore()).thenReturn(mBlockStore);
+    Mockito.when(mFileSystemContext.getAlluxioBlockStore()).thenReturn(mBlockStore);
     Mockito.when(mBlockStoreContext.acquireWorkerClient()).thenReturn(mBlockWorkerClient);
     Mockito.when(mFileSystemContext.acquireMasterClient()).thenReturn(mFileSystemMasterClient);
     Mockito.when(mFileSystemMasterClient.getStatus(Mockito.any(AlluxioURI.class))).thenReturn(