#ifndef TARANTOOL_PTHREAD_H_INCLUDED
#define TARANTOOL_PTHREAD_H_INCLUDED
/*
 * Copyright 2010-2016, Tarantool AUTHORS, please see AUTHORS file.
 *
 * Redistribution and use in source and binary forms, with or
 * without modification, are permitted provided that the following
 * conditions are met:
 *
 * 1. Redistributions of source code must retain the above
 *    copyright notice, this list of conditions and the
 *    following disclaimer.
 *
 * 2. Redistributions in binary form must reproduce the above
 *    copyright notice, this list of conditions and the following
 *    disclaimer in the documentation and/or other materials
 *    provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY <COPYRIGHT HOLDER> ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
 * <COPYRIGHT HOLDER> OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
 * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
 * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */

#include "trivia/config.h"
#include "trivia/util.h"

#include <stdio.h>
#include <errno.h>
#include <pthread.h>
#if HAVE_PTHREAD_NP_H || (__OpenBSD__)
#include <pthread_np.h>
#endif
#if (__OpenBSD__)
#include <signal.h>
#include <sys/signal.h>
#endif
#include "say.h"

/**
 * Assert on any pthread* error in debug mode. In release,
 * write into the log file where and what has failed.
 *
 * Still give the user an opportunity to manually
 * check for error, by assigning pthread_* function status
 * to errno and returning -1.
 */

#define tt_pthread_error(e)			\
	if (e != 0) {				\
		say_syserror("%s error %d", __func__, e);\
		errno = e;			\
	}					\
	assert(e == 0);				\
	e != 0 ? -1 : 0

/**
 * Debug/logging friendly wrappers around pthread
 * functions.
 */
#ifndef NDEBUG
#define tt_pthread_mutex_init(mutex, attr)	\
({						\
	pthread_mutexattr_t *p_attr = attr;	\
	pthread_mutexattr_t errorcheck;	\
	if (p_attr == NULL) {			\
		(void) tt_pthread_mutexattr_init(&errorcheck);\
		(void) pthread_mutexattr_settype(&errorcheck, \
				 PTHREAD_MUTEX_ERRORCHECK);   \
		p_attr = &errorcheck;		\
	}					\
	int e__ = pthread_mutex_init(mutex, p_attr);\
	(void) tt_pthread_mutexattr_destroy(&errorcheck); \
	tt_pthread_error(e__);			\
})
#else
#define tt_pthread_mutex_init(mutex, attr)	\
({						\
	int e__ = pthread_mutex_init(mutex, attr);\
	tt_pthread_error(e__);			\
})
#endif

