Package com.google.common.jimfs

Class JimfsAsynchronousFileChannel

java.lang.Object

java.nio.channels.AsynchronousFileChannel

com.google.common.jimfs.JimfsAsynchronousFileChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.AsynchronousChannel, java.nio.channels.Channel

final class JimfsAsynchronousFileChannel
extends java.nio.channels.AsynchronousFileChannel

AsynchronousFileChannel implementation that delegates to a JimfsFileChannel.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	JimfsAsynchronousFileChannel.CompletionHandlerCallback<R,A>	Runnable callback that wraps a CompletionHandler and an attachment.

Field Summary

Fields

Modifier and Type	Field	Description
private JimfsFileChannel	channel
private com.google.common.util.concurrent.ListeningExecutorService	executor

Constructor Summary

Constructors

Constructor	Description
JimfsAsynchronousFileChannel(JimfsFileChannel channel, java.util.concurrent.ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
private <R,A> void	addCallback(com.google.common.util.concurrent.ListenableFuture<R> future, java.nio.channels.CompletionHandler<R,? super A> handler, @Nullable A attachment)
void	close()
private static <V> com.google.common.util.concurrent.ListenableFuture<V>	closedChannelFuture()	Immediate future indicating that the channel is closed.
void	force(boolean metaData)
boolean	isOpen()
com.google.common.util.concurrent.ListenableFuture<java.nio.channels.FileLock>	lock(long position, long size, boolean shared)
<A> void	lock(long position, long size, boolean shared, @Nullable A attachment, java.nio.channels.CompletionHandler<java.nio.channels.FileLock,? super A> handler)
com.google.common.util.concurrent.ListenableFuture<java.lang.Integer>	read(java.nio.ByteBuffer dst, long position)
<A> void	read(java.nio.ByteBuffer dst, long position, @Nullable A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
long	size()
java.nio.channels.AsynchronousFileChannel	truncate(long size)
java.nio.channels.FileLock	tryLock(long position, long size, boolean shared)
com.google.common.util.concurrent.ListenableFuture<java.lang.Integer>	write(java.nio.ByteBuffer src, long position)
<A> void	write(java.nio.ByteBuffer src, long position, @Nullable A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

Methods inherited from class java.nio.channels.AsynchronousFileChannel

lock, lock, open, open, tryLock

Methods inherited from class java.lang.Object

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

Field Detail

channel

private final JimfsFileChannel channel

executor

private final com.google.common.util.concurrent.ListeningExecutorService executor

Constructor Detail

JimfsAsynchronousFileChannel

public JimfsAsynchronousFileChannel(JimfsFileChannel channel,
                                    java.util.concurrent.ExecutorService executor)

Method Detail

size

public long size()
          throws java.io.IOException

Specified by:

size in class java.nio.channels.AsynchronousFileChannel

Throws:

java.io.IOException

addCallback

private <R,A> void addCallback(com.google.common.util.concurrent.ListenableFuture<R> future,
                                     java.nio.channels.CompletionHandler<R,? super A> handler,
                                     @Nullable A attachment)

truncate

@CanIgnoreReturnValue
public java.nio.channels.AsynchronousFileChannel truncate(long size)
                                                   throws java.io.IOException

Specified by:

truncate in class java.nio.channels.AsynchronousFileChannel

Throws:

java.io.IOException

force

public void force(boolean metaData)
           throws java.io.IOException

Specified by:

force in class java.nio.channels.AsynchronousFileChannel

Throws:

java.io.IOException

lock

public <A> void lock(long position,
                     long size,
                     boolean shared,
                     @Nullable A attachment,
                     java.nio.channels.CompletionHandler<java.nio.channels.FileLock,? super A> handler)

Specified by:

lock in class java.nio.channels.AsynchronousFileChannel

lock

public com.google.common.util.concurrent.ListenableFuture<java.nio.channels.FileLock> lock(long position,
                                                                                           long size,
                                                                                           boolean shared)

Specified by:

lock in class java.nio.channels.AsynchronousFileChannel

tryLock

public java.nio.channels.FileLock tryLock(long position,
                                          long size,
                                          boolean shared)
                                   throws java.io.IOException

Specified by:

tryLock in class java.nio.channels.AsynchronousFileChannel

Throws:

java.io.IOException

read

public <A> void read(java.nio.ByteBuffer dst,
                     long position,
                     @Nullable A attachment,
                     java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

Specified by:

read in class java.nio.channels.AsynchronousFileChannel

read

public com.google.common.util.concurrent.ListenableFuture<java.lang.Integer> read(java.nio.ByteBuffer dst,
                                                                                  long position)

Specified by:

read in class java.nio.channels.AsynchronousFileChannel

write

public <A> void write(java.nio.ByteBuffer src,
                      long position,
                      @Nullable A attachment,
                      java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

Specified by:

write in class java.nio.channels.AsynchronousFileChannel

write

public com.google.common.util.concurrent.ListenableFuture<java.lang.Integer> write(java.nio.ByteBuffer src,
                                                                                   long position)

Specified by:

write in class java.nio.channels.AsynchronousFileChannel

isOpen

public boolean isOpen()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

closedChannelFuture

private static <V> com.google.common.util.concurrent.ListenableFuture<V> closedChannelFuture()

Immediate future indicating that the channel is closed.