#include <cstdlib> 
#include "OpenSSL.h"
#include "log.h"

// This array will store all of the mutex available for OpenSSL.
pthread_mutex_t* OpenSSL::mutexArray = NULL;

bool OpenSSL::ClassInit()
{
	// First initialize OpenSSL stuff.
	SSL_load_error_strings();
	SSL_library_init();
	
	OpenSSL_add_all_algorithms();
	ERR_load_crypto_strings();

	// Then set the stuff to make OpenSSL thread-safe.
	if (!SetThreadSafe())
		return Error("-OpenSSL::ClassInit(): SetThreadSafe() failed\n");
	
	return true;
}


bool OpenSSL::SetThreadSafe()
{
	//Create mutex array
	mutexArray = (pthread_mutex_t*)malloc(sizeof(pthread_mutex_t) * CRYPTO_num_locks());
	
	if (!mutexArray) 
		return Error("-OpenSSL::SetThreadSafe(): allocation of mutexArray failed\n");

	for (int i=0; i<CRYPTO_num_locks(); i++)
		pthread_mutex_init(&mutexArray[i], NULL);

	// For OpenSSL >= 1.0.0.
	CRYPTO_THREADID_set_callback(SetThreadId);

	// Set OpenSSL locking callback.
	CRYPTO_set_locking_callback(LockingFunction);

	return true;
}

void OpenSSL::SetThreadId(CRYPTO_THREADID* thread_id)
{
	// Let's assume pthread_self() is an unsigned long (otherwise this won't compile anyway).
	CRYPTO_THREADID_set_numeric(thread_id, (unsigned long)pthread_self());
}


void OpenSSL::LockingFunction(int mode, int n, const char *file, int line)
{
	/**
	 * - mode:  bitfield describing what should be done with the lock:
	 *     CRYPTO_LOCK     0x01
	 *     CRYPTO_UNLOCK   0x02
	 *     CRYPTO_READ     0x04
	 *     CRYPTO_WRITE    0x08
	 * - n:  the number of the mutex.
	 * - file:  source file calling this function.
	 * - line:  line in the source file calling this function.
	 */
	if (mode & CRYPTO_LOCK)
		pthread_mutex_lock(&mutexArray[n]);
	else
		pthread_mutex_unlock(&mutexArray[n]);
}