From: Michael Tremer <michael.tremer@ipfire.org>
Date: Thu, 27 Mar 2025 10:33:04 +0000 (+0000)
Subject: job: Always stream logs
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=95082846576ad661efd12cb8d1478e7dc27e18ec;p=pakfire.git

job: Always stream logs

This was too fragile before and I think we should be able to afford the
stupid traffic...

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
---

diff --git a/src/pakfire/job.c b/src/pakfire/job.c
index 78f4c9e2..7dc7dc7e 100644
--- a/src/pakfire/job.c
+++ b/src/pakfire/job.c
@@ -69,7 +69,6 @@ struct pakfire_job {
 	enum {
 		PAKFIRE_JOB_TEST       = (1 << 0),
 		PAKFIRE_JOB_CCACHE     = (1 << 1),
-		PAKFIRE_JOB_STREAM_LOG = (1 << 2),
 	} flags;
 
 	// Package URL
@@ -837,10 +836,6 @@ int pakfire_job_stream_logs(struct pakfire_job* self) {
 	int priority;
 	int r;
 
-	// Don't do this if not enabled
-	if (!pakfire_job_has_flag(self, PAKFIRE_JOB_STREAM_LOG))
-		return 0;
-
 	// Try to dequeue a line from the log buffer
 	r = pakfire_log_buffer_dequeue(self->log.buffer, &timestamp, &priority, &line, &length);
 	if (r < 0) {
@@ -976,14 +971,6 @@ int pakfire_job_handle_message(struct pakfire_job* self, struct json_object* mes
 		return r;
 	}
 
-	// Launch log stream
-	if (pakfire_string_equals(command, "launch-log-stream"))
-		self->flags |= PAKFIRE_JOB_STREAM_LOG;
-
-	// Terminate log stream
-	else if (pakfire_string_equals(command, "terminate-log-stream"))
-		self->flags &= ~PAKFIRE_JOB_STREAM_LOG;
-
 	// Abort job
 	if (pakfire_string_equals(command, "abort"))
 		return pakfire_job_terminate(self, SIGTERM);