hendrik/lens
1
0
Fork 0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00
Code Issues Projects Releases Wiki Activity

Improve

Browse Source 
Signed-off-by: Hung-Han (Henry) Chen <chenhungh@gmail.com>
This commit is contained in:
Hung-Han (Henry) Chen 2021-11-22 09:52:20 +02:00
parent 473ecda1bd
commit 41678ffaff
No known key found for this signature in database
GPG Key ID: 54B44603D251B788
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/common/k8s-api/kube-api.ts
View File

@ -548,14 +548,12 @@ export class KubeApi<T extends KubeObject> {
});
}
private watchSystemStatus(forUrl: string) {
private watchSystemStatus() {
electron.powerMonitor.on("suspend", () => {
logger.info(`[KUBE-API] system suspended... ${forUrl}`);
this.systemSuspended = true;
});
electron.powerMonitor.on("resume", () => {
logger.info(`[KUBE-API] system resumed! ${forUrl}`);
this.systemSuspended = false;
});
@ -580,28 +578,30 @@ export class KubeApi<T extends KubeObject> {
logger.info(`[KUBE-API] watch (${watchId}) ${retry === true ? "retried" : "started"} ${watchUrl}`);
if (!this.watchingSystemStatus) {
this.watchSystemStatus(watchUrl);
this.watchSystemStatus();
}
onceSystemResume().then(() => {
clearTimeout(timedRetry);
logger.info(`[KUBE-API] system resumed, resume watching of ${watchUrl}...`);
timedRetry = setTimeout(() => {
this.watch({ ...opts, namespace, callback, watchId, retry: true });
// 3000 is a non-evident random value, we assume that after 3 seconds the system is ready
// to start watching again. (Network interface/DNS is ready etc.)
}, 3000);
}).catch((error) => {
logger.warn(`[KUBE-API] resume watching of ${watchUrl} error`, error);
});
onceSystemSuspend().then((suspended) => {
onceSystemSuspend().then(async (suspended) => {
if (suspended) {
logger.info(`[KUBE-API] system suspended, abort watching ${watchUrl}...`);
abort?.();
logger.info(`[KUBE-API] system suspended, abort watching of ${watchUrl}...`);
try {
abort();
} catch (error) {
logger.error(`[KUBE-API] error aborting watch (${watchId})`, error);
}
const resumed = await onceSystemResume();
if (resumed) {
clearTimeout(timedRetry);
logger.info(`[KUBE-API] system resumed, resume watching of ${watchUrl}...`);
timedRetry = setTimeout(() => {
this.watch({ ...opts, namespace, callback, watchId, retry: true });
// 3000 is a naive value, we assume that after 3 seconds the system is ready
// to start watching again. (Network interface/DNS is ready etc.)
}, 3000);
}
}
}).catch((error) => {
logger.warn(`[KUBE-API] abort watching of ${watchUrl} error`, error);
});
responsePromise
@ -623,7 +623,7 @@ export class KubeApi<T extends KubeObject> {
return;
}
logger.info(`[KUBE-API] watch (${watchId}) ${eventName} ${watchUrl}`);
logger.info(`[KUBE-API] watch (${watchId}) ${eventName} ${watchUrl}, signal.aborted: ${signal.aborted}`);
clearTimeout(timedRetry);
timedRetry = setTimeout(() => { // we did not get any kubernetes errors so let's retry