From 842f219d83eb530e44550f393b1235f8923c6ae3 Mon Sep 17 00:00:00 2001 From: Wei Zhou Date: Wed, 26 Jun 2024 11:03:26 +0200 Subject: [PATCH 1/2] agent: reconnect after waiting 5 seconds (#9258) * agent: reconnect after waiting 5 seconds * Update agent/src/main/java/com/cloud/agent/Agent.java * Update agent/src/main/java/com/cloud/agent/Agent.java Co-authored-by: Suresh Kumar Anaparti --- agent/src/main/java/com/cloud/agent/Agent.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/agent/src/main/java/com/cloud/agent/Agent.java b/agent/src/main/java/com/cloud/agent/Agent.java index 23b5e790eb93..5f5b8ecaa438 100644 --- a/agent/src/main/java/com/cloud/agent/Agent.java +++ b/agent/src/main/java/com/cloud/agent/Agent.java @@ -1228,6 +1228,12 @@ public void doTask(final Task task) throws TaskExecutionException { logger.error("Error parsing task", e); } } else if (task.getType() == Task.Type.DISCONNECT) { + try { + // an issue has been found if reconnect immediately after disconnecting. please refer to https://github.com/apache/cloudstack/issues/8517 + // wait 5 seconds before reconnecting + Thread.sleep(5000); + } catch (InterruptedException e) { + } logger.debug("Executing disconnect task - {}", () -> getLinkLog(task.getLink())); reconnect(task.getLink()); } else if (task.getType() == Task.Type.OTHER) { From d21aaa4271f4b4f1626f5fc5f44a7fe7ac403ac1 Mon Sep 17 00:00:00 2001 From: Suresh Kumar Anaparti Date: Thu, 27 Nov 2025 15:05:07 +0530 Subject: [PATCH 2/2] logs update --- agent/src/main/java/com/cloud/agent/Agent.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/agent/src/main/java/com/cloud/agent/Agent.java b/agent/src/main/java/com/cloud/agent/Agent.java index 5f5b8ecaa438..c1a9942174a6 100644 --- a/agent/src/main/java/com/cloud/agent/Agent.java +++ b/agent/src/main/java/com/cloud/agent/Agent.java @@ -1231,10 +1231,11 @@ public void doTask(final Task task) throws TaskExecutionException { try { // an issue has been found if reconnect immediately after disconnecting. please refer to https://github.com/apache/cloudstack/issues/8517 // wait 5 seconds before reconnecting + logger.debug("Wait for 5 secs before reconnecting, disconnect task - {}", () -> getLinkLog(task.getLink())); Thread.sleep(5000); } catch (InterruptedException e) { } - logger.debug("Executing disconnect task - {}", () -> getLinkLog(task.getLink())); + logger.debug("Executing disconnect task - {} and reconnecting", () -> getLinkLog(task.getLink())); reconnect(task.getLink()); } else if (task.getType() == Task.Type.OTHER) { processOtherTask(task);