@Test public void isCompleteTest() throws SuspectedFileSizeException, BlockInfoException { InodeFile inodeFile = new InodeFile("testFile1", 1, 0, 1000, System.currentTimeMillis()); Assert.assertFalse(inodeFile.isComplete()); inodeFile.setComplete(); Assert.assertTrue(inodeFile.isComplete()); }
public synchronized boolean isComplete() { return mIsComplete; }
InodeFile extends Inode { public synchronized boolean isComplete() { return mIsComplete; } }
InodeFile extends Inode { public synchronized boolean isComplete() { return mIsComplete; } InodeFile(String name, int id, int parentId, long blockSizeByte, long creationTimeMs); }
InodeFile extends Inode { public synchronized boolean isComplete() { return mIsComplete; } InodeFile(String name, int id, int parentId, long blockSizeByte, long creationTimeMs); synchronized void addBlock(BlockInfo blockInfo); synchronized void addLocation(int blockIndex, long workerId, NetAddress workerAddress); @Override ClientFileInfo generateClientFileInfo(String path); long getBlockIdBasedOnOffset(long offset); synchronized List<Long> getBlockIds(); synchronized List<Pair<Long, Long>> getBlockIdWorkerIdPairs(); List<BlockInfo> getBlockList(); synchronized List<NetAddress> getBlockLocations(int blockIndex); long getBlockSizeByte(); synchronized String getUfsPath(); synchronized ClientBlockInfo getClientBlockInfo(int blockIndex); synchronized List<ClientBlockInfo> getClientBlockInfos(); synchronized int getDependencyId(); synchronized long getLength(); synchronized long getNewBlockId(); synchronized int getNumberOfBlocks(); synchronized boolean hasCheckpointed(); synchronized boolean isCache(); synchronized boolean isComplete(); synchronized boolean isFullyInMemory(); synchronized void removeLocation(int blockIndex, long workerId); synchronized void setCache(boolean cache); synchronized void setUfsPath(String ufsPath); synchronized void setComplete(); synchronized void setComplete(boolean complete); synchronized void setDependencyId(int dependencyId); synchronized void setLength(long length); @Override String toString(); @Override synchronized void writeImage(ObjectWriter objWriter, DataOutputStream dos); }
InodeFile extends Inode { public synchronized boolean isComplete() { return mIsComplete; } InodeFile(String name, int id, int parentId, long blockSizeByte, long creationTimeMs); synchronized void addBlock(BlockInfo blockInfo); synchronized void addLocation(int blockIndex, long workerId, NetAddress workerAddress); @Override ClientFileInfo generateClientFileInfo(String path); long getBlockIdBasedOnOffset(long offset); synchronized List<Long> getBlockIds(); synchronized List<Pair<Long, Long>> getBlockIdWorkerIdPairs(); List<BlockInfo> getBlockList(); synchronized List<NetAddress> getBlockLocations(int blockIndex); long getBlockSizeByte(); synchronized String getUfsPath(); synchronized ClientBlockInfo getClientBlockInfo(int blockIndex); synchronized List<ClientBlockInfo> getClientBlockInfos(); synchronized int getDependencyId(); synchronized long getLength(); synchronized long getNewBlockId(); synchronized int getNumberOfBlocks(); synchronized boolean hasCheckpointed(); synchronized boolean isCache(); synchronized boolean isComplete(); synchronized boolean isFullyInMemory(); synchronized void removeLocation(int blockIndex, long workerId); synchronized void setCache(boolean cache); synchronized void setUfsPath(String ufsPath); synchronized void setComplete(); synchronized void setComplete(boolean complete); synchronized void setDependencyId(int dependencyId); synchronized void setLength(long length); @Override String toString(); @Override synchronized void writeImage(ObjectWriter objWriter, DataOutputStream dos);  }