Package org.infinispan.server.test.core

Class EmbeddedInfinispanServerDriver

java.lang.Object

org.infinispan.server.test.core.AbstractInfinispanServerDriver

org.infinispan.server.test.core.EmbeddedInfinispanServerDriver

All Implemented Interfaces:

InfinispanServerDriver

public class EmbeddedInfinispanServerDriver
extends AbstractInfinispanServerDriver

Since:

10.0

Author:

Tristan Tarrant <tristan@infinispan.org>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	OFFSET_FACTOR

Fields inherited from class org.infinispan.server.test.core.AbstractInfinispanServerDriver

BASE_DN, configuration, DEFAULT_CLUSTERED_INFINISPAN_CONFIG_FILE_NAME, DEFAULT_SERVER_CONFIG, DEFAULT_SERVER_DATA, DEFAULT_SERVER_LIB, DEFAULT_SERVER_LOG, INFINISPAN_CLUSTER_NAME, INFINISPAN_CLUSTER_STACK, INFINISPAN_SERVER_CONFIG_PATH, INFINISPAN_SERVER_ROOT_PATH, JOIN_TIMEOUT, KEY_ALGORITHM, KEY_PASSWORD, KEY_SIGNATURE_ALGORITHM, TEST_HOST_ADDRESS, testHostAddress

Fields inherited from interface org.infinispan.server.test.core.InfinispanServerDriver

log

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EmbeddedInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
static boolean	areCacheViewsComplete(List<org.infinispan.manager.EmbeddedCacheManager> cacheManagers, boolean fail)
protected int	clusterPortOffset()
MBeanServerConnection	getJmxConnection(int server)	Returns a MBeanServerConnection to the specified server
InetAddress	getServerAddress(int serverIndex)	Returns an InetAddress that points to a specific server.
InetSocketAddress	getServerSocket(int serverIndex, int port)	Returns an InetSocketAddress for connecting to a specific port on a specific server.
int	getTimeout()	Returns the amount of time in seconds that we should wait for a server start/stop operation.
boolean	isRunning(int serverIndex)	Determines whether a specific server is running as part of a server configuration
void	kill(int serverIndex)	Forcefully stops a server.
void	pause(int serverIndex)	Pauses the server.
void	restart(int serverIndex)	Restarts a previously stopped server.
void	restartCluster()	Restarts all of the nodes
void	resume(int serverIndex)	Resumes a paused server.
protected void	start(String name, File rootDir, File configurationFile)
protected void	stop()
void	stop(int serverIndex)	Gracefully stops a running server
String	syncFilesFromServer(int server, String dir)	Synchronizes files from the server to the local filesystem
String	syncFilesToServer(int server, String path)

Methods inherited from class org.infinispan.server.test.core.AbstractInfinispanServerDriver

applyKeyStore, applyKeyStore, applyKeyStore, applyKeyStore, applyTrustStore, applyTrustStore, applyTrustStore, applyTrustStore, copyArtifactsToUserLibDir, createKeyStores, createRemoteCacheManager, createSelfSignedCertificate, createServerHierarchy, createServerHierarchy, createSignedCertificate, createUserFile, debugJvmOption, dn, getCertificateFile, getConfDir, getConfiguration, getName, getRootDir, getStatus, prepare, serverRoot, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

OFFSET_FACTOR

public static final int OFFSET_FACTOR

See Also:

• Constant Field Values

Constructor Details

EmbeddedInfinispanServerDriver

protected EmbeddedInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Details

clusterPortOffset

protected int clusterPortOffset()

start

protected void start(String name,
 File rootDir,
 File configurationFile)

Specified by:

start in class AbstractInfinispanServerDriver

stop

protected void stop()

Specified by:

stop in class AbstractInfinispanServerDriver

getServerSocket

public InetSocketAddress getServerSocket(int serverIndex,
 int port)

Description copied from interface: InfinispanServerDriver

Returns an InetSocketAddress for connecting to a specific port on a specific server. The implementation will need to provide a specific mapping (e.g. port offset).

Parameters:

serverIndex - the index of the server

port - the service port

Returns:

an unresolved InetSocketAddress pointing to the actual running service

getServerAddress

public InetAddress getServerAddress(int serverIndex)

Description copied from interface: InfinispanServerDriver

Returns an InetAddress that points to a specific server.

Parameters:

serverIndex - the index of the server

Returns:

an InetAddress pointing to the server's address

pause

public void pause(int serverIndex)

Description copied from class: AbstractInfinispanServerDriver

Pauses the server. Equivalent to kill -SIGSTOP

Specified by:

pause in interface InfinispanServerDriver

Overrides:

pause in class AbstractInfinispanServerDriver

Parameters:

serverIndex - the index of the server

resume

public void resume(int serverIndex)

Description copied from interface: InfinispanServerDriver

Resumes a paused server. Equivalent to kill -SIGCONT

Parameters:

serverIndex - the index of the server

stop

public void stop(int serverIndex)

Description copied from interface: InfinispanServerDriver

Gracefully stops a running server

Parameters:

serverIndex - the index of the server

kill

public void kill(int serverIndex)

Description copied from interface: InfinispanServerDriver

Forcefully stops a server. Equivalent to kill -SIGKILL

Parameters:

serverIndex - the index of the server

restart

public void restart(int serverIndex)

Description copied from interface: InfinispanServerDriver

Restarts a previously stopped server.

Parameters:

serverIndex - the index of the server

restartCluster

public void restartCluster()

Description copied from interface: InfinispanServerDriver

Restarts all of the nodes

isRunning

public boolean isRunning(int serverIndex)

Description copied from interface: InfinispanServerDriver

Determines whether a specific server is running as part of a server configuration

Parameters:

serverIndex - the

Returns:

true if the server is running, false otherwise

getJmxConnection

public MBeanServerConnection getJmxConnection(int server)

Description copied from interface: InfinispanServerDriver

Returns a MBeanServerConnection to the specified server

Parameters:

server - the index of the server

getTimeout

public int getTimeout()

Description copied from interface: InfinispanServerDriver

Returns the amount of time in seconds that we should wait for a server start/stop operation. This may vary depending on the type of driver (embedded, container)

Returns:

the number of seconds after which a server start/stop is considered to timeout

areCacheViewsComplete

public static boolean areCacheViewsComplete(List<org.infinispan.manager.EmbeddedCacheManager> cacheManagers,
 boolean fail)

syncFilesFromServer

public String syncFilesFromServer(int server,
 String dir)

Description copied from interface: InfinispanServerDriver

Synchronizes files from the server to the local filesystem

Parameters:

server - the server

dir - if relative, the path relative to the server root, otherwise an absolute path

Returns:

the path where the data has been synced to

syncFilesToServer

public String syncFilesToServer(int server,
 String path)