Class ForkedInfinispanServerDriver

java.lang.Object

org.infinispan.server.test.core.AbstractInfinispanServerDriver

org.infinispan.server.test.core.ForkedInfinispanServerDriver

All Implemented Interfaces:

InfinispanServerDriver

public class ForkedInfinispanServerDriver
extends AbstractInfinispanServerDriver

Since:

11.0

Author:

Gustavo Lira <glira@redhat.com>, Radoslav Husar

Field Summary

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

BASE_DN, configuration, DEFAULT_CLUSTERED_INFINISPAN_CONFIG_FILE_NAME, JMX_PORT, JOIN_TIMEOUT, KEY_ALGORITHM, KEY_PASSWORD, KEY_SIGNATURE_ALGORITHM, TEST_HOST_ADDRESS, testHostAddress

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ForkedInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
MBeanServerConnection	getJmxConnection(int server, String username, String password, Consumer<Closeable> reaper)	Returns a MBeanServerConnection to the specified server
InetAddress	getServerAddress(int server)	Returns an InetAddress that points to a specific server.
InetSocketAddress	getServerSocket(int server, 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 server)	Determines whether a specific server is running as part of a server configuration
void	kill(int server)	Forcefully stops a server.
void	pause(int server)	Pauses the server.
void	prepare(String name)	Prepare a server layout
void	restart(int server)	Restarts a previously stopped server.
void	restartCluster()	Restarts all of the nodes
void	resume(int server)	Resumes a paused server.
protected void	start(String name, File rootDir, File configurationFile)
protected void	stop()	Stop whole cluster.
void	stop(int server)	Stop a specific 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

abbreviate, applyKeyStore, applyKeyStore, applyKeyStore, applyKeyStore, applyTrustStore, applyTrustStore, applyTrustStore, applyTrustStore, applyTrustStore, applyTrustStore, copyArtifactsToDataDir, copyArtifactsToUserLibDir, createCertificate, createKeyStores, createRemoteCacheManager, createServerHierarchy, createServerHierarchy, createSignedCertificate, createUserFile, debugJvmOption, dn, getCertificateFile, getConfDir, getConfiguration, getName, getRootDir, getStatus, serverRoot, start, stop, writeKeyStore

Methods inherited from class java.lang.Object

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

Constructor Details

ForkedInfinispanServerDriver

protected ForkedInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Details

prepare

public void prepare(String name)

Description copied from class: AbstractInfinispanServerDriver

Prepare a server layout

Specified by:

prepare in interface InfinispanServerDriver

Overrides:

prepare in class AbstractInfinispanServerDriver

Parameters:

name - the name of the server configuration

start

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

Specified by:

start in class AbstractInfinispanServerDriver

stop

protected void stop()

Stop whole cluster.

Specified by:

stop in class AbstractInfinispanServerDriver

stop

public void stop(int server)

Stop a specific server

Parameters:

server - the index of the server

isRunning

public boolean isRunning(int server)

Description copied from interface: InfinispanServerDriver

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

Parameters:

server - the

Returns:

true if the server is running, false otherwise

getServerSocket

public InetSocketAddress getServerSocket(int server,
 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:

server - the index of the server

port - the service port

Returns:

an unresolved InetSocketAddress pointing to the actual running service

getServerAddress

public InetAddress getServerAddress(int server)

Description copied from interface: InfinispanServerDriver

Returns an InetAddress that points to a specific server.

Parameters:

server - the index of the server

Returns:

an InetAddress pointing to the server's address

pause

public void pause(int server)

Description copied from class: AbstractInfinispanServerDriver

Pauses the server. Equivalent to kill -SIGSTOP

Specified by:

pause in interface InfinispanServerDriver

Overrides:

pause in class AbstractInfinispanServerDriver

Parameters:

server - the index of the server

resume

public void resume(int server)

Description copied from interface: InfinispanServerDriver

Resumes a paused server. Equivalent to kill -SIGCONT

Parameters:

server - the index of the server

kill

public void kill(int server)

Description copied from interface: InfinispanServerDriver

Forcefully stops a server. Equivalent to kill -SIGKILL

Parameters:

server - the index of the server

restart

public void restart(int server)

Description copied from interface: InfinispanServerDriver

Restarts a previously stopped server.

Parameters:

server - the index of the server

restartCluster

public void restartCluster()

Description copied from interface: InfinispanServerDriver

Restarts all of the nodes

getJmxConnection

public MBeanServerConnection getJmxConnection(int server,
 String username,
 String password,
 Consumer<Closeable> reaper)

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

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)