Signed-off-by: Jens Axboe <axboe@kernel.dk>
static bool is_socket(const char *path)
{
struct stat buf;
static bool is_socket(const char *path)
{
struct stat buf;
- int r = stat(path, &buf);
+ int r;
+
+ r = stat(path, &buf);
if (r == -1)
return false;
if (r == -1)
return false;
static int open_socket(const char *path)
{
static int open_socket(const char *path)
{
- int fd = socket(AF_UNIX, SOCK_STREAM, 0);
+ int ret, fd;
+
+ fd = socket(AF_UNIX, SOCK_STREAM, 0);
addr.sun_family = AF_UNIX;
if (snprintf(addr.sun_path, sizeof(addr.sun_path), "%s", path) >=
addr.sun_family = AF_UNIX;
if (snprintf(addr.sun_path, sizeof(addr.sun_path), "%s", path) >=
+ sizeof(addr.sun_path)) {
log_err("%s: path name %s is too long for a Unix socket\n",
__func__, path);
log_err("%s: path name %s is too long for a Unix socket\n",
__func__, path);
- if (connect(fd, (const struct sockaddr *)&addr, strlen(path) + sizeof(addr.sun_family)) == 0)
+ }
+
+ ret = connect(fd, (const struct sockaddr *)&addr, strlen(path) + sizeof(addr.sun_family));
+ if (!ret)
*/
static bool init_iolog_read(struct thread_data *td)
{
*/
static bool init_iolog_read(struct thread_data *td)
{
+ char buffer[256], *p, *fname;
- bool ret;
- char* fname = get_name_by_idx(td->o.read_iolog_file, td->subjob_number);
+
+ fname = get_name_by_idx(td->o.read_iolog_file, td->subjob_number);
dprint(FD_IO, "iolog: name=%s\n", fname);
if (is_socket(fname)) {
dprint(FD_IO, "iolog: name=%s\n", fname);
if (is_socket(fname)) {
- int fd = open_socket(fname);
- if (fd >= 0) {
+ int fd;
+
+ fd = open_socket(fname);
+ if (fd >= 0)
} else
f = fopen(fname, "r");
} else
f = fopen(fname, "r");
if (!f) {
perror("fopen read iolog");
return false;
if (!f) {
perror("fopen read iolog");
return false;
fclose(f);
return false;
}
fclose(f);
return false;
}
/*
* version 2 of the iolog stores a specific string as the
* first line, check for that
*/
if (!strncmp(iolog_ver2, buffer, strlen(iolog_ver2))) {
free_release_files(td);
/*
* version 2 of the iolog stores a specific string as the
* first line, check for that
*/
if (!strncmp(iolog_ver2, buffer, strlen(iolog_ver2))) {
free_release_files(td);
- ret = read_iolog2(td);
- }
- else {
- log_err("fio: iolog version 1 is no longer supported\n");
- ret = false;
+ return read_iolog2(td);
+ log_err("fio: iolog version 1 is no longer supported\n");
+ return false;