/*
 * This file and its contents are supplied under the terms of the
 * Common Development and Distribution License ("CDDL"), version 1.0.
 * You may only use this file in accordance with the terms of version
 * 1.0 of the CDDL.
 *
 * A full copy of the text of the CDDL should have accompanied this
 * source.  A copy of the CDDL is also available via the Internet at
 * http://www.illumos.org/license/CDDL.
 */

/*
 * Copyright 2022 OmniOS Community Edition (OmniOSce) Association.
 */

#ifndef _COMPAT_FREEBSD_PTHREAD_H_
#define	_COMPAT_FREEBSD_PTHREAD_H_

#include <sys/debug.h>
#include_next <pthread.h>

/*
 * Mutexes on FreeBSD are error-checking by default. Wrap pthread_mutex_*()
 * to deliver the same, and check for errors.
 */

#undef PTHREAD_MUTEX_INITIALIZER
#define	PTHREAD_MUTEX_INITIALIZER PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP

static __inline int
checked_pthread_mutex_init(pthread_mutex_t *restrict mutex,
    const pthread_mutexattr_t *restrict cattr)
{
	if (cattr != NULL) {
		VERIFY0(pthread_mutex_init(mutex, cattr));
	} else {
		pthread_mutexattr_t attr = { 0 };

		VERIFY0(pthread_mutexattr_init(&attr));
		VERIFY0(pthread_mutexattr_settype(&attr,
		    PTHREAD_MUTEX_ERRORCHECK));
		VERIFY0(pthread_mutex_init(mutex, &attr));
		VERIFY0(pthread_mutexattr_destroy(&attr));
	}

	return (0);
}

static __inline int
checked_pthread_mutex_destroy(pthread_mutex_t *mutex)
{
	VERIFY0(pthread_mutex_destroy(mutex));
	return (0);
}

#define	pthread_mutex_init(m, a)	checked_pthread_mutex_init(m, a)
#define	pthread_mutex_destroy(m)	checked_pthread_mutex_destroy(m)
#define	pthread_mutex_lock(m)		pthread_mutex_enter_np(m)
#define	pthread_mutex_unlock(m)		pthread_mutex_exit_np(m)

#endif	/* _COMPAT_FREEBSD_PTHREAD_H_ */