--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/apicompatanamdw/bcdrivers/os/ossrv/glib/tests/timeloop.c	Thu Apr 22 17:15:08 2010 +0530
@@ -0,0 +1,231 @@
+/*
+* 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 <errno.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <stdio.h>
+#include <sys/time.h>
+#include <sys/resource.h>
+
+#include <glib.h>
+
+#ifdef SYMBIAN
+#include <glib_global.h>
+#include "mrt2_glib2_test.h"
+#endif /*SYMBIAN*/
+
+
+static int n_children = 4;
+static int n_active_children;
+static int n_iters = 5;
+static GMainLoop *loop;
+
+static void
+io_pipe (GIOChannel **channels)
+{
+  int fds[2];
+
+  if (pipe(fds) < 0)
+    {
+      g_print ("Cannot create pipe %s\n", g_strerror (errno));
+      g_assert(FALSE && "timeloop failed");  
+    
+#ifdef SYMBIAN
+  testResultXml("timeloop");
+#endif /* EMULATOR */
+      exit (1);
+    }
+
+  channels[0] = g_io_channel_unix_new (fds[0]);
+  channels[1] = g_io_channel_unix_new (fds[1]);
+}
+
+static gboolean
+read_all (GIOChannel *channel, char *buf, int len)
+{
+  gsize bytes_read = 0;
+  gsize count;
+  GIOError err;
+
+  while (bytes_read < len)
+    {
+      err = g_io_channel_read (channel, buf + bytes_read, len - bytes_read, &count);
+      if (err)
+	{
+	  if (err != G_IO_ERROR_AGAIN)
+	  {
+	  	g_assert(FALSE && "timeloop failed");
+	    return FALSE;
+	  }
+	}
+      else if (count == 0)
+	return FALSE;
+
+      bytes_read += count;
+    }
+
+  return TRUE;
+}
+
+static gboolean
+write_all (GIOChannel *channel, char *buf, int len)
+{
+  gsize bytes_written = 0;
+  gsize count;
+  GIOError err;
+
+  while (bytes_written < len)
+    {
+      err = g_io_channel_write (channel, buf + bytes_written, len - bytes_written, &count);
+      if (err && err != G_IO_ERROR_AGAIN)
+	return FALSE;
+
+      bytes_written += count;
+    }
+
+  return TRUE;
+}
+
+gpointer
+run_child (gpointer data)
+{
+  int i;
+  int val = 1;
+  GIOChannel *in_channel,*out_channel;
+  GTimer *timer = g_timer_new();
+  
+  GIOChannel **channels = data;
+  
+  in_channel = channels[0];
+  out_channel = channels[1];
+
+  for (i = 0; i < n_iters; i++)
+    {
+      write_all (out_channel, (char *)&val, sizeof (val));
+      read_all (in_channel, (char *)&val, sizeof (val));
+    }
+
+  val = 0;
+  write_all (out_channel, (char *)&val, sizeof (val));
+
+  val = g_timer_elapsed (timer, NULL) * 1000;
+  
+  write_all (out_channel, (char *)&val, sizeof (val));
+  g_timer_destroy (timer);
+
+  return NULL;
+}
+
+static gboolean
+input_callback (GIOChannel   *source,
+		GIOCondition  condition,
+		gpointer      data)
+{
+  int val;
+  GIOChannel *dest = (GIOChannel *)data;
+  
+  if (!read_all (source, (char *)&val, sizeof(val)))
+    {
+      g_print("Unexpected EOF\n");
+      g_assert(FALSE && "timeloop failed");
+    #ifdef SYMBIAN
+  testResultXml("timeloop");
+#endif /* EMULATOR */
+      exit (1);
+    }
+
+  if (val)
+    {
+      write_all (dest, (char *)&val, sizeof(val));
+      
+      return TRUE;
+    }
+  else
+    {
+      g_io_channel_close (source);
+      g_io_channel_close (dest);
+      
+      g_io_channel_unref (source);
+      g_io_channel_unref (dest);
+
+      n_active_children--;
+      if (n_active_children == 0)
+	g_main_loop_quit (loop);
+      
+      return FALSE;
+    }
+}
+
+static void
+create_child (void)
+{
+  GError *err = NULL;
+  GIOChannel *in_channels[2];
+  GIOChannel *out_channels[2];
+  
+  GIOChannel **sub_channels;
+  
+  sub_channels = g_new (GIOChannel *, 2);
+  
+  io_pipe (in_channels);
+  io_pipe (out_channels);
+  
+  sub_channels[0] = in_channels[0];
+  sub_channels[1] = out_channels[1];
+
+  g_io_add_watch (out_channels[0], G_IO_IN | G_IO_HUP,
+		      input_callback, in_channels[1]);
+  
+  g_thread_create(run_child,sub_channels,FALSE,&err);
+}
+
+int 
+main (int argc, char **argv)
+{
+  int i;
+  
+  #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);
+  #endif /*SYMBIAN*/
+	  
+  g_thread_init(NULL);
+  
+  if (argc > 1)
+    n_children = atoi(argv[1]);
+
+  if (argc > 2)
+    n_iters = atoi(argv[2]);
+
+  //printf ("Children: %d     Iters: %d\n", n_children, n_iters);
+
+  n_active_children = n_children;
+  for (i = 0; i < n_children; i++)
+    create_child ();
+
+  loop = g_main_loop_new (NULL, FALSE);
+  
+  g_assert(loop != NULL);
+  
+  g_main_loop_run (loop);
+  #ifdef SYMBIAN
+  testResultXml("timeloop");
+  #endif /* EMULATOR */
+  return 0;
+}