Package org.jdrupes.vmoperator.runner.qemu

Class QemuMonitor

java.lang.Object

org.jgrapes.core.internal.ComponentVertex

org.jgrapes.core.Component

org.jdrupes.vmoperator.runner.qemu.QemuConnector

org.jdrupes.vmoperator.runner.qemu.QemuMonitor

All Implemented Interfaces:

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

public class QemuMonitor
extends QemuConnector

A component that handles the communication over the Qemu monitor socket.

If the log level for this class is set to fine, the messages exchanged on the monitor socket are logged.

Nested Class Summary

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

Channel.Default

Field Summary

Fields inherited from class org.jdrupes.vmoperator.runner.qemu.QemuConnector

mapper

Fields inherited from class org.jgrapes.core.Component

logger

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
QemuMonitor(Channel componentChannel, Path configDir)	Instantiates a new QEMU monitor.

Method Summary

Modifier and Type	Method	Description
(package private) void	configure(Path socketPath, int powerdownTimeout)	As the initial configuration of this component depends on the configuration of the Runner, it doesn’t have a handler for the ConfigurationUpdate event.
void	onClosed(Closed<?> event, SocketIOChannel channel)	On closed.
void	onConfigureQemu(ConfigureQemu event)	On configure qemu.
void	onMonitorCommand(MonitorCommand event)	On monitor command.
void	onPowerdownEvent(PowerdownEvent event)	When the powerdown event is confirmed, wait for termination or timeout.
void	onProcessExited(ProcessExited event)	On process exited.
void	onStop(Stop event)	Shutdown the VM.
protected void	processInput(String line)	Process agent input.
protected void	socketConnected()	When the socket is connected, send the capabilities command.

Methods inherited from class org.jdrupes.vmoperator.runner.qemu.QemuConnector

configure, onClientConnected, onConnectError, onFileChanged, onInput, onStart, qemuChannel, rep, sendCommand, writer

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

QemuMonitor

public QemuMonitor(Channel componentChannel,
 Path configDir)
            throws IOException

Instantiates a new QEMU monitor.

Parameters:

componentChannel - the component channel

configDir - the config dir

Throws:

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

Method Details

configure

void configure(Path socketPath,
 int powerdownTimeout)

As the initial configuration of this component depends on the configuration of the Runner, it doesn’t have a handler for the ConfigurationUpdate event.

The values are forwarded from the Runner instead.

Parameters:

socketPath - the socket path

powerdownTimeout -

socketConnected

protected void socketConnected()

When the socket is connected, send the capabilities command.

Overrides:

socketConnected in class QemuConnector

processInput

protected void processInput(String line)
                     throws IOException

Description copied from class: QemuConnector

Process agent input.

Specified by:

processInput in class QemuConnector

Parameters:

line - the line

Throws:

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

onClosed

@Handler
public void onClosed(Closed<?> event,
 SocketIOChannel channel)

On closed.

Overrides:

onClosed in class QemuConnector

Parameters:

event - the event

channel - the channel

onMonitorCommand

@Handler
public void onMonitorCommand(MonitorCommand event)
                      throws IOException

On monitor command.

Parameters:

event - the event

Throws:

IOException

onStop

@Handler(priority=100)
public void onStop(Stop event)

Shutdown the VM.

Parameters:

event - the event

onPowerdownEvent

@Handler
public void onPowerdownEvent(PowerdownEvent event)

When the powerdown event is confirmed, wait for termination or timeout.

Termination is detected by the qemu process exiting (see onProcessExited(ProcessExited)).

Parameters:

event - the event

onProcessExited

@Handler
public void onProcessExited(ProcessExited event)

On process exited.

Parameters:

event - the event

onConfigureQemu

@Handler
public void onConfigureQemu(ConfigureQemu event)

On configure qemu.

Parameters:

event - the event