Package org.jdrupes.vmoperator.runner.qemu

Class Runner

java.lang.Object

org.jgrapes.core.internal.ComponentVertex

org.jgrapes.core.Component

org.jdrupes.vmoperator.runner.qemu.Runner

All Implemented Interfaces:

Iterable<ComponentType>, Channel, ComponentType, Eligible, Manager

public class Runner
extends Component

The Runner is responsible for managing the Qemu process and optionally a process that emulates a TPM (software TPM).

It’s main function is best described by the following state diagram.

The Runner associates an EventProcessor with the Start event. This “runner event processor” must be used for all events related to the application level function. Components that handle events from other sources (and thus event processors) must fire any resulting events on the runner event processor in order to maintain synchronization.

Nested Class Summary

Nested classes/interfaces inherited from interface org.jgrapes.core.Channel

Channel.Default

Field Summary

Fields inherited from class org.jgrapes.core.Component

logger

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
Runner(org.apache.commons.cli.CommandLine cmdLine)	Instantiates a new runner.

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)	The main method.
void	onConfigurationUpdate(ConfigurationUpdate event)	Process the initial configuration.
void	onConfigureQemu(ConfigureQemu event)	Whenever a new QEMU configuration is available, check if it is supposed to trigger a reset.
void	onConfigureQemuFinal(ConfigureQemu event)	As last step when handling a new configuration, check if QEMU is suspended after startup and should be continued.
void	onExit(Exit event)	On exit.
void	onFileChanged(FileChanged event)	Watch for the creation of the swtpm socket and start the qemu process if it has been created.
void	onHandlingError(HandlingError event)	Log the exception when a handling error is reported.
void	onInput(Input<?> event, ProcessManager.ProcessChannel channel)	Forward output from the processes to to the log.
void	onOsinfo(OsinfoEvent event)	Receiving the OSinfo means that the OS has been booted.
void	onProcessExited(ProcessExited event, ProcessManager.ProcessChannel channel)	On process exited.
void	onProcessStarted(ProcessStarted event, ProcessManager.ProcessChannel channel)	Associate required data with the process channel and register the channel in the context.
void	onQmpConfigured(QmpConfigured event)	Note ready state and send a ConfigureQemu event for any pending configuration (initial or change).
void	onStart(Start event)	Handle the start event.
void	onStarted(Started event)	Handle the started event.
void	onStopFirst(Stop event)	On stop.
void	onStopLast(Stop event)	On stop.

Methods inherited from class org.jgrapes.core.Component

channel, component, defaultCriterion, isEligibleFor, setName

Methods inherited from class org.jgrapes.core.internal.ComponentVertex

activeEventPipeline, addHandler, attach, channelReplacements, children, componentPath, componentVertex, detach, fire, initComponentsHandlers, iterator, name, newEventPipeline, newEventPipeline, parent, registerAsGenerator, root, toString, unregisterAsGenerator

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.jgrapes.core.Manager

stream

Constructor Details

Runner

public Runner(org.apache.commons.cli.CommandLine cmdLine)
       throws IOException

Instantiates a new runner.

Parameters:

cmdLine - the cmd line

Throws:

IOException - Signals that an I/O exception has occurred.

Method Details

onHandlingError

@Handler(channels=org.jgrapes.core.Channel.class,
         priority=-10000)
public void onHandlingError(HandlingError event)

Log the exception when a handling error is reported.

Parameters:

event - the event

onConfigurationUpdate

@Handler
public void onConfigurationUpdate(ConfigurationUpdate event)

Process the initial configuration.

The initial configuration and any subsequent updates will be forwarded to other components only when the QMP connection is ready (see @link #onQmpConfigured(QmpConfigured)).

Parameters:

event - the event

onQmpConfigured

@Handler
public void onQmpConfigured(QmpConfigured event)

Note ready state and send a ConfigureQemu event for any pending configuration (initial or change).

Parameters:

event - the event

onStart

@Handler(priority=100)
public void onStart(Start event)

Handle the start event.

Parameters:

event - the event

onStarted

@Handler
public void onStarted(Started event)

Handle the started event.

Parameters:

event - the event

onFileChanged

@Handler
public void onFileChanged(FileChanged event)

Watch for the creation of the swtpm socket and start the qemu process if it has been created.

Parameters:

event - the event

onProcessStarted

@Handler
public void onProcessStarted(ProcessStarted event,
 ProcessManager.ProcessChannel channel)
                      throws InterruptedException

Associate required data with the process channel and register the channel in the context.

Parameters:

event - the event

channel - the channel

Throws:

InterruptedException - the interrupted exception

onInput

@Handler
public void onInput(Input<?> event,
 ProcessManager.ProcessChannel channel)

Forward output from the processes to to the log.

Parameters:

event - the event

channel - the channel

onConfigureQemu

@Handler
public void onConfigureQemu(ConfigureQemu event)

Whenever a new QEMU configuration is available, check if it is supposed to trigger a reset.

Parameters:

event - the event

onConfigureQemuFinal

@Handler(priority=-1000)
public void onConfigureQemuFinal(ConfigureQemu event)

As last step when handling a new configuration, check if QEMU is suspended after startup and should be continued.

Parameters:

event - the event

onOsinfo

@Handler
public void onOsinfo(OsinfoEvent event)

Receiving the OSinfo means that the OS has been booted.

Parameters:

event - the event

onProcessExited

@Handler
public void onProcessExited(ProcessExited event,
 ProcessManager.ProcessChannel channel)

On process exited.

Parameters:

event - the event

channel - the channel

onExit

@Handler(priority=10001)
public void onExit(Exit event)

On exit.

Parameters:

event - the event

onStopFirst

@Handler(priority=10000)
public void onStopFirst(Stop event)

On stop.

Parameters:

event - the event

onStopLast

@Handler(priority=-10000)
public void onStopLast(Stop event)

On stop.

Parameters:

event - the event

main

public static void main(String[] args)

The main method.

Parameters:

args - the command