Package org.apache.geode.distributed

Class ServerLauncher

java.lang.Object
org.apache.geode.distributed.AbstractLauncher<String>
org.apache.geode.distributed.ServerLauncher
All Implemented Interfaces:
Runnable
public class ServerLauncher extends AbstractLauncher<String>
The ServerLauncher class is a launcher class with main method to start a Geode Server (implying a Geode Cache Server process).
Since:
GemFire 7.0
See Also:

  • Method Details

    • main

      public static void main(String... args)
      Launches a Geode Server from the command-line configured with the given arguments.
      Parameters:
      args - the command-line arguments used to configure the Geode Server at runtime.

    • getInstance

      public static ServerLauncher getInstance()
      Gets the instance of the ServerLauncher used to launch the Geode Cache Server, or null if this VM does not have an instance of ServerLauncher indicating no Geode Cache Server is running.
      Returns:
      the instance of ServerLauncher used to launcher a Geode Cache Server in this VM.

    • getServerState

      public static ServerLauncher.ServerState getServerState()
      Gets the ServerState for this process or null if this process was not launched using this VM's ServerLauncher reference .
      Returns:
      the ServerState for this process or null.

    • getCache

      public Cache getCache()
      Gets a reference to the Cache that was created by this ServerLauncher.
      Returns:
      a reference to the Cache
      See Also:

    • getCacheConfig

      public org.apache.geode.internal.cache.CacheConfig getCacheConfig()
      Gets the CacheConfig object used to configure additional Geode Cache components and features (e.g. PDX).
      Returns:
      a CacheConfig object with additional Geode Cache configuration meta-data used on startup to configure the Cache.

    • getId

      public String getId()
      Gets an identifier that uniquely identifies and represents the Server associated with this launcher.
      Returns:
      a String value identifier to uniquely identify the Server and it's launcher.
      See Also:

    • getCommand

      public ServerLauncher.Command getCommand()
      Get the Server launcher command used to invoke the Server.
      Returns:
      the Server launcher command used to invoke the Server.
      See Also:

    • isAssignBuckets

      public boolean isAssignBuckets()
      Determines whether buckets should be assigned to partitioned regions in the cache upon Server start.
      Returns:
      a boolean indicating if buckets should be assigned upon Server start.

    • isDisableDefaultServer

      public boolean isDisableDefaultServer()
      Determines whether a default cache server will be added when the Geode Server comes online.
      Returns:
      a boolean value indicating whether to add a default cache server.

    • isForcing

      public boolean isForcing()
      Determines whether the PID file is allowed to be overwritten when the Server is started and a PID file already exists in the Server's specified working directory.
      Returns:
      boolean indicating if force has been enabled.

    • isHelping

      public boolean isHelping()
      Determines whether this launcher will be used to display help information. If so, then none of the standard Server launcher commands will be used to affect the state of the Server. A launcher is said to be 'helping' if the user entered the "--help" option (switch) on the command-line.
      Returns:
      a boolean value indicating if this launcher is used for displaying help information.
      See Also:

    • isRebalancing

      public boolean isRebalancing()
      Determines whether a rebalance operation on the cache will occur upon starting the Geode server using this launcher.
      Returns:
      a boolean indicating if the cache will be rebalance when the Geode server starts.

    • isRedirectingOutput

      public boolean isRedirectingOutput()
      Determines whether this launcher will redirect output to system logs when starting a new Server process.
      Returns:
      a boolean value indicating if this launcher will redirect output to system logs when starting a new Server process

    • getLogFileName

      public String getLogFileName()
      Gets the name of the log file used to log information about this Server.
      Specified by:
      getLogFileName in class AbstractLauncher<String>
      Returns:
      a String value indicating the name of this Server's log file.

    • getMemberName

      public String getMemberName()
      Gets the name of this member (this Server) in the Geode distributed system as determined by the 'name' Geode property.
      Overrides:
      getMemberName in class AbstractLauncher<String>
      Returns:
      a String indicating the name of the member (this Server) in the Geode distributed system.

    • getPid

      public Integer getPid()
      Gets the user-specified process ID (PID) of the running Server that ServerLauncher uses to issue status and stop commands to the Server.
      Specified by:
      getPid in class AbstractLauncher<String>
      Returns:
      an Integer value indicating the process ID (PID) of the running Server.

    • getProperties

      public Properties getProperties()
      Gets the Geode Distributed System (cluster) Properties.
      Returns:
      a Properties object containing the configuration settings for the Geode Distributed System (cluster).
      See Also:

    • getServerBindAddress

      public InetAddress getServerBindAddress()
      Gets the IP address to which the Server is bound listening for and accepting cache client connections. This property should not be confused with 'bindAddress' ServerLauncher property, which is the port for binding the Server's ServerSocket used in distribution and messaging between the peers of the Geode distributed system.
      Returns:
      an InetAddress indicating the IP address that the Server is bound to listening for and accepting cache client connections in a client/server topology.

    • getServerBindAddressAsString

      public String getServerBindAddressAsString()
      Gets the host, as either hostname or IP address, on which the Server was bound and running. An attempt is made to get the canonical hostname for IP address to which the Server was bound for accepting client requests. If the server bind address is null or localhost is unknown, then a default String value of "localhost/127.0.0.1" is returned. Note, this information is purely information and should not be used to re-construct state or for other purposes.
      Returns:
      the hostname or IP address of the host running the Server, based on the bind-address, or 'localhost/127.0.0.1' if the bind address is null and localhost is unknown.
      See Also:

    • getServerPort

      public Integer getServerPort()
      Gets the port on which the Server is listening for cache client connections. This property should not be confused with the 'port' ServerLauncher property, which is used by the Server to set the 'tcp-port' distribution config property and is used by the ServerSocket for peer distribution and messaging.
      Returns:
      an Integer value indicating the port the Server is listening on for cache client connections in the client/server topology.

    • getServerPortAsString

      public String getServerPortAsString()
      Gets the server port on which the Server is listening for client requests represented as a String value.
      Returns:
      a String representing the server port on which the Server is listening for client requests.
      See Also:

    • getServiceName

      public String getServiceName()
      Gets the name for a Geode Server.
      Specified by:
      getServiceName in class AbstractLauncher<String>
      Returns:
      a String indicating the name for a Geode Server.

    • getSpringXmlLocation

      public String getSpringXmlLocation()
      Gets the location of the Spring XML configuration meta-data file used to bootstrap, configure and initialize the Geode Server on start.

      Returns:
      a String indicating the location of the Spring XML configuration file.
      See Also:

    • isSpringXmlLocationSpecified

      public boolean isSpringXmlLocationSpecified()
      Determines whether this Geode Server was configured and initialized with Spring configuration meta-data.

      Returns:
      a boolean value indicating whether this Geode Server was configured with Spring configuration meta-data.

    • getWorkingDirectory

      public String getWorkingDirectory()
      Gets the working directory pathname in which the Server will be run.
      Overrides:
      getWorkingDirectory in class AbstractLauncher<String>
      Returns:
      a String value indicating the pathname of the Server's working directory.

    • getCriticalHeapPercentage

      public Float getCriticalHeapPercentage()

    • getEvictionHeapPercentage

      public Float getEvictionHeapPercentage()

    • getCriticalOffHeapPercentage

      public Float getCriticalOffHeapPercentage()

    • getEvictionOffHeapPercentage

      public Float getEvictionOffHeapPercentage()

    • getHostNameForClients

      public String getHostNameForClients()

    • getMaxConnections

      public Integer getMaxConnections()

    • getMaxMessageCount

      public Integer getMaxMessageCount()

    • getMessageTimeToLive

      public Integer getMessageTimeToLive()

    • getMaxThreads

      public Integer getMaxThreads()

    • getSocketBufferSize

      public Integer getSocketBufferSize()

    • help

      public void help(ServerLauncher.Command command)
      Displays help for the specified Server launcher command to standard output. If the Server launcher command is unspecified, then usage information is displayed instead.
      Parameters:
      command - the Server launcher command in which to display help information.
      See Also:

    • usage

      public void usage()
      Displays usage information on the proper invocation of the ServerLauncher from the command-line to standard output.
      See Also:

    • run

      public void run()
      A Runnable method used to invoke the Geode server (cache server) with the specified command. From run, a user can invoke 'start', 'status', 'stop' and 'version'. Note, that 'version' is also a command-line option, but can be treated as a "command" as well.
      See Also:

    • getServerPidFile

      protected File getServerPidFile()
      Gets a File reference with the path to the PID file for the Server.
      Returns:
      a File reference to the path of the Server's PID file.

    • start

      public ServerLauncher.ServerState start()
      Invokes the 'start' command and operation to startup a Geode server (a cache server). Note, this method will cause the JVM to block upon server start, providing the calling Thread is a non-daemon Thread.
      Returns:
      a ServerLauncher.ServerState representing the state of the server following the attempt to start
      See Also:

    • isServing

      protected boolean isServing(Cache cache)
      Determines whether the specified Cache has any CacheServers.
      Parameters:
      cache - the Cache to check for existing CacheServers.
      Returns:
      a boolean value indicating if any CacheServers were added to the Cache.

    • waitOnServer

      public void waitOnServer()
      Causes the calling Thread to block until the Geode Cache Server/Data Member stops.

    • isDefaultServerEnabled

      protected boolean isDefaultServerEnabled(Cache cache)
      Determines whether a default server (a cache server) should be created on startup as determined by the absence of specifying the --disable-default-server command-line option (switch). In addition, a default cache server is started only if no cache servers have been added to the Cache by way of cache.xml.
      Parameters:
      cache - the reference to the Cache to check for any existing cache servers.
      Returns:
      a boolean indicating whether a default server should be added to the Cache.
      See Also:

    • isStartingOrRunning

      protected boolean isStartingOrRunning()
      Determines whether the Server is the process of starting or is already running.
      Returns:
      a boolean indicating if the Server is starting or is already running.

    • status

      public ServerLauncher.ServerState status()
      Invokes the 'status' command and operation to check the status of a Geode server (a cache server).
      Returns:
      a ServerLauncher.ServerState representing the status of the server

    • stop

      public ServerLauncher.ServerState stop()
      Invokes the 'stop' command and operation to stop a Geode server (a cache server).
      Returns:
      a ServerLauncher.ServerState representing the state of the server following the attempt to stop