/*
 * Read/Write lock functions for testing
 *
 * Copyright (C) 2009-2019, Joachim Metz <joachim.metz@gmail.com>
 *
 * Refer to AUTHORS for acknowledgements.
 *
 * This software is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This software 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 Lesser General Public License
 * along with this software.  If not, see <http://www.gnu.org/licenses/>.
 */

#include <common.h>

#if defined( HAVE_STDLIB_H ) || defined( WINAPI )
#include <stdlib.h>
#endif

#include <errno.h>

#if defined( HAVE_GNU_DL_DLSYM ) && defined( __GNUC__ )
#define __USE_GNU
#include <dlfcn.h>
#undef __USE_GNU
#endif

#include "bfio_test_rwlock.h"

#if defined( HAVE_BFIO_TEST_RWLOCK )

static int (*bfio_test_real_pthread_rwlock_destroy)(pthread_rwlock_t *) = NULL;
static int (*bfio_test_real_pthread_rwlock_rdlock)(pthread_rwlock_t *)  = NULL;
static int (*bfio_test_real_pthread_rwlock_wrlock)(pthread_rwlock_t *)  = NULL;
static int (*bfio_test_real_pthread_rwlock_unlock)(pthread_rwlock_t *)  = NULL;

int bfio_test_pthread_rwlock_destroy_attempts_before_fail               = -1;
int bfio_test_pthread_rwlock_rdlock_attempts_before_fail                = -1;
int bfio_test_pthread_rwlock_wrlock_attempts_before_fail                = -1;
int bfio_test_pthread_rwlock_unlock_attempts_before_fail                = -1;

#if defined( TODO )

/* TODO currently disabled since this causes the tests to segfault on Ubuntu 14.04
 */
static int (*bfio_test_real_pthread_rwlock_init)(pthread_rwlock_t *, const pthread_rwlockattr_t *) = NULL;

int bfio_test_pthread_rwlock_init_attempts_before_fail                                             = -1;

/* Custom pthread_rwlock_init for testing error cases
 * Returns 0 if successful or an error value otherwise
 */
int pthread_rwlock_init(
     pthread_rwlock_t *rwlock,
     const pthread_rwlockattr_t *attr )
{
	int result = 0;

	if( bfio_test_real_pthread_rwlock_init == NULL )
	{
		bfio_test_real_pthread_rwlock_init = dlsym(
		                                      RTLD_NEXT,
		                                      "pthread_rwlock_init" );
	}
	if( bfio_test_pthread_rwlock_init_attempts_before_fail == 0 )
	{
		bfio_test_pthread_rwlock_init_attempts_before_fail = -1;

		return( EBUSY );
	}
	else if( bfio_test_pthread_rwlock_init_attempts_before_fail > 0 )
	{
		bfio_test_pthread_rwlock_init_attempts_before_fail--;
	}
	result = bfio_test_real_pthread_rwlock_init(
	          rwlock,
	          attr );

	return( result );
}

#endif /* defined( TODO ) */

/* Custom pthread_rwlock_destroy for testing error cases
 * Returns 0 if successful or an error value otherwise
 */
int pthread_rwlock_destroy(
     pthread_rwlock_t *rwlock )
{
	int result = 0;

	if( bfio_test_real_pthread_rwlock_destroy == NULL )
	{
		bfio_test_real_pthread_rwlock_destroy = dlsym(
		                                         RTLD_NEXT,
		                                         "pthread_rwlock_destroy" );
	}
	if( bfio_test_pthread_rwlock_destroy_attempts_before_fail == 0 )
	{
		bfio_test_pthread_rwlock_destroy_attempts_before_fail = -1;

		return( EBUSY );
	}
	else if( bfio_test_pthread_rwlock_destroy_attempts_before_fail > 0 )
	{
		bfio_test_pthread_rwlock_destroy_attempts_before_fail--;
	}
	result = bfio_test_real_pthread_rwlock_destroy(
	          rwlock );

	return( result );
}

/* Custom pthread_rwlock_rdlock for testing error cases
 * Returns 0 if successful or an error value otherwise
 */
int pthread_rwlock_rdlock(
     pthread_rwlock_t *rwlock )
{
	int result = 0;

	if( bfio_test_real_pthread_rwlock_rdlock == NULL )
	{
		bfio_test_real_pthread_rwlock_rdlock = dlsym(
		                                        RTLD_NEXT,
		                                        "pthread_rwlock_rdlock" );
	}
	if( bfio_test_pthread_rwlock_rdlock_attempts_before_fail == 0 )
	{
		bfio_test_pthread_rwlock_rdlock_attempts_before_fail = -1;

		return( EBUSY );
	}
	else if( bfio_test_pthread_rwlock_rdlock_attempts_before_fail > 0 )
	{
		bfio_test_pthread_rwlock_rdlock_attempts_before_fail--;
	}
	result = bfio_test_real_pthread_rwlock_rdlock(
	          rwlock );

	return( result );
}

/* Custom pthread_rwlock_wrlock for testing error cases
 * Returns 0 if successful or an error value otherwise
 */
int pthread_rwlock_wrlock(
     pthread_rwlock_t *rwlock )
{
	int result = 0;

	if( bfio_test_real_pthread_rwlock_wrlock == NULL )
	{
		bfio_test_real_pthread_rwlock_wrlock = dlsym(
		                                        RTLD_NEXT,
		                                        "pthread_rwlock_wrlock" );
	}
	if( bfio_test_pthread_rwlock_wrlock_attempts_before_fail == 0 )
	{
		bfio_test_pthread_rwlock_wrlock_attempts_before_fail = -1;

		return( EBUSY );
	}
	else if( bfio_test_pthread_rwlock_wrlock_attempts_before_fail > 0 )
	{
		bfio_test_pthread_rwlock_wrlock_attempts_before_fail--;
	}
	result = bfio_test_real_pthread_rwlock_wrlock(
	          rwlock );

	return( result );
}

/* Custom pthread_rwlock_unlock for testing error cases
 * Returns 0 if successful or an error value otherwise
 */
int pthread_rwlock_unlock(
     pthread_rwlock_t *rwlock )
{
	int result = 0;

	if( bfio_test_real_pthread_rwlock_unlock == NULL )
	{
		bfio_test_real_pthread_rwlock_unlock = dlsym(
		                                        RTLD_NEXT,
		                                        "pthread_rwlock_unlock" );
	}
	if( bfio_test_pthread_rwlock_unlock_attempts_before_fail == 0 )
	{
		/* Unlock the lock otherwise it can enter a nondeterministic state
		 */
		bfio_test_real_pthread_rwlock_unlock(
		 rwlock );

		bfio_test_pthread_rwlock_unlock_attempts_before_fail = -1;

		return( EBUSY );
	}
	else if( bfio_test_pthread_rwlock_unlock_attempts_before_fail > 0 )
	{
		bfio_test_pthread_rwlock_unlock_attempts_before_fail--;
	}
	result = bfio_test_real_pthread_rwlock_unlock(
	          rwlock );

	return( result );
}

#endif /* defined( HAVE_BFIO_TEST_RWLOCK ) */