org.treetank.access

Class FilelistenerWriteTrx

java.lang.Object

org.treetank.access.FilelistenerWriteTrx

All Implemented Interfaces:

IFilelistenerReadTrx, IFilelistenerWriteTrx

public class FilelistenerWriteTrx
extends Object
implements IFilelistenerWriteTrx

Author:

Andreas Rain

Constructor Summary

Constructors

Constructor and Description
FilelistenerWriteTrx(IBucketWriteTrx pPageTrx, ISession pSession)

Method Summary

Methods

Modifier and Type	Method and Description
void	abort() Abort all modifications of the exclusive write transaction.
void	addEmptyFile(String pRelativePath) Add an empty file in case of ENTRY_CREATE event.
void	addFile(File pFile, String pRelativePath) Add a new file to the system
void	close() Close this transaction
void	commit() Non-blocking commit in TT
void	commitBlocked() Blocking commit in TT
boolean	fileExists(String pRelativePath) The returned array consists of all the relative paths there are in the storage.
int	getCount()
String[]	getFilePaths() The returned array consists of all the relative paths there are in the storage.
File	getFullFile(String pRelativePath) This method allows you to get a full file using the node key of the header
boolean	isClosed() Check whether or not this transaction has been closed
void	removeFile(String pRelativePath) Remove file from desired path

Methods inherited from class java.lang.Object

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

Constructor Detail

FilelistenerWriteTrx

public FilelistenerWriteTrx(IBucketWriteTrx pPageTrx,
                    ISession pSession)
                     throws TTException

Throws:

TTException

Method Detail

getFilePaths

public String[] getFilePaths()

The returned array consists of all the relative paths there are in the storage.

Specified by:

getFilePaths in interface IFilelistenerReadTrx

Returns:

getCount

public int getCount()

Specified by:

getCount in interface IFilelistenerReadTrx

Specified by:

getCount in interface IFilelistenerWriteTrx

Returns:

int - amount of buckets

fileExists

public boolean fileExists(String pRelativePath)

The returned array consists of all the relative paths there are in the storage.

Specified by:

fileExists in interface IFilelistenerReadTrx

Returns:

getFullFile

public File getFullFile(String pRelativePath)
                 throws TTIOException,
                        IOException

This method allows you to get a full file using the node key of the header

Specified by:

getFullFile in interface IFilelistenerReadTrx

Returns:

true if successful, false otherwise

Throws:

TTIOException

IOException

close

public void close()
           throws TTIOException

Close this transaction

Specified by:

close in interface IFilelistenerReadTrx

Throws:

TTIOException

isClosed

public boolean isClosed()

Check whether or not this transaction has been closed

Specified by:

isClosed in interface IFilelistenerReadTrx

Returns:

true if closed, false otherwise

addEmptyFile

public void addEmptyFile(String pRelativePath)
                  throws TTException,
                         IOException

Add an empty file in case of ENTRY_CREATE event.

Specified by:

addEmptyFile in interface IFilelistenerWriteTrx

Throws:

TTException

IOException

addFile

public void addFile(File pFile,
           String pRelativePath)
             throws TTException,
                    IOException

Add a new file to the system

Specified by:

addFile in interface IFilelistenerWriteTrx

Throws:

TTException

IOException

removeFile

public void removeFile(String pRelativePath)
                throws TTException

Remove file from desired path

Specified by:

removeFile in interface IFilelistenerWriteTrx

Throws:

TTException - if node couldn't be removed

commit

public void commit()
            throws TTException

Non-blocking commit in TT

Specified by:

commit in interface IFilelistenerWriteTrx

Throws:

TTException - if this revision couldn't be commited

commitBlocked

public void commitBlocked()
                   throws TTException

Blocking commit in TT

Specified by:

commitBlocked in interface IFilelistenerWriteTrx

Throws:

TTException - if this revision couldn't be commited

abort

public void abort()
           throws TTException

Abort all modifications of the exclusive write transaction.

Specified by:

abort in interface IFilelistenerWriteTrx

Throws:

TTIOException - if this revision couldn't be aborted

TTException