com.alipay.sofa.jraft.storage.snapshot.remote

Class CopySession

java.lang.Object

com.alipay.sofa.jraft.storage.snapshot.remote.CopySession

All Implemented Interfaces:

Session, Closeable, AutoCloseable

@ThreadSafe
public class CopySession
extends Object
implements Session

Copy session.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-08 12:01:23 PM

Constructor Summary

Constructors

Constructor and Description
CopySession(RaftClientService rpcService, Scheduler timerManager, SnapshotThrottle snapshotThrottle, RaftOptions raftOptions, RpcRequests.GetFileRequest.Builder rb, Endpoint ep)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancel the copy job.
void	close()
void	join() Block the thread to wait the copy job finishes or canceled.
void	setCopyOptions(CopyOptions copyOptions)
void	setDestBuf(ByteBufferCollector bufRef)
void	setDestPath(String destPath)
void	setOutputStream(OutputStream out)
Status	status() Returns the copy job status.

Methods inherited from class java.lang.Object

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

Constructor Detail

CopySession

public CopySession(RaftClientService rpcService,
                   Scheduler timerManager,
                   SnapshotThrottle snapshotThrottle,
                   RaftOptions raftOptions,
                   RpcRequests.GetFileRequest.Builder rb,
                   Endpoint ep)

Method Detail

setDestPath

public void setDestPath(String destPath)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

setDestBuf

public void setDestBuf(ByteBufferCollector bufRef)

setCopyOptions

public void setCopyOptions(CopyOptions copyOptions)

setOutputStream

public void setOutputStream(OutputStream out)

cancel

public void cancel()

Description copied from interface: Session

Cancel the copy job.

Specified by:

cancel in interface Session

join

public void join()
          throws InterruptedException

Description copied from interface: Session

Block the thread to wait the copy job finishes or canceled.

Specified by:

join in interface Session

Throws:

InterruptedException - if the current thread is interrupted while waiting

status

public Status status()

Description copied from interface: Session

Returns the copy job status.

Specified by:

status in interface Session