X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Futils.c;h=d8cb4a60f1574a936fab23bcf3a9535b2875a136;hp=0494b23bdcd0bd356f45c0f4f8c5bf8a0f99c871;hb=2d85110833f3ffc12a62b3c13b39216d6fd769d8;hpb=a4b92340642035d1eafeb1eead0ad01f64d2007d diff --git a/src/common/utils.c b/src/common/utils.c index 0494b23bd..d8cb4a60f 100644 --- a/src/common/utils.c +++ b/src/common/utils.c @@ -16,11 +16,15 @@ */ #define _GNU_SOURCE +#include #include #include #include #include #include +#include +#include +#include #include @@ -32,6 +36,7 @@ * /tmp/test1 does, the real path is returned. In normal time, realpath(3) * fails if the end point directory does not exist. */ +__attribute__((visibility("hidden"))) char *utils_expand_path(const char *path) { const char *end_path = path; @@ -70,7 +75,7 @@ char *utils_expand_path(const char *path) } /* Add end part to expanded path */ - strncat(expanded_path, end_path, PATH_MAX); + strncat(expanded_path, end_path, PATH_MAX - strlen(expanded_path) - 1); free(cut_path); return expanded_path; @@ -84,6 +89,7 @@ error: /* * Create a pipe in dst. */ +__attribute__((visibility("hidden"))) int utils_create_pipe(int *dst) { int ret; @@ -106,6 +112,7 @@ int utils_create_pipe(int *dst) * Make sure the pipe opened by this function are closed at some point. Use * utils_close_pipe(). */ +__attribute__((visibility("hidden"))) int utils_create_pipe_cloexec(int *dst) { int ret, i; @@ -134,6 +141,7 @@ error: /* * Close both read and write side of the pipe. */ +__attribute__((visibility("hidden"))) void utils_close_pipe(int *src) { int i, ret; @@ -158,6 +166,7 @@ void utils_close_pipe(int *src) /* * Create a new string using two strings range. */ +__attribute__((visibility("hidden"))) char *utils_strdupdelim(const char *begin, const char *end) { char *str; @@ -174,3 +183,121 @@ char *utils_strdupdelim(const char *begin, const char *end) error: return str; } + +/* + * Set CLOEXEC flag to the give file descriptor. + */ +__attribute__((visibility("hidden"))) +int utils_set_fd_cloexec(int fd) +{ + int ret; + + if (fd < 0) { + ret = -EINVAL; + goto end; + } + + ret = fcntl(fd, F_SETFD, FD_CLOEXEC); + if (ret < 0) { + PERROR("fcntl cloexec"); + ret = -errno; + } + +end: + return ret; +} + +/* + * Create pid file to the given path and filename. + */ +__attribute__((visibility("hidden"))) +int utils_create_pid_file(pid_t pid, const char *filepath) +{ + int ret; + FILE *fp; + + assert(filepath); + + fp = fopen(filepath, "w"); + if (fp == NULL) { + PERROR("open pid file %s", filepath); + ret = -1; + goto error; + } + + ret = fprintf(fp, "%d\n", pid); + if (ret < 0) { + PERROR("fprintf pid file"); + } + + fclose(fp); + DBG("Pid %d written in file %s", pid, filepath); +error: + return ret; +} + +/* + * Recursively create directory using the given path and mode. + * + * On success, return 0 else a negative error code. + */ +__attribute__((visibility("hidden"))) +int utils_mkdir_recursive(const char *path, mode_t mode) +{ + char *p, tmp[PATH_MAX]; + struct stat statbuf; + size_t len; + int ret; + + assert(path); + + ret = snprintf(tmp, sizeof(tmp), "%s", path); + if (ret < 0) { + PERROR("snprintf mkdir"); + goto error; + } + + len = ret; + if (tmp[len - 1] == '/') { + tmp[len - 1] = 0; + } + + for (p = tmp + 1; *p; p++) { + if (*p == '/') { + *p = 0; + if (tmp[strlen(tmp) - 1] == '.' && + tmp[strlen(tmp) - 2] == '.' && + tmp[strlen(tmp) - 3] == '/') { + ERR("Using '/../' is not permitted in the trace path (%s)", + tmp); + ret = -1; + goto error; + } + ret = stat(tmp, &statbuf); + if (ret < 0) { + ret = mkdir(tmp, mode); + if (ret < 0) { + if (errno != EEXIST) { + PERROR("mkdir recursive"); + ret = -errno; + goto error; + } + } + } + *p = '/'; + } + } + + ret = mkdir(tmp, mode); + if (ret < 0) { + if (errno != EEXIST) { + PERROR("mkdir recursive last piece"); + ret = -errno; + } else { + ret = 0; + } + } + +error: + return ret; +}