public class SftpRemotePathChannel extends FileChannel
FileChannel.MapMode
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<Thread> |
blockingThreadHolder |
protected boolean |
closeOnExit |
protected SftpClient.CloseableHandle |
handle |
protected Object |
lock |
protected org.slf4j.Logger |
log |
protected Collection<SftpClient.OpenMode> |
modes |
protected AtomicLong |
posTracker |
static Set<SftpClient.OpenMode> |
READ_MODES |
protected SftpClient |
sftp |
static Set<SftpClient.OpenMode> |
WRITE_MODES |
Constructor and Description |
---|
SftpRemotePathChannel(String path,
SftpClient sftp,
boolean closeOnExit,
Collection<SftpClient.OpenMode> modes) |
Modifier and Type | Method and Description |
---|---|
protected void |
beginBlocking(Object actionHint) |
protected long |
doRead(Collection<? extends ByteBuffer> buffers,
long position) |
protected long |
doWrite(Collection<? extends ByteBuffer> buffers,
long position) |
protected void |
endBlocking(Object actionHint,
boolean completed) |
void |
force(boolean metaData) |
String |
getRemotePath() |
protected void |
implCloseChannel() |
FileLock |
lock(long position,
long size,
boolean shared) |
MappedByteBuffer |
map(FileChannel.MapMode mode,
long position,
long size) |
long |
position() |
FileChannel |
position(long newPosition) |
int |
read(ByteBuffer dst) |
long |
read(ByteBuffer[] dsts,
int offset,
int length) |
int |
read(ByteBuffer dst,
long position) |
long |
size() |
String |
toString() |
long |
transferFrom(ReadableByteChannel src,
long position,
long count) |
long |
transferTo(long position,
long count,
WritableByteChannel target) |
FileChannel |
truncate(long size) |
FileLock |
tryLock(long position,
long size,
boolean shared) |
int |
write(ByteBuffer src) |
long |
write(ByteBuffer[] srcs,
int offset,
int length) |
int |
write(ByteBuffer src,
long position) |
begin, close, end, isOpen
public static final Set<SftpClient.OpenMode> READ_MODES
public static final Set<SftpClient.OpenMode> WRITE_MODES
protected final org.slf4j.Logger log
protected final Collection<SftpClient.OpenMode> modes
protected final boolean closeOnExit
protected final SftpClient sftp
protected final SftpClient.CloseableHandle handle
protected final Object lock
protected final AtomicLong posTracker
protected final AtomicReference<Thread> blockingThreadHolder
public SftpRemotePathChannel(String path, SftpClient sftp, boolean closeOnExit, Collection<SftpClient.OpenMode> modes) throws IOException
IOException
public String getRemotePath()
public int read(ByteBuffer dst) throws IOException
read
in interface ReadableByteChannel
read
in interface SeekableByteChannel
read
in class FileChannel
IOException
public int read(ByteBuffer dst, long position) throws IOException
read
in class FileChannel
IOException
public long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read
in interface ScatteringByteChannel
read
in class FileChannel
IOException
protected long doRead(Collection<? extends ByteBuffer> buffers, long position) throws IOException
IOException
public int write(ByteBuffer src) throws IOException
write
in interface SeekableByteChannel
write
in interface WritableByteChannel
write
in class FileChannel
IOException
public int write(ByteBuffer src, long position) throws IOException
write
in class FileChannel
IOException
public long write(ByteBuffer[] srcs, int offset, int length) throws IOException
write
in interface GatheringByteChannel
write
in class FileChannel
IOException
protected long doWrite(Collection<? extends ByteBuffer> buffers, long position) throws IOException
IOException
public long position() throws IOException
position
in interface SeekableByteChannel
position
in class FileChannel
IOException
public FileChannel position(long newPosition) throws IOException
position
in interface SeekableByteChannel
position
in class FileChannel
IOException
public long size() throws IOException
size
in interface SeekableByteChannel
size
in class FileChannel
IOException
public FileChannel truncate(long size) throws IOException
truncate
in interface SeekableByteChannel
truncate
in class FileChannel
IOException
public void force(boolean metaData) throws IOException
force
in class FileChannel
IOException
public long transferTo(long position, long count, WritableByteChannel target) throws IOException
transferTo
in class FileChannel
IOException
public long transferFrom(ReadableByteChannel src, long position, long count) throws IOException
transferFrom
in class FileChannel
IOException
public MappedByteBuffer map(FileChannel.MapMode mode, long position, long size) throws IOException
map
in class FileChannel
IOException
public FileLock lock(long position, long size, boolean shared) throws IOException
lock
in class FileChannel
IOException
public FileLock tryLock(long position, long size, boolean shared) throws IOException
tryLock
in class FileChannel
IOException
protected void implCloseChannel() throws IOException
implCloseChannel
in class AbstractInterruptibleChannel
IOException
protected void beginBlocking(Object actionHint)
protected void endBlocking(Object actionHint, boolean completed) throws AsynchronousCloseException
AsynchronousCloseException
Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.