#define tt_pthread_mutex_destroy(mutex)		\
({	int e__ = pthread_mutex_destroy(mutex);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_mutex_lock(mutex)		\
({	int e__ = pthread_mutex_lock(mutex);	\
	say_debug("%s: locking %s", __func__, #mutex);\
	tt_pthread_error(e__);\
})

#define tt_pthread_mutex_trylock(mutex)		\
({	int e__ = pthread_mutex_trylock(mutex);	\
	if (e__ != 0 && e__ != EBUSY)		\
		say_error("%s error %d at %s:%d", __func__, e__, __FILE__, __LINE__);\
	assert(e__ == 0 || e__ == EBUSY);	\
	e__;					\
})

#define tt_pthread_mutex_unlock(mutex)		\
({	int e__ = pthread_mutex_unlock(mutex);	\
	say_debug("%s: unlocking %s", __func__, #mutex);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_mutex_destroy(mutex)		\
({	int e__ = pthread_mutex_destroy(mutex);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_mutexattr_init(attr)		\
({	int e__ = pthread_mutexattr_init(attr);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_mutexattr_destroy(attr)	\
({	int e__ = pthread_mutexattr_destroy(attr);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_mutexattr_gettype(attr, type)\
({	int e__ = pthread_mutexattr_gettype(attr, type);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_mutexattr_settype(attr, type)\
({	int e__ = pthread_mutexattr_settype(attr, type);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlock_init(rwlock, attr)	\
({						\
	int e__ = pthread_rwlock_init(rwlock, attr);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlock_destroy(rwlock)		\
({	int e__ = pthread_rwlock_destroy(rwlock);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlock_rdlock(rwlock)		\
({	int e__ = pthread_rwlock_rdlock(rwlock);	\
	say_debug("%s: locking %s", __func__, #rwlock);\
	tt_pthread_error(e__);\
})

#define tt_pthread_rwlock_tryrdlock(rwlock)		\
({	int e__ = pthread_rwlock_tryrdlock(rwlock);	\
	if (e__ != 0 && e__ != EBUSY)		\
		say_error("%s error %d at %s:%d", __func__, e__, __FILE__, __LINE__);\
	assert(e__ == 0 || e__ == EBUSY);	\
	e__;					\
})

#define tt_pthread_rwlock_wrlock(rwlock)		\
({	int e__ = pthread_rwlock_wrlock(rwlock);	\
	say_debug("%s: locking %s", __func__, #rwlock);\
	tt_pthread_error(e__);\
})

#define tt_pthread_rwlock_trywrlock(rwlock)		\
({	int e__ = pthread_rwlock_trywrlock(rwlock);	\
	if (e__ != 0 && e__ != EBUSY)		\
		say_error("%s error %d at %s:%d", __func__, e__, __FILE__, __LINE__);\
	assert(e__ == 0 || e__ == EBUSY);	\
	e__;					\
})

#define tt_pthread_rwlock_unlock(rwlock)		\
({	int e__ = pthread_rwlock_unlock(rwlock);	\
	say_debug("%s: unlocking %s", __func__, #rwlock);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlock_destroy(rwlock)		\
({	int e__ = pthread_rwlock_destroy(rwlock);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlockattr_init(attr)		\
({	int e__ = pthread_rwlockattr_init(attr);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlockattr_destroy(attr)	\
({	int e__ = pthread_rwlockattr_destroy(attr);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlockattr_gettype(attr, type)\
({	int e__ = pthread_rwlockattr_gettype(attr, type);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_rwlockattr_settype(attr, type)\
({	int e__ = pthread_rwlockattr_settype(attr, type);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_condattr_init(attr)		\
({	int e__ = pthread_condattr_init(attr);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_condattr_destroy(attr)	\
({ int e__ = pthread_condattr_destroy(attr);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_cond_init(cond, attr)	\
({	int e__ = pthread_cond_init(cond, attr);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_cond_destroy(cond)		\
({	int e__ = pthread_cond_destroy(cond);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_cond_signal(cond)		\
({	int e__ = pthread_cond_signal(cond);	\
	tt_pthread_error(e__);			\
})

#define tt_pthread_cond_broadcast(cond)		\
({	int e__ = pthread_cond_broadcast(cond);	\
	tt_pthread_error(e__);			\
})


#define tt_pthread_cond_wait(cond, mutex)	\
({	int e__ = pthread_cond_wait(cond, mutex);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_cond_timedwait(cond, mutex, timeout)	\
({	int e__ = pthread_cond_timedwait(cond, mutex, timeout);\
	if (ETIMEDOUT != e__ && e__ != 0)		\
		say_error("%s error %d", __func__, e__);\
	assert(e__ == 0 || e__ == ETIMEDOUT);	\
	e__;					\
})

#define tt_pthread_once(control, function)	\
({	int e__ = pthread_once(control, function);\
	tt_pthread_error(e__);			\
})

#define tt_pthread_atfork(prepare, parent, child)\
({	int e__ = pthread_atfork(prepare, parent, child);\
	tt_pthread_error(e__);			\
})

/** Make sure the created thread blocks all signals,
 * they are handled in the main thread.
 */
#define tt_pthread_create(thread, attr, run, arg)	\
({	sigset_t set, oldset;				\
	sigfillset(&set);				\
	pthread_sigmask(SIG_BLOCK, &set, &oldset);	\
	int e__ = pthread_create(thread, attr, run, arg);\
	pthread_sigmask(SIG_SETMASK, &oldset, NULL);	\
	tt_pthread_error(e__);				\
})

#define tt_pthread_join(thread, ret)			\
({	int e__ = pthread_join(thread, ret);		\
	tt_pthread_error(e__);				\
})

#define tt_pthread_cancel(thread)			\
({	int e__ = pthread_cancel(thread);		\
	assert(e__ == 0 || e__ == ESRCH);		\
	e__;						\
})

#define tt_pthread_key_create(key, dtor)		\
({	int e__ = pthread_key_create(key, dtor);	\
	tt_pthread_error(e__);				\
})

#define tt_pthread_key_delete(key)			\
({	int e__ = pthread_key_delete(key);		\
	tt_pthread_error(e__);				\
})

#define tt_pthread_setspecific(key, value)		\
({	int e__ = pthread_setspecific(key, value);	\
	tt_pthread_error(e__);				\
})

#define tt_pthread_getspecific(key) pthread_getspecific(key)

#define tt_pthread_setcancelstate(state, oldstate)	\
({	int e__ = pthread_setcancelstate(state, oldstate);\
	tt_pthread_error(e__);				\
})

/** Set the current thread's name
 */
static inline void
tt_pthread_setname(const char *name)
{
	/* Setting the name fails if the name was too long. Linux limits a
	 * name to 16 bytes (including the trailing NUL), other OS don't
	 * even bother to document the limit.
	 */
	char short_name[16];
	snprintf(short_name, sizeof(short_name), "%s", name);

#if HAVE_PTHREAD_SETNAME_NP
	pthread_setname_np(pthread_self(), short_name);
#elif HAVE_PTHREAD_SETNAME_NP_1
	pthread_setname_np(short_name);
#elif HAVE_PTHREAD_SET_NAME_NP
	pthread_set_name_np(pthread_self(), short_name);
#endif
}

static inline void
tt_pthread_attr_getstack(pthread_t thread, void **stackaddr, size_t *stacksize)
{
#if HAVE_PTHREAD_GETATTR_NP
	/*
	 * GLIBC
	 *
	 * From glib-2.24/sysdeps/nptl/pthread.h pthread_getattr_np():
	 * It shall be called on uninitialized ATTR and destroyed with
	 * pthread_attr_destroy when no longer needed.
	 */
	pthread_attr_t thread_attr;
	pthread_getattr_np(thread, &thread_attr);
	pthread_attr_getstack(&thread_attr, stackaddr, stacksize);
	pthread_attr_destroy(&thread_attr);
#elif HAVE_PTHREAD_ATTR_GET_NP
	/*
	 * xBSD/new macOS
	 *
	 * From pthread_attr_get_np(3):
	 * It is HIGHLY RECOMMENDED to use pthread_attr_init(3) function to
	 * allocate attribute storage.
	 */
	pthread_attr_t thread_attr;
	pthread_attr_init(&thread_attr);
	pthread_attr_get_np(thread, &thread_attr);
	pthread_attr_getstack(&thread_attr, stackaddr, stacksize);
	pthread_attr_destroy(&thread_attr);
#elif (HAVE_PTHREAD_GET_STACKSIZE_NP && HAVE_PTHREAD_GET_STACKADDR_NP)
	/* Old macOS */
	*stacksize = pthread_get_stacksize_np(thread);
	*stackaddr = pthread_get_stackaddr_np(thread);
#elif (__OpenBSD__)
	stack_t *sinfo = (stack_t*)malloc(sizeof(stack_t));
	pthread_stackseg_np(thread, sinfo);
	*stacksize = sinfo->ss_size;
	*stackaddr = sinfo->ss_sp;
#else
#error Unable to get thread stack
#endif
}

#endif /* TARANTOOL_PTHREAD_H_INCLUDED */