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.QemuMonitor

All Implemented Interfaces:

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

public class QemuMonitor
extends Component

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.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	onClientConnected(ClientConnected event, SocketIOChannel channel)	Check if this is from opening the monitor socket and if true, save the socket in the context and associate the channel with the context.
void	onClosed(Closed<?> event, SocketIOChannel channel)	On closed.
void	onConfigureQemu(ConfigureQemu event)	On configure qemu.
void	onConnectError(ConnectError event, SocketIOChannel channel)	Called when a connection attempt fails.
void	onExecQmpCommand(MonitorCommand event)	On monitor command.
void	onFileChanged(FileChanged event)	Watch for the creation of the swtpm socket and start the qemu process if it has been created.
void	onInput(Input<?> event, SocketIOChannel channel)	Handle data from qemu monitor connection.
void	onPowerdownEvent(PowerdownEvent event)	On powerdown event.
void	onStart(Start event)	Handle the start event.
void	onStop(Stop event)	Shutdown the VM.

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 -

onStart

@Handler
public void onStart(Start event)
             throws IOException

Handle the start event.

Parameters:

event - the event

Throws:

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

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

onClientConnected

@Handler
public void onClientConnected(ClientConnected event,
 SocketIOChannel channel)

Check if this is from opening the monitor socket and if true, save the socket in the context and associate the channel with the context.

Then send the initial message to the socket.

Parameters:

event - the event

channel - the channel

onConnectError

@Handler
public void onConnectError(ConnectError event,
 SocketIOChannel channel)

Called when a connection attempt fails.

Parameters:

event - the event

channel - the channel

onInput

@Handler
public void onInput(Input<?> event,
 SocketIOChannel channel)

Handle data from qemu monitor connection.

Parameters:

event - the event

channel - the channel

onClosed

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

On closed.

Parameters:

event - the event

onExecQmpCommand

@Handler
public void onExecQmpCommand(MonitorCommand event)

On monitor command.

Parameters:

event - the event

onStop

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

Shutdown the VM.

Parameters:

event - the event

onPowerdownEvent

@Handler
public void onPowerdownEvent(PowerdownEvent event)

On powerdown event.

Parameters:

event - the event

onConfigureQemu

@Handler
public void onConfigureQemu(ConfigureQemu event)

On configure qemu.

Parameters:

event - the event