From nobody Mon Feb 9 17:56:07 2026 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id E051CC761AF for ; Fri, 31 Mar 2023 00:49:37 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S229810AbjCaAtg (ORCPT ); Thu, 30 Mar 2023 20:49:36 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:39948 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S229788AbjCaAte (ORCPT ); Thu, 30 Mar 2023 20:49:34 -0400 Received: from mail-yb1-xb49.google.com (mail-yb1-xb49.google.com [IPv6:2607:f8b0:4864:20::b49]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id AFD6C1207F for ; Thu, 30 Mar 2023 17:49:23 -0700 (PDT) Received: by mail-yb1-xb49.google.com with SMTP id w5-20020a253005000000b00aedd4305ff2so20601714ybw.13 for ; Thu, 30 Mar 2023 17:49:23 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20210112; t=1680223763; h=to:from:subject:references:mime-version:message-id:in-reply-to:date :from:to:cc:subject:date:message-id:reply-to; bh=r8kDVr0L3/jz3PKx2/Xe0c5OesyXlwiHmE5YPaDrqp0=; b=hFAdw/K0Go/isitryy0LSHmnD7fhXsz6n3po1ZSyOfHRKVuSNM5iVw+qzblpNVH8yK GgL6o5uLCXZvmcAFyfPz3JBPLTw0eMlCG2qqY1m16DWdaGNHzawprr4+y2ey38eunBer RL5zjRvWS2cNNW8HGaPz4aVYxSRoClBE6FRl0BXcQZ6bQQmJrKRAEELHWmuaGm+r99Dy mlrfvTFbxAT9IJd6Wko+gkL9o+7NJIog04d/2w34avGJjqU8AfK8gbPBzjtGPWeq+wx2 7eR5TUc4VXzVqAQbUrJB6KWkbYIdmonFVIBRBweNMozheXLLgY4LqL79KPDAs9JmK1Pb QeGQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; t=1680223763; h=to:from:subject:references:mime-version:message-id:in-reply-to:date :x-gm-message-state:from:to:cc:subject:date:message-id:reply-to; bh=r8kDVr0L3/jz3PKx2/Xe0c5OesyXlwiHmE5YPaDrqp0=; b=iJmDGssFS+tV50z1QPYHtGK4hMw6/MTHSWR7oRzb7N7kEJVdTB5G+0NTvboXydLZzp K45RcqN1x2hOZjwgfu1E2Rf6RDAedZj9H7O3MwYCfQU+pO/xL21m9+/uhi0sCjVtpUWX Ch0Q3Wh0v+ySGdRA39oMLzedSqpA2mcKksE6Oe22pfgA7Zz7zmjBUep2GSNXgESccMyb R35xBUspazPSxDEvXBhl0phq4uDbSoctzSMlZAyNW7X8oXnF/QmmhsKyAN8Wxlnn7ajD h3gHwcU3zoLk4HsgOAY5+zX0wqo79b156sLDKb+ikyZsQ7+O6+Nb8KnGi2FMbtv159Co QfSg== X-Gm-Message-State: AAQBX9c0bTkBkNaLfsmheHVfTH9yLX2RXQnQiMpB7lToGdcbaGGJ4Tvx YDUrIummutSsuHRt/fBRppjJKvRNUKPF X-Google-Smtp-Source: AKy350aJkuyRGOFqyRqlaNJdTuRJxkuDhuBr5i7y2eTM0OAROBvmVidnwWbq21tgIgl3OOw+ykZgzlmpCkHY X-Received: from irogers.svl.corp.google.com ([2620:15c:2d4:203:11ea:eb75:e48c:2c04]) (user=irogers job=sendgmr) by 2002:a05:6902:168d:b0:b6d:1483:bc18 with SMTP id bx13-20020a056902168d00b00b6d1483bc18mr16244213ybb.7.1680223762986; Thu, 30 Mar 2023 17:49:22 -0700 (PDT) Date: Thu, 30 Mar 2023 17:48:42 -0700 In-Reply-To: <20230331004844.1592789-1-irogers@google.com> Message-Id: <20230331004844.1592789-3-irogers@google.com> Mime-Version: 1.0 References: <20230331004844.1592789-1-irogers@google.com> X-Mailer: git-send-email 2.40.0.348.gf938b09366-goog Subject: [PATCH v1 2/4] perf srcline: Simplify addr2line subprocess From: Ian Rogers To: Peter Zijlstra , Ingo Molnar , Arnaldo Carvalho de Melo , Mark Rutland , Alexander Shishkin , Jiri Olsa , Namhyung Kim , Ian Rogers , Adrian Hunter , Nathan Chancellor , Nick Desaulniers , Tom Rix , linux-kernel@vger.kernel.org, linux-perf-users@vger.kernel.org, llvm@lists.linux.dev Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset="utf-8" Don't wrap stdin and stdout of subprocess with streams, use the api/io library for buffering. Signed-off-by: Ian Rogers --- tools/perf/util/srcline.c | 103 ++++++++++++++------------------------ 1 file changed, 38 insertions(+), 65 deletions(-) diff --git a/tools/perf/util/srcline.c b/tools/perf/util/srcline.c index f0a96a834e4b..2da86e57215d 100644 --- a/tools/perf/util/srcline.c +++ b/tools/perf/util/srcline.c @@ -10,6 +10,8 @@ #include #include =20 +#include + #include "util/dso.h" #include "util/debug.h" #include "util/callchain.h" @@ -366,12 +368,6 @@ void dso__free_a2l(struct dso *dso) =20 #else /* HAVE_LIBBFD_SUPPORT */ =20 -struct a2l_subprocess { - struct child_process addr2line; - FILE *to_child; - FILE *from_child; -}; - static int filename_split(char *filename, unsigned int *line_nr) { char *sep; @@ -393,28 +389,18 @@ static int filename_split(char *filename, unsigned in= t *line_nr) return 0; } =20 -static void addr2line_subprocess_cleanup(struct a2l_subprocess *a2l) +static void addr2line_subprocess_cleanup(struct child_process *a2l) { - if (a2l->addr2line.pid !=3D -1) { - kill(a2l->addr2line.pid, SIGKILL); - finish_command(&a2l->addr2line); /* ignore result, we don't care */ - a2l->addr2line.pid =3D -1; - } - - if (a2l->to_child !=3D NULL) { - fclose(a2l->to_child); - a2l->to_child =3D NULL; - } - - if (a2l->from_child !=3D NULL) { - fclose(a2l->from_child); - a2l->from_child =3D NULL; + if (a2l->pid !=3D -1) { + kill(a2l->pid, SIGKILL); + finish_command(a2l); /* ignore result, we don't care */ + a2l->pid =3D -1; } =20 free(a2l); } =20 -static struct a2l_subprocess *addr2line_subprocess_init(const char *addr2l= ine_path, +static struct child_process *addr2line_subprocess_init(const char *addr2li= ne_path, const char *binary_path) { const char *argv[] =3D { @@ -422,54 +408,34 @@ static struct a2l_subprocess *addr2line_subprocess_in= it(const char *addr2line_pa "-e", binary_path, "-i", "-f", NULL }; - struct a2l_subprocess *a2l =3D zalloc(sizeof(*a2l)); + struct child_process *a2l =3D zalloc(sizeof(*a2l)); int start_command_status =3D 0; =20 - if (a2l =3D=3D NULL) - goto out; - - a2l->to_child =3D NULL; - a2l->from_child =3D NULL; + if (a2l =3D=3D NULL) { + pr_err("Failed to allocate memory for addr2line"); + return NULL; + } =20 - a2l->addr2line.pid =3D -1; - a2l->addr2line.in =3D -1; - a2l->addr2line.out =3D -1; - a2l->addr2line.no_stderr =3D 1; + a2l->pid =3D -1; + a2l->in =3D -1; + a2l->out =3D -1; + a2l->no_stderr =3D 1; =20 - a2l->addr2line.argv =3D argv; - start_command_status =3D start_command(&a2l->addr2line); - a2l->addr2line.argv =3D NULL; /* it's not used after start_command; avoid= dangling pointers */ + a2l->argv =3D argv; + start_command_status =3D start_command(a2l); + a2l->argv =3D NULL; /* it's not used after start_command; avoid dangling = pointers */ =20 if (start_command_status !=3D 0) { pr_warning("could not start addr2line (%s) for %s: start_command return = code %d\n", addr2line_path, binary_path, start_command_status); - goto out; - } - - a2l->to_child =3D fdopen(a2l->addr2line.in, "w"); - if (a2l->to_child =3D=3D NULL) { - pr_warning("could not open write-stream to addr2line (%s) of %s\n", - addr2line_path, binary_path); - goto out; - } - - a2l->from_child =3D fdopen(a2l->addr2line.out, "r"); - if (a2l->from_child =3D=3D NULL) { - pr_warning("could not open read-stream from addr2line (%s) of %s\n", - addr2line_path, binary_path); - goto out; + addr2line_subprocess_cleanup(a2l); + return NULL; } =20 return a2l; - -out: - if (a2l) - addr2line_subprocess_cleanup(a2l); - - return NULL; } =20 -static int read_addr2line_record(struct a2l_subprocess *a2l, +static int read_addr2line_record(struct io *io, char **function, char **filename, unsigned int *line_nr) @@ -494,7 +460,7 @@ static int read_addr2line_record(struct a2l_subprocess = *a2l, if (line_nr !=3D NULL) *line_nr =3D 0; =20 - if (getline(&line, &line_len, a2l->from_child) < 0 || !line_len) + if (io__getline(&line, &line_len, io) < 0 || !line_len) goto error; if (function !=3D NULL) *function =3D strdup(strim(line)); @@ -502,7 +468,7 @@ static int read_addr2line_record(struct a2l_subprocess = *a2l, zfree(&line); line_len =3D 0; =20 - if (getline(&line, &line_len, a2l->from_child) < 0 || !line_len) + if (io__getline(&line, &line_len, io) < 0 || !line_len) goto error; =20 if (filename_split(line, line_nr =3D=3D NULL ? &dummy_line_nr : line_nr) = =3D=3D 0) { @@ -546,13 +512,17 @@ static int addr2line(const char *dso_name, u64 addr, struct inline_node *node, struct symbol *sym __maybe_unused) { - struct a2l_subprocess *a2l =3D dso->a2l; + struct child_process *a2l =3D dso->a2l; char *record_function =3D NULL; char *record_filename =3D NULL; unsigned int record_line_nr =3D 0; int record_status =3D -1; int ret =3D 0; size_t inline_count =3D 0; + int len; + char buf[128]; + ssize_t written; + struct io io; =20 if (!a2l) { if (!filename__has_section(dso_name, ".debug_line")) @@ -578,13 +548,16 @@ static int addr2line(const char *dso_name, u64 addr, * though, because it may be genuinely unknown, in which case we'll get t= wo sets of * "??"/"??:0" lines. */ - if (fprintf(a2l->to_child, "%016"PRIx64"\n,\n", addr) < 0 || fflush(a2l->= to_child) !=3D 0) { + len =3D snprintf(buf, sizeof(buf), "%016"PRIx64"\n,\n", addr); + written =3D len > 0 ? write(a2l->in, buf, len) : -1; + if (written !=3D len) { if (!symbol_conf.disable_add2line_warn) pr_warning("%s %s: could not send request\n", __func__, dso_name); goto out; } + io__init(&io, a2l->out, buf, sizeof(buf)); =20 - switch (read_addr2line_record(a2l, &record_function, &record_filename, &r= ecord_line_nr)) { + switch (read_addr2line_record(&io, &record_function, &record_filename, &r= ecord_line_nr)) { case -1: if (!symbol_conf.disable_add2line_warn) pr_warning("%s %s: could not read first record\n", __func__, dso_name); @@ -594,7 +567,7 @@ static int addr2line(const char *dso_name, u64 addr, * The first record was invalid, so return failure, but first read anoth= er * record, since we asked a junk question and have to clear the answer o= ut. */ - switch (read_addr2line_record(a2l, NULL, NULL, NULL)) { + switch (read_addr2line_record(&io, NULL, NULL, NULL)) { case -1: if (!symbol_conf.disable_add2line_warn) pr_warning("%s %s: could not read delimiter record\n", @@ -632,7 +605,7 @@ static int addr2line(const char *dso_name, u64 addr, } =20 /* We have to read the records even if we don't care about the inline inf= o. */ - while ((record_status =3D read_addr2line_record(a2l, + while ((record_status =3D read_addr2line_record(&io, &record_function, &record_filename, &record_line_nr)) =3D=3D 1) { @@ -656,7 +629,7 @@ static int addr2line(const char *dso_name, u64 addr, =20 void dso__free_a2l(struct dso *dso) { - struct a2l_subprocess *a2l =3D dso->a2l; + struct child_process *a2l =3D dso->a2l; =20 if (!a2l) return; --=20 2.40.0.348.gf938b09366-goog