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

Improve readability.

Browse source
This commit is contained in:
Michael Lipp 2025-01-26 14:52:26 +01:00
parent 224855efd3
commit 981cbe2744
3 changed files with 65 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

22
org.jdrupes.vmoperator.manager/src/org/jdrupes/vmoperator/manager/PoolMonitor.java
View file

@ -23,7 +23,6 @@ import io.kubernetes.client.apimachinery.GroupVersionKind;
import io.kubernetes.client.openapi.ApiException;
import io.kubernetes.client.util.Watch;
import java.io.IOException;
import java.time.Instant;
import java.util.Collections;
import java.util.List;
import java.util.Map;
@ -171,17 +170,18 @@ public class PoolMonitor extends
}
// Sync last usage to console state change if user matches
var assignedTo = vmDef.assignedTo().orElse(null);
if (assignedTo == null || !assignedTo
.equals(vmDef.<String> fromStatus("consoleUser").orElse(null))) {
if (vmDef.assignedTo()
.map(at -> at.equals(vmDef.consoleUser().orElse(null)))
.orElse(true)) {
return;
}
var lastUsed
= vmDef.assignmentLastUsed().orElse(Instant.ofEpochSecond(0));
var conChange = vmDef.condition("ConsoleConnected")
.map(c -> c.getLastTransitionTime().toInstant())
.orElse(Instant.ofEpochSecond(0));
if (!conChange.isAfter(lastUsed)) {
var ccChange = vmDef.condition("ConsoleConnected")
.map(cc -> cc.getLastTransitionTime().toInstant());
if (ccChange
.map(tt -> vmDef.assignmentLastUsed().map(alu -> alu.isAfter(tt))
.orElse(true))
.orElse(true)) {
return;
}
var vmStub = VmDefinitionStub.get(client(),
@ -190,7 +190,7 @@ public class PoolMonitor extends
vmStub.updateStatus(from -> {
JsonObject status = from.status();
var assignment = GsonPtr.to(status).to("assignment");
assignment.set("lastUsed", conChange.toString());
assignment.set("lastUsed", ccChange.get().toString());
return status;
});
}

45
org.jdrupes.vmoperator.manager/src/org/jdrupes/vmoperator/manager/VmMonitor.java
View file

@ -283,15 +283,7 @@ public class VmMonitor extends
// Find available VM.
var pool = vmPool;
assignedVm = channelManager.channels().stream()
.filter(c -> c.vmDefinition().pools()
.contains(event.fromPool()))
.filter(c -> !c.vmDefinition()
.conditionStatus("ConsoleConnected").orElse(false))
.filter(c -> c.vmDefinition().assignedTo().isEmpty()
|| pool.retainUntil(c.vmDefinition()
.<String> fromStatus("assignment", "lastUsed")
.map(Instant::parse).orElse(Instant.ofEpochSecond(0)))
.isBefore(Instant.now()))
.filter(c -> isAssignable(pool, c.vmDefinition()))
.sorted(Comparator.comparing(c -> c.vmDefinition()
.assignmentLastUsed().orElse(Instant.ofEpochSecond(0))))
.findFirst();
@ -320,4 +312,39 @@ public class VmMonitor extends
assignedVm.get()));
}
}
@SuppressWarnings("PMD.SimplifyBooleanReturns")
private boolean isAssignable(VmPool pool, VmDefinition vmDef) {
// Check if the VM is in the pool
if (!vmDef.pools().contains(pool.name())) {
return false;
}
// Check if the VM is not in use
if (vmDef.consoleConnected()) {
return false;
}
// If not assigned, it's usable
if (vmDef.assignedTo().isEmpty()) {
return true;
}
// Check if it is to be retained
if (vmDef.assignmentLastUsed()
.map(lu -> pool.retainUntil(lu))
.map(ru -> Instant.now().isBefore(ru)).orElse(false)) {
return false;
}
// Additional check in case lastUsed has not been updated
// by PoolMonitor#onVmDefChanged() yet ("race condition")
if (vmDef.condition("ConsoleConnected")
.map(cc -> cc.getLastTransitionTime().toInstant())
.map(t -> pool.retainUntil(t))
.map(ru -> Instant.now().isBefore(ru)).orElse(false)) {
return false;
}
return true;
}
}