public class ScpCommand extends AbstractFileSystemCommand implements ServerChannelSessionHolder
Modifier and Type | Field and Description |
---|---|
protected IOException |
error |
protected ScpTransferEventListener |
listener |
protected ScpFileOpener |
opener |
protected boolean |
optD |
protected boolean |
optF |
protected boolean |
optP |
protected boolean |
optR |
protected boolean |
optT |
protected String |
path |
protected int |
receiveBufferSize |
protected int |
sendBufferSize |
fileSystem
cbCalled, cmdRunner, executorService
log
Constructor and Description |
---|
ScpCommand(ChannelSession channelSession,
String command,
CloseableExecutorService executorService,
int sendSize,
int receiveSize,
ScpFileOpener fileOpener,
ScpTransferEventListener eventListener) |
Modifier and Type | Method and Description |
---|---|
ChannelSession |
getServerChannelSession() |
void |
run() |
void |
start(ChannelSession channel,
Environment env)
Starts the command execution.
|
String |
toString() |
protected void |
writeCommandResponseMessage(String command,
int exitValue,
String exitMessage) |
destroy, getFileSystem, setFileSystem
getCommand, getEnvironment, getErrorStream, getExecutorService, getExitCallback, getInputStream, getOutputStream, getServerSession, getSession, getStartedCommandFuture, onExit, onExit, setErrorStream, setExitCallback, setInputStream, setOutputStream, setSession
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setFileSystemFactory
getSessionContext
protected final int sendBufferSize
protected final int receiveBufferSize
protected final ScpFileOpener opener
protected boolean optR
protected boolean optT
protected boolean optF
protected boolean optD
protected boolean optP
protected String path
protected IOException error
protected ScpTransferEventListener listener
public ScpCommand(ChannelSession channelSession, String command, CloseableExecutorService executorService, int sendSize, int receiveSize, ScpFileOpener fileOpener, ScpTransferEventListener eventListener)
channelSession
- The ChannelSession
through which the command was receivedcommand
- The command to be executedexecutorService
- An CloseableExecutorService
to be used when
start(ChannelSession, Environment)
-ing execution. If null
an ad-hoc
single-threaded service is created and used.sendSize
- Size (in bytes) of buffer to use when sending filesreceiveSize
- Size (in bytes) of buffer to use when receiving filesfileOpener
- The ScpFileOpener
- if null
then DefaultScpFileOpener
is usedeventListener
- An ScpTransferEventListener
- may be null
ThreadUtils.newSingleThreadExecutor(String)
,
ScpHelper.MIN_SEND_BUFFER_SIZE
,
ScpHelper.MIN_RECEIVE_BUFFER_SIZE
public ChannelSession getServerChannelSession()
getServerChannelSession
in interface ServerChannelSessionHolder
public void start(ChannelSession channel, Environment env) throws IOException
CommandLifecycle
Runnable
, and this method should spawn a new thread like:
Thread(this).start();
start
in interface CommandLifecycle
start
in class AbstractCommandSupport
channel
- The ChannelSession
through which the command has been receivedenv
- The Environment
IOException
- If failed to startprotected void writeCommandResponseMessage(String command, int exitValue, String exitMessage) throws IOException
IOException
public String toString()
toString
in class AbstractCommandSupport
Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.