Package com.orientechnologies.orient.core.storage.fs

Class AsyncFile

java.lang.Object

com.orientechnologies.orient.core.storage.fs.AsyncFile

All Implemented Interfaces:

OClosableItem, OFile

public final class AsyncFile
extends Object
implements OFile

Field Summary

Fields inherited from interface com.orientechnologies.orient.core.storage.fs.OFile

HEADER_SIZE

Constructor Summary

Constructors

Constructor	Description
AsyncFile(Path osFile, int pageSize, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
long	allocateSpace(int size)
void	close()
void	create()
void	delete()
boolean	exists()
long	getFileSize()
String	getName()
boolean	isOpen()
void	open()
void	read(long offset, ByteBuffer buffer, boolean throwOnEof)
void	renameTo(Path newFile)
void	replaceContentWith(Path newContentFile)
void	shrink(long size)
void	synch()
void	write(long offset, ByteBuffer buffer)
IOResult	write(List<ORawPair<Long,ByteBuffer>> buffers)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.orientechnologies.orient.core.storage.fs.OFile

toString

Constructor Details

AsyncFile

public AsyncFile(Path osFile,
 int pageSize,
 ExecutorService executor)

Method Details

create

public void create()
            throws IOException

Specified by:

create in interface OFile

Throws:

IOException

open

public void open()

Specified by:

open in interface OClosableItem

Specified by:

open in interface OFile

getFileSize

public long getFileSize()

Specified by:

getFileSize in interface OFile

getName

public String getName()

Specified by:

getName in interface OFile

isOpen

public boolean isOpen()

Specified by:

isOpen in interface OClosableItem

Specified by:

isOpen in interface OFile

exists

public boolean exists()

Specified by:

exists in interface OFile

write

public void write(long offset,
 ByteBuffer buffer)

Specified by:

write in interface OFile

write

public IOResult write(List<ORawPair<Long,ByteBuffer>> buffers)

Specified by:

write in interface OFile

read

public void read(long offset,
 ByteBuffer buffer,
 boolean throwOnEof)
          throws IOException

Specified by:

read in interface OFile

Throws:

IOException

allocateSpace

public long allocateSpace(int size)

Specified by:

allocateSpace in interface OFile

shrink

public void shrink(long size)
            throws IOException

Specified by:

shrink in interface OFile

Throws:

IOException

synch

public void synch()

Specified by:

synch in interface OFile

close

public void close()

Specified by:

close in interface OClosableItem

Specified by:

close in interface OFile

delete

public void delete()
            throws IOException

Specified by:

delete in interface OFile

Throws:

IOException

renameTo

public void renameTo(Path newFile)
              throws IOException

Specified by:

renameTo in interface OFile

Throws:

IOException

replaceContentWith

public void replaceContentWith(Path newContentFile)
                        throws IOException

Specified by:

replaceContentWith in interface OFile

Throws:

IOException