Package io.gem.api.impl

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. - Optionally delete/copy SBK directory on remote hosts. - 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.sbk.api.Benchmark sbmBenchmark, @NotNull GemConfig config, @NotNull GemParameters params, String sbkArgs)	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 java.lang.Object

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

Constructor Details

SbkGemBenchmark

public SbkGemBenchmark(io.sbk.api.Benchmark sbmBenchmark,
 @NotNull
 @NotNull GemConfig config,
 @NotNull
 @NotNull GemParameters params,
 String sbkArgs)

Constructor SbkGemBenchmark is responsible for initializing all values.

Parameters:

sbmBenchmark - Benchmark

config - NotNull GemConfig

params - NotNull GemParameters

sbkArgs - String

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