This is an automated email from the ASF dual-hosted git repository.

heneveld pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/brooklyn-server.git


The following commit(s) were added to refs/heads/master by this push:
     new ddad49043a fix for occasional test failure where task status includes 
bogus 'null'
ddad49043a is described below

commit ddad49043a85f4e95189c8eb5c193af34d501175
Author: Alex Heneveld <[email protected]>
AuthorDate: Fri Nov 11 16:07:18 2022 +0000

    fix for occasional test failure where task status includes bogus 'null'
---
 .../java/org/apache/brooklyn/util/core/task/BasicTask.java | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/core/src/main/java/org/apache/brooklyn/util/core/task/BasicTask.java 
b/core/src/main/java/org/apache/brooklyn/util/core/task/BasicTask.java
index 485238d9c8..8ab13b603f 100644
--- a/core/src/main/java/org/apache/brooklyn/util/core/task/BasicTask.java
+++ b/core/src/main/java/org/apache/brooklyn/util/core/task/BasicTask.java
@@ -645,7 +645,7 @@ public class BasicTask<T> implements TaskInternal<T> {
             computeStatusStringActive(verbosity, data);
         }
 
-        if (Strings.isBlank(data.mainShortSummary)) data.mainShortSummary = 
"Unknown"; //shouldn't happen
+        if (Strings.isBlank(data.mainShortSummary)) 
data.setSummary("Unknown"); //shouldn't happen
         if (verbosity<=0) return data.mainShortSummary;
         String result = data.mainShortSummary + Strings.join(data.oneLineData, 
"");
         if (verbosity==1) return result;
@@ -673,12 +673,12 @@ public class BasicTask<T> implements TaskInternal<T> {
         // the intermediate checks returned started==true isDone()==false.
         if (t == null) {
             if (done) {
-                if (data.mainShortSummary ==null) {
+                if (data.mainShortSummary==null) {
                     data.setSummary("Finishing");
                     data.appendToSummary("; just went done, no thread 
available");
                 }
             } else {
-                if (data.mainShortSummary ==null) {
+                if (data.mainShortSummary==null) {
                     //should only happen for repeating task which is not active
                     data.setSummary("Sleeping");
                     data.appendToSummary("; no thread available");
@@ -702,7 +702,7 @@ public class BasicTask<T> implements TaskInternal<T> {
             computeStatusStringOptionalDetails(verbosity, data);
             if (Strings.isBlank(data.mainShortSummary)) data.setSummary("In 
progress");
             computeStatusStringError(verbosity, data);
-        } else if (data.mainShortSummary ==null) {
+        } else if (data.mainShortSummary==null) {
             data.setSummary("Finishing");
             data.appendToSummary("; just went done");
             computeStatusStringOptionalDetails(verbosity, data);
@@ -714,14 +714,16 @@ public class BasicTask<T> implements TaskInternal<T> {
     protected void computeStatusStringThreadInfo(int verbosity, 
StatusStringData data, ThreadInfo ti) {
         if (verbosity>=1) {
             LockInfo lock = ti.getLockInfo();
-            String msg = null;
+            String msg;
             if (lock==null && ti.getThreadState()==Thread.State.RUNNABLE) {
                 //not blocked
                 if (ti.isSuspended()) {
                     msg = "Thread suspended";
                 } else {
                     if (verbosity >= 2) {
-                        msg += " (" + ti.getThreadState() + ")";
+                        msg = " (" + ti.getThreadState() + ")";
+                    } else {
+                        msg = null;
                     }
                 }
             } else {

Reply via email to