/* Portions copyright (c) 2009 Nokia Corporation.  All rights reserved. */

#undef G_DISABLE_ASSERT

#undef G_LOG_DOMAIN

#define G_ERRORCHECK_MUTEXES

#include <glib.h>

#include <stdio.h>

#include <string.h>

#ifdef __SYMBIAN32__

#include <glib_global.h>

#include "mrt2_glib2_test.h"

#endif /*__SYMBIAN32__*/

static gpointer

locking_thread (gpointer mutex)

{

  g_mutex_lock ((GMutex*)mutex);

  return NULL;

}

static void

lock_locked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  g_mutex_lock (mutex);

  g_mutex_lock (mutex);

}

static void

trylock_locked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  g_mutex_lock (mutex);

  g_mutex_trylock (mutex);

}

static void

unlock_unlocked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  g_mutex_lock (mutex);

  g_mutex_unlock (mutex);

  g_mutex_unlock (mutex);

}

static void

free_locked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  g_mutex_lock (mutex);

  g_mutex_free (mutex);

}

static void

wait_on_unlocked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  GCond* cond = g_cond_new ();

  g_cond_wait (cond, mutex);

}

static void

wait_on_otherwise_locked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  GCond* cond = g_cond_new ();

  GThread* thread = g_thread_create (locking_thread, mutex, TRUE, NULL);

  g_assert (thread != NULL);

  g_usleep (G_USEC_PER_SEC);

  g_cond_wait (cond, mutex);

}

static void

timed_wait_on_unlocked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  GCond* cond = g_cond_new ();

  g_cond_timed_wait (cond, mutex, NULL);

}

static void

timed_wait_on_otherwise_locked_mutex (void)

{

  GMutex* mutex = g_mutex_new ();

  GCond* cond = g_cond_new ();

  GThread* thread = g_thread_create (locking_thread, mutex, TRUE, NULL);

  g_assert (thread != NULL);

  g_usleep (G_USEC_PER_SEC);

  g_cond_timed_wait (cond, mutex, NULL);

}

struct

{

  char *name;

  void (*func)();

} func_table[] =

{

  {"lock_locked_mutex", lock_locked_mutex},

  {"trylock_locked_mutex", trylock_locked_mutex},

  {"unlock_unlocked_mutex", unlock_unlocked_mutex},

  {"free_locked_mutex", free_locked_mutex},

  {"wait_on_unlocked_mutex", wait_on_unlocked_mutex},

  {"wait_on_otherwise_locked_mutex", wait_on_otherwise_locked_mutex},

  {"timed_wait_on_unlocked_mutex", timed_wait_on_unlocked_mutex},

  {"timed_wait_on_otherwise_locked_mutex",

   timed_wait_on_otherwise_locked_mutex}

};

int

main (int argc, char* argv[])

{

  int i;

#ifdef __SYMBIAN32__

 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 /*__SYMBIAN32__*/

  if (argc == 2)

    {

      for (i = 0; i < G_N_ELEMENTS (func_table); i++)

        {

          if (strcmp (func_table[i].name, argv[1]) == 0)

            {

              g_thread_init (NULL);

              func_table[i].func ();

              g_assert_not_reached ();

            }

        }

    }

  fprintf (stderr, "Usage: errorcheck-mutex-test [TEST]\n\n");

  fprintf (stderr, "   where TEST can be one of:\n\n");

  for (i = 0; i < G_N_ELEMENTS (func_table); i++)

    {

      fprintf (stderr, "      %s\n", func_table[i].name);

    }

#ifdef __SYMBIAN32__

  testResultXml("errorcheck-mutex-test");

  #endif /* EMULATOR */

  return 0;

}