Signed-off-by: Tim Wiederhake <twiederh@xxxxxxxxxx> --- tests/commandhelper.c | 52 +++++++++++++++++++++---------------------- 1 file changed, 26 insertions(+), 26 deletions(-) diff --git a/tests/commandhelper.c b/tests/commandhelper.c index 5f0c1f5a51..df9be7d424 100644 --- a/tests/commandhelper.c +++ b/tests/commandhelper.c @@ -54,6 +54,19 @@ static void cleanupArguments(struct Arguments **ptr) free(args); } +static void cleanupStringList(char ***ptr) +{ + char **strings = *ptr; + + if (strings) { + char **str; + for (str = strings; *str; str++) + free(*str); + } + + free(strings); +} + static void cleanupGeneric(void *ptr) { void **ptrptr = ptr; @@ -219,26 +232,25 @@ static int printCwd(FILE *log) static int printInput(struct Arguments *args) { char buf[1024]; - struct pollfd *fds = NULL; - char **buffers = NULL; - size_t *buflen = NULL; - int ret = -1; + cleanup(struct pollfd *, cleanupGeneric) fds = NULL; + cleanup(char **, cleanupStringList) buffers = NULL; + cleanup(size_t *, cleanupGeneric) buflen = NULL; size_t i; ssize_t got; if (!(fds = calloc(args->numreadfds, sizeof(*fds)))) - goto cleanup; + return -1; /* plus one NULL terminator */ if (!(buffers = calloc(args->numreadfds + 1, sizeof(*buffers)))) - goto cleanup; + return -1; if (!(buflen = calloc(args->numreadfds, sizeof(*buflen)))) - goto cleanup; + return -1; if (args->close_stdin) { if (freopen("/dev/null", "r", stdin) != stdin) - goto cleanup; + return -1; usleep(100 * 1000); } @@ -258,7 +270,7 @@ static int printInput(struct Arguments *args) if (poll(fds, args->numreadfds, -1) < 0) { printf("poll failed: %s\n", strerror(errno)); - goto cleanup; + return -1; } for (i = 0; i < args->numreadfds; i++) { @@ -277,7 +289,7 @@ static int printInput(struct Arguments *args) got = read(fds[i].fd, buf, sizeof(buf)); if (got < 0) - goto cleanup; + return -1; if (got == 0) { /* do not want to hear from this fd anymore */ fds[i].events = 0; @@ -285,7 +297,7 @@ static int printInput(struct Arguments *args) buffers[i] = realloc(buffers[i], buflen[i] + got); if (!buf[i]) { fprintf(stdout, "Out of memory!\n"); - goto cleanup; + return -1; } memcpy(buffers[i] + buflen[i], buf, got); buflen[i] += got; @@ -304,9 +316,9 @@ static int printInput(struct Arguments *args) for (i = 0; i < args->numreadfds; i++) { if (fwrite(buffers[i], 1, buflen[i], stdout) != buflen[i]) - goto cleanup; + return -1; if (fwrite(buffers[i], 1, buflen[i], stderr) != buflen[i]) - goto cleanup; + return -1; } fprintf(stdout, "END STDOUT\n"); @@ -314,19 +326,7 @@ static int printInput(struct Arguments *args) fprintf(stderr, "END STDERR\n"); fflush(stderr); - ret = 0; - - cleanup: - if (buffers) { - char **ptr; - for (ptr = buffers; *ptr; ptr++) - free(*ptr); - } - free(fds); - free(buflen); - free(buffers); - - return ret; + return 0; } int main(int argc, char **argv) { -- 2.26.2