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

Make recovery work.

Browse source
This commit is contained in:
Michael Lipp 2023-08-04 10:21:22 +02:00
parent 476d2cf84f
commit 134e4c02f4
1 changed files with 3 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

13
org.jdrupes.vmoperator.manager/src/org/jdrupes/vmoperator/manager/VmWatcher.java
View file

@ -152,21 +152,14 @@ public class VmWatcher extends Component {
private void serveCrVersion(CustomObjectsApi coa, V1APIResource crd, private void serveCrVersion(CustomObjectsApi coa, V1APIResource crd,
String version) { String version) {
Call call;
try {
call = coa.listNamespacedCustomObjectCall(VM_OP_GROUP, version,
managedNamespace, crd.getName(), null, false, null, null, null,
null, null, null, null, true, null);
} catch (ApiException e) {
logger.log(Level.FINE, e,
() -> "Probem watching: " + e.getMessage());
return;
}
@SuppressWarnings("PMD.AvoidInstantiatingObjectsInLoops") @SuppressWarnings("PMD.AvoidInstantiatingObjectsInLoops")
var watcher = new Thread(() -> { var watcher = new Thread(() -> {
try { try {
// Watch sometimes terminates without apparent reason. // Watch sometimes terminates without apparent reason.
while (true) { while (true) {
var call = coa.listNamespacedCustomObjectCall(VM_OP_GROUP,
version, managedNamespace, crd.getName(), null, false,
null, null, null, null, null, null, null, true, null);
try (Watch<V1Namespace> watch try (Watch<V1Namespace> watch
= Watch.createWatch(client, call, = Watch.createWatch(client, call,
new TypeToken<Watch.Response<V1Namespace>>() { new TypeToken<Watch.Response<V1Namespace>>() {