public class Configuration extends Object
Modifier and Type | Field and Description |
---|---|
protected io.netty.channel.Channel |
bindNoSSL
Main bind address in no ssl mode
|
protected io.netty.channel.Channel |
bindSSL
Main bind address in ssl mode
|
static int |
BUFFERSIZEDEFAULT
Default size for buffers (NIO)
|
static Configuration |
configuration
General Configuration object
|
protected boolean |
configured |
protected ExecutorService |
execOtherWorker
ExecutorService Other Worker
|
static String |
EXT_R66
Extension of file during transfer
|
protected io.netty.handler.traffic.GlobalTrafficShapingHandler |
globalTrafficShapingHandler
Global TrafficCounter (set from global configuration)
|
protected io.netty.channel.EventLoopGroup |
handlerGroup |
protected io.netty.bootstrap.ServerBootstrap |
httpBootstrap
Bootstrap for Http server
|
protected io.netty.channel.group.ChannelGroup |
httpChannelGroup
List of all Http Channels to enable the close call on them using Netty
ChannelGroup
|
protected io.netty.bootstrap.ServerBootstrap |
httpsBootstrap
Bootstrap for Https server
|
protected io.netty.channel.EventLoopGroup |
httpWorkerGroup |
protected LocalTransaction |
localTransaction
LocalTransaction
|
protected NetworkServerInitializer |
networkServerInitializer
Factory for NON SSL Server
|
protected NetworkSslServerInitializer |
networkSslServerInitializer
Factory for SSL Server
|
protected ThreadPoolRunnerExecutor |
retrieveRunnerGroup |
static long |
RETRYINMS
Time elapse for retry in ms
|
static int |
RETRYNB
Number of retry before error
|
protected ScheduledExecutorService |
scheduledExecutorService
ExecutorService Scheduled tasks
|
protected io.netty.bootstrap.ServerBootstrap |
serverBootstrap
Bootstrap for server
|
protected io.netty.channel.group.ChannelGroup |
serverChannelGroup
List of all Server Channels to enable the close call on them using Netty
ChannelGroup
|
protected io.netty.channel.group.ChannelGroup |
serverConnectedChannelGroup
List of all Server Channels connected to remote to enable the close call
on them using Netty ChannelGroup
|
protected io.netty.channel.EventLoopGroup |
serverGroup |
protected io.netty.bootstrap.ServerBootstrap |
serverSslBootstrap
Bootstrap for SSL server
|
static String |
SnmpDefaultAuthor |
static String |
SnmpDefaultLocalization |
static String |
SnmpName |
static int |
SnmpPrivateId |
static int |
SnmpR66Id |
static int |
SnmpService |
static String |
SnmpVersion |
protected io.netty.channel.EventLoopGroup |
subTaskGroup |
static long |
WAITFORNETOP
Time elapse for WRITE OR CLOSE WAIT elaps in ms
|
protected io.netty.channel.EventLoopGroup |
workerGroup |
Constructor and Description |
---|
Configuration() |
Modifier and Type | Method and Description |
---|---|
void |
changeNetworkLimit(long writeGlobalLimit,
long readGlobalLimit,
long writeSessionLimit,
long readSessionLimit,
long delayLimit)
Reset the global monitor for bandwidth limitation and change future
channel
monitors
|
void |
clientStop()
To be called after all other stuff are closed for Client
|
void |
clientStop(boolean shutdownQuickly)
To be called after all other stuff are closed for Client
|
void |
computeNbThreads()
Compute number of threads for both client and server from the real number
of available processors (double +
1) if the value is less than 32 threads else (available +1).
|
String |
getAdminName() |
WaarpSnmpAgent |
getAgentSnmp() |
Map<String,String> |
getAliases() |
String |
getArchivePath() |
String |
getAuthFile() |
String |
getBaseDirectory() |
int |
getBlockSize() |
Set<String> |
getBusinessWhiteSet() |
int |
getClientThread() |
String |
getConfigPath() |
R66ConstraintLimitHandler |
getConstraintLimitHandler() |
String |
getCryptoFile() |
Des |
getCryptoKey() |
long |
getDEFAULT_GLOBAL_LIMIT() |
long |
getDEFAULT_SESSION_LIMIT() |
long |
getDelayCommander() |
long |
getDelayLimit() |
long |
getDelayRetry() |
FilesystemBasedDigest.DigestAlgo |
getDigest() |
ExecutorService |
getExecutorService() |
static FilesystemBasedFileParameterImpl |
getFileParameter() |
io.netty.handler.traffic.GlobalTrafficShapingHandler |
getGlobalTrafficShapingHandler() |
io.netty.channel.EventLoopGroup |
getHandlerGroup() |
DbHostAuth |
getHostAuth() |
String |
getHostId() |
String |
getHostId(boolean isSSL) |
String |
getHostId(String remoteHost) |
DbHostAuth |
getHostSslAuth() |
String |
getHostSslId() |
String |
getHttpBasePath() |
io.netty.channel.group.ChannelGroup |
getHttpChannelGroup() |
int |
getHttpModel() |
io.netty.channel.EventLoopGroup |
getHttpWorkerGroup() |
String |
getInPath() |
InternalRunner |
getInternalRunner() |
int |
getLimitCache() |
LocalTransaction |
getLocalTransaction() |
int |
getMaxfilenamelength() |
int |
getMaxGlobalMemory() |
long |
getMinimalDelay() |
Monitoring |
getMonitoring() |
int |
getMultipleMonitors() |
static int |
getNbDbSession() |
io.netty.channel.EventLoopGroup |
getNetworkWorkerGroup() |
String |
getOutPath() |
long |
getPastLimit() |
R66BusinessFactoryInterface |
getR66BusinessFactory() |
R66PrivateMib |
getR66Mib() |
static int |
getRankRestart() |
List<RestConfiguration> |
getRestConfigurations() |
ThreadPoolRunnerExecutor |
getRetrieveRunnerGroup() |
Map<String,String[]> |
getReverseAliases() |
Map<String,RoleDefault> |
getRoles() |
int |
getRunnerThread() |
byte[] |
getServerAdminKey() |
io.netty.channel.group.ChannelGroup |
getServerChannelGroup() |
long |
getServerChannelReadLimit() |
long |
getServerChannelWriteLimit() |
io.netty.channel.group.ChannelGroup |
getServerConnectedChannelGroup() |
long |
getServerGlobalReadLimit() |
long |
getServerGlobalWriteLimit() |
String[] |
getServerHttpAddresses() |
int |
getServerHttpport() |
String[] |
getServerHttpsAddresses() |
int |
getServerHttpsPort() |
String[] |
getServerIpsAddresses() |
String |
getServerKeyFile() |
int |
getServerPort() |
String[] |
getServerSslAddresses() |
int |
getServerSslPort() |
int |
getServerThread() |
WaarpShutdownHook.ShutdownConfiguration |
getShutdownConfiguration() |
String |
getSnmpConfig() |
io.netty.channel.EventLoopGroup |
getSubTaskGroup() |
int |
getThriftport() |
R66ThriftServerService |
getThriftService() |
long |
getTimeLimitCache() |
long |
getTimeoutCon() |
io.netty.util.Timer |
getTimerClose() |
int |
getTimeStat() |
ConcurrentMap<String,PartnerConfiguration> |
getVersions() |
static WaarpSecureKeyStore |
getWaarpSecureKeyStore() |
static WaarpSslContextFactory |
getWaarpSslContextFactory() |
String |
getWorkingPath() |
static String |
hashStatus() |
boolean |
isAuthentNoReuse() |
boolean |
isBlacklistBadAuthent() |
boolean |
isCheckClientAddress() |
boolean |
isCheckRemoteAddress() |
boolean |
isChrootChecked() |
boolean |
isCompressionAvailable() |
boolean |
isConfigured() |
boolean |
isExecuteErrorBeforeTransferAllowed() |
boolean |
isExtendedProtocol() |
boolean |
isGlobalDigest() |
boolean |
isHostProxyfied() |
static boolean |
isIsUnix() |
boolean |
isKeyValid(byte[] newkey)
Is the given key a valid one
|
boolean |
isLocalDigest() |
boolean |
isSaveTaskRunnerWithNoDb() |
boolean |
isServer() |
boolean |
isShutdown() |
boolean |
isTimerCloseReady() |
boolean |
isTransferGuid() |
boolean |
isUseHttpCompression() |
boolean |
isUseLocalExec() |
boolean |
isUseNOSSL() |
boolean |
isUseSSL() |
boolean |
isWarnOnStartup() |
void |
launchInFixedDelay(Thread thread,
long delay,
TimeUnit unit)
submit a task in a fixed delay
|
void |
launchStatistics()
Used to log statistics information regularly
|
void |
pipelineInit()
Configure the pipeline for client (to be called only once)
|
void |
prepareServerStop()
Prepare the server to stop
To be called early before other stuff will be closed
|
void |
r66Startup() |
boolean |
reloadCommanderDelay()
Try to reload the Commander
|
void |
scheduleWithFixedDelay(Thread thread,
long delay,
TimeUnit unit)
submit a task in a repeated delay
|
void |
serverPipelineInit() |
void |
serverStartup()
Startup the server
|
void |
serverStop()
Stops the server
To be called after all other stuff are closed (channels, connections)
|
void |
setAdminName(String aDMINNAME) |
void |
setAgentSnmp(WaarpSnmpAgent agentSnmp) |
void |
setArchivePath(String archivePath) |
void |
setAuthentNoReuse(boolean authentNoReuse) |
void |
setAuthFile(String file) |
void |
setBaseDirectory(String baseDirectory) |
void |
setBlacklistBadAuthent(boolean blacklistBadAuthent) |
void |
setBlockSize(int blockSIZE) |
void |
setCheckClientAddress(boolean checkClientAddress) |
void |
setCheckRemoteAddress(boolean checkRemoteAddress) |
void |
setChrootChecked(boolean chrootChecked) |
void |
setClientThread(int clientTHREAD) |
void |
setCompressionAvailable(boolean compressionAvailable) |
void |
setConfigPath(String configPath) |
void |
setConfigured(boolean configured) |
void |
setConstraintLimitHandler(R66ConstraintLimitHandler constraintLimitHandler) |
void |
setCryptoFile(String cryptoFile) |
void |
setCryptoKey(Des cryptoKey) |
void |
setDelayCommander(long delayCommander) |
void |
setDelayLimit(long delayLimit) |
void |
setDelayRetry(long delayRetry) |
void |
setDigest(FilesystemBasedDigest.DigestAlgo digest) |
void |
setExecuteErrorBeforeTransferAllowed(boolean isExecuteErrorBeforeTransferAllowed) |
void |
setExtendedProtocol(boolean extendedProtocol) |
void |
setGlobalDigest(boolean globalDigest) |
void |
setHostAuth(DbHostAuth hostAUTH) |
void |
setHostId(String hostID) |
void |
setHostProxyfied(boolean isHostProxyfied) |
void |
setHostSslAuth(DbHostAuth hostSSLAUTH) |
void |
setHostSslId(String hostSSLID) |
void |
setHttpBasePath(String httpBasePath) |
void |
setHttpModel(int httpModel) |
void |
setInPath(String inPath) |
static void |
setIsUnix(boolean iSUNIX) |
void |
setLimitCache(int limitCache) |
void |
setLocalDigest(boolean localDigest) |
void |
setMaxfilenamelength(int maxfilenamelength) |
void |
setMaxGlobalMemory(int maxGlobalMemory) |
void |
setMinimalDelay(long minimalDelay) |
void |
setMonitorExporterTransfers(String url,
String basicAuthent,
String token,
String apiKey,
String endpoint,
int delay,
boolean keepConnection,
boolean monitorIntervalIncluded,
boolean monitorTransformLongAsString)
Set the parameters for MonitorExporterTransfers using API REST
|
boolean |
setMonitorExporterTransfers(String remoteBaseUrl,
String username,
String pwd,
String token,
String apiKey,
String prefix,
String index,
boolean intervalMonitoringIncluded,
boolean transformLongAsString,
boolean compression,
int delay)
Set the parameters for MonitorExporterTransfers using Elasticsearch (JRE
>= 8)
|
void |
setMonitoring(Monitoring monitoring) |
void |
setMultipleMonitors(int multipleMonitors) |
static void |
setNbDbSession(int nBDBSESSION) |
void |
setOutPath(String outPath) |
void |
setPastLimit(long pastLimit) |
void |
setR66BusinessFactory(R66BusinessFactoryInterface r66BusinessFactory) |
void |
setR66Mib(R66PrivateMib r66Mib) |
static void |
setRankRestart(int rANKRESTART) |
void |
setRunnerThread(int runnerTHREAD) |
void |
setSaveTaskRunnerWithNoDb(boolean saveTaskRunnerWithNoDb) |
protected void |
setServer(boolean isServer) |
void |
setServerAddresses(String[] serverAddresses) |
void |
setServerChannelReadLimit(long serverChannelReadLimit) |
void |
setServerChannelWriteLimit(long serverChannelWriteLimit) |
void |
setServerGlobalReadLimit(long serverGlobalReadLimit) |
void |
setServerGlobalWriteLimit(long serverGlobalWriteLimit) |
void |
setServerHttpAddresses(String[] serverHTTPAddresses) |
void |
setServerHttpport(int serverHTTPPORT) |
void |
setServerHttpsAddresses(String[] serverHTTPSAddresses) |
void |
setServerHttpsPort(int serverHTTPSPORT) |
void |
setSERVERKEY(byte[] serverkey) |
void |
setServerKeyFile(String serverKeyFile) |
void |
setServerPort(int serverPORT) |
void |
setServerSslAddresses(String[] serverSSLAddresses) |
void |
setServerSslPort(int serverSSLPORT) |
void |
setServerThread(int serverTHREAD) |
void |
setShutdown(boolean isShutdown) |
void |
setSnmpConfig(String snmpConfig) |
void |
setThriftport(int thriftport) |
void |
setThriftService(R66ThriftServerService thriftService) |
void |
setTimeLimitCache(long timeLimitCache) |
void |
setTimeoutCon(long timeoutCON) |
void |
setTimeStat(int timeStat) |
void |
setTransferGuid(boolean transferGuid) |
void |
setupLimitHandler() |
void |
setUseHttpCompression(boolean useHttpCompression) |
void |
setUseLocalExec(boolean useLocalExec) |
void |
setUseNOSSL(boolean useNOSSL) |
void |
setUseSSL(boolean useSSL) |
static void |
setWaarpSecureKeyStore(WaarpSecureKeyStore waarpSecureKeyStore) |
static void |
setWaarpSslContextFactory(WaarpSslContextFactory waarpSslContextFactory) |
void |
setWarnOnStartup(boolean warnOnStartup) |
void |
setWorkingPath(String workingPath) |
void |
shutdownGracefully() |
void |
shutdownQuickly() |
void |
startHttpSupport() |
void |
startJunitRestSupport(RestConfiguration config) |
void |
startMonitorExporterTransfers()
Start the Monitor Exporter Transfers (through REST API)
|
void |
startMonitoring() |
void |
startRestSupport() |
String |
toString() |
void |
unbindServer()
Unbind network connectors
|
public static Configuration configuration
public static final String SnmpName
public static final int SnmpPrivateId
public static final int SnmpR66Id
public static final String SnmpDefaultAuthor
public static final String SnmpVersion
public static final String SnmpDefaultLocalization
public static final int SnmpService
public static final long RETRYINMS
public static final int RETRYNB
public static final int BUFFERSIZEDEFAULT
public static final long WAITFORNETOP
public static final String EXT_R66
protected io.netty.channel.group.ChannelGroup serverChannelGroup
protected io.netty.channel.group.ChannelGroup serverConnectedChannelGroup
protected io.netty.channel.Channel bindNoSSL
protected io.netty.channel.Channel bindSSL
protected final ExecutorService execOtherWorker
protected io.netty.channel.EventLoopGroup serverGroup
protected io.netty.channel.EventLoopGroup workerGroup
protected io.netty.channel.EventLoopGroup handlerGroup
protected io.netty.channel.EventLoopGroup subTaskGroup
protected io.netty.channel.EventLoopGroup httpWorkerGroup
protected ThreadPoolRunnerExecutor retrieveRunnerGroup
protected final ScheduledExecutorService scheduledExecutorService
protected io.netty.bootstrap.ServerBootstrap serverBootstrap
protected io.netty.bootstrap.ServerBootstrap serverSslBootstrap
protected NetworkServerInitializer networkServerInitializer
protected NetworkSslServerInitializer networkSslServerInitializer
protected io.netty.bootstrap.ServerBootstrap httpBootstrap
protected io.netty.bootstrap.ServerBootstrap httpsBootstrap
protected io.netty.channel.group.ChannelGroup httpChannelGroup
protected io.netty.handler.traffic.GlobalTrafficShapingHandler globalTrafficShapingHandler
protected LocalTransaction localTransaction
protected boolean configured
public final void pipelineInit()
public final void setConfigured(boolean configured)
public final boolean isConfigured()
public final void serverPipelineInit()
public void serverStartup() throws WaarpDatabaseNoConnectionException, WaarpDatabaseSqlException, ServerException
public final void launchStatistics()
public void r66Startup() throws WaarpDatabaseNoConnectionException, WaarpDatabaseSqlException, ServerException
public void startHttpSupport() throws ServerException
ServerException
public final void startRestSupport()
public final void startMonitoring() throws WaarpDatabaseSqlException
WaarpDatabaseSqlException
public final void startJunitRestSupport(RestConfiguration config)
public final InternalRunner getInternalRunner()
public final void prepareServerStop()
To be called early before other stuff will be closed
public final void unbindServer()
public final void shutdownGracefully()
public final void shutdownQuickly()
public void serverStop()
To be called after all other stuff are closed (channels, connections)
public final void clientStop()
public final void clientStop(boolean shutdownQuickly)
shutdownQuickly
- For client only, shall be true to speedup
the
end of the processpublic final boolean reloadCommanderDelay()
public final void launchInFixedDelay(Thread thread, long delay, TimeUnit unit)
thread
- delay
- unit
- public final void scheduleWithFixedDelay(Thread thread, long delay, TimeUnit unit)
thread
- delay
- unit
- public final void setupLimitHandler()
public final void changeNetworkLimit(long writeGlobalLimit, long readGlobalLimit, long writeSessionLimit, long readSessionLimit, long delayLimit)
writeGlobalLimit
- readGlobalLimit
- writeSessionLimit
- readSessionLimit
- delayLimit
- public void computeNbThreads()
public final ExecutorService getExecutorService()
public final io.netty.util.Timer getTimerClose()
public final boolean isTimerCloseReady()
public final io.netty.handler.traffic.GlobalTrafficShapingHandler getGlobalTrafficShapingHandler()
public final io.netty.channel.group.ChannelGroup getServerChannelGroup()
public final io.netty.channel.group.ChannelGroup getServerConnectedChannelGroup()
public final io.netty.channel.group.ChannelGroup getHttpChannelGroup()
public final io.netty.channel.EventLoopGroup getNetworkWorkerGroup()
public final ThreadPoolRunnerExecutor getRetrieveRunnerGroup()
public final io.netty.channel.EventLoopGroup getHandlerGroup()
public final io.netty.channel.EventLoopGroup getSubTaskGroup()
public final io.netty.channel.EventLoopGroup getHttpWorkerGroup()
public final LocalTransaction getLocalTransaction()
public static FilesystemBasedFileParameterImpl getFileParameter()
public final byte[] getServerAdminKey()
public final boolean isKeyValid(byte[] newkey)
newkey
- public final void setSERVERKEY(byte[] serverkey)
serverkey
- the SERVERADMINKEY to setpublic final String getHostId(boolean isSSL) throws OpenR66ProtocolNoSslException
isSSL
- OpenR66ProtocolNoSslException
public final String getHostId(String remoteHost) throws WaarpDatabaseException
remoteHost
- WaarpDatabaseException
public static String hashStatus()
public static int getNbDbSession()
public static void setNbDbSession(int nBDBSESSION)
nBDBSESSION
- the nBDBSESSION to setpublic static int getRankRestart()
public static void setRankRestart(int rANKRESTART)
rANKRESTART
- the rANKRESTART to setpublic static boolean isIsUnix()
public static void setIsUnix(boolean iSUNIX)
iSUNIX
- the iSUNIX to setpublic final R66BusinessFactoryInterface getR66BusinessFactory()
public final boolean isExtendedProtocol()
public final void setExtendedProtocol(boolean extendedProtocol)
extendedProtocol
- the extendedProtocol to setpublic final boolean isGlobalDigest()
public final void setGlobalDigest(boolean globalDigest)
globalDigest
- the globalDigest to setpublic final boolean isLocalDigest()
public final void setLocalDigest(boolean localDigest)
localDigest
- the localDigest to setpublic final Map<String,RoleDefault> getRoles()
public final ConcurrentMap<String,PartnerConfiguration> getVersions()
public final String getHostId()
public final void setHostId(String hostID)
hostID
- the hOST_ID to setpublic final String getHostSslId()
public final void setHostSslId(String hostSSLID)
hostSSLID
- the hOST_SSLID to setpublic final String getAdminName()
public final void setAdminName(String aDMINNAME)
aDMINNAME
- the aDMINNAME to setpublic final String getServerKeyFile()
public final void setServerKeyFile(String serverKeyFile)
serverKeyFile
- the serverKeyFile to setpublic final DbHostAuth getHostAuth()
public final void setHostAuth(DbHostAuth hostAUTH)
hostAUTH
- the hOST_AUTH to setpublic final DbHostAuth getHostSslAuth()
public final void setHostSslAuth(DbHostAuth hostSSLAUTH)
hostSSLAUTH
- the hOST_SSLAUTH to setpublic final String getAuthFile()
public final void setAuthFile(String file)
public final int getServerThread()
public final void setServerThread(int serverTHREAD)
serverTHREAD
- the sERVER_THREAD to setpublic final int getClientThread()
public final void setClientThread(int clientTHREAD)
clientTHREAD
- the cLIENT_THREAD to setpublic final long getDEFAULT_SESSION_LIMIT()
public final long getDEFAULT_GLOBAL_LIMIT()
public final int getServerPort()
public final void setServerPort(int serverPORT)
serverPORT
- the sERVER_PORT to setpublic final int getServerSslPort()
public final void setServerSslPort(int serverSSLPORT)
serverSSLPORT
- the sERVER_SSLPORT to setpublic final int getServerHttpport()
public final void setServerHttpport(int serverHTTPPORT)
serverHTTPPORT
- the sERVER_HTTPPORT to setpublic final int getServerHttpsPort()
public final void setServerHttpsPort(int serverHTTPSPORT)
serverHTTPSPORT
- the sERVER_HTTPSPORT to setpublic final String[] getServerIpsAddresses()
public final void setServerAddresses(String[] serverAddresses)
serverAddresses
- the sERVER_Addresses to setpublic final String[] getServerSslAddresses()
public final void setServerSslAddresses(String[] serverSSLAddresses)
serverSSLAddresses
- the sERVER_SSLIAddresses to setpublic final String[] getServerHttpAddresses()
public final void setServerHttpAddresses(String[] serverHTTPAddresses)
serverHTTPAddresses
- the sERVER_HTTPAddresses to setpublic final String[] getServerHttpsAddresses()
public final void setServerHttpsAddresses(String[] serverHTTPSAddresses)
serverHTTPSAddresses
- the sERVER_HTTPSAddresses to setpublic final long getTimeoutCon()
public final void setTimeoutCon(long timeoutCON)
timeoutCON
- the timeoutCON to setpublic final int getBlockSize()
public final void setBlockSize(int blockSIZE)
blockSIZE
- the bLOCKSIZE to setpublic final int getMaxGlobalMemory()
public final void setMaxGlobalMemory(int maxGlobalMemory)
maxGlobalMemory
- the maxGlobalMemory to setpublic final List<RestConfiguration> getRestConfigurations()
public final String getBaseDirectory()
public final void setBaseDirectory(String baseDirectory)
baseDirectory
- the baseDirectory to setpublic final String getInPath()
public final void setInPath(String inPath)
inPath
- the inPath to setpublic final String getOutPath()
public final void setOutPath(String outPath)
outPath
- the outPath to setpublic final String getArchivePath()
public final void setArchivePath(String archivePath)
archivePath
- the archivePath to setpublic final String getWorkingPath()
public final void setWorkingPath(String workingPath)
workingPath
- the workingPath to setpublic final String getConfigPath()
public final void setConfigPath(String configPath)
configPath
- the configPath to setpublic final String getHttpBasePath()
public final void setHttpBasePath(String httpBasePath)
httpBasePath
- the httpBasePath to setpublic final int getHttpModel()
public final void setHttpModel(int httpModel)
httpModel
- the httpModel to setpublic final boolean isShutdown()
public final void setShutdown(boolean isShutdown)
isShutdown
- the isShutdown to setpublic final long getServerGlobalWriteLimit()
public final void setServerGlobalWriteLimit(long serverGlobalWriteLimit)
serverGlobalWriteLimit
- the serverGlobalWriteLimit to setpublic final long getServerGlobalReadLimit()
public final void setServerGlobalReadLimit(long serverGlobalReadLimit)
serverGlobalReadLimit
- the serverGlobalReadLimit to setpublic final long getServerChannelWriteLimit()
public final void setServerChannelWriteLimit(long serverChannelWriteLimit)
serverChannelWriteLimit
- the serverChannelWriteLimit to setpublic final long getServerChannelReadLimit()
public final void setServerChannelReadLimit(long serverChannelReadLimit)
serverChannelReadLimit
- the serverChannelReadLimit to setpublic final long getDelayLimit()
public final void setDelayLimit(long delayLimit)
delayLimit
- the delayLimit to setpublic final boolean isUseSSL()
public final void setUseSSL(boolean useSSL)
useSSL
- the useSSL to setpublic final boolean isUseNOSSL()
public final void setUseNOSSL(boolean useNOSSL)
useNOSSL
- the useNOSSL to setpublic final FilesystemBasedDigest.DigestAlgo getDigest()
public final void setDigest(FilesystemBasedDigest.DigestAlgo digest)
digest
- the digest to setpublic final boolean isUseHttpCompression()
public final void setUseHttpCompression(boolean useHttpCompression)
useHttpCompression
- the useHttpCompression to setpublic final Des getCryptoKey()
public final void setCryptoKey(Des cryptoKey)
cryptoKey
- the cryptoKey to setpublic final String getCryptoFile()
public final void setCryptoFile(String cryptoFile)
cryptoFile
- the cryptoFile to setpublic final boolean isUseLocalExec()
public final void setUseLocalExec(boolean useLocalExec)
useLocalExec
- the useLocalExec to setpublic final boolean isServer()
protected final void setServer(boolean isServer)
isServer
- the isServer to setpublic final int getRunnerThread()
public final void setRunnerThread(int runnerTHREAD)
runnerTHREAD
- the rUNNER_THREAD to setpublic final long getDelayCommander()
public final void setDelayCommander(long delayCommander)
delayCommander
- the delayCommander to setpublic final long getDelayRetry()
public final void setDelayRetry(long delayRetry)
delayRetry
- the delayRetry to setpublic final R66ConstraintLimitHandler getConstraintLimitHandler()
public final void setConstraintLimitHandler(R66ConstraintLimitHandler constraintLimitHandler)
constraintLimitHandler
- the constraintLimitHandler to setpublic final boolean isCheckRemoteAddress()
public final void setCheckRemoteAddress(boolean checkRemoteAddress)
checkRemoteAddress
- the checkRemoteAddress to setpublic final boolean isCheckClientAddress()
public final void setCheckClientAddress(boolean checkClientAddress)
checkClientAddress
- the checkClientAddress to setpublic final boolean isSaveTaskRunnerWithNoDb()
public final void setSaveTaskRunnerWithNoDb(boolean saveTaskRunnerWithNoDb)
saveTaskRunnerWithNoDb
- the saveTaskRunnerWithNoDb to setpublic final int getMultipleMonitors()
public final void setMultipleMonitors(int multipleMonitors)
multipleMonitors
- the multipleMonitors to setpublic final Monitoring getMonitoring()
public final void setMonitoring(Monitoring monitoring)
monitoring
- the monitoring to setpublic final long getPastLimit()
public final void setPastLimit(long pastLimit)
pastLimit
- the pastLimit to setpublic final long getMinimalDelay()
public final void setMinimalDelay(long minimalDelay)
minimalDelay
- the minimalDelay to setpublic final String getSnmpConfig()
public final void setSnmpConfig(String snmpConfig)
snmpConfig
- the snmpConfig to setpublic final WaarpSnmpAgent getAgentSnmp()
public final void setAgentSnmp(WaarpSnmpAgent agentSnmp)
agentSnmp
- the agentSnmp to setpublic final R66PrivateMib getR66Mib()
public final void setR66Mib(R66PrivateMib r66Mib)
r66Mib
- the r66Mib to setpublic static WaarpSecureKeyStore getWaarpSecureKeyStore()
public static void setWaarpSecureKeyStore(WaarpSecureKeyStore waarpSecureKeyStore)
waarpSecureKeyStore
- the waarpSecureKeyStore to setpublic static WaarpSslContextFactory getWaarpSslContextFactory()
public static void setWaarpSslContextFactory(WaarpSslContextFactory waarpSslContextFactory)
waarpSslContextFactory
- the waarpSslContextFactory to setpublic final R66ThriftServerService getThriftService()
public final void setThriftService(R66ThriftServerService thriftService)
thriftService
- the thriftService to setpublic final int getThriftport()
public final void setThriftport(int thriftport)
thriftport
- the thriftport to setpublic final boolean isExecuteErrorBeforeTransferAllowed()
public final void setExecuteErrorBeforeTransferAllowed(boolean isExecuteErrorBeforeTransferAllowed)
isExecuteErrorBeforeTransferAllowed
- the
isExecuteErrorBeforeTransferAllowed
to setpublic final WaarpShutdownHook.ShutdownConfiguration getShutdownConfiguration()
public final boolean isHostProxyfied()
public final void setHostProxyfied(boolean isHostProxyfied)
isHostProxyfied
- the isHostProxyfied to setpublic final boolean isAuthentNoReuse()
public final void setAuthentNoReuse(boolean authentNoReuse)
authentNoReuse
- public final void setTransferGuid(boolean transferGuid)
transferGuid
- public final boolean isTransferGuid()
public final boolean isWarnOnStartup()
public final void setWarnOnStartup(boolean warnOnStartup)
warnOnStartup
- the warnOnStartup to setpublic final boolean isChrootChecked()
public final void setChrootChecked(boolean chrootChecked)
chrootChecked
- the chrootChecked to setpublic final boolean isBlacklistBadAuthent()
public final void setBlacklistBadAuthent(boolean blacklistBadAuthent)
blacklistBadAuthent
- the blacklistBadAuthent to setpublic final int getMaxfilenamelength()
public final void setMaxfilenamelength(int maxfilenamelength)
maxfilenamelength
- the maxfilenamelength to setpublic final int getTimeStat()
public final void setTimeStat(int timeStat)
timeStat
- the timeStat to setpublic final int getLimitCache()
public final void setLimitCache(int limitCache)
limitCache
- the limitCache to setpublic final long getTimeLimitCache()
public final void setTimeLimitCache(long timeLimitCache)
timeLimitCache
- the timeLimitCache to setpublic final void setMonitorExporterTransfers(String url, String basicAuthent, String token, String apiKey, String endpoint, int delay, boolean keepConnection, boolean monitorIntervalIncluded, boolean monitorTransformLongAsString)
url
- as 'http://myhost.com:8080' or 'https://myhost.com:8443'basicAuthent
- Basic Authent in Base64 to connect to REST API if
any (Basic authentication) (nullable)token
- access token (Bearer Token authorization
by Header) (nullable)apiKey
- API Key (Base64 of 'apiId:apiKey') (ApiKey authorization
by Header) (nullable)endpoint
- as '/waarpr66monitor' or simply '/'keepConnection
- True to keep the connexion opened, False to release the connexion each timemonitorIntervalIncluded
- True to include the interval information within 'waarpMonitor'
fieldmonitorTransformLongAsString
- True to transform Long as String (ELK)delay
- delay between 2 exportspublic final boolean isCompressionAvailable()
public final void setCompressionAvailable(boolean compressionAvailable)
compressionAvailable
- public final boolean setMonitorExporterTransfers(String remoteBaseUrl, String username, String pwd, String token, String apiKey, String prefix, String index, boolean intervalMonitoringIncluded, boolean transformLongAsString, boolean compression, int delay)
remoteBaseUrl
- as 'http://myelastic.com:9200' or 'https://myelastic.com:9201'username
- username to connect to Elasticsearch if any (Basic
authentication) (nullable)pwd
- password to connect to Elasticsearch if any (Basic
authentication) (nullable)token
- access token (Bearer Token authorization
by Header) (nullable)apiKey
- API Key (Base64 of 'apiId:apiKey') (ApiKey authorization
by Header) (nullable)prefix
- as '/prefix' or null if noneindex
- as 'waarpr66monitor' as the index name within
Elasticsearch, including extra dynamic informationintervalMonitoringIncluded
- True to include the interval information within 'waarpMonitor' fieldtransformLongAsString
- True to transform Long as String (ELK)compression
- True to compress REST exchanges between the client
and the Elasticsearch serverdelay
- delay between 2 exportspublic final void startMonitorExporterTransfers()
public final void setR66BusinessFactory(R66BusinessFactoryInterface r66BusinessFactory)
r66BusinessFactory
- the r66BusinessFactory to setCopyright © 2009–2022 Waarp. All rights reserved.