@Test public void testMultipleCheckIn() throws Exception { mManager.acquire(mUfs, FILE_NAME, FILE_ID, OpenOptions.defaults().setOffset(2)); mManager.acquire(mUfs, FILE_NAME, FILE_ID, OpenOptions.defaults().setOffset(4)); mManager.acquire(mUfs, FILE_NAME, FILE_ID, OpenOptions.defaults().setOffset(6)); verify(mUfs, times(3)).openExistingFile(eq(FILE_NAME), any(OpenOptions.class)); }
public InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions) throws IOException { return acquire(ufs, path, fileId, openOptions, true); }
UfsInputStreamManager { public InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions) throws IOException { return acquire(ufs, path, fileId, openOptions, true); } }
UfsInputStreamManager { public InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions) throws IOException { return acquire(ufs, path, fileId, openOptions, true); } UfsInputStreamManager(); }
UfsInputStreamManager { public InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions) throws IOException { return acquire(ufs, path, fileId, openOptions, true); } UfsInputStreamManager(); void release(InputStream inputStream); void invalidate(CachedSeekableInputStream inputStream); InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions); InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions,
      boolean reuse); }
UfsInputStreamManager { public InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions) throws IOException { return acquire(ufs, path, fileId, openOptions, true); } UfsInputStreamManager(); void release(InputStream inputStream); void invalidate(CachedSeekableInputStream inputStream); InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions); InputStream acquire(UnderFileSystem ufs, String path, long fileId, OpenOptions openOptions,
      boolean reuse);  }