Skip to content

Commit 2c13754

Browse files
authored
fix: remove synchronized statements (#187)
1 parent bfa4d32 commit 2c13754

1 file changed

Lines changed: 10 additions & 12 deletions

File tree

  • src/main/java/org/waveywaves/jenkins/plugins/tekton/client/build/create

src/main/java/org/waveywaves/jenkins/plugins/tekton/client/build/create/CreateRaw.java

Lines changed: 10 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -338,18 +338,16 @@ private void setParamOnPipelineRunSpec(@NonNull PipelineRunSpec spec, String par
338338
}
339339

340340
public void streamTaskRunLogsToConsole(TaskRun taskRun) throws Exception {
341-
synchronized (consoleLogger) {
342-
KubernetesClient kc = (KubernetesClient) kubernetesClient;
343-
TektonClient tc = (TektonClient) tektonClient;
344-
Thread logWatchTask = null;
345-
TaskRunLogWatch logWatch = new TaskRunLogWatch(kc, tc, taskRun, consoleLogger);
346-
logWatchTask = new Thread(logWatch);
347-
logWatchTask.start();
348-
logWatchTask.join();
349-
Exception e = logWatch.getException();
350-
if (e != null) {
351-
throw e;
352-
}
341+
KubernetesClient kc = (KubernetesClient) kubernetesClient;
342+
TektonClient tc = (TektonClient) tektonClient;
343+
Thread logWatchTask = null;
344+
TaskRunLogWatch logWatch = new TaskRunLogWatch(kc, tc, taskRun, consoleLogger);
345+
logWatchTask = new Thread(logWatch);
346+
logWatchTask.start();
347+
logWatchTask.join();
348+
Exception e = logWatch.getException();
349+
if (e != null) {
350+
throw e;
353351
}
354352
}
355353

0 commit comments

Comments
 (0)