/*
* Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description: 
*
*/
#undef G_DISABLE_ASSERT
#undef G_LOG_DOMAIN

#include <glib.h>
#include <stdio.h>

#ifdef SYMBIAN
#include <glib_global.h>
#include "mrt2_glib2_test.h"
#endif /*SYMBIAN*/


static GAsyncQueue *queue;
G_LOCK_DEFINE_STATIC (queue_lock);
static guint queue_ready;
#define THREADS 10

static gpointer thread_push (gpointer data)
{
	g_async_queue_push (queue, data);
	return NULL;
}

static gpointer thread_pop (gpointer data)
{
	gint flag = *(gint*)&data;
	gpointer res = g_async_queue_pop (queue);
	gint g_async_queue_pop_op = *(gint*)&res;
	
	G_LOCK (queue_lock);
	queue_ready++;
	G_UNLOCK (queue_lock);
	g_assert (g_async_queue_pop_op == (34 + flag));
	return NULL;
}

void basic_test()
{
	GThread *thread1[THREADS], *thread2[THREADS];
	int i;
	
	queue = g_async_queue_new ();
	
	for(i = 0; i < THREADS; i++)
	{
		thread1[i] = g_thread_create (thread_push, GINT_TO_POINTER(34+i), TRUE, NULL);
		thread2[i] = g_thread_create (thread_pop, GINT_TO_POINTER(i), TRUE, NULL);
	}
	
	/*while(queue_ready != 9)
		g_usleep (G_USEC_PER_SEC / 5);*/
	
	for(i = 0; i < THREADS; i++)
	{
		g_thread_join (thread1[i]);
		g_thread_join (thread2[i]);
	}
	
}


static gpointer thread_ref_push (gpointer data)
{
	g_async_queue_lock (queue);					//Lock the queue
	g_async_queue_ref (queue);					//Increase ref by 1
	g_async_queue_unref_and_unlock (queue);		//Decrease ref by 1 and unlock
	g_async_queue_push (queue, data);
	sleep(2);
	g_async_queue_push (queue, data);
	return NULL;
}

static gpointer thread_ref_pop (gpointer data)
{
	gpointer res;
	gint g_async_queue_try_pop_unlocked_op;
	GTimeVal time_val = 
	{
		0,100
	};
	
	g_async_queue_ref_unlocked (queue);			//Increase ref by 1 and unlock
	
	g_async_queue_lock (queue);					//Lock the queue
	res = g_async_queue_try_pop_unlocked (queue);
	g_async_queue_try_pop_unlocked_op = *(gint*)&res;
	g_async_queue_unlock (queue);					//unlock the queue while the other thread sleeps
	g_assert(g_async_queue_timed_pop (queue, &time_val) == NULL);
	
	G_LOCK (queue_lock);
	queue_ready++;
	G_UNLOCK (queue_lock);
	g_assert (g_async_queue_try_pop_unlocked_op == 55);
	return NULL;
}

void ref_test()
{
	GThread *thread1, *thread2;
	
	g_assert (g_async_queue_try_pop (queue) == NULL);
	
	thread1 = g_thread_create (thread_ref_push, GINT_TO_POINTER(55), TRUE, NULL);
	thread2 = g_thread_create (thread_ref_pop, NULL, TRUE, NULL);
		
/*	while(!queue_ready)
		g_usleep (G_USEC_PER_SEC / 5);*/
	
	g_thread_join (thread1);
	g_thread_join (thread2);
		
}


/* run all the tests */
void
run_all_tests()
{
	queue_ready = 0;
	basic_test();
	queue_ready = 0;
	ref_test()	;
}

int 
main (int   argc,
      char *argv[])
{
  #ifdef SYMBIAN
  g_log_set_handler (NULL,  G_LOG_FLAG_FATAL| G_LOG_FLAG_RECURSION | G_LOG_LEVEL_CRITICAL | G_LOG_LEVEL_WARNING | G_LOG_LEVEL_MESSAGE | G_LOG_LEVEL_INFO | G_LOG_LEVEL_DEBUG, &mrtLogHandler, NULL);
  g_set_print_handler(mrtPrintHandler);
  #endif /*SYMBIAN*/
	  

  /* Only run the test, if threads are enabled and a default thread
     implementation is available */
#if defined(G_THREADS_ENABLED) && ! defined(G_THREADS_IMPL_NONE)
  g_thread_init (NULL);
  run_all_tests ();
#endif
#ifdef SYMBIAN
  testResultXml("tasyncqueue");
#endif /* EMULATOR */
  return 0;
}