Re: [igt-dev] [PATCH i-g-t v2 2/6] igt_core: Split too long log lines when sending to runner with comms

[Kamil Konieczny <kamil.konieczny@linux.intel.com>]

Hi Petri,

On 2022-11-08 at 12:07:29 +0200, Petri Latvala wrote:
> Especially with file dumps a single log packet could exceed the max
> size of a UNIX datagram. Split too long log chunks instead.
> 
> v2: Use while loop instead of recursion (Kamil).
> 
> Signed-off-by: Petri Latvala <petri.latvala@intel.com>
> Cc: Arkadiusz Hiler <arek@hiler.eu>
> Cc: Kamil Konieczny <kamil.konieczny@linux.intel.com>
> ---
>  lib/igt_core.c | 23 ++++++++++++++++++++++-
>  1 file changed, 22 insertions(+), 1 deletion(-)
> 
> diff --git a/lib/igt_core.c b/lib/igt_core.c
> index 3941c528..cab5f860 100644
> --- a/lib/igt_core.c
> +++ b/lib/igt_core.c
> @@ -457,6 +457,27 @@ static void _igt_log_buffer_reset(void)
>  	pthread_mutex_unlock(&log_buffer_mutex);
>  }
>  
> +static void _log_to_runner_split(int stream, const char *str)
> +{
> +	size_t limit = 4096;
> +	char *buf = NULL;
> +
> +	while (strlen(str) > limit) {

Small optimization would be to get once size = strlen(str)
before while and use it in loop
	while (size > limit) {

> +		if (!buf)
> +			buf = malloc(limit + 1);
> +
> +		strncpy(buf, str, limit);
> +		buf[limit] = '\0';
> +
> +		send_to_runner(runnerpacket_log(stream, buf));
> +
> +		str += limit;

So you can add here:
		size -= limit;

With or without it

Reviewed-by: Kamil Konieczny <kamil.konieczny@linux.intel.com>

--
Kamil

> +	}
> +
> +	send_to_runner(runnerpacket_log(stream, str));
> +	free(buf);
> +}
> +
>  __attribute__((format(printf, 2, 3)))
>  static void _log_line_fprintf(FILE* stream, const char *format, ...)
>  {
> @@ -467,7 +488,7 @@ static void _log_line_fprintf(FILE* stream, const char *format, ...)
>  
>  	if (runner_connected()) {
>  		vasprintf(&str, format, ap);
> -		send_to_runner(runnerpacket_log(fileno(stream), str));
> +		_log_to_runner_split(fileno(stream), str);
>  		free(str);
>  	} else {
>  		vfprintf(stream, format, ap);
> -- 
> 2.30.2
>