blob: 1de00ffb3e15e5377727091148bad2e69ac30c70 [file]
/*****************************************************************************\
* extra_get_functions.c - Interface to functions dealing with
* getting info from the database, and this
* these were unrelated to other functionality.
******************************************************************************
* Copyright (C) 2010 Lawrence Livermore National Security.
* Produced at Lawrence Livermore National Laboratory (cf, DISCLAIMER).
* Written by Danny Auble da@llnl.gov, et. al.
* 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.
\*****************************************************************************/
#include "slurm/slurm.h"
#include "slurm/slurm_errno.h"
#include "slurm/slurmdb.h"
#include "src/common/parse_time.h"
#include "src/interfaces/accounting_storage.h"
/*
* reconfigure the slurmdbd
*/
extern int slurmdb_reconfig(void *db_conn)
{
return acct_storage_g_reconfig(db_conn, 1);
}
extern list_t *slurmdb_config_get_keypairs(const slurmdbd_conf_t *slurmdbd_conf)
{
char time_str[32];
char *tmp_ptr = NULL;
list_t *my_list = list_create(destroy_config_key_pair);
add_key_pair_bool(my_list, "AllowNoDefAcct",
(slurmdbd_conf->flags &
DBD_CONF_FLAG_ALLOW_NO_DEF_ACCT));
add_key_pair(my_list, "ArchiveDir", "%s", slurmdbd_conf->archive_dir);
add_key_pair_bool(my_list, "ArchiveEvents",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf
->purge_event));
add_key_pair_bool(my_list, "ArchiveJobs",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf->purge_job));
add_key_pair_bool(my_list, "ArchiveJobScript",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf
->purge_jobscript));
add_key_pair_bool(my_list, "ArchiveJobEnv",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf
->purge_jobenv));
add_key_pair_bool(my_list, "ArchiveResvs",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf->purge_resv));
add_key_pair(my_list, "ArchiveScript", "%s",
slurmdbd_conf->archive_script);
add_key_pair_bool(my_list, "ArchiveSteps",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf->purge_step));
add_key_pair_bool(my_list, "ArchiveSuspend",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf
->purge_suspend));
add_key_pair_bool(my_list, "ArchiveTXN",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf->purge_txn));
add_key_pair_bool(my_list, "ArchiveUsage",
SLURMDB_PURGE_ARCHIVE_SET(slurmdbd_conf
->purge_usage));
add_key_pair(my_list, "AuthAltTypes", "%s", slurm_conf.authalttypes);
add_key_pair(my_list, "AuthAltParameters", "%s",
slurm_conf.authalt_params);
add_key_pair(my_list, "AuthInfo", "%s", slurm_conf.authinfo);
add_key_pair(my_list, "AuthType", "%s", slurm_conf.authtype);
add_key_pair(my_list, "CommitDelay", "%u", slurmdbd_conf->commit_delay);
add_key_pair(my_list, "CommunicationParameters", "%s",
slurm_conf.comm_params);
add_key_pair(my_list, "DbdAddr", "%s", slurmdbd_conf->dbd_addr);
add_key_pair(my_list, "DbdBackupHost", "%s", slurmdbd_conf->dbd_backup);
add_key_pair(my_list, "DbdHost", "%s", slurmdbd_conf->dbd_host);
add_key_pair(my_list, "DbdPort", "%u", slurmdbd_conf->dbd_port);
add_key_pair_own(my_list, "DebugFlags",
debug_flags2str(slurm_conf.debug_flags));
add_key_pair(my_list, "DebugLevel", "%s",
log_num2string(slurmdbd_conf->debug_level));
add_key_pair(my_list, "DebugLevelSyslog", "%s",
log_num2string(slurmdbd_conf->syslog_debug));
add_key_pair(my_list, "DefaultQOS", "%s", slurmdbd_conf->default_qos);
add_key_pair_bool(my_list, "DisableCoordDBD",
(slurmdbd_conf->flags &
DBD_CONF_FLAG_DISABLE_COORD_DBD));
add_key_pair_bool(my_list, "DisableArchiveCommands",
(slurmdbd_conf->flags &
DBD_CONF_FLAG_DISABLE_ARCHIVE_COMMANDS));
add_key_pair_bool(my_list, "DisableRollups",
(slurmdbd_conf->flags &
DBD_CONF_FLAG_DISABLE_ROLLUPS));
add_key_pair(my_list, "HashPlugin", "%s", slurm_conf.hash_plugin);
add_key_pair(my_list, "LogFile", "%s", slurmdbd_conf->log_file);
add_key_pair(my_list, "MaxPurgeLimit", "%u",
slurmdbd_conf->max_purge_limit);
secs2time_str(slurmdbd_conf->max_time_range, time_str,
sizeof(time_str));
add_key_pair(my_list, "MaxQueryTimeRange", "%s", time_str);
add_key_pair(my_list, "MessageTimeout", "%u secs",
slurm_conf.msg_timeout);
add_key_pair(my_list, "Parameters", "%s", slurmdbd_conf->parameters);
add_key_pair(my_list, "PidFile", "%s", slurmdbd_conf->pid_file);
add_key_pair(my_list, "PluginDir", "%s", slurm_conf.plugindir);
tmp_ptr = xmalloc(128);
private_data_string(slurm_conf.private_data, tmp_ptr, 128);
add_key_pair(my_list, "PrivateData", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_event != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_event, tmp_ptr, 32,
1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeEventAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_job != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_job, tmp_ptr, 32, 1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeJobAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_resv != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_resv, tmp_ptr, 32, 1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeResvAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_step != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_step, tmp_ptr, 32, 1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeStepAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_suspend != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_suspend, tmp_ptr, 32,
1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeSuspendAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_txn != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_txn, tmp_ptr, 32, 1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeTXNAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_usage != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_usage, tmp_ptr, 32,
1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeUsageAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_jobscript != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_jobscript, tmp_ptr,
32, 1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeJobScriptAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
if (slurmdbd_conf->purge_jobenv != NO_VAL) {
tmp_ptr = xmalloc(32);
slurmdb_purge_string(slurmdbd_conf->purge_jobenv, tmp_ptr, 32,
1);
} else
tmp_ptr = xstrdup("NONE");
add_key_pair(my_list, "PurgeJobEnvAfter", "%s", tmp_ptr);
xfree(tmp_ptr);
add_key_pair_own(my_list, "SLURMDBD_CONF",
get_extra_conf_path("slurmdbd.conf"));
add_key_pair(my_list, "SLURMDBD_VERSION", "%s", SLURM_VERSION_STRING);
add_key_pair(my_list, "SlurmUser", "%s(%u)", slurm_conf.slurm_user_name,
slurm_conf.slurm_user_id);
add_key_pair(my_list, "StorageBackupHost", "%s",
slurm_conf.accounting_storage_backup_host);
add_key_pair(my_list, "StorageHost", "%s",
slurm_conf.accounting_storage_host);
add_key_pair(my_list, "StorageLoc", "%s", slurmdbd_conf->storage_loc);
add_key_pair(my_list, "StorageParameters", "%s",
slurm_conf.accounting_storage_params);
/* StoragePass should NOT be passed due to security reasons */
add_key_pair(my_list, "StoragePassScript", "%s",
slurmdbd_conf->storage_pass_script);
add_key_pair(my_list, "StoragePort", "%u",
slurm_conf.accounting_storage_port);
add_key_pair(my_list, "StorageType", "%s",
slurm_conf.accounting_storage_type);
add_key_pair(my_list, "StorageUser", "%s", slurmdbd_conf->storage_user);
add_key_pair(my_list, "TCPTimeout", "%u secs", slurm_conf.tcp_timeout);
add_key_pair(my_list, "TLSParameters", "%s", slurm_conf.tls_params);
add_key_pair(my_list, "TLSType", "%s", slurm_conf.tls_type);
add_key_pair_bool(my_list, "TrackWCKey", slurmdbd_conf->track_wckey);
add_key_pair_bool(my_list, "TrackSlurmctldDown",
slurmdbd_conf->track_ctld);
return my_list;
}
extern int slurmdb_config_get(void *db_conn,
slurmdbd_conf_t **slurmdbd_conf_ptr)
{
return acct_storage_g_get_config(db_conn, slurmdbd_conf_ptr);
}
/*
* get info from the storage
* IN: slurmdb_event_cond_t *
* RET: List of slurmdb_event_rec_t *
* note List needs to be freed when called
*/
extern list_t *slurmdb_events_get(void *db_conn,
slurmdb_event_cond_t *event_cond)
{
if (db_api_uid == -1)
db_api_uid = getuid();
return acct_storage_g_get_events(db_conn, db_api_uid, event_cond);
}
/*
* get info from the storage
*
* IN: slurmdb_instance_cond_t *
* RET: List of slurmdb_instance_rec_t *
* note List needs to be freed when called
*/
extern list_t *slurmdb_instances_get(void *db_conn,
slurmdb_instance_cond_t *instance_cond)
{
if (db_api_uid == -1)
db_api_uid = getuid();
return acct_storage_g_get_instances(db_conn, db_api_uid, instance_cond);
}
/*
* get info from the storage
* IN: slurmdb_assoc_cond_t *
* RET: List of slurmdb_assoc_rec_t *
* note List needs to be freed when called
*/
extern list_t *slurmdb_problems_get(void *db_conn,
slurmdb_assoc_cond_t *assoc_cond)
{
if (db_api_uid == -1)
db_api_uid = getuid();
return acct_storage_g_get_problems(db_conn, db_api_uid, assoc_cond);
}
/*
* get info from the storage
* IN: slurmdb_reservation_cond_t *
* RET: List of slurmdb_reservation_rec_t *
* note List needs to be freed when called
*/
extern list_t *slurmdb_reservations_get(void *db_conn,
slurmdb_reservation_cond_t *resv_cond)
{
if (db_api_uid == -1)
db_api_uid = getuid();
return acct_storage_g_get_reservations(db_conn, db_api_uid, resv_cond);
}
/*
* get info from the storage
* IN: slurmdb_txn_cond_t *
* RET: List of slurmdb_txn_rec_t *
* note List needs to be freed when called
*/
extern list_t *slurmdb_txn_get(void *db_conn, slurmdb_txn_cond_t *txn_cond)
{
if (db_api_uid == -1)
db_api_uid = getuid();
return acct_storage_g_get_txn(db_conn, db_api_uid, txn_cond);
}
/*
* shutdown the slurmdbd
*/
extern int slurmdb_shutdown(void *db_conn)
{
return acct_storage_g_shutdown(db_conn);
}
/*
* clear the slurmdbd statistics
*/
extern int slurmdb_clear_stats(void *db_conn)
{
return acct_storage_g_clear_stats(db_conn);
}
/*
* get the slurmdbd statistics
* Call slurmdb_destroy_stats_rec() to free stats_pptr
*/
extern int slurmdb_get_stats(void *db_conn, slurmdb_stats_rec_t **stats_pptr)
{
return acct_storage_g_get_stats(db_conn, stats_pptr);
}