| /****************************************************************************\ |
| * slurmdbd_defs.h - definitions used for Slurm DBD RPCs |
| ***************************************************************************** |
| * Copyright (C) 2008-2010 Lawrence Livermore National Security. |
| * Produced at Lawrence Livermore National Laboratory (cf, DISCLAIMER). |
| * Written by Morris Jette <jette1@llnl.gov> |
| * CODE-OCEC-09-009. All rights reserved. |
| * |
| * This file is part of Slurm, a resource management program. |
| * For details, see <https://slurm.schedmd.com/>. |
| * Please also read the included file: DISCLAIMER. |
| * |
| * Slurm is free software; you can redistribute it and/or modify it under |
| * the terms of the GNU General Public License as published by the Free |
| * Software Foundation; either version 2 of the License, or (at your option) |
| * any later version. |
| * |
| * In addition, as a special exception, the copyright holders give permission |
| * to link the code of portions of this program with the OpenSSL library under |
| * certain conditions as described in each individual source file, and |
| * distribute linked combinations including the two. You must obey the GNU |
| * General Public License in all respects for all of the code used other than |
| * OpenSSL. If you modify file(s) with this exception, you may extend this |
| * exception to your version of the file(s), but you are not obligated to do |
| * so. If you do not wish to do so, delete this exception statement from your |
| * version. If you delete this exception statement from all source files in |
| * the program, then also delete it here. |
| * |
| * Slurm is distributed in the hope that it will be useful, but WITHOUT ANY |
| * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS |
| * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more |
| * details. |
| * |
| * You should have received a copy of the GNU General Public License along |
| * with Slurm; if not, write to the Free Software Foundation, Inc., |
| * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. |
| \*****************************************************************************/ |
| |
| #ifndef _SLURMDBD_DEFS_H |
| #define _SLURMDBD_DEFS_H |
| |
| #include <inttypes.h> |
| |
| #include "slurm/slurm.h" |
| |
| #include "src/common/list.h" |
| #include "src/interfaces/accounting_storage.h" |
| |
| #define RC_AS_CLUSTER_ID SLURM_BIT(31) |
| |
| /* Slurm DBD message types */ |
| /* ANY TIME YOU ADD TO THIS LIST UPDATE THE CONVERSION FUNCTIONS! */ |
| typedef enum { |
| SLURM_DBD_MESSAGES_START = 1400, /* So that we don't overlap with any |
| * slurm_msg_type_t numbers. */ |
| DBD_FINI, /* Connection finalization */ |
| DBD_ADD_ACCOUNTS, /* Add new account to the mix */ |
| DBD_ADD_ACCOUNT_COORDS, /* Add new coordinatior to an account */ |
| DBD_ADD_ASSOCS, /* Add new association to the mix */ |
| DBD_ADD_CLUSTERS, /* Add new cluster to the mix */ |
| DBD_ADD_USERS, /* Add new user to the mix */ |
| DBD_CLUSTER_TRES, /* Record total tres on cluster */ |
| DBD_FLUSH_JOBS, /* End jobs that are still running |
| * when a controller is restarted. */ |
| DBD_GET_ACCOUNTS, /* Get account information */ |
| DBD_GET_ASSOCS, /* #1410, Get association information */ |
| DBD_GET_ASSOC_USAGE, /* Get assoc usage information */ |
| DBD_GET_CLUSTERS, /* Get account information */ |
| DBD_GET_CLUSTER_USAGE, /* Get cluster usage information */ |
| DBD_RECONFIG, /* Reread the slurmdbd.conf */ |
| DBD_GET_USERS, /* Get account information */ |
| DBD_GOT_ACCOUNTS, /* Response to DBD_GET_ACCOUNTS */ |
| DBD_GOT_ASSOCS, /* Response to DBD_GET_ASSOCS */ |
| DBD_GOT_ASSOC_USAGE, /* Response to DBD_GET_ASSOC_USAGE */ |
| DBD_GOT_CLUSTERS, /* Response to DBD_GET_CLUSTERS */ |
| DBD_GOT_CLUSTER_USAGE, /* #1420, Response to DBD_GET_CLUSTER_USAGE */ |
| DBD_GOT_JOBS, /* Response to DBD_GET_JOBS */ |
| DBD_GOT_LIST, /* Response to DBD_MODIFY/REMOVE MOVE_* */ |
| DBD_GOT_USERS, /* Response to DBD_GET_USERS */ |
| DBD_JOB_COMPLETE, /* Record job completion */ |
| DBD_JOB_START, /* Record job starting */ |
| DBD_ID_RC, /* return db_index from job |
| * insertion, or any other id from |
| * other commands. */ |
| DBD_JOB_SUSPEND, /* Record job suspension */ |
| DBD_MODIFY_ACCOUNTS, /* Modify existing account */ |
| DBD_MODIFY_ASSOCS, /* Modify existing association */ |
| DBD_MODIFY_CLUSTERS, /* #1430, Modify existing cluster */ |
| DBD_MODIFY_USERS, /* Modify existing user */ |
| DBD_NODE_STATE, /* Record node state transition */ |
| SLURM_PERSIST_RC, /* To mirror the DBD_RC this is replacing */ |
| DBD_REGISTER_CTLD, /* Register a slurmctld's comm port */ |
| DBD_REMOVE_ACCOUNTS, /* Remove existing account */ |
| DBD_REMOVE_ACCOUNT_COORDS,/* Remove existing coordinator from |
| * an account */ |
| DBD_REMOVE_ASSOCS, /* Remove existing association */ |
| DBD_REMOVE_CLUSTERS, /* Remove existing cluster */ |
| DBD_REMOVE_USERS, /* Remove existing user */ |
| DBD_ROLL_USAGE, /* #1440 Roll up usage */ |
| DBD_STEP_COMPLETE, /* Record step completion */ |
| DBD_STEP_START, /* Record step starting */ |
| DBD_DEFUNCT_RPC_1443, /* Free for reuse */ |
| DBD_GET_JOBS_COND, /* Get job information with a condition */ |
| DBD_GET_TXN, /* Get transaction information */ |
| DBD_GOT_TXN, /* Got transaction information */ |
| DBD_ADD_QOS, /* Add QOS information */ |
| DBD_GET_QOS, /* Get QOS information */ |
| DBD_GOT_QOS, /* Got QOS information */ |
| DBD_REMOVE_QOS, /* #1450, Remove QOS information */ |
| DBD_MODIFY_QOS, /* Modify existing QOS */ |
| DBD_ADD_WCKEYS, /* Add WCKEY information */ |
| DBD_GET_WCKEYS, /* Get WCKEY information */ |
| DBD_GOT_WCKEYS, /* Got WCKEY information */ |
| DBD_REMOVE_WCKEYS, /* Remove WCKEY information */ |
| DBD_MODIFY_WCKEYS, /* Modify existing WCKEY */ |
| DBD_GET_WCKEY_USAGE, /* Get wckey usage information */ |
| DBD_GOT_WCKEY_USAGE, /* Get wckey usage information */ |
| DBD_ARCHIVE_DUMP, /* issue a request to dump jobs to |
| * archive */ |
| DBD_ARCHIVE_LOAD, /* #1460, load an archive file */ |
| DBD_ADD_RESV, /* add a reservation */ |
| DBD_REMOVE_RESV, /* remove a reservation */ |
| DBD_MODIFY_RESV, /* modify a reservation */ |
| DBD_GET_RESVS, /* Get reservation information */ |
| DBD_GOT_RESVS, /* Response to DBD_GET_RESV */ |
| DBD_GET_CONFIG, /* Get configuration information */ |
| DBD_GOT_CONFIG, /* Response to DBD_GET_CONFIG */ |
| DBD_GET_PROBS, /* Get problems existing in accounting */ |
| DBD_GOT_PROBS, /* Response to DBD_GET_PROBS */ |
| DBD_GET_EVENTS, /* #1470, Get event information */ |
| DBD_GOT_EVENTS, /* Response to DBD_GET_EVENTS */ |
| DBD_SEND_MULT_JOB_START,/* Send multiple job starts */ |
| DBD_GOT_MULT_JOB_START, /* Get response to DBD_SEND_MULT_JOB_START */ |
| DBD_SEND_MULT_MSG, /* Send multiple message */ |
| DBD_GOT_MULT_MSG, /* Get response to DBD_SEND_MULT_MSG */ |
| DBD_MODIFY_JOB, /* Modify existing Job(s) */ |
| DBD_ADD_RES, /* Add new system resource to the mix */ |
| DBD_GET_RES, /* Get resource information */ |
| DBD_GOT_RES, /* Got resource information */ |
| DBD_REMOVE_RES, /* #1480, Remove existing resource */ |
| DBD_MODIFY_RES, /* Modify existing resource */ |
| DBD_ADD_CLUS_RES, /* Add cluster using a resource */ |
| DBD_REMOVE_CLUS_RES, /* Remove existing cluster resource */ |
| DBD_MODIFY_CLUS_RES, /* Modify existing cluster resource */ |
| DBD_ADD_TRES, /* Add tres to the database */ |
| DBD_GET_TRES, /* Get tres from the database */ |
| DBD_GOT_TRES, /* Got tres from the database */ |
| DBD_FIX_RUNAWAY_JOB, /* Fix any runaway jobs */ |
| DBD_GET_STATS, /* Get daemon statistics */ |
| DBD_GOT_STATS, /* #1490 ,Got daemon statistics data */ |
| DBD_CLEAR_STATS, /* Clear daemon statistics */ |
| DBD_SHUTDOWN, /* Shutdown daemon */ |
| DBD_ADD_FEDERATIONS, /* Add new federation to the mix */ |
| DBD_GET_FEDERATIONS, /* Get federation information */ |
| DBD_GOT_FEDERATIONS, /* Response to DBD_GET_FEDERATIONS */ |
| DBD_MODIFY_FEDERATIONS, /* Modify existing federation */ |
| DBD_REMOVE_FEDERATIONS, /* Removing existing federation */ |
| DBD_JOB_HEAVY, /* Send job script/env */ |
| DBD_GOT_JOB_ENV, /* Loading env hash table*/ |
| DBD_GOT_JOB_SCRIPT, /* #1450, Loading bash script hash table */ |
| DBD_ADD_ACCOUNTS_COND, /* Add new account to the mix with acct_rec and |
| * add_assoc_cond */ |
| DBD_ADD_USERS_COND, /* Add new user to the mix with user_rec and |
| * add_assoc_cond */ |
| DBD_GET_INSTANCES, /* Get instance information */ |
| DBD_GOT_INSTANCES, /* Response to DBD_GET_INSTANCES */ |
| DBD_GET_QOS_USAGE, /* Get qos usage information */ |
| DBD_GOT_QOS_USAGE, /* Response to DBD_GET_QOS_USAGE */ |
| DBD_GET_ASSOC_NG_USAGE, /* Get non-grouped assoc usage |
| * (this is used for sreport user topuser) */ |
| SLURM_DBD_MESSAGES_END = 2000, /* So that we don't overlap with any |
| * slurm_msg_type_t numbers. */ |
| SLURM_PERSIST_INIT = 6500, /* So we don't use the |
| * REQUEST_PERSIST_INIT also used here. |
| */ |
| SLURM_PERSIST_INIT_TLS = 6501, |
| } slurmdbd_msg_type_t; |
| |
| /*****************************************************************************\ |
| * Slurm DBD protocol data structures |
| \*****************************************************************************/ |
| |
| typedef struct { |
| list_t *acct_list; /* list of account names (char *'s) */ |
| slurmdb_user_cond_t *cond; |
| } dbd_acct_coord_msg_t; |
| |
| typedef struct dbd_cluster_tres_msg { |
| char *cluster_nodes; /* nodes in cluster */ |
| time_t event_time; /* time of transition */ |
| char *tres_str; /* Simple comma separated list of TRES */ |
| } dbd_cluster_tres_msg_t; |
| |
| typedef struct { |
| void *rec; /* this could be anything based on the type types |
| * are defined in slurm_accounting_storage.h |
| * *_rec_t */ |
| } dbd_rec_msg_t; |
| |
| typedef struct { |
| void *cond; /* this could be anything based on the type types |
| * are defined in slurm_accounting_storage.h |
| * *_cond_t */ |
| } dbd_cond_msg_t; |
| |
| typedef struct { |
| uint16_t archive_data; |
| time_t end; |
| time_t start; |
| } dbd_roll_usage_msg_t; |
| |
| typedef struct { |
| time_t end; |
| void *rec; |
| time_t start; |
| } dbd_usage_msg_t; |
| |
| typedef struct dbd_get_jobs_msg { |
| char *cluster_name; /* name of cluster to query */ |
| uint16_t completion; /* get job completion records instead |
| * of accounting record */ |
| uint32_t gid; /* group id */ |
| time_t last_update; /* time of latest info */ |
| list_t *selected_steps; /* list_t *of slurm_selected_step_t *'s */ |
| list_t *selected_parts; /* list_t *of char *'s */ |
| char *user; /* user name */ |
| } dbd_get_jobs_msg_t; |
| |
| typedef struct dbd_init_msg { |
| char *cluster_name; /* cluster this message is coming from */ |
| uint16_t version; /* protocol version */ |
| uint32_t uid; /* UID originating connection, |
| * filled by authtentication plugin*/ |
| } dbd_init_msg_t; |
| |
| typedef struct dbd_fini_msg { |
| uint16_t close_conn; /* to close connection 1, 0 will keep |
| connection open */ |
| uint16_t commit; /* to rollback(0) or commit(1) changes */ |
| } dbd_fini_msg_t; |
| |
| typedef struct dbd_job_comp_msg { |
| char * admin_comment; /* job admin comment field */ |
| uint32_t assoc_id; /* accounting association id needed to |
| * find job record in db */ |
| char * comment; /* job comment field */ |
| uint64_t db_index; /* index into the db for this job */ |
| uint32_t derived_ec; /* derived job exit code or signal */ |
| time_t end_time; /* job termintation time */ |
| char *failed_node; /* Name of node that failed which caused |
| * this job to be killed. |
| * NULL in all other situations */ |
| uint32_t exit_code; /* job exit code or signal */ |
| char *extra; /* job extra field */ |
| uint32_t job_id; /* job ID */ |
| uint32_t job_state; /* job state */ |
| char * nodes; /* hosts allocated to the job */ |
| uint32_t req_uid; /* requester user ID */ |
| time_t start_time; /* job start time */ |
| time_t submit_time; /* job submit time needed to find job |
| * record in db */ |
| char * system_comment;/* job system comment field */ |
| char *tres_alloc_str;/* Simple comma separated list of TRES */ |
| } dbd_job_comp_msg_t; |
| |
| typedef struct dbd_job_start_msg { |
| char * account; /* Account name for those not running |
| * with associations */ |
| uint32_t alloc_nodes; /* how many nodes used in job */ |
| uint32_t array_job_id; /* job_id of a job array or 0 if N/A */ |
| uint32_t array_max_tasks;/* max number of tasks able to run at once */ |
| uint32_t array_task_id; /* task_id of a job array of NO_VAL |
| * if N/A */ |
| char * array_task_str;/* hex string of unstarted tasks */ |
| uint32_t array_task_pending;/* number of tasks still pending */ |
| uint32_t assoc_id; /* accounting association id */ |
| char * constraints; /* features/constraints requested by job */ |
| char *container; /* OCI Container bundle path */ |
| uint32_t db_flags; /* flags about job */ |
| uint64_t db_index; /* index into the db for this job */ |
| time_t eligible_time; /* time job becomes eligible to run */ |
| char *env_hash; /* hash value of env */ |
| uint32_t gid; /* group ID */ |
| uint32_t het_job_id; /* ID of hetjob leader or 0 */ |
| uint32_t het_job_offset; /* Hetjob component ID, zero-origin */ |
| uint32_t job_id; /* job ID */ |
| uint32_t job_state; /* job state */ |
| char *licenses; /* job licenses */ |
| char * mcs_label; /* job mcs_label */ |
| char * name; /* job name */ |
| char * nodes; /* hosts allocated to the job */ |
| char * node_inx; /* ranged bitmap string of hosts |
| * allocated to the job */ |
| char * partition; /* partition job is running on */ |
| uint32_t priority; /* job priority */ |
| uint32_t qos_id; /* qos job is running with */ |
| char *qos_req; /* qos(s) requested for the job */ |
| uint32_t req_cpus; /* count of req processors */ |
| uint64_t req_mem; /* requested minimum memory */ |
| uint16_t restart_cnt; /* How many times the job has been restarted */ |
| uint32_t resv_id; /* reservation id */ |
| char *resv_req; /* original requested reservations */ |
| char *script_hash; /* hash value of script */ |
| uint16_t segment_size; /* requested segment size */ |
| time_t start_time; /* job start time */ |
| uint32_t state_reason_prev; /* Last reason of blocking before job |
| * started */ |
| char *std_err; /* The stderr file path of the job */ |
| char *std_in; /* The stdin file path of the job */ |
| char *std_out; /* The stdout file path of the job */ |
| char *submit_line; /* The command issued with all it's options in a |
| * string */ |
| time_t submit_time; /* job submit time */ |
| uint32_t timelimit; /* job timelimit */ |
| uint32_t uid; /* user ID if associations are being used */ |
| char* gres_used; /* String depicting the GRES actually used by |
| * type for the entire job on all nodes. */ |
| char *tres_alloc_str;/* Simple comma separated list of TRES */ |
| char *tres_req_str; /* Simple comma separated list of TRES */ |
| char * wckey; /* wckey name */ |
| char *work_dir; /* work dir of job */ |
| } dbd_job_start_msg_t; |
| |
| /* returns a uint32_t along with a return code */ |
| typedef struct dbd_id_rc_msg { |
| uint32_t job_id; |
| uint64_t db_index; |
| uint64_t flags; |
| uint32_t return_code; |
| } dbd_id_rc_msg_t; |
| |
| typedef struct { |
| char *env; /* job environment in text form */ |
| char *env_hash; /* hash value of env */ |
| char *script; /* job_script in text form */ |
| char *script_hash; /* hash value of script */ |
| buf_t *script_buf; /* job script as mmap buf */ |
| } dbd_job_heavy_msg_t; |
| |
| typedef struct dbd_job_suspend_msg { |
| uint32_t assoc_id; /* accounting association id needed |
| * to find job record in db */ |
| uint64_t db_index; /* index into the db for this job */ |
| uint32_t job_id; /* job ID needed to find job record |
| * in db */ |
| uint32_t job_state; /* job state */ |
| time_t submit_time; /* job submit time needed to find job record |
| * in db */ |
| time_t suspend_time; /* job suspend or resume time */ |
| } dbd_job_suspend_msg_t; |
| |
| typedef struct { |
| list_t *my_list; /* this list could be of any type as long as it |
| * is handled correctly on both ends */ |
| uint32_t return_code; /* If there was an error and a list of |
| * them this is the type of error it |
| * was */ |
| } dbd_list_msg_t; |
| |
| typedef struct { |
| void *cond; |
| void *rec; |
| } dbd_modify_msg_t; |
| |
| #define DBD_NODE_STATE_DOWN 1 |
| #define DBD_NODE_STATE_UP 2 |
| #define DBD_NODE_STATE_UPDATE 3 |
| |
| typedef struct dbd_node_state_msg { |
| time_t event_time; /* time of transition */ |
| char *extra; /* arbitrary string */ |
| char *hostlist; /* name of hosts */ |
| char *instance_id; /* cloud instance id */ |
| char *instance_type; /* cloud instance type */ |
| uint16_t new_state; /* new state of host, see DBD_NODE_STATE_* */ |
| char *reason; /* explanation for the node's state */ |
| uint32_t reason_uid; /* User that set the reason, ignore if |
| * no reason is set. */ |
| uint32_t state; /* current state of node. Used to get |
| flags on the state (i.e. maintenance) */ |
| char *tres_str; /* Simple comma separated list of TRES */ |
| } dbd_node_state_msg_t; |
| |
| typedef struct dbd_register_ctld_msg { |
| uint16_t dimensions; /* dimensions of system */ |
| uint32_t flags; /* flags for cluster */ |
| uint16_t port; /* slurmctld's comm port */ |
| uint32_t cluster_id; /* cluster id of cluster making request */ |
| } dbd_register_ctld_msg_t; |
| |
| typedef struct dbd_step_comp_msg { |
| uint32_t assoc_id; /* accounting association id */ |
| uint64_t db_index; /* index into the db for this job */ |
| time_t end_time; /* job termintation time */ |
| uint32_t exit_code; /* job exit code or signal */ |
| jobacctinfo_t *jobacct; /* status info */ |
| time_t job_submit_time;/* job submit time needed to find job record |
| * in db */ |
| char *job_tres_alloc_str;/* Simple comma separated list of TRES for |
| * the job (primarily for the energy of the |
| * completing job. This is only filled in |
| * on the last step in the job. */ |
| uint32_t req_uid; /* requester user ID */ |
| time_t start_time; /* step start time */ |
| uint16_t state; /* current state of node. Used to get |
| flags on the state (i.e. maintenance) */ |
| slurm_step_id_t step_id; |
| uint32_t total_tasks; /* count of tasks for step */ |
| } dbd_step_comp_msg_t; |
| |
| typedef struct dbd_step_start_msg { |
| uint32_t assoc_id; /* accounting association id */ |
| uint64_t db_index; /* index into the db for this job */ |
| char *container; /* OCI Container Bundle path */ |
| char * name; /* step name */ |
| char * nodes; /* hosts allocated to the step */ |
| char * node_inx; /* bitmap index of hosts allocated to |
| * the step */ |
| uint32_t node_cnt; /* how many nodes used in step */ |
| time_t start_time; /* step start time */ |
| time_t job_submit_time;/* job submit time needed to find job record |
| * in db */ |
| uint32_t req_cpufreq_min; /* requested minimum CPU frequency */ |
| uint32_t req_cpufreq_max; /* requested maximum CPU frequency */ |
| uint32_t req_cpufreq_gov; /* requested CPU frequency governor */ |
| slurm_step_id_t step_id; |
| char *cwd; /* Current work dir of the step */ |
| char *std_err; /* The stderr file path of the step */ |
| char *std_in; /* The stdin file path of the step */ |
| char *std_out; /* The stdout file path of the step */ |
| char *submit_line; /* The command issued with all it's options in a |
| * string */ |
| uint32_t task_dist; /* layout method of step */ |
| uint32_t time_limit; /* time limit of step */ |
| uint32_t total_tasks; /* count of tasks for step */ |
| char *tres_alloc_str; /* Simple comma separated list of TRES */ |
| } dbd_step_start_msg_t; |
| |
| typedef struct { |
| void *data; |
| uint16_t msg_type; |
| } dbd_relay_msg_t; |
| |
| /*****************************************************************************\ |
| * Slurm DBD message processing functions |
| \*****************************************************************************/ |
| |
| extern slurmdbd_msg_type_t str_2_slurmdbd_msg_type(char *msg_type); |
| extern char *slurmdbd_msg_type_2_str(slurmdbd_msg_type_t msg_type, |
| int get_enum); |
| |
| /*****************************************************************************\ |
| * Free various SlurmDBD message structures |
| \*****************************************************************************/ |
| extern void slurmdbd_free_buffer(void *x); |
| |
| extern void slurmdbd_free_acct_coord_msg(dbd_acct_coord_msg_t *msg); |
| extern void slurmdbd_free_cluster_tres_msg(dbd_cluster_tres_msg_t *msg); |
| extern void slurmdbd_free_msg(persist_msg_t *msg); |
| extern void slurmdbd_free_rec_msg(dbd_rec_msg_t *msg, slurmdbd_msg_type_t type); |
| extern void slurmdbd_free_cond_msg(dbd_cond_msg_t *msg, |
| slurmdbd_msg_type_t type); |
| extern void slurmdbd_free_fini_msg(dbd_fini_msg_t *msg); |
| extern void slurmdbd_free_job_complete_msg(dbd_job_comp_msg_t *msg); |
| extern void slurmdbd_free_job_start_msg(void *in); |
| extern void slurmdbd_free_job_heavy_msg(void *in); |
| extern void slurmdbd_free_id_rc_msg(void *in); |
| extern void slurmdbd_free_job_suspend_msg(dbd_job_suspend_msg_t *msg); |
| extern void slurmdbd_free_list_msg(dbd_list_msg_t *msg); |
| extern void slurmdbd_free_modify_msg(dbd_modify_msg_t *msg, |
| slurmdbd_msg_type_t type); |
| extern void slurmdbd_free_node_state_msg(dbd_node_state_msg_t *msg); |
| extern void slurmdbd_free_register_ctld_msg(dbd_register_ctld_msg_t *msg); |
| extern void slurmdbd_free_roll_usage_msg(dbd_roll_usage_msg_t *msg); |
| extern void slurmdbd_free_step_complete_msg(dbd_step_comp_msg_t *msg); |
| extern void slurmdbd_free_step_start_msg(dbd_step_start_msg_t *msg); |
| extern void slurmdbd_free_usage_msg(dbd_usage_msg_t *msg, |
| slurmdbd_msg_type_t type); |
| |
| #endif /* !_SLURMDBD_DEFS_H */ |
