Skip to content

Commit

Permalink
mxq_job: Minor cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
mariux committed Nov 3, 2015
1 parent acc1eb6 commit 8a1c40d
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 5 deletions.
5 changes: 2 additions & 3 deletions mxq_job.c
Original file line number Diff line number Diff line change
Expand Up @@ -149,6 +149,7 @@ char *mxq_job_status_to_name(uint64_t status)
void mxq_job_free_content(struct mxq_job *j)
{
mx_free_null(j->job_workdir);
mx_free_null(j->job_argv);
mx_free_null(j->job_argv_str);
mx_free_null(j->job_stdout);
mx_free_null(j->job_stderr);
Expand All @@ -161,11 +162,9 @@ void mxq_job_free_content(struct mxq_job *j)
mx_free_null(j->tmp_stderr);
mx_free_null(j->host_submit);
mx_free_null(j->host_id);
mx_free_null(j->host_cpu_set_str);
mx_free_null(j->server_id);
mx_free_null(j->host_hostname);
mx_free_null(j->job_argv);
j->job_argv = NULL;
mx_free_null(j->host_cpu_set_str);
}

static int do_jobs_statement(struct mx_mysql *mysql, char *query, struct mx_mysql_bind *param, struct mxq_job **jobs)
Expand Down
4 changes: 2 additions & 2 deletions mxqd.c
Original file line number Diff line number Diff line change
Expand Up @@ -765,8 +765,8 @@ int mxq_redirect_open(char *fname)
} else if (!mx_streq(fname, "/dev/null")) {
res = unlink(fname);
if (res == -1 && errno != ENOENT) {
mx_log_err("unlink() failed: %m");
return -2;
mx_log_err("%s: unlink() failed: %m", fname);
return -2;
}
flags |= O_EXCL;
}
Expand Down

0 comments on commit 8a1c40d

Please sign in to comment.