mnl/VM-Operator
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 4 Wiki Activity Actions

Cancel timer if no longer needed.

Browse source
This commit is contained in:
Michael Lipp 2023-06-11 12:47:11 +02:00
parent 7dffeb8665
commit 15e83c082e
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
org.jdrupes.vmoperator.runner.qemu/src/org/jdrupes/vmoperator/runner/qemu/QemuMonitor.java
View file

@ -34,6 +34,7 @@ import java.util.logging.Logger;
import org.jgrapes.core.Channel; import org.jgrapes.core.Channel;
import org.jgrapes.core.Component; import org.jgrapes.core.Component;
import org.jgrapes.core.Components; import org.jgrapes.core.Components;
import org.jgrapes.core.Components.Timer;
import org.jgrapes.core.annotation.Handler; import org.jgrapes.core.annotation.Handler;
import org.jgrapes.core.events.Start; import org.jgrapes.core.events.Start;
import org.jgrapes.core.events.Stop; import org.jgrapes.core.events.Stop;
@ -74,6 +75,8 @@ public class QemuMonitor extends Component {
private SocketIOChannel monitorChannel; private SocketIOChannel monitorChannel;
private Stop suspendedStop; private Stop suspendedStop;
private Timer powerdownTimer;
/** /**
* Instantiates a new qemu monitor. * Instantiates a new qemu monitor.
* *
@ -223,6 +226,7 @@ public class QemuMonitor extends Component {
monitorChannel = null; monitorChannel = null;
synchronized (this) { synchronized (this) {
if (suspendedStop != null) { if (suspendedStop != null) {
powerdownTimer.cancel();
suspendedStop.resumeHandling(); suspendedStop.resumeHandling();
suspendedStop = null; suspendedStop = null;
} }
@ -244,7 +248,7 @@ public class QemuMonitor extends Component {
writeToMonitor(monitorMessages.get("powerdown")); writeToMonitor(monitorMessages.get("powerdown"));
// Schedule timer as fallback // Schedule timer as fallback
Components.schedule(t -> { powerdownTimer = Components.schedule(t -> {
synchronized (this) { synchronized (this) {
if (suspendedStop != null) { if (suspendedStop != null) {
suspendedStop.resumeHandling(); suspendedStop.resumeHandling();