Attachment #6896 for ticket #5086




	else if (job_ptr->partition)
		partition = job_ptr->partition;

	slurm_mutex_lock(&rollup_lock);
	if (!job_ptr->db_index) {
		if (start_time && (job_state >= JOB_COMPLETE) &&
		    (!job_ptr->tres_alloc_str &&

			as_mysql_suspend(mysql_conn, job_db_inx, job_ptr);
	}
end_it:
	slurm_mutex_unlock(&rollup_lock);
	xfree(tres_alloc_str);
	xfree(block_id);
	xfree(query);


	if (debug_flags & DEBUG_FLAG_DB_JOB)
		DB_DEBUG(mysql_conn->conn, "query\n%s", query);
	slurm_mutex_lock(&rollup_lock);
	rc = mysql_db_query(mysql_conn, query);
	slurm_mutex_unlock(&rollup_lock);
	xfree(query);
end_it:
	xfree(tres_alloc_str);

		step_ptr->tres_alloc_str);
	if (debug_flags & DEBUG_FLAG_DB_STEP)
		DB_DEBUG(mysql_conn->conn, "query\n%s", query);
	slurm_mutex_lock(&rollup_lock);
	rc = mysql_db_query(mysql_conn, query);
	slurm_mutex_unlock(&rollup_lock);
	xfree(query);

	return rc;

		   step_ptr->job_ptr->db_index, step_ptr->step_id);
	if (debug_flags & DEBUG_FLAG_DB_STEP)
		DB_DEBUG(mysql_conn->conn, "query\n%s", query);
	slurm_mutex_lock(&rollup_lock);
	rc = mysql_db_query(mysql_conn, query);
	xfree(query);


		rc = mysql_db_query(mysql_conn, query);
		xfree(query);
	}
	slurm_mutex_unlock(&rollup_lock);

	return rc;
}

Return to ticket 5086

Lines 512-517 no_rollup_change: Link Here

(-)a/src/plugins/accounting_storage/mysql/as_mysql_job.c (+8 lines)
512	else if (job_ptr->partition)	512	else if (job_ptr->partition)
513	partition = job_ptr->partition;	513	partition = job_ptr->partition;
514		514
		515	slurm_mutex_lock(&rollup_lock);
515	if (!job_ptr->db_index) {	516	if (!job_ptr->db_index) {
516	if (start_time && (job_state >= JOB_COMPLETE) &&	517	if (start_time && (job_state >= JOB_COMPLETE) &&
517	(!job_ptr->tres_alloc_str &&	518	(!job_ptr->tres_alloc_str &&
Lines 785-790 no_rollup_change: Link Here
785	as_mysql_suspend(mysql_conn, job_db_inx, job_ptr);	786	as_mysql_suspend(mysql_conn, job_db_inx, job_ptr);
786	}	787	}
787	end_it:	788	end_it:
		789	slurm_mutex_unlock(&rollup_lock);
788	xfree(tres_alloc_str);	790	xfree(tres_alloc_str);
789	xfree(block_id);	791	xfree(block_id);
790	xfree(query);	792	xfree(query);
Lines 1050-1056 extern int as_mysql_job_complete(mysql_conn_t *mysql_conn, Link Here
1050		1052
1051	if (debug_flags & DEBUG_FLAG_DB_JOB)	1053	if (debug_flags & DEBUG_FLAG_DB_JOB)
1052	DB_DEBUG(mysql_conn->conn, "query\n%s", query);	1054	DB_DEBUG(mysql_conn->conn, "query\n%s", query);
		1055	slurm_mutex_lock(&rollup_lock);
1053	rc = mysql_db_query(mysql_conn, query);	1056	rc = mysql_db_query(mysql_conn, query);
		1057	slurm_mutex_unlock(&rollup_lock);
1054	xfree(query);	1058	xfree(query);
1055	end_it:	1059	end_it:
1056	xfree(tres_alloc_str);	1060	xfree(tres_alloc_str);
Lines 1211-1217 extern int as_mysql_step_start(mysql_conn_t *mysql_conn, Link Here
1211	step_ptr->tres_alloc_str);	1215	step_ptr->tres_alloc_str);
1212	if (debug_flags & DEBUG_FLAG_DB_STEP)	1216	if (debug_flags & DEBUG_FLAG_DB_STEP)
1213	DB_DEBUG(mysql_conn->conn, "query\n%s", query);	1217	DB_DEBUG(mysql_conn->conn, "query\n%s", query);
		1218	slurm_mutex_lock(&rollup_lock);
1214	rc = mysql_db_query(mysql_conn, query);	1219	rc = mysql_db_query(mysql_conn, query);
		1220	slurm_mutex_unlock(&rollup_lock);
1215	xfree(query);	1221	xfree(query);
1216		1222
1217	return rc;	1223	return rc;
Lines 1410-1415 extern int as_mysql_step_complete(mysql_conn_t *mysql_conn, Link Here
1410	step_ptr->job_ptr->db_index, step_ptr->step_id);	1416	step_ptr->job_ptr->db_index, step_ptr->step_id);
1411	if (debug_flags & DEBUG_FLAG_DB_STEP)	1417	if (debug_flags & DEBUG_FLAG_DB_STEP)
1412	DB_DEBUG(mysql_conn->conn, "query\n%s", query);	1418	DB_DEBUG(mysql_conn->conn, "query\n%s", query);
		1419	slurm_mutex_lock(&rollup_lock);
1413	rc = mysql_db_query(mysql_conn, query);	1420	rc = mysql_db_query(mysql_conn, query);
1414	xfree(query);	1421	xfree(query);
1415		1422
Lines 1426-1431 extern int as_mysql_step_complete(mysql_conn_t *mysql_conn, Link Here
1426	rc = mysql_db_query(mysql_conn, query);	1433	rc = mysql_db_query(mysql_conn, query);
1427	xfree(query);	1434	xfree(query);
1428	}	1435	}
		1436	slurm_mutex_unlock(&rollup_lock);
1429		1437
1430	return rc;	1438	return rc;
1431	}	1439	}