diff --git a/src/plugins/accounting_storage/common/common_as.c b/src/plugins/accounting_storage/common/common_as.c
index 3206c78390a467e760de61f00e1f55e11bd031f0..e14701325e2f82e381568655300363af2560644f 100644
--- a/src/plugins/accounting_storage/common/common_as.c
+++ b/src/plugins/accounting_storage/common/common_as.c
@@ -57,43 +57,6 @@ extern char *wckey_hour_table;
extern char *wckey_day_table;
extern char *wckey_month_table;
-
-/* here to add \\ to all \" in a string */
-extern char *fix_double_quotes(char *str)
-{
- int i=0, start=0;
- char *fixed = NULL;
-
- if(!str)
- return NULL;
-
- while(str[i]) {
- if((str[i] == '"')) {
- char *tmp = xstrndup(str+start, i-start);
- xstrfmtcat(fixed, "%s\\\"", tmp);
- xfree(tmp);
- start = i+1;
- }
-
- if((str[i] == '\'')) {
- char *tmp = xstrndup(str+start, i-start);
- xstrfmtcat(fixed, "%s\\\'", tmp);
- xfree(tmp);
- start = i+1;
- }
-
- i++;
- }
-
- if((i-start) > 0) {
- char *tmp = xstrndup(str+start, i-start);
- xstrcat(fixed, tmp);
- xfree(tmp);
- }
-
- return fixed;
-}
-
/*
* send_accounting_update - send update to controller of cluster
* IN update_list: updates to send
diff --git a/src/plugins/accounting_storage/common/common_as.h b/src/plugins/accounting_storage/common/common_as.h
index 372d88c38935ea632e8f81ac7e09ad294c686797..58f2b3c8d91940c6c2d275e222432b3995c44377 100644
--- a/src/plugins/accounting_storage/common/common_as.h
+++ b/src/plugins/accounting_storage/common/common_as.h
@@ -45,8 +45,6 @@
#define THIS_FILE ((strrchr(__FILE__, '/') ?: __FILE__ - 1) + 1)
-extern char *fix_double_quotes(char *str);
-
extern int send_accounting_update(List update_list, char *cluster, char *host,
uint16_t port, uint16_t rpc_version);
diff --git a/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c b/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c
index ced159c1c96d853032fc724eeacad5f2a8027ae0..66ecc3c99006ce2f235841e87c710f6422e52fab 100644
--- a/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c
+++ b/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c
@@ -1260,7 +1260,7 @@ extern int modify_common(mysql_conn_t *mysql_conn,
{
char *query = NULL;
int rc = SLURM_SUCCESS;
- char *tmp_cond_char = fix_double_quotes(cond_char);
+ char *tmp_cond_char = slurm_add_slash_to_quotes(cond_char);
char *tmp_vals = NULL;
bool cluster_centric = true;
@@ -1271,7 +1271,7 @@ extern int modify_common(mysql_conn_t *mysql_conn,
cluster_centric = false;
if(vals[1])
- tmp_vals = fix_double_quotes(vals+2);
+ tmp_vals = slurm_add_slash_to_quotes(vals+2);
if(cluster_centric) {
xassert(cluster_name);
@@ -1334,7 +1334,7 @@ extern int remove_common(mysql_conn_t *mysql_conn,
MYSQL_ROW row;
time_t day_old = now - DELETE_SEC_BACK;
bool has_jobs = false;
- char *tmp_name_char = fix_double_quotes(name_char);
+ char *tmp_name_char = slurm_add_slash_to_quotes(name_char);
bool cluster_centric = true;
/* figure out which tables we need to append the cluster name to */
diff --git a/src/plugins/accounting_storage/mysql/as_mysql_acct.c b/src/plugins/accounting_storage/mysql/as_mysql_acct.c
index 3e52511f45e231d611ba23cca79296860525fe88..01ad2944af849edc0f12cb2346f061126ba2d25a 100644
--- a/src/plugins/accounting_storage/mysql/as_mysql_acct.c
+++ b/src/plugins/accounting_storage/mysql/as_mysql_acct.c
@@ -182,7 +182,7 @@ extern int as_mysql_add_accts(mysql_conn_t *mysql_conn, uint32_t uid,
}
/* we always have a ', ' as the first 2 chars */
- tmp_extra = fix_double_quotes(extra+2);
+ tmp_extra = slurm_add_slash_to_quotes(extra+2);
if(txn_query)
xstrfmtcat(txn_query,
diff --git a/src/plugins/accounting_storage/mysql/as_mysql_assoc.c b/src/plugins/accounting_storage/mysql/as_mysql_assoc.c
index 3ed74f4728e437c3afb6b7acbc22af47fe681710..1c81465de63a42fb0a2d96b20de9e36a7f52e237 100644
--- a/src/plugins/accounting_storage/mysql/as_mysql_assoc.c
+++ b/src/plugins/accounting_storage/mysql/as_mysql_assoc.c
@@ -2259,7 +2259,7 @@ extern int as_mysql_add_assocs(mysql_conn_t *mysql_conn, uint32_t uid,
}
/* we always have a ', ' as the first 2 chars */
- tmp_extra = fix_double_quotes(extra+2);
+ tmp_extra = slurm_add_slash_to_quotes(extra+2);
if(txn_query)
xstrfmtcat(txn_query,
diff --git a/src/plugins/accounting_storage/mysql/as_mysql_cluster.c b/src/plugins/accounting_storage/mysql/as_mysql_cluster.c
index 942d9942193d2d048c685f52ca2412bff4860ed0..566653e5be86f6d5601b9d0168eca1da84f97eb7 100644
--- a/src/plugins/accounting_storage/mysql/as_mysql_cluster.c
+++ b/src/plugins/accounting_storage/mysql/as_mysql_cluster.c
@@ -144,7 +144,7 @@ extern int as_mysql_add_clusters(mysql_conn_t *mysql_conn, uint32_t uid,
}
/* we always have a ', ' as the first 2 chars */
- tmp_extra = fix_double_quotes(extra+2);
+ tmp_extra = slurm_add_slash_to_quotes(extra+2);
xstrfmtcat(query,
"insert into %s "
@@ -940,9 +940,9 @@ extern int as_mysql_node_down(mysql_conn_t *mysql_conn,
cpus = node_ptr->cpus;
if (reason)
- my_reason = fix_double_quotes(reason);
+ my_reason = slurm_add_slash_to_quotes(reason);
else
- my_reason = fix_double_quotes(node_ptr->reason);
+ my_reason = slurm_add_slash_to_quotes(node_ptr->reason);
debug2("inserting %s(%s) with %u cpus",
node_ptr->name, mysql_conn->cluster_name, cpus);
diff --git a/src/plugins/accounting_storage/mysql/as_mysql_qos.c b/src/plugins/accounting_storage/mysql/as_mysql_qos.c
index 32168cd9505113736f7cef60370f4dd8c329b68a..f786a97daf7b8359fabec3b5ad3ba3197fd46d5d 100644
--- a/src/plugins/accounting_storage/mysql/as_mysql_qos.c
+++ b/src/plugins/accounting_storage/mysql/as_mysql_qos.c
@@ -354,7 +354,7 @@ extern int as_mysql_add_qos(mysql_conn_t *mysql_conn, uint32_t uid, List qos_lis
}
/* we always have a ', ' as the first 2 chars */
- tmp_extra = fix_double_quotes(extra+2);
+ tmp_extra = slurm_add_slash_to_quotes(extra+2);
xstrfmtcat(query,
"insert into %s "
diff --git a/src/plugins/accounting_storage/mysql/as_mysql_user.c b/src/plugins/accounting_storage/mysql/as_mysql_user.c
index e938fc837a1964163b0117afeebbc9b977c0f0c0..3dbf414275081dbb641093e512cefc63fb33c517 100644
--- a/src/plugins/accounting_storage/mysql/as_mysql_user.c
+++ b/src/plugins/accounting_storage/mysql/as_mysql_user.c
@@ -224,7 +224,7 @@ extern int as_mysql_add_users(mysql_conn_t *mysql_conn, uint32_t uid,
list_remove(itr);
/* we always have a ', ' as the first 2 chars */
- tmp_extra = fix_double_quotes(extra+2);
+ tmp_extra = slurm_add_slash_to_quotes(extra+2);
if(txn_query)
xstrfmtcat(txn_query,
diff --git a/src/plugins/accounting_storage/mysql/as_mysql_wckey.c b/src/plugins/accounting_storage/mysql/as_mysql_wckey.c
index 6dc27709a883ebc7c352d1f6a6838db40988e1ce..b934c12d855a1d15a779e43c36b7a5f8fb46fc6a 100644
--- a/src/plugins/accounting_storage/mysql/as_mysql_wckey.c
+++ b/src/plugins/accounting_storage/mysql/as_mysql_wckey.c
@@ -317,7 +317,7 @@ extern int as_mysql_add_wckeys(mysql_conn_t *mysql_conn, uint32_t uid,
}
/* we always have a ', ' as the first 2 chars */
- tmp_extra = fix_double_quotes(extra+2);
+ tmp_extra = slurm_add_slash_to_quotes(extra+2);
xstrfmtcat(query,
"insert into %s "