diff --git a/src/plugins/accounting_storage/slurmdbd/accounting_storage_slurmdbd.c b/src/plugins/accounting_storage/slurmdbd/accounting_storage_slurmdbd.c index a304d4725f899db04c6882a9d7364cc5addf8946..c4eba753fe4110ef14134e8372c4b02724d0e47c 100644 --- a/src/plugins/accounting_storage/slurmdbd/accounting_storage_slurmdbd.c +++ b/src/plugins/accounting_storage/slurmdbd/accounting_storage_slurmdbd.c @@ -202,9 +202,6 @@ static void *_set_db_inx_thread(void *no_data) { struct job_record *job_ptr = NULL; ListIterator itr; - /* Read lock on jobs */ - slurmctld_lock_t job_read_lock = - { NO_LOCK, READ_LOCK, NO_LOCK, NO_LOCK }; /* Write lock on jobs */ slurmctld_lock_t job_write_lock = { NO_LOCK, WRITE_LOCK, NO_LOCK, NO_LOCK }; @@ -235,7 +232,7 @@ static void *_set_db_inx_thread(void *no_data) * job db_index here we use a read lock since the * data isn't that sensitive and will only be updated * later in this function. */ - lock_slurmctld(job_read_lock); + lock_slurmctld(job_write_lock); itr = list_iterator_create(job_list); while ((job_ptr = list_next(itr))) { if (!job_ptr->db_index) { @@ -275,7 +272,7 @@ static void *_set_db_inx_thread(void *no_data) } } list_iterator_destroy(itr); - unlock_slurmctld(job_read_lock); + unlock_slurmctld(job_write_lock); if (local_job_list) { slurmdbd_msg_t req, resp;