Package org.h2.store.fs.retry

Class FileRetryOnInterrupt

java.lang.Object

java.nio.channels.spi.AbstractInterruptibleChannel

java.nio.channels.FileChannel

org.h2.store.fs.FileBase

org.h2.store.fs.retry.FileRetryOnInterrupt

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, GatheringByteChannel, InterruptibleChannel, ReadableByteChannel, ScatteringByteChannel, SeekableByteChannel, WritableByteChannel

class FileRetryOnInterrupt
extends FileBase

A file object that re-opens and re-tries the operation if the file was closed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	FileRetryOnInterrupt.FileLockRetry	A wrapped file lock.

Nested classes/interfaces inherited from class java.nio.channels.FileChannel

FileChannel.MapMode

Field Summary

Fields

Modifier and Type	Field	Description
private FileChannel	channel
private final String	fileName
private FileRetryOnInterrupt.FileLockRetry	lock
private final String	mode

Constructor Summary

Constructors

Constructor	Description
FileRetryOnInterrupt(String fileName, String mode)

Method Summary

Modifier and Type	Method	Description
void	force(boolean metaData)
void	implCloseChannel()
private void	open()
long	position()
FileChannel	position(long pos)
int	read(ByteBuffer dst)
int	read(ByteBuffer dst, long position)
private void	reLock()
private void	reopen(int i, IOException e)
long	size()
String	toString()
FileChannel	truncate(long newLength)
FileLock	tryLock(long position, long size, boolean shared)
int	write(ByteBuffer src)
int	write(ByteBuffer src, long position)

Methods inherited from class org.h2.store.fs.FileBase

lock, map, read, transferFrom, transferTo, write

Methods inherited from class java.nio.channels.FileChannel

lock, map, open, open, read, tryLock, write

Methods inherited from class java.nio.channels.spi.AbstractInterruptibleChannel

begin, close, end, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.nio.channels.Channel

isOpen

Field Details

fileName

private final String fileName

mode

private final String mode

channel

private FileChannel channel

lock

private FileRetryOnInterrupt.FileLockRetry lock

Constructor Details

FileRetryOnInterrupt

FileRetryOnInterrupt(String fileName,
 String mode)
              throws IOException

Throws:

IOException

Method Details

open

private void open()
           throws IOException

Throws:

IOException

reopen

private void reopen(int i,
 IOException e)
             throws IOException

Throws:

IOException

reLock

private void reLock()
             throws IOException

Throws:

IOException

implCloseChannel

public void implCloseChannel()
                      throws IOException

Overrides:

implCloseChannel in class FileBase

Throws:

IOException

position

public long position()
              throws IOException

Specified by:

position in interface SeekableByteChannel

Specified by:

position in class FileChannel

Throws:

IOException

size

public long size()
          throws IOException

Specified by:

size in interface SeekableByteChannel

Specified by:

size in class FileChannel

Throws:

IOException

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Specified by:

read in interface SeekableByteChannel

Specified by:

read in class FileChannel

Throws:

IOException

read

public int read(ByteBuffer dst,
 long position)
         throws IOException

Overrides:

read in class FileBase

Throws:

IOException

position

public FileChannel position(long pos)
                     throws IOException

Specified by:

position in interface SeekableByteChannel

Specified by:

position in class FileChannel

Throws:

IOException

truncate

public FileChannel truncate(long newLength)
                     throws IOException

Specified by:

truncate in interface SeekableByteChannel

Specified by:

truncate in class FileChannel

Throws:

IOException

force

public void force(boolean metaData)
           throws IOException

Overrides:

force in class FileBase

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface SeekableByteChannel

Specified by:

write in interface WritableByteChannel

Specified by:

write in class FileChannel

Throws:

IOException

write

public int write(ByteBuffer src,
 long position)
          throws IOException

Overrides:

write in class FileBase

Throws:

IOException

tryLock

public FileLock tryLock(long position,
 long size,
 boolean shared)
                 throws IOException

Overrides:

tryLock in class FileBase

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object