com.spectralogic.ds3client.helpers.channels

Class RangedSeekableByteChannel

java.lang.Object

com.spectralogic.ds3client.helpers.channels.RangedSeekableByteChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.ByteChannel, java.nio.channels.Channel, java.nio.channels.ReadableByteChannel, java.nio.channels.SeekableByteChannel, java.nio.channels.WritableByteChannel

public class RangedSeekableByteChannel
extends java.lang.Object
implements java.nio.channels.SeekableByteChannel

Constructor Summary

Constructors

Constructor and Description
RangedSeekableByteChannel(java.nio.channels.SeekableByteChannel byteChannel, com.google.common.collect.ImmutableMultimap<BulkObject,Range> ranges)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isOpen()
long	position()
java.nio.channels.SeekableByteChannel	position(long newPosition)
int	read(java.nio.ByteBuffer dst)
long	size()
java.nio.channels.SeekableByteChannel	truncate(long size)
static RangedSeekableByteChannel	wrap(java.nio.channels.SeekableByteChannel byteChannel, com.google.common.collect.ImmutableMultimap<BulkObject,Range> ranges)
int	write(java.nio.ByteBuffer src)

Methods inherited from class java.lang.Object

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

Constructor Detail

RangedSeekableByteChannel

public RangedSeekableByteChannel(java.nio.channels.SeekableByteChannel byteChannel,
                                 com.google.common.collect.ImmutableMultimap<BulkObject,Range> ranges)
                          throws java.io.IOException

Throws:

java.io.IOException

Method Detail

wrap

public static RangedSeekableByteChannel wrap(java.nio.channels.SeekableByteChannel byteChannel,
                                             com.google.common.collect.ImmutableMultimap<BulkObject,Range> ranges)
                                      throws java.io.IOException

Throws:

java.io.IOException

read

public int read(java.nio.ByteBuffer dst)
         throws java.io.IOException

Specified by:

read in interface java.nio.channels.ReadableByteChannel

Specified by:

read in interface java.nio.channels.SeekableByteChannel

Throws:

java.io.IOException

write

public int write(java.nio.ByteBuffer src)
          throws java.io.IOException

Specified by:

write in interface java.nio.channels.SeekableByteChannel

Specified by:

write in interface java.nio.channels.WritableByteChannel

Throws:

java.io.IOException

position

public long position()
              throws java.io.IOException

Specified by:

position in interface java.nio.channels.SeekableByteChannel

Throws:

java.io.IOException

position

public java.nio.channels.SeekableByteChannel position(long newPosition)
                                               throws java.io.IOException

Specified by:

position in interface java.nio.channels.SeekableByteChannel

Throws:

java.io.IOException

size

public long size()
          throws java.io.IOException

Specified by:

size in interface java.nio.channels.SeekableByteChannel

Throws:

java.io.IOException

truncate

public java.nio.channels.SeekableByteChannel truncate(long size)
                                               throws java.io.IOException

Specified by:

truncate in interface java.nio.channels.SeekableByteChannel

Throws:

java.io.IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface java.nio.channels.Channel

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.Channel

Throws:

java.io.IOException