Skip to content

Commit

Permalink
Merge pull request #97 from mariux64/rename-mxqd-prerequisites-to-tags
Browse files Browse the repository at this point in the history
Rename mxqd prerequisites to tags
  • Loading branch information
donald authored Mar 29, 2021
2 parents 3f78307 + 4d577b2 commit 78c12d0
Show file tree
Hide file tree
Showing 7 changed files with 22 additions and 22 deletions.
6 changes: 3 additions & 3 deletions Makefile
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
MXQ_VERSION_MAJOR = 0
MXQ_VERSION_MINOR = 26
MXQ_VERSION_PATCH = 6
MXQ_VERSION_MINOR = 27
MXQ_VERSION_PATCH = 0
MXQ_VERSION_EXTRA = "beta"
MXQ_VERSIONDATE = 2016
MXQ_VERSIONDATE = 2021

MXQ_VERSION_GIT := $(shell git describe --long --tags 2>/dev/null)

Expand Down
8 changes: 4 additions & 4 deletions mxq_daemon.c
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
" UNIX_TIMESTAMP(daemon_start) as daemon_start," \
" UNIX_TIMESTAMP(daemon_stop) as daemon_stop," \
" daemon_flags," \
" prerequisites"
" tags"

#undef _to_string
#undef status_str
Expand Down Expand Up @@ -78,7 +78,7 @@ static int bind_result_daemon_fields(struct mx_mysql_bind *result, struct mxq_da
res += mx_mysql_bind_var(result, idx++, int64, &(daemon->daemon_stop.tv_sec));

res += mx_mysql_bind_var(result, idx++, int32, &(daemon->daemon_flags));
res += mx_mysql_bind_var(result, idx++, string, &(daemon->prerequisites));
res += mx_mysql_bind_var(result, idx++, string, &(daemon->tags));

return res;
}
Expand Down Expand Up @@ -143,7 +143,7 @@ int mxq_daemon_register(struct mx_mysql *mysql, struct mxq_daemon *daemon)
" daemon_start = CURRENT_TIMESTAMP(),"
" daemon_stop = 0,"
" daemon_flags = ?,"
" prerequisites = ?"
" tags = ?"
);
if (!stmt) {
mx_log_err("mx_mysql_statement_prepare(): %m");
Expand All @@ -169,7 +169,7 @@ int mxq_daemon_register(struct mx_mysql *mysql, struct mxq_daemon *daemon)
res += mx_mysql_statement_param_bind(stmt, idx++, uint64, &(daemon->daemon_memory_limit_slot_soft));
res += mx_mysql_statement_param_bind(stmt, idx++, uint64, &(daemon->daemon_memory_limit_slot_hard));
res += mx_mysql_statement_param_bind(stmt, idx++, int32, &(daemon->daemon_flags));
res += mx_mysql_statement_param_bind(stmt, idx++, string, &(daemon->prerequisites));
res += mx_mysql_statement_param_bind(stmt, idx++, string, &(daemon->tags));

assert(res ==0);

Expand Down
2 changes: 1 addition & 1 deletion mxq_daemon.h
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ struct mxq_daemon {
struct timeval daemon_stop;

int daemon_flags;
char *prerequisites;
char *tags;
};

void mxq_daemon_free_content(struct mxq_daemon *daemon);
Expand Down
20 changes: 10 additions & 10 deletions mxqd.c
Original file line number Diff line number Diff line change
Expand Up @@ -813,12 +813,12 @@ int server_init(struct mxq_server *server, int argc, char *argv[])
daemon->daemon_memory_limit_slot_soft = server->memory_limit_slot_soft;
daemon->daemon_memory_limit_slot_hard = server->memory_limit_slot_hard;

server->prerequisites=keywordset_new("true");
keywordset_add(server->prerequisites, server->hostname);
keywordset_add(server->prerequisites, server->hostname_short);
read_hostconfig_retry(server->prerequisites);
read_cpufeatures(server->prerequisites);
daemon->prerequisites = keywordset_get(server->prerequisites);
server->tags=keywordset_new("true");
keywordset_add(server->tags, server->hostname);
keywordset_add(server->tags, server->hostname_short);
read_hostconfig_retry(server->tags);
read_cpufeatures(server->tags);
daemon->tags = keywordset_get(server->tags);

return 0;
}
Expand Down Expand Up @@ -1602,10 +1602,10 @@ void server_free(struct mxq_server *server)
mx_flock_free(server->flock);
mx_free_null(server->supgid);
mx_free_null(server->hostname_short);
if (server->prerequisites)
keywordset_free(server->prerequisites);
if (server->daemon.prerequisites)
free(server->daemon.prerequisites);
if (server->tags)
keywordset_free(server->tags);
if (server->daemon.tags)
free(server->daemon.tags);

mx_log_finish();
}
Expand Down
2 changes: 1 addition & 1 deletion mxqd.h
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ struct mxq_server {

size_t supgid_cnt;
gid_t *supgid;
struct keywordset *prerequisites;
struct keywordset *tags;
};


Expand Down
2 changes: 1 addition & 1 deletion mxqd_control.c
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ static int server_is_qualified(struct mxq_server *server, struct mxq_group *grou
if (*group->prerequisites != 0) {
struct parser_context parser_context = {
.input = group->prerequisites,
.tags = server->prerequisites,
.tags = server->tags,
.pos=0,
.result = 0,
};
Expand Down
4 changes: 2 additions & 2 deletions web/pages/mxq/mxq.in
Original file line number Diff line number Diff line change
Expand Up @@ -519,7 +519,7 @@ sub server_detail {
daemon_memory_limit_slot_soft daemon_memory_limit_slot_hard
daemon_jobs_running daemon_slots_running
daemon_threads_running daemon_memory_used
mtime daemon_start daemon_stop daemon_flags prerequisites
mtime daemon_start daemon_stop daemon_flags tags
);
my $sth=$dbh->prepare('SELECT '.join(',',@cols).' FROM mxq_daemon WHERE daemon_id=? LIMIT 1', undef);
$sth->execute($daemon_id);
Expand Down Expand Up @@ -558,7 +558,7 @@ daemon_stop : $o{daemon_stop}
daemon_flags : $o{daemon_flags}
prerequisites : $o{prerequisites}
tags : $o{tags}
</pre>
EOF
}
Expand Down

0 comments on commit 78c12d0

Please sign in to comment.