Package org.apache.cassandra.service
Class CassandraDaemon
- java.lang.Object
-
- org.apache.cassandra.service.CassandraDaemon
-
public class CassandraDaemon extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interfaceCassandraDaemon.Server
-
Field Summary
Fields Modifier and Type Field Description static java.lang.StringMBEAN_NAMEstatic java.lang.RunnableSPECULATION_THRESHOLD_UPDATERprotected StartupChecksstartupChecks
-
Constructor Summary
Constructors Constructor Description CassandraDaemon()CassandraDaemon(boolean runManaged)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidactivate()A convenience method to initialize and start the daemon in one shot.voidapplyConfig()voidclearConnectionHistory()voidcompleteSetup()voiddeactivate()A convenience method to stop and destroy the daemon in one shot.voiddestroy()Clean up all resources obtained during the lifetime of the daemon.voiddestroyClientTransports()static CassandraDaemongetInstanceForTesting()voidinit(java.lang.String[] arguments)Initialize the Cassandra Daemon based on the given Commons Daemon-specific arguments.voidinitializeClientTransports()booleanisNativeTransportRunning()static voidmain(java.lang.String[] args)voidmigrateSystemDataIfNeeded()Checks if the data of the local system keyspaces need to be migrated to a different location.static voidregisterNativeAccess()voidrunStartupChecks()protected voidsetup()This is a hook for concrete daemons to initialize themselves suitably.booleansetupCompleted()voidsetupVirtualKeyspaces()voidstart()Start the Cassandra Daemon, assuming that it has already been initialized viainit(String[])Hook for JSVCvoidstartNativeTransport()voidstop()Stop the daemon, ideally in an idempotent manner.static voidstop(java.lang.String[] args)voidstopNativeTransport()voidvalidateTransportsCanStart()
-
-
-
Field Detail
-
MBEAN_NAME
public static final java.lang.String MBEAN_NAME
- See Also:
- Constant Field Values
-
SPECULATION_THRESHOLD_UPDATER
public static java.lang.Runnable SPECULATION_THRESHOLD_UPDATER
-
startupChecks
protected final StartupChecks startupChecks
-
-
Method Detail
-
getInstanceForTesting
public static CassandraDaemon getInstanceForTesting()
-
setup
protected void setup()
This is a hook for concrete daemons to initialize themselves suitably. Subclasses should override this to finish the job (listening on ports, etc.)
-
runStartupChecks
public void runStartupChecks()
-
migrateSystemDataIfNeeded
public void migrateSystemDataIfNeeded() throws java.io.IOExceptionChecks if the data of the local system keyspaces need to be migrated to a different location.- Throws:
java.io.IOException
-
setupVirtualKeyspaces
public void setupVirtualKeyspaces()
-
initializeClientTransports
public void initializeClientTransports()
-
completeSetup
public void completeSetup()
-
setupCompleted
public boolean setupCompleted()
-
init
public void init(java.lang.String[] arguments) throws java.io.IOExceptionInitialize the Cassandra Daemon based on the given Commons Daemon-specific arguments. To clarify, this is a hook for JSVC.- Parameters:
arguments- the arguments passed in from JSVC- Throws:
java.io.IOException
-
start
public void start()
Start the Cassandra Daemon, assuming that it has already been initialized viainit(String[])Hook for JSVC
-
stop
public void stop()
Stop the daemon, ideally in an idempotent manner. Hook for JSVC / Procrun
-
destroyClientTransports
public void destroyClientTransports()
-
destroy
public void destroy()
Clean up all resources obtained during the lifetime of the daemon. This is a hook for JSVC.
-
activate
public void activate()
A convenience method to initialize and start the daemon in one shot.
-
registerNativeAccess
public static void registerNativeAccess() throws javax.management.NotCompliantMBeanException- Throws:
javax.management.NotCompliantMBeanException
-
applyConfig
public void applyConfig()
-
validateTransportsCanStart
public void validateTransportsCanStart()
-
startNativeTransport
public void startNativeTransport()
-
stopNativeTransport
public void stopNativeTransport()
-
isNativeTransportRunning
public boolean isNativeTransportRunning()
-
deactivate
public void deactivate()
A convenience method to stop and destroy the daemon in one shot.
-
stop
public static void stop(java.lang.String[] args)
-
main
public static void main(java.lang.String[] args)
-
clearConnectionHistory
public void clearConnectionHistory()
-
-