|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectopenr66.protocol.configuration.Configuration
public class Configuration
Configuration class
Field Summary | |
---|---|
String |
ADMINNAME
Server Administration user name |
goldengate.snmp.GgSnmpAgent |
agentSnmp
SNMP Agent (if any) |
boolean |
anyBandwidthLimitation
Any limitation on bandwidth active? |
String |
archivePath
Archive path |
String |
baseDirectory
Base Directory |
int |
BLOCKSIZE
Size by default of block size for receive/sending files. |
static int |
BUFFERSIZEDEFAULT
Default size for buffers (NIO) |
HashSet<String> |
businessWhiteSet
White List of allowed Partners to use Business Requests |
boolean |
checkClientAddress
Do we check address even for Client |
boolean |
checkRemoteAddress
Do we check Remote Address from DbHost |
int |
CLIENT_THREAD
Default number of threads in pool for Client. |
String |
configPath
Config path |
static Configuration |
configuration
General Configuration object |
R66ConstraintLimitHandler |
constraintLimitHandler
Constraint Limit Handler on CPU usage and Connection limitation |
goldengate.common.crypto.Des |
cryptoKey
Crypto Key |
long |
DEFAULT_GLOBAL_LIMIT
Default global limit 1024Mbit |
long |
DEFAULT_SESSION_LIMIT
Default session limit 64Mbit, so up to 16 full simultaneous clients |
long |
delayCommander
Delay in ms between two steps of Commander |
long |
delayLimit
Delay in ms between two checks |
long |
delayRetry
Delay in ms between two retries |
goldengate.common.digest.FilesystemBasedDigest.DigestAlgo |
digest
Algorithm to use for Digest |
protected ExecutorService |
execOtherWorker
ExecutorService Other Worker |
protected ExecutorService |
execServerBoss
ExecutorService Server Boss |
protected ExecutorService |
execServerWorker
ExecutorService Server Worker |
static String |
EXT_R66
Extension of file during transfer |
boolean |
extendedProtocol
Version validation |
static goldengate.common.crypto.ssl.GgSecureKeyStore |
ggSecureKeyStore
|
static goldengate.common.crypto.ssl.GgSslContextFactory |
ggSslContextFactory
|
DbHostAuth |
HOST_AUTH
Server Actual Authentication |
String |
HOST_ID
Actual Host ID |
DbHostAuth |
HOST_SSLAUTH
Server Actual SSL Authentication |
String |
HOST_SSLID
Actual SSL Host ID |
String |
httpBasePath
Http Admin base |
protected org.jboss.netty.bootstrap.ServerBootstrap |
httpBootstrap
Bootstrap for Http server |
protected org.jboss.netty.channel.ChannelFactory |
httpChannelFactory
ChannelFactory for HttpServer part |
protected org.jboss.netty.channel.group.ChannelGroup |
httpChannelGroup
List of all Http Channels to enable the close call on them using Netty ChannelGroup |
protected org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor |
httpPipelineExecutor
ThreadPoolExecutor for Http and Https Server |
protected org.jboss.netty.bootstrap.ServerBootstrap |
httpsBootstrap
Bootstrap for Https server |
protected org.jboss.netty.channel.ChannelFactory |
httpsChannelFactory
ChannelFactory for HttpsServer part |
String |
inPath
In path (receive) |
boolean |
isServer
Does the current program running as Server |
boolean |
isShutdown
True if the service is going to shutdown |
static boolean |
ISUNIX
Hack to say Windows or Unix (USR1 not OK on Windows) |
long |
maxGlobalMemory
Max global memory limit: default is 4GB |
long |
minimalDelay
Monitoring: minimal interval in ms before redo real monitoring |
Monitoring |
monitoring
Monitoring object |
int |
multipleMonitors
In case of Multiple OpenR66 monitor servers behing a load balancer (HA solution) |
protected org.jboss.netty.util.ObjectSizeEstimator |
objectSizeEstimator
ObjectSizeEstimator |
String |
outPath
Out path (send, copy, pending) |
long |
pastLimit
Monitoring: how long in ms to get back in monitoring |
R66BusinessFactoryInterface |
r66BusinessFactory
|
R66PrivateMib |
r66Mib
Associated MIB |
static int |
RANKRESTART
Rank to redo when a restart occurs |
static long |
RETRYINMS
Time elapse for retry in ms |
static int |
RETRYNB
Number of retry before error |
int |
RUNNER_THREAD
Maximum number of concurrent active transfer by submission. |
boolean |
saveTaskRunnerWithNoDb
For No Db client, do we saved TaskRunner in a XML |
int |
SERVER_HTTPPORT
Default HTTP server port |
int |
SERVER_HTTPSPORT
Default HTTP server port |
int |
SERVER_PORT
Default server port |
int |
SERVER_SSLPORT
Default SSL server port |
int |
SERVER_THREAD
Default number of threads in pool for Server (true network listeners). |
long |
serverChannelReadLimit
Limit in Read byte/s to apply by session to the FTP Server |
long |
serverChannelWriteLimit
Limit in Write byte/s to apply by session to the FTP Server |
long |
serverGlobalReadLimit
Limit in Read byte/s to apply globally to the FTP Server |
long |
serverGlobalWriteLimit
Limit in Write byte/s to apply globally to the FTP Server |
String |
snmpConfig
Monitoring: snmp configuration file (empty means no snmp support) |
static String |
SnmpDefaultAuthor
|
static String |
SnmpDefaultLocalization
|
static String |
SnmpName
|
static int |
SnmpPrivateId
|
static int |
SnmpR66Id
|
static int |
SnmpService
|
static String |
SnmpVersion
|
long |
TIMEOUTCON
Nb of milliseconds after connection is in timeout |
boolean |
useHttpCompression
Does this OpenR66 server will try to compress HTTP connections |
static boolean |
USEJDK6
True if JDK6 or upper, False if JDK5. |
boolean |
useLocalExec
Does this OpenR66 server will use GoldenGate LocalExec Daemon for ExecTask and ExecMoveTask |
boolean |
useNOSSL
Does this OpenR66 server will use and accept non SSL connections |
boolean |
useSSL
Does this OpenR66 server will use and accept SSL connections |
static long |
WAITFORNETOP
Time elapse for WRITE OR CLOSE WAIT elaps in ms |
String |
workingPath
Working path |
Constructor Summary | |
---|---|
Configuration()
|
Method Summary | |
---|---|
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 |
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). |
ExecutorService |
getExecutorService()
|
static goldengate.common.file.filesystembased.FilesystemBasedFileParameterImpl |
getFileParameter()
|
org.jboss.netty.handler.traffic.GlobalTrafficShapingHandler |
getGlobalTrafficShapingHandler()
|
String |
getHostId(boolean isSSL)
|
String |
getHostId(goldengate.common.database.DbSession dbSession,
String remoteHost)
|
org.jboss.netty.channel.ChannelFactory |
getHttpChannelFactory()
|
org.jboss.netty.channel.group.ChannelGroup |
getHttpChannelGroup()
|
org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor |
getHttpPipelineExecutor()
|
org.jboss.netty.channel.ChannelFactory |
getHttpsChannelFactory()
|
InternalRunner |
getInternalRunner()
|
org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor |
getLocalClientPipelineExecutor()
|
org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor |
getLocalPipelineExecutor()
|
LocalTransaction |
getLocalTransaction()
|
byte[] |
getSERVERADMINKEY()
|
org.jboss.netty.channel.ChannelFactory |
getServerChannelFactory()
|
org.jboss.netty.channel.group.ChannelGroup |
getServerChannelGroup()
|
org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor |
getServerPipelineExecutor()
|
org.jboss.netty.util.Timer |
getTimerClose()
|
org.jboss.netty.util.Timer |
getTimerTraffic()
|
void |
httpPipelineInit()
|
boolean |
isKeyValid(byte[] newkey)
Is the given key a valid one |
org.jboss.netty.handler.traffic.ChannelTrafficShapingHandler |
newChannelTrafficShapingHandler()
|
void |
pipelineInit()
Configure the pipeline for client (to be called ony 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 |
serverStartup()
Startup the server |
void |
serverStop()
Stops the server To be called after all other stuff are closed (channels, connections) |
void |
setSERVERKEY(byte[] serverkey)
|
void |
startHttpSupport()
|
void |
startMonitoring()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
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 boolean USEJDK6
public static final long RETRYINMS
public static final int RETRYNB
public static boolean ISUNIX
public static final int BUFFERSIZEDEFAULT
public static final long WAITFORNETOP
public static final String EXT_R66
public static int RANKRESTART
public R66BusinessFactoryInterface r66BusinessFactory
public boolean extendedProtocol
public HashSet<String> businessWhiteSet
public String HOST_ID
public String HOST_SSLID
public String ADMINNAME
public DbHostAuth HOST_AUTH
public DbHostAuth HOST_SSLAUTH
public int SERVER_THREAD
public int CLIENT_THREAD
public final long DEFAULT_SESSION_LIMIT
public final long DEFAULT_GLOBAL_LIMIT
public int SERVER_PORT
public int SERVER_SSLPORT
public int SERVER_HTTPPORT
public int SERVER_HTTPSPORT
public long TIMEOUTCON
public int BLOCKSIZE
public long maxGlobalMemory
public String baseDirectory
public String inPath
public String outPath
public String archivePath
public String workingPath
public String configPath
public String httpBasePath
public volatile boolean isShutdown
public long serverGlobalWriteLimit
public long serverGlobalReadLimit
public long serverChannelWriteLimit
public long serverChannelReadLimit
public boolean anyBandwidthLimitation
public long delayLimit
public boolean useSSL
public boolean useNOSSL
public goldengate.common.digest.FilesystemBasedDigest.DigestAlgo digest
public boolean useHttpCompression
public boolean useLocalExec
public goldengate.common.crypto.Des cryptoKey
public boolean isServer
protected ExecutorService execServerBoss
protected ExecutorService execServerWorker
protected ExecutorService execOtherWorker
protected volatile org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor httpPipelineExecutor
protected org.jboss.netty.bootstrap.ServerBootstrap httpBootstrap
protected org.jboss.netty.bootstrap.ServerBootstrap httpsBootstrap
protected org.jboss.netty.channel.ChannelFactory httpChannelFactory
protected org.jboss.netty.channel.ChannelFactory httpsChannelFactory
protected org.jboss.netty.channel.group.ChannelGroup httpChannelGroup
protected org.jboss.netty.util.ObjectSizeEstimator objectSizeEstimator
public int RUNNER_THREAD
public long delayCommander
public long delayRetry
public R66ConstraintLimitHandler constraintLimitHandler
public boolean checkRemoteAddress
public boolean checkClientAddress
public boolean saveTaskRunnerWithNoDb
public int multipleMonitors
public Monitoring monitoring
public long pastLimit
public long minimalDelay
public String snmpConfig
public goldengate.snmp.GgSnmpAgent agentSnmp
public R66PrivateMib r66Mib
public static goldengate.common.crypto.ssl.GgSecureKeyStore ggSecureKeyStore
public static goldengate.common.crypto.ssl.GgSslContextFactory ggSslContextFactory
Constructor Detail |
---|
public Configuration()
Method Detail |
---|
public void pipelineInit()
public void httpPipelineInit()
public void serverStartup() throws goldengate.common.database.exception.GoldenGateDatabaseNoConnectionException, goldengate.common.database.exception.GoldenGateDatabaseSqlException
goldengate.common.database.exception.GoldenGateDatabaseSqlException
goldengate.common.database.exception.GoldenGateDatabaseNoConnectionException
public void r66Startup() throws goldengate.common.database.exception.GoldenGateDatabaseNoConnectionException, goldengate.common.database.exception.GoldenGateDatabaseSqlException
goldengate.common.database.exception.GoldenGateDatabaseNoConnectionException
goldengate.common.database.exception.GoldenGateDatabaseSqlException
public void startHttpSupport()
public void startMonitoring() throws goldengate.common.database.exception.GoldenGateDatabaseSqlException
goldengate.common.database.exception.GoldenGateDatabaseSqlException
public InternalRunner getInternalRunner()
public void prepareServerStop()
public void serverStop()
public void clientStop()
public boolean reloadCommanderDelay()
public void changeNetworkLimit(long writeGlobalLimit, long readGlobalLimit, long writeSessionLimit, long readSessionLimit, long delayLimit)
writeGlobalLimit
- readGlobalLimit
- writeSessionLimit
- readSessionLimit
- delayLimit
- public void computeNbThreads()
public org.jboss.netty.handler.traffic.ChannelTrafficShapingHandler newChannelTrafficShapingHandler() throws OpenR66ProtocolNoDataException
OpenR66ProtocolNoDataException
public ExecutorService getExecutorService()
public org.jboss.netty.util.Timer getTimerTraffic()
public org.jboss.netty.util.Timer getTimerClose()
public org.jboss.netty.handler.traffic.GlobalTrafficShapingHandler getGlobalTrafficShapingHandler()
public org.jboss.netty.channel.group.ChannelGroup getServerChannelGroup()
public org.jboss.netty.channel.ChannelFactory getServerChannelFactory()
public org.jboss.netty.channel.group.ChannelGroup getHttpChannelGroup()
public org.jboss.netty.channel.ChannelFactory getHttpChannelFactory()
public org.jboss.netty.channel.ChannelFactory getHttpsChannelFactory()
public org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor getServerPipelineExecutor()
public org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor getLocalPipelineExecutor()
public org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor getLocalClientPipelineExecutor()
public org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor getHttpPipelineExecutor()
public LocalTransaction getLocalTransaction()
public static goldengate.common.file.filesystembased.FilesystemBasedFileParameterImpl getFileParameter()
public byte[] getSERVERADMINKEY()
public boolean isKeyValid(byte[] newkey)
newkey
-
public void setSERVERKEY(byte[] serverkey)
serverkey
- the SERVERADMINKEY to setpublic String getHostId(boolean isSSL) throws OpenR66ProtocolNoSslException
isSSL
-
OpenR66ProtocolNoSslException
public String getHostId(goldengate.common.database.DbSession dbSession, String remoteHost) throws goldengate.common.database.exception.GoldenGateDatabaseException
dbSession
- remoteHost
-
goldengate.common.database.exception.GoldenGateDatabaseException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |