Class SbkGemBenchmark

java.lang.Object

io.gem.api.impl.SbkGemBenchmark

All Implemented Interfaces:

GemBenchmark

public final class SbkGemBenchmark
extends Object
implements GemBenchmark

Coordinates remote SBK execution and local SBM lifecycle.

Responsibilities: - Establish SSH sessions to all nodes and validate remote Java versions. - Reconcile the expected SBK version on every remote host. - Start SBM locally, then execute SBK remotely and collect results. - Aggregate remote outputs into RemoteResponse[] and shutdown cleanly.

Constructor Summary

Constructors

Constructor	Description
SbkGemBenchmark(io.sbm.api.impl.SbmBenchmark sbmBenchmark, @NotNull GemConfig config, @NotNull GemParameters params, List<List<String>> sbkArgsByNode)	Constructor SbkGemBenchmark is responsible for initializing all values.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<RemoteResponse[]>	start()	Start the Benchmark.
void	stop()	stop/shutdown the Benchmark.

Methods inherited from class Object

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

Constructor Details

SbkGemBenchmark

public SbkGemBenchmark(io.sbm.api.impl.SbmBenchmark sbmBenchmark,
 @NotNull
 @NotNull GemConfig config,
 @NotNull
 @NotNull GemParameters params,
 List<List<String>> sbkArgsByNode)

Constructor SbkGemBenchmark is responsible for initializing all values.

Parameters:

sbmBenchmark - embedded SBM benchmark

config - NotNull GemConfig

params - NotNull GemParameters

sbkArgsByNode - normalized remote SBK argument tokens for each node

Throws:

IllegalArgumentException - when the argument-set count does not match the connection count

Method Details

start

public CompletableFuture<RemoteResponse[]> start()
                                          throws IOException,
InterruptedException,
ExecutionException,
IllegalStateException

Description copied from interface: GemBenchmark

Start the Benchmark.

Specified by:

start in interface GemBenchmark

Returns:

CompletableFuture.

Throws:

IOException - If an exception occurred.

InterruptedException - If an exception occurred

ExecutionException - If an exception occurred

IllegalStateException - If an exception occurred.

stop

public void stop()

Description copied from interface: GemBenchmark

stop/shutdown the Benchmark.

Specified by:

stop in interface GemBenchmark