Skip to content

Commit

Permalink
mxq_job: Remove unused job_flags column
Browse files Browse the repository at this point in the history
  • Loading branch information
donald committed Dec 29, 2023
1 parent 2f1562c commit d25a77e
Show file tree
Hide file tree
Showing 6 changed files with 4 additions and 14 deletions.
4 changes: 1 addition & 3 deletions mxq_job.c
Original file line number Diff line number Diff line change
Expand Up @@ -18,11 +18,10 @@
#include "mxq_group.h"
#include "mxq_job.h"

#define JOB_FIELDS_CNT 38
#define JOB_FIELDS_CNT 37
#define JOB_FIELDS \
" job_id, " \
" job_status, " \
" job_flags, " \
" job_priority, " \
" group_id, " \
" job_workdir, " \
Expand Down Expand Up @@ -67,7 +66,6 @@ static void bind_result_job_fields(struct mx_mysql_bind *result, struct mxq_job

mx_mysql_bind_var(result, idx++, uint64, &(j->job_id));
mx_mysql_bind_var(result, idx++, uint16, &(j->job_status));
mx_mysql_bind_var(result, idx++, uint64, &(j->job_flags));
mx_mysql_bind_var(result, idx++, uint16, &(j->job_priority));
mx_mysql_bind_var(result, idx++, uint64, &(j->group_id));
mx_mysql_bind_var(result, idx++, string, &(j->job_workdir));
Expand Down
1 change: 0 additions & 1 deletion mxq_job.h
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
struct mxq_job {
uint64_t job_id;
uint16_t job_status;
uint64_t job_flags;
uint16_t job_priority;

uint64_t group_id;
Expand Down
8 changes: 1 addition & 7 deletions mxqsub.c
Original file line number Diff line number Diff line change
Expand Up @@ -521,9 +521,7 @@ static int add_job(struct mx_mysql *mysql, struct mxq_job *j)

" job_umask = ?,"

" host_submit = ?,"

" job_flags = ?"
" host_submit = ?"
);
if (!stmt) {
mx_log_err("mx_mysql_statement_prepare(): %s", mx_mysql_error());
Expand All @@ -540,7 +538,6 @@ static int add_job(struct mx_mysql *mysql, struct mxq_job *j)
mx_mysql_statement_param_bind(stmt, 6, string, &(j->job_stderr));
mx_mysql_statement_param_bind(stmt, 7, uint32, &(j->job_umask));
mx_mysql_statement_param_bind(stmt, 8, string, &(j->host_submit));
mx_mysql_statement_param_bind(stmt, 9, uint64, &(j->job_flags));

res = mx_mysql_statement_execute(stmt, &num_rows);
if (res < 0) {
Expand Down Expand Up @@ -707,7 +704,6 @@ int main(int argc, char *argv[])
char *arg_mysql_default_file;
char *arg_mysql_default_group;
char arg_debug;
char arg_jobflags;
u_int32_t arg_tmpdir;
u_int16_t arg_gpu;

Expand Down Expand Up @@ -796,7 +792,6 @@ int main(int argc, char *argv[])
arg_stderr = "stdout";
arg_umask = getumask();
arg_debug = 0;
arg_jobflags = 0;
arg_groupid = UINT64_UNSET;
arg_tmpdir = 10; // 10G
arg_blacklist = NULL;
Expand Down Expand Up @@ -1132,7 +1127,6 @@ int main(int argc, char *argv[])

group.job_max_per_node = arg_max_per_node;

job.job_flags = arg_jobflags;
job.job_priority = arg_priority;
job.job_workdir = arg_workdir;
job.job_stdout = arg_stdout;
Expand Down
2 changes: 0 additions & 2 deletions mysql/create_tables.sql
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ CREATE TABLE IF NOT EXISTS mxq_group (
group_id INT8 UNSIGNED NOT NULL PRIMARY KEY AUTO_INCREMENT,
group_name VARCHAR(128) NOT NULL DEFAULT 'default',
group_status INT1 UNSIGNED NOT NULL DEFAULT 0,
group_flags INT8 UNSIGNED NOT NULL DEFAULT 0,
group_priority INT2 UNSIGNED NOT NULL DEFAULT 127,
group_blacklist VARCHAR(1000) NOT NULL DEFAULT '',
group_whitelist VARCHAR(1000) NOT NULL DEFAULT '',
Expand Down Expand Up @@ -71,7 +70,6 @@ CREATE TABLE IF NOT EXISTS mxq_group (
CREATE TABLE IF NOT EXISTS mxq_job (
job_id INT8 UNSIGNED NOT NULL PRIMARY KEY AUTO_INCREMENT,
job_status INT2 UNSIGNED NOT NULL DEFAULT 0,
job_flags INT8 UNSIGNED NOT NULL DEFAULT 0,
job_priority INT2 UNSIGNED NOT NULL DEFAULT 127,

group_id INT8 UNSIGNED NOT NULL,
Expand Down
2 changes: 2 additions & 0 deletions mysql/migrate_016_remove_job_flags.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
ALTER TABLE mxq_job
DROP COLUMN job_flags;
1 change: 0 additions & 1 deletion web/pages/mxq/mxq.in
Original file line number Diff line number Diff line change
Expand Up @@ -587,7 +587,6 @@ sub job {
$out.=<<"EOF";
<pre>
job_status : $job_status_text
job_flags : $o{job_flags}
job_priority : $o{job_priority}
group_id : $link_group_id
Expand Down

0 comments on commit d25a77e

Please sign in to comment.