Lustre Repository Browser

Viewing: upcall_cache_internal.h

/* SPDX-License-Identifier: GPL-2.0 */

/*
 * Copyright (c) 2023, Whamcloud.
 */

/*
 * This file is part of Lustre, http://www.lustre.org/
 */

#ifndef _UPCALL_CACHE_INTERNAL_H
#define _UPCALL_CACHE_INTERNAL_H

#include <upcall_cache.h>

/* protected by cache lock */
static void free_entry(struct upcall_cache *cache,
		       struct upcall_cache_entry *entry)
{
	if (cache->uc_ops->free_entry)
		cache->uc_ops->free_entry(cache, entry);

	list_del(&entry->ue_hash);
	CDEBUG(D_OTHER, "destroy cache entry %p for key %llu\n",
	       entry, entry->ue_key);
	if (cache->uc_ops->free_delay)
		cache->uc_ops->free_delay(entry);
	else
		OBD_FREE(entry, sizeof(*entry));
}

static inline void get_entry(struct upcall_cache_entry *entry)
{
	atomic_inc(&entry->ue_refcount);
}

static inline void put_entry(struct upcall_cache *cache,
			     struct upcall_cache_entry *entry)
{
	if (atomic_dec_and_test(&entry->ue_refcount) &&
	    (UC_CACHE_IS_INVALID(entry) || UC_CACHE_IS_EXPIRED(entry))) {
		free_entry(cache, entry);
	}
}

#ifdef CONFIG_LUSTRE_FS_SERVER
void refresh_entry_internal(struct upcall_cache *cache,
			    struct upcall_cache_entry *entry,
			    __u32 fsgid, struct group_info **ginfo);
int upcall_cache_get_entry_internal(struct upcall_cache *cache,
				    struct upcall_cache_entry *entry,
				    void *args, gid_t *fsgid,
				    struct group_info **ginfo);
#else /* CONFIG_LUSTRE_FS_SERVER */
static inline
void refresh_entry_internal(struct upcall_cache *cache,
			    struct upcall_cache_entry *entry,
			    __u32 fsgid, struct group_info **ginfo)
{ }
static inline int upcall_cache_get_entry_internal(struct upcall_cache *cache,
					       struct upcall_cache_entry *entry,
					       void *args, gid_t *fsgid,
					       struct group_info **ginfo)
{
	return -EOPNOTSUPP;
}
#endif

static inline void upcall_group_usage_inc(struct group_info *group)
{
#ifdef HAVE_GROUP_INFO_USAGE_AS_REFCOUNT
	refcount_inc(&group->usage);
#else
	atomic_inc(&group->usage);
#endif
}

static inline void upcall_group_usage_dec(struct group_info *group)
{
#ifdef HAVE_GROUP_INFO_USAGE_AS_REFCOUNT
	return refcount_dec(&group->usage);
#else
	return atomic_dec(&group->usage);
#endif
}

#endif /* _UPCALL_CACHE_INTERNAL_H */