From c74124236edfe494adf21ecfc3fa21cc017fc919 Mon Sep 17 00:00:00 2001 From: Marius Tolzmann Date: Sun, 26 Jul 2015 01:17:00 +0200 Subject: [PATCH] mxq_job: Retry on fail when changing status to loaded, running, exited --- mxq_job.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/mxq_job.c b/mxq_job.c index 78c4343..d85a540 100644 --- a/mxq_job.c +++ b/mxq_job.c @@ -364,7 +364,7 @@ int mxq_set_job_status_loaded_on_server(struct mx_mysql *mysql, struct mxq_job * res += mx_mysql_bind_var(¶m, 2, string, &(job->server_id)); assert(res == 0); - res = mx_mysql_do_statement_noresult(mysql, query, ¶m); + res = mx_mysql_do_statement_noresult_retry_on_fail(mysql, query, ¶m); if (res < 0) { mx_log_err("mx_mysql_do_statement(): %m"); return res; @@ -410,7 +410,7 @@ int mxq_set_job_status_running(struct mx_mysql *mysql, struct mxq_job *job) res += mx_mysql_bind_var(¶m, 4, string, &(job->server_id)); assert(res == 0); - res = mx_mysql_do_statement_noresult(mysql, query, ¶m); + res = mx_mysql_do_statement_noresult_retry_on_fail(mysql, query, ¶m); if (res < 0) { mx_log_err("mx_mysql_do_statement(): %m"); return res; @@ -499,7 +499,7 @@ int mxq_set_job_status_exited(struct mx_mysql *mysql, struct mxq_job *job) res += mx_mysql_bind_var(¶m, 19, uint32, &(job->host_pid)); assert(res == 0); - res = mx_mysql_do_statement_noresult(mysql, query, ¶m); + res = mx_mysql_do_statement_noresult_retry_on_fail(mysql, query, ¶m); if (res < 0) { mx_log_err("mx_mysql_do_statement(): %m"); return res;