org.schmant.task.at4j.bzip2
Class AbstractBZip2WritableFileProxy

java.lang.Object
  org.schmant.task.at4j.bzip2.AbstractBZip2WritableFileProxy

All Implemented Interfaces:

Lockable, WriteLockable, WritableFile

Direct Known Subclasses:

BZip2ExistingWritableFileProxy, BZip2NewWritableFileProxy

public abstract class AbstractBZip2WritableFileProxy
extends Object
implements WritableFile

This is an abstract base class for bzip2 writable file proxies.

Since:

0.8

Author:

Karl Gustafsson

Task_package:

org.at4j

Constructor Summary

protected	AbstractBZip2WritableFileProxy(Object proxied)
protected	AbstractBZip2WritableFileProxy(Object proxied, BZip2WritableFileSettings settings) The proxied file.
protected	AbstractBZip2WritableFileProxy(Object proxied, CompressionLevel level)
protected	AbstractBZip2WritableFileProxy(Object proxied, int blockSize)

Method Summary

protected WritableFile	getFile()
protected abstract WritableFile	getFileFromArgumentInterpreter(Object proxied)
EntityLock	getWriteLock() Get the write lock without locking it.
boolean	isWriteLockedByCurrentThread() Does the calling thread hold a write lock for the lockable object (this)?
EntityLock	lockForWriting() Lock the object for writing and return the lock.
WritableByteChannel	openChannelForAppend() Open a WritableByteChannel for appending to the file.
WritableByteChannel	openChannelForWrite() Open a WritableByteChannel for writing on the file.
OutputStream	openForAppend() Open the file for appending.
OutputStream	openForWrite() Opens the file for writing.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractBZip2WritableFileProxy

protected AbstractBZip2WritableFileProxy(Object proxied)

AbstractBZip2WritableFileProxy

protected AbstractBZip2WritableFileProxy(Object proxied,
                                         int blockSize)

AbstractBZip2WritableFileProxy

protected AbstractBZip2WritableFileProxy(Object proxied,
                                         BZip2WritableFileSettings settings)

The proxied file.

Parameters:

proxied - The proxied file.

settings - bzip2 settings

Since:

1.0.1

AbstractBZip2WritableFileProxy

protected AbstractBZip2WritableFileProxy(Object proxied,
                                         CompressionLevel level)

Since:

1.0

Method Detail

getFileFromArgumentInterpreter

protected abstract WritableFile getFileFromArgumentInterpreter(Object proxied)

getFile

protected WritableFile getFile()

openChannelForAppend

public WritableByteChannel openChannelForAppend()
                                         throws UnsupportedOperationException

Description copied from interface: WritableFile

Open a WritableByteChannel for appending to the file. The semantics of this method is the same as for WritableFile.openForAppend().

Specified by:

openChannelForAppend in interface WritableFile

Returns:

An open WritableByteChannel. The channel must be closed by the caller. The returned channel may be a GatheringByteChannel, but that is not required.

Throws:

UnsupportedOperationException - Always!

openChannelForWrite

public WritableByteChannel openChannelForWrite()
                                        throws WriteLockRequiredException,
                                               AccessDeniedException,
                                               ReadOnlyException

Description copied from interface: WritableFile

Open a WritableByteChannel for writing on the file. The semantics of this method is the same as for WritableFile.openForWrite().

Specified by:

openChannelForWrite in interface WritableFile

Returns:

An open WritableByteChannel. The channel must be closed by the caller. The returned channel may be a GatheringByteChannel, but that is not required.

Throws:

WriteLockRequiredException - If the client does not have a write lock for the file.

AccessDeniedException - If the client does not have write access to the file.

ReadOnlyException - If the file system is read-only.

See Also:

WritableFile.openForWrite(), WritableFile.openChannelForAppend()

openForAppend

public OutputStream openForAppend()
                           throws UnsupportedOperationException

Description copied from interface: WritableFile

Open the file for appending. This preserves all previous contents of the file. Use WritableFile.openForWrite() to delete the previous contents before writing. This requires that the file supports the FCAppendable capability (and/or that the file system supports the FSCAppendableFiles capability.

The caller is responsible for closing the stream.

When two appending output streams are open on the same file, one stream will not overwrite contents written by the other stream. Compare this with the behavior of one writing and one appending stream.

Although a write lock on the file is required for the execution thread opening the stream, the stream itself is not protected from access by other threads. It can be protected by wrapping it in a LockAwareWritableByteChannel.

Specified by:

openForAppend in interface WritableFile

Returns:

An OutputStream to write to. The stream must be closed by the caller.

Throws:

UnsupportedOperationException - Always!

See Also:

WritableFile.openForWrite(), WritableFile.openChannelForAppend()

openForWrite

public OutputStream openForWrite()
                          throws WriteLockRequiredException,
                                 AccessDeniedException,
                                 ReadOnlyException

Description copied from interface: WritableFile

Opens the file for writing. This deletes all previous contents of the file. Use WritableFile.openForAppend() to append to the file.

The caller is responsible for closing the stream.

When two output streams, one writing and one appending are open on the same file, the stream opened for write will ignore the contents written by the other stream and the content written by the other stream will be overwritten. When two or more appending streams are opened on a file, a stream will not overwrite the content written by the other streams.

Although a write lock on the file is required for the execution thread opening the stream, the stream itself is not protected from access by other threads. It can be protected by wrapping it in a LockAwareOutputStream.

Specified by:

openForWrite in interface WritableFile

Returns:

An OutputStream to write to. The stream must be closed by the caller.

Throws:

WriteLockRequiredException - If the client does not have a write lock for the file.

AccessDeniedException - If the client does not have write access to the file.

ReadOnlyException - If the file system is read-only.

See Also:

WritableFile.openForAppend(), WritableFile.openChannelForWrite()

getWriteLock

public EntityLock getWriteLock()

Description copied from interface: WriteLockable

Get the write lock without locking it.

This method always returns a lock, even if the object's file system is not locking or if the object is read only.

Specified by:

getWriteLock in interface WriteLockable

Returns:

The lockable's write lock. This might be unlocked or locked by someone else.

isWriteLockedByCurrentThread

public boolean isWriteLockedByCurrentThread()

Description copied from interface: WriteLockable

Does the calling thread hold a write lock for the lockable object (this)?

Specified by:

isWriteLockedByCurrentThread in interface WriteLockable

Returns:

true if the lockable object is write locked by the current thread.

lockForWriting

public EntityLock lockForWriting()
                          throws LockTimeoutException

Description copied from interface: WriteLockable

Lock the object for writing and return the lock. How the lock is acquired is determined by the EntityLockAdapterFactory and LockAcquiringStrategy used. If this is called on an object that is somehow connected to an Entity object, that entity's file systems' lock adapter factory and lock acquiring strategy is used. A write lock can be downgraded to a read lock (by calling ReadLockable.lockForReading() and then releasing the write lock).

An entity in a locking read only file system may still be locked for writing.

For more discussions on locks and locking, see Entity and FileSystem.

This method always returns a lock, even if the file system is not locking.

Specified by:

lockForWriting in interface WriteLockable

Returns:

A locked write lock.

Throws:

LockTimeoutException - If the lock acquiring timed out. (It is up to the LockAcquiringStrategy to decide if lock acquiring can time out.)