| /*****************************************************************************\ | |
| * src/common/uid.c - uid/gid lookup utility functions | |
| ***************************************************************************** | |
| * Copyright (C) 2002-2007 The Regents of the University of California. | |
| * Copyright (C) 2008-2009 Lawrence Livermore National Security. | |
| * Produced at Lawrence Livermore National Laboratory (cf, DISCLAIMER). | |
| * Written by Mark Grondona <mgrondona@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. | |
| \*****************************************************************************/ | |
| #define _GNU_SOURCE | |
| #include <ctype.h> | |
| #include <errno.h> | |
| #include <grp.h> | |
| #include <limits.h> | |
| #include <pwd.h> | |
| #include <stdlib.h> | |
| #include <string.h> | |
| #include <unistd.h> | |
| #include "slurm/slurm_errno.h" | |
| #include "src/common/macros.h" | |
| #include "src/common/slurm_protocol_defs.h" | |
| #include "src/common/timers.h" | |
| #include "src/common/uid.h" | |
| #include "src/common/xmalloc.h" | |
| #include "src/common/xstring.h" | |
| typedef enum { | |
| UID_CACHE_SORT_UID = 0, | |
| UID_CACHE_SORT_USERNAME = 1, | |
| } uid_cache_sort_t; | |
| #define UID_CACHE_MAX_UNLIMITED 0 | |
| #define UID_CACHE_MAX_UPPER 65536 | |
| typedef struct { | |
| uid_t uid; | |
| char *username; | |
| } uid_cache_entry_t; | |
| typedef struct { | |
| uid_cache_entry_t *cache; | |
| int capacity; | |
| int max_entries; | |
| int sort; | |
| int used; | |
| } uid_cache_t; | |
| static pthread_mutex_t uid_lock = PTHREAD_MUTEX_INITIALIZER; | |
| static uid_cache_t uid_cache = { | |
| .max_entries = UID_CACHE_MAX_UNLIMITED, | |
| .sort = UID_CACHE_SORT_UID, | |
| }; | |
| static uid_cache_t uidfrom_uid_cache = { | |
| .max_entries = UID_CACHE_MAX_UNLIMITED, | |
| .sort = UID_CACHE_SORT_UID, | |
| }; | |
| static uid_cache_t uidfrom_uname_cache = { | |
| .max_entries = UID_CACHE_MAX_UNLIMITED, | |
| .sort = UID_CACHE_SORT_USERNAME, | |
| }; | |
| static uid_cache_t uidfrom_uname_neg_cache = { | |
| .max_entries = UID_CACHE_MAX_UPPER, | |
| .sort = UID_CACHE_SORT_USERNAME, | |
| }; | |
| static int uidfrom_cache_enabled = 0; | |
| extern void slurm_getpwuid_r(uid_t uid, struct passwd *pwd, char **curr_buf, | |
| char **buf_malloc, size_t *bufsize, | |
| struct passwd **result) | |
| { | |
| DEF_TIMERS; | |
| if (uid == SLURM_AUTH_NOBODY) { | |
| *result = NULL; | |
| return; | |
| } | |
| START_TIMER; | |
| while (true) { | |
| int rc = getpwuid_r(uid, pwd, *curr_buf, *bufsize, result); | |
| if (!rc && *result) | |
| break; | |
| if (rc == EINTR) { | |
| continue; | |
| } else if (rc == ERANGE) { | |
| *bufsize *= 2; | |
| *curr_buf = xrealloc(*buf_malloc, *bufsize); | |
| continue; | |
| } else if ((rc == 0) || (rc == ENOENT) || (rc == ESRCH) || | |
| (rc == EBADF) || (rc == EPERM)) { | |
| debug2("%s: getpwuid_r(%u): no record found", | |
| __func__, uid); | |
| } else { | |
| error("%s: getpwuid_r(%u): %s", | |
| __func__, uid, slurm_strerror(rc)); | |
| } | |
| *result = NULL; | |
| break; | |
| } | |
| END_TIMER2("getpwuid_r"); | |
| } | |
| static int _uid_cache_cmp_uid(const void *tkey, const void *tmember) | |
| { | |
| const uid_t key = *(const uid_t *) tkey; | |
| const uid_cache_entry_t *member = (const uid_cache_entry_t *) tmember; | |
| if (key < member->uid) | |
| return -1; | |
| else if (key == member->uid) | |
| return 0; | |
| else | |
| return 1; | |
| } | |
| static int _uid_cache_cmp_username(const void *tkey, const void *tmember) | |
| { | |
| const char *key = *(const char **) tkey; | |
| const uid_cache_entry_t *member = (const uid_cache_entry_t *) tmember; | |
| return xstrcmp(key, member->username); | |
| } | |
| static int _uid_cache_cmp(uid_cache_t *cache, int i, uid_cache_entry_t *item) | |
| { | |
| if (cache->sort == UID_CACHE_SORT_UID) | |
| return _uid_cache_cmp_uid(&item->uid, &cache->cache[i]); | |
| /* must be UID_CACHE_SORT_USERNAME */ | |
| return _uid_cache_cmp_username(&item->username, &cache->cache[i]); | |
| } | |
| /* | |
| * _uid_cache_insert - add a new entry into the uid cache | |
| * will automatically expand the cache as needed | |
| * IN pointer to entry, this function copies the values as-is, assumes | |
| * ownership of the username pointer | |
| * | |
| * NOTE: caller MUST have the mutex uid_lock prior to the call | |
| */ | |
| static void _uid_cache_insert(uid_cache_t *cache, uid_cache_entry_t *item) | |
| { | |
| int low = 0, high = cache->used; | |
| if ((cache->max_entries != UID_CACHE_MAX_UNLIMITED) && | |
| (cache->used >= cache->max_entries)) { | |
| xfree(item->username); | |
| return; | |
| } | |
| /* binary insertion sort to manage cache */ | |
| while (low < high) { | |
| int mid = (low + high) / 2; | |
| int cmp = _uid_cache_cmp(cache, mid, item); | |
| if (!cmp) { | |
| /* had a cache hit, do not insert, clean up */ | |
| xfree(item->username); | |
| return; | |
| } else if (cmp > 0) { | |
| low = mid + 1; | |
| } else { | |
| high = mid; | |
| } | |
| } | |
| if (cache->used >= cache->capacity) { | |
| cache->capacity += 128; | |
| cache->cache = xrecalloc(cache->cache, cache->capacity, | |
| sizeof(uid_cache_entry_t)); | |
| } | |
| if (low < cache->used) | |
| memmove(&cache->cache[low + 1], &cache->cache[low], | |
| (cache->used - low) * sizeof(uid_cache_entry_t)); | |
| cache->cache[low] = *item; | |
| cache->used++; | |
| } | |
| static void _uid_cache_insert_by_username(uid_cache_t *cache, const char *name) | |
| { | |
| uid_cache_entry_t entry = { 0 }; | |
| entry.uid = NO_VAL; | |
| entry.username = xstrdup(name); | |
| _uid_cache_insert(cache, &entry); | |
| } | |
| static uid_cache_entry_t *_uid_cache_search_uid(const uid_cache_t *cache, | |
| uid_t tgt_uid) | |
| { | |
| if (cache->sort == UID_CACHE_SORT_UID) { | |
| return bsearch(&tgt_uid, cache->cache, cache->used, | |
| sizeof(uid_cache_entry_t), _uid_cache_cmp_uid); | |
| } else { | |
| /* linear scan fallback in case cache is searched by uid */ | |
| for (int i = 0; i < cache->used; i++) { | |
| if (cache->cache[i].uid == tgt_uid) { | |
| return &cache->cache[i]; | |
| } | |
| } | |
| } | |
| return NULL; | |
| } | |
| static uid_cache_entry_t *_uid_cache_search_username(const uid_cache_t *cache, | |
| const char *tgt_username) | |
| { | |
| if (cache->sort == UID_CACHE_SORT_USERNAME) { | |
| return bsearch(&tgt_username, cache->cache, cache->used, | |
| sizeof(uid_cache_entry_t), | |
| _uid_cache_cmp_username); | |
| } else { | |
| /* linear scan fallback in case cache is searched by username */ | |
| for (int i = 0; i < cache->used; i++) { | |
| if (!xstrcmp(cache->cache[i].username, tgt_username)) { | |
| return &cache->cache[i]; | |
| } | |
| } | |
| } | |
| return NULL; | |
| } | |
| /* | |
| * _uid_from_string_cached() - check username_cache for any entry matching | |
| * the input string. | |
| * | |
| * IN name - string with either a provided username or provided string uid | |
| * IN uidp - pointer to the caller's uid_t memory. Upon success, will be | |
| * populated with the identified uid. | |
| * | |
| * Returns: | |
| * SLURM_SUCCESS: uid was successfully looked up in the cache, uidp | |
| * populated with the cached version of the uid | |
| * SLURM_ERROR: the name was not in the username cache | |
| * | |
| * | |
| * NOTE: Caller is assumed to hold lock on uid_lock to call this | |
| */ | |
| static int _uid_from_string_cached(const char *name, uid_t *uidp) | |
| { | |
| uid_cache_entry_t *entry = NULL; | |
| long l; | |
| char *p = NULL; | |
| uid_t target; | |
| if (!name) | |
| return SLURM_ERROR; | |
| entry = _uid_cache_search_username(&uidfrom_uname_cache, name); | |
| if (entry) { | |
| *uidp = entry->uid; | |
| return SLURM_SUCCESS; | |
| } | |
| /* maybe we were given a string of a uid? */ | |
| errno = 0; | |
| l = strtol(name, &p, 10); | |
| if (((errno == ERANGE) && ((l == LONG_MIN) || (l == LONG_MAX))) || | |
| (name == p) || (*p != '\0') || (l < 0) || (l > UINT32_MAX)) | |
| return SLURM_ERROR; | |
| target = (uid_t) l; | |
| entry = _uid_cache_search_uid(&uidfrom_uid_cache, target); | |
| /* | |
| * Only trusting a string of a uid if it is already cached because then | |
| * the insertion point will have been a valid lookup of the uid | |
| * previously. | |
| */ | |
| if (entry) { | |
| *uidp = entry->uid; | |
| return SLURM_SUCCESS; | |
| } | |
| return SLURM_ERROR; | |
| } | |
| /* | |
| * _uid_from_string() - given a string with either a username or a uid in it | |
| * populate the passed uid pointer with the correct uid and return an | |
| * integer indicated the degree of success. This function is sanitizing | |
| * inputs against current system state and provides UIDs that the Slurm | |
| * daemons use in a security sensitive manner. | |
| * | |
| * IN name: string with either a provided username or provided string uid | |
| * ownership of the username pointer | |
| * IN/OUT uidp: pointer to the caller's uid_t memory, will be populated with | |
| * the identified uid, though degree of success is communicated via | |
| * the return code. | |
| * IN/OUT unamep - pointer to caller's username string, if non-NULL, will be | |
| * populated with the identified username only when SLURM_SUCCESS is | |
| * returned. If non-NULL, will be populated with NULL when | |
| * ESLURM_USER_ID_UNKNOWN is returned. Unchanged for any other return | |
| * values. Caller takes on ownership of any non-NULL value set in | |
| * unamep. | |
| * | |
| * Returns: | |
| * SLURM_SUCCESS: uid was successfully looked up, uidp populated with | |
| * the passwd database version of the uid | |
| * SLURM_ERROR: the name string was not a username nor was it a valid | |
| * number that *might* be a uid. uidp is NOT populated, | |
| * caller should NOT proceed with the results | |
| * ESLURM_USER_ID_UNKNOWN: the name string had an encoded number but was | |
| * not in the user database accessible to the system. | |
| * uidp is populated with the parsed uid number. caller | |
| * should proceed with care. | |
| * SLURM_AUTH_NOBODY: requested name matches SLURM_AUTH_NOBODY_NAME, | |
| * the in/out variables are untouched. | |
| */ | |
| static int _uid_from_string(const char *name, uid_t *uidp, char **unamep) | |
| { | |
| DEF_TIMERS; | |
| struct passwd pwd, *result = NULL; | |
| char buf_stack[PW_BUF_SIZE]; | |
| char *buf_malloc = NULL; | |
| size_t bufsize = PW_BUF_SIZE; | |
| char *curr_buf = buf_stack; | |
| char *p = NULL; | |
| long l; | |
| if (!name) | |
| return SLURM_ERROR; | |
| if (!xstrcmp(name, SLURM_AUTH_NOBODY_NAME)) | |
| return SLURM_AUTH_NOBODY; | |
| /* | |
| * Check to see if name is a valid username first. | |
| */ | |
| START_TIMER; | |
| while (true) { | |
| int rc = getpwnam_r(name, &pwd, curr_buf, bufsize, &result); | |
| if (!rc && result) | |
| break; | |
| if (rc == EINTR) { | |
| continue; | |
| } else if (rc == ERANGE) { | |
| bufsize *= 2; | |
| curr_buf = xrealloc(buf_malloc, bufsize); | |
| continue; | |
| } else if ((rc == 0) || (rc == ENOENT) || (rc == ESRCH) || | |
| (rc == EBADF) || (rc == EPERM)) { | |
| debug2("%s: getpwnam_r(%s): no record found", | |
| __func__, name); | |
| } else { | |
| error("%s: getpwnam_r(%s): %s", | |
| __func__, name, slurm_strerror(rc)); | |
| } | |
| result = NULL; | |
| break; | |
| } | |
| END_TIMER2("getpwnam_r"); | |
| if (result) | |
| goto success; | |
| /* | |
| * If username was not valid, check for a valid UID. | |
| */ | |
| errno = 0; | |
| l = strtol(name, &p, 10); | |
| if (((errno == ERANGE) && ((l == LONG_MIN) || (l == LONG_MAX))) || | |
| (name == p) || (*p != '\0') || (l < 0) || (l > UINT32_MAX)) { | |
| xfree(buf_malloc); | |
| return SLURM_ERROR; | |
| } | |
| /* | |
| * Now ensure the supplied uid is in the user database | |
| */ | |
| slurm_getpwuid_r(l, &pwd, &curr_buf, &buf_malloc, &bufsize, &result); | |
| if (!result) { | |
| /* | |
| * some calling clients still use the value of *uidp even with | |
| * ESLURM_USER_ID_UNKNOWN | |
| */ | |
| *uidp = (uid_t) l; | |
| if (unamep) | |
| *unamep = NULL; | |
| xfree(buf_malloc); | |
| return ESLURM_USER_ID_UNKNOWN; | |
| } | |
| success: | |
| *uidp = pwd.pw_uid; | |
| if (unamep) | |
| *unamep = xstrdup(pwd.pw_name); | |
| xfree(buf_malloc); | |
| return SLURM_SUCCESS; | |
| } | |
| extern int uid_from_string(const char *name, uid_t *uidp) | |
| { | |
| return _uid_from_string(name, uidp, NULL); | |
| } | |
| extern int uid_from_numeric_string(const char *str, uid_t *uidp) | |
| { | |
| unsigned long long num; | |
| char *end = NULL; | |
| if (!str || !isdigit((unsigned char) str[0])) | |
| return SLURM_ERROR; | |
| errno = 0; | |
| num = strtoull(str, &end, 10); | |
| if (errno || end[0] || (num > UINT32_MAX)) | |
| return SLURM_ERROR; | |
| *uidp = num; | |
| return SLURM_SUCCESS; | |
| } | |
| extern int uid_from_string_cached(const char *name, uid_t *uidp) | |
| { | |
| int rc = SLURM_ERROR; | |
| char *resolved_username = NULL; | |
| if (!name) | |
| return SLURM_ERROR; | |
| /* Check to see if name is in username cache first */ | |
| slurm_mutex_lock(&uid_lock); | |
| if (uidfrom_cache_enabled) { | |
| if (_uid_from_string_cached(name, uidp) == SLURM_SUCCESS) { | |
| slurm_mutex_unlock(&uid_lock); | |
| return SLURM_SUCCESS; | |
| } | |
| if (_uid_cache_search_username(&uidfrom_uname_neg_cache, | |
| name)) { | |
| slurm_mutex_unlock(&uid_lock); | |
| return SLURM_ERROR; | |
| } | |
| } | |
| slurm_mutex_unlock(&uid_lock); | |
| rc = _uid_from_string(name, uidp, &resolved_username); | |
| slurm_mutex_lock(&uid_lock); | |
| if (uidfrom_cache_enabled) { | |
| if (rc == SLURM_SUCCESS) { | |
| uid_cache_entry_t entry = { 0 }; | |
| entry.uid = *uidp; | |
| /* duplicating username for first cache reference */ | |
| entry.username = xstrdup(resolved_username); | |
| _uid_cache_insert(&uidfrom_uname_cache, &entry); | |
| /* handing off username for second cache reference */ | |
| entry.username = resolved_username; | |
| _uid_cache_insert(&uidfrom_uid_cache, &entry); | |
| resolved_username = NULL; | |
| } else if (rc == SLURM_ERROR) { | |
| _uid_cache_insert_by_username(&uidfrom_uname_neg_cache, | |
| name); | |
| } else if (rc == ESLURM_USER_ID_UNKNOWN) { | |
| /* do nothing */ | |
| } else if (rc == SLURM_AUTH_NOBODY) { | |
| /* do nothing */ | |
| } | |
| } | |
| slurm_mutex_unlock(&uid_lock); | |
| xfree(resolved_username); | |
| return rc; | |
| } | |
| /* | |
| * Return an xmalloc'd string, or null on error. | |
| * Caller must free eventually. | |
| */ | |
| char *uid_to_string_or_null(uid_t uid) | |
| { | |
| struct passwd pwd, *result; | |
| char buf_stack[PW_BUF_SIZE]; | |
| char *buf_malloc = NULL; | |
| size_t bufsize = PW_BUF_SIZE; | |
| char *curr_buf = buf_stack; | |
| char *ustring = NULL; | |
| /* Suse Linux does not handle multiple users with UID=0 well */ | |
| if (uid == 0) | |
| return xstrdup("root"); | |
| if (uid == NO_VAL) | |
| return NULL; | |
| if (uid == SLURM_AUTH_NOBODY) | |
| return xstrdup(SLURM_AUTH_NOBODY_NAME); | |
| slurm_getpwuid_r(uid, &pwd, &curr_buf, &buf_malloc, &bufsize, &result); | |
| if (result) | |
| ustring = xstrdup(result->pw_name); | |
| xfree(buf_malloc); | |
| return ustring; | |
| } | |
| extern char *uid_to_string(uid_t uid) | |
| { | |
| char *result = uid_to_string_or_null(uid); | |
| if (!result) | |
| result = xstrdup_printf("%u", uid); | |
| return result; | |
| } | |
| static void _uid_cache_clear(uid_cache_t *cache) | |
| { | |
| for (int i = 0; i < cache->used; i++) | |
| xfree(cache->cache[i].username); | |
| xfree(cache->cache); | |
| cache->used = 0; | |
| cache->capacity = 0; | |
| } | |
| extern void uid_cache_clear(void) | |
| { | |
| slurm_mutex_lock(&uid_lock); | |
| _uid_cache_clear(&uid_cache); | |
| _uid_cache_clear(&uidfrom_uid_cache); | |
| _uid_cache_clear(&uidfrom_uname_cache); | |
| _uid_cache_clear(&uidfrom_uname_neg_cache); | |
| slurm_mutex_unlock(&uid_lock); | |
| } | |
| /* | |
| * Turns on uid_from_string caching. Will clear any entries existing in the | |
| * cache. Reference counts so as not to re-init the caches until truly | |
| * re-enabling from a disabled state. | |
| */ | |
| extern void uid_from_string_cache_enable(void) | |
| { | |
| slurm_mutex_lock(&uid_lock); | |
| if (!uidfrom_cache_enabled) { | |
| _uid_cache_clear(&uidfrom_uid_cache); | |
| _uid_cache_clear(&uidfrom_uname_cache); | |
| _uid_cache_clear(&uidfrom_uname_neg_cache); | |
| } | |
| uidfrom_cache_enabled += 1; | |
| slurm_mutex_unlock(&uid_lock); | |
| } | |
| /* | |
| * Turns off uid_from_string caching. xassert exists to make sure we do not | |
| * underflow the reference count if there is an imbalance in enable/disable | |
| * calls | |
| */ | |
| extern void uid_from_string_cache_disable(void) | |
| { | |
| slurm_mutex_lock(&uid_lock); | |
| uidfrom_cache_enabled -= 1; | |
| xassert(uidfrom_cache_enabled >= 0); | |
| slurm_mutex_unlock(&uid_lock); | |
| } | |
| extern char *uid_to_string_cached(uid_t uid) | |
| { | |
| uid_cache_entry_t *entry; | |
| if (uid == SLURM_AUTH_NOBODY) | |
| return SLURM_AUTH_NOBODY_NAME; | |
| slurm_mutex_lock(&uid_lock); | |
| entry = _uid_cache_search_uid(&uid_cache, uid); | |
| if (entry == NULL) { | |
| uid_cache_entry_t new_entry = {uid, uid_to_string(uid)}; | |
| _uid_cache_insert(&uid_cache, &new_entry); | |
| slurm_mutex_unlock(&uid_lock); | |
| return new_entry.username; | |
| } | |
| slurm_mutex_unlock(&uid_lock); | |
| return entry->username; | |
| } | |
| extern char *uid_to_dir(uid_t uid) | |
| { | |
| struct passwd pwd, *result; | |
| char buf_stack[PW_BUF_SIZE]; | |
| char *buf_malloc = NULL; | |
| size_t bufsize = PW_BUF_SIZE; | |
| char *curr_buf = buf_stack; | |
| char *dir = NULL; | |
| slurm_getpwuid_r(uid, &pwd, &curr_buf, &buf_malloc, &bufsize, &result); | |
| if (result) | |
| dir = xstrdup(result->pw_dir); | |
| xfree(buf_malloc); | |
| return dir; | |
| } | |
| extern char *uid_to_shell(uid_t uid) | |
| { | |
| struct passwd pwd, *result; | |
| char buf_stack[PW_BUF_SIZE]; | |
| char *buf_malloc = NULL; | |
| size_t bufsize = PW_BUF_SIZE; | |
| char *curr_buf = buf_stack; | |
| char *shell = NULL; | |
| slurm_getpwuid_r(uid, &pwd, &curr_buf, &buf_malloc, &bufsize, &result); | |
| if (result) | |
| shell = xstrdup(result->pw_shell); | |
| xfree(buf_malloc); | |
| return shell; | |
| } | |
| gid_t gid_from_uid(uid_t uid) | |
| { | |
| struct passwd pwd, *result; | |
| char buf_stack[PW_BUF_SIZE]; | |
| char *buf_malloc = NULL; | |
| size_t bufsize = PW_BUF_SIZE; | |
| char *curr_buf = buf_stack; | |
| gid_t gid; | |
| if (uid == NO_VAL) | |
| return -1; | |
| slurm_getpwuid_r(uid, &pwd, &curr_buf, &buf_malloc, &bufsize, &result); | |
| if (result) | |
| gid = result->pw_gid; | |
| else | |
| gid = (gid_t) -1; | |
| xfree(buf_malloc); | |
| return gid; | |
| } | |
| int gid_from_string(const char *name, gid_t *gidp) | |
| { | |
| DEF_TIMERS; | |
| struct group grp, *result = NULL; | |
| char buf_stack[PW_BUF_SIZE]; | |
| char *buf_malloc = NULL; | |
| char *curr_buf = buf_stack; | |
| size_t bufsize = PW_BUF_SIZE; | |
| char *p = NULL; | |
| long l; | |
| if (!name) | |
| return -1; | |
| /* | |
| * Check for valid group name first. | |
| */ | |
| START_TIMER; | |
| while (true) { | |
| int rc = getgrnam_r(name, &grp, curr_buf, bufsize, &result); | |
| if (!rc && result) | |
| break; | |
| if (rc == EINTR) { | |
| continue; | |
| } else if (rc == ERANGE) { | |
| bufsize *= 2; | |
| curr_buf = xrealloc(buf_malloc, bufsize); | |
| continue; | |
| } else if ((rc == 0) || (rc == ENOENT) || (rc == ESRCH) || | |
| (rc == EBADF) || (rc == EPERM)) { | |
| debug2("%s: getgrnam_r(%s): no record found", | |
| __func__, name); | |
| } else { | |
| error("%s: getgrnam_r(%s): %s", | |
| __func__, name, slurm_strerror(rc)); | |
| } | |
| result = NULL; | |
| break; | |
| } | |
| END_TIMER2("getgrnam_r"); | |
| if (result) { | |
| *gidp = result->gr_gid; | |
| xfree(buf_malloc); | |
| return 0; | |
| } | |
| /* | |
| * If group name was not valid, perhaps it is a valid GID. | |
| */ | |
| errno = 0; | |
| l = strtol(name, &p, 10); | |
| if (((errno == ERANGE) && ((l == LONG_MIN) || (l == LONG_MAX))) || | |
| (name == p) || (*p != '\0') || (l < 0) || (l > UINT32_MAX)) { | |
| xfree(buf_malloc); | |
| return -1; | |
| } | |
| /* | |
| * Now ensure the supplied uid is in the user database | |
| */ | |
| START_TIMER; | |
| while (true) { | |
| int rc = getgrgid_r(l, &grp, curr_buf, bufsize, &result); | |
| if (!rc && result) | |
| break; | |
| if (rc == EINTR) { | |
| continue; | |
| } else if (rc == ERANGE) { | |
| bufsize *= 2; | |
| curr_buf = xrealloc(buf_malloc, bufsize); | |
| continue; | |
| } else if ((rc == 0) || (rc == ENOENT) || (rc == ESRCH) || | |
| (rc == EBADF) || (rc == EPERM)) { | |
| debug2("%s: getgrgid_r(%ld): no record found", | |
| __func__, l); | |
| } else { | |
| error("%s: getgrgid_r(%ld): %s", | |
| __func__, l, slurm_strerror(rc)); | |
| } | |
| result = NULL; | |
| break; | |
| } | |
| END_TIMER2("getgrgid_r"); | |
| xfree(buf_malloc); | |
| /* | |
| * Warning - result is now a pointer to invalid memory. | |
| * Do not dereference it, but checking that it is non-NULL is safe. | |
| */ | |
| if (!result) | |
| return -1; | |
| *gidp = (gid_t) l; | |
| return 0; | |
| } | |
| extern char *gid_to_string(gid_t gid) | |
| { | |
| char *result = NULL; | |
| if (gid == SLURM_AUTH_NOBODY) | |
| return xstrdup(SLURM_AUTH_NOBODY_NAME); | |
| if (!(result = gid_to_string_or_null(gid))) | |
| return xstrdup_printf("%u", gid); | |
| return result; | |
| } | |
| /* | |
| * Return an xmalloc'd string, or null on error. | |
| * Caller must xfree() eventually. | |
| */ | |
| char *gid_to_string_or_null(gid_t gid) | |
| { | |
| DEF_TIMERS; | |
| struct group grp, *result = NULL; | |
| char buf_stack[PW_BUF_SIZE]; | |
| char *buf_malloc = NULL; | |
| size_t bufsize = PW_BUF_SIZE; | |
| char *curr_buf = buf_stack; | |
| char *name = NULL; | |
| if (gid == SLURM_AUTH_NOBODY) | |
| return NULL; | |
| if (gid == NO_VAL) | |
| return NULL; | |
| START_TIMER; | |
| while (true) { | |
| int rc = getgrgid_r(gid, &grp, curr_buf, bufsize, &result); | |
| if (!rc && result) | |
| break; | |
| if (rc == EINTR) { | |
| continue; | |
| } else if (rc == ERANGE) { | |
| bufsize *= 2; | |
| curr_buf = xrealloc(buf_malloc, bufsize); | |
| continue; | |
| } else if ((rc == 0) || (rc == ENOENT) || (rc == ESRCH) || | |
| (rc == EBADF) || (rc == EPERM)) { | |
| debug2("%s: getgrgid_r(%u): no record found", | |
| __func__, gid); | |
| } else { | |
| error("%s: getgrgid_r(%u): %s", | |
| __func__, gid, slurm_strerror(rc)); | |
| } | |
| result = NULL; | |
| break; | |
| } | |
| END_TIMER2("getgrgid_r"); | |
| if (result) | |
| name = xstrdup(result->gr_name); | |
| xfree(buf_malloc); | |
| return name; | |
| } | |
| extern int drop_supplementary_groups(uid_t uid, gid_t gid) | |
| { | |
| int rc = EINVAL; | |
| gid_t *gids = NULL; | |
| bool need_drop = false; | |
| int gid_count = getgroups(0, NULL); | |
| if (gid_count < 0) { | |
| rc = errno; | |
| error("%s: getgroups(0, NULL) failed: %s", | |
| __func__, slurm_strerror(rc)); | |
| return rc; | |
| } | |
| if (!gid_count) | |
| return SLURM_SUCCESS; | |
| gids = xcalloc(gid_count, sizeof(*gids)); | |
| if ((gid_count = getgroups(gid_count, gids)) < 0) { | |
| rc = errno; | |
| error("%s: getgroups() failed: %s", | |
| __func__, slurm_strerror(rc)); | |
| xfree(gids); | |
| return rc; | |
| } | |
| for (int i = 0; i < gid_count; i++) { | |
| /* | |
| * Ignore same gid being in supplementary groups | |
| * as it won't change permissions | |
| */ | |
| if (gids[i] == gid) | |
| continue; | |
| need_drop = true; | |
| debug("%s: Supplementary group %u needs to be dropped", | |
| __func__, gids[i]); | |
| } | |
| xfree(gids); | |
| if (!need_drop) | |
| return SLURM_SUCCESS; | |
| debug("%s: Dropping all supplementary groups", __func__); | |
| if (!setgroups(0, NULL)) | |
| return SLURM_SUCCESS; | |
| rc = errno; | |
| #ifdef __linux__ | |
| if (rc == EPERM) { | |
| warning("Process lacks CAP_SETGID to drop supplementary groups. Supplementary groups should be removed from user (uid=%u,gid=%u) prior to starting process.", | |
| uid, gid); | |
| return SLURM_SUCCESS; | |
| } | |
| #endif /* __linux__ */ | |
| warning("Unable to drop supplementary groups: %s", slurm_strerror(rc)); | |
| return rc; | |
| } | |
| extern int set_supplementary_groups(uid_t uid, gid_t *gids, int ngids) | |
| { | |
| int rc; | |
| if (!setgroups(ngids, gids)) | |
| return SLURM_SUCCESS; | |
| rc = errno; | |
| #ifdef __linux__ | |
| if (rc == EPERM) { | |
| warning("Process lacks CAP_SETGID to set supplementary groups. Supplementary groups should be configured for user (uid=%u) prior to starting process.", | |
| uid); | |
| return SLURM_SUCCESS; | |
| } | |
| #endif /* __linux__ */ | |
| error("%s: Unable to setgroups(): %s", __func__, slurm_strerror(rc)); | |
| return rc; | |
| } |