#undef G_DISABLE_ASSERT

#undef G_LOG_DOMAIN

#include <sys/types.h>

#include <sys/stat.h>

#include <fcntl.h>

#include <glib.h>

#include <string.h>

#include <stdio.h>

#include <stdlib.h>

#ifdef __SYMBIAN32__

#include "mrt2_glib2_test.h"

#endif /*__SYMBIAN32__*/

#define BUFFER_SIZE 1024

static void

test_small_writes (void)

{

  GIOChannel *io;

  GIOStatus status;

  guint cnt; 

  gchar tmp;

  GError *error = NULL;

  io = g_io_channel_new_file ("c:\\iochannel-test-outfile", "w", &error);

  if (error)

    {

      g_warning ("Unable to open file %s: %s", 

		 "iochannel-test-outfile", 

		 error->message);

      g_error_free (error);

      exit (1);

    }

  g_io_channel_set_encoding (io, NULL, NULL);

  g_io_channel_set_buffer_size (io, 1022);

  cnt = 2 * g_io_channel_get_buffer_size (io);

  tmp = 0;

  while (cnt)

    {

      status = g_io_channel_write_chars (io, &tmp, 1, NULL, NULL);

      if (status == G_IO_STATUS_ERROR)

	break;

      if (status == G_IO_STATUS_NORMAL)

	cnt--;

    }

  g_assert (status == G_IO_STATUS_NORMAL);

  g_io_channel_unref (io);

}

gint main (gint argc, gchar * argv[])

{

    GIOChannel *gio_r, *gio_w ;

    GError *gerr = NULL;

    GString *buffer;

    char *filename;

    char *srcdir = getenv ("srcdir");

    gint rlength = 0;

    glong wlength = 0;

    gsize length_out;

    const gchar encoding[] = "ISO-8859-5";

    GIOStatus status;

    GIOFlags flags;

  #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 (!srcdir)

      srcdir = "c:";

    filename = g_strconcat (srcdir, G_DIR_SEPARATOR_S, "iochannel-test-infile", NULL);

    setbuf (stdout, NULL); /* For debugging */

    gio_r = g_io_channel_new_file (filename, "r", &gerr);

    if (gerr)

      {

        g_warning ("Unable to open file %s: %s", filename, gerr->message);

        g_error_free (gerr);

        g_assert(FALSE && "iochannel-test failed");

        #if __SYMBIAN32__

  		testResultXml("iochannel-test");

  		#endif /* EMULATOR */

        return 1;

      }

    gio_w = g_io_channel_new_file ("c:\\iochannel-test-outfile", "w", &gerr);

    if (gerr)

      {

        g_warning ("Unable to open file %s: %s", "iochannel-test-outfile", gerr->message);

        g_error_free (gerr);

        #if __SYMBIAN32__

  		testResultXml("iochannel-test");

  		#endif /* EMULATOR */

        return 1;

      }

    g_io_channel_set_encoding (gio_r, encoding, &gerr);

    if (gerr)

      {

        g_warning (gerr->message);

        /* Keep going if this is just a case of iconv not supporting EUC-JP, see bug 428048 */

        if (gerr->code != G_CONVERT_ERROR_NO_CONVERSION)

          return 1;

        g_error_free (gerr);

        g_assert(FALSE && "iochannel-test failed");

        #if __SYMBIAN32__

  		testResultXml("iochannel-test");

  		#endif /* EMULATOR */

        return 1;

      }

    g_io_channel_set_buffer_size (gio_r, BUFFER_SIZE);

    status = g_io_channel_set_flags (gio_r, G_IO_FLAG_NONBLOCK, &gerr);

    if (status == G_IO_STATUS_ERROR)

      {

        g_warning (gerr->message);

        g_assert(FALSE && "iochannel-test failed");

        g_error_free (gerr);

        gerr = NULL;

      }

    flags = g_io_channel_get_flags (gio_r);

    buffer = g_string_sized_new (BUFFER_SIZE);

    while (TRUE)

    {

        do

          status = g_io_channel_read_line_string (gio_r, buffer, NULL, &gerr);

        while (status == G_IO_STATUS_AGAIN);

        if (status != G_IO_STATUS_NORMAL)

          break;

        rlength += buffer->len;

        do

          status = g_io_channel_write_chars (gio_w, buffer->str, buffer->len,

            &length_out, &gerr);

        while (status == G_IO_STATUS_AGAIN);

        if (status != G_IO_STATUS_NORMAL)

          break;

        wlength += length_out;

        if (length_out < buffer->len)

        {

        	g_warning ("Only wrote part of the line.");

        	g_assert(FALSE && "iochannel-test failed");

        }

#ifdef VERBOSE

        g_print ("%s", buffer->str);

#endif

        g_string_truncate (buffer, 0);

    }

    switch (status)

      {

        case G_IO_STATUS_EOF:

          break;

        case G_IO_STATUS_ERROR:

          g_warning (gerr->message);

          g_error_free (gerr);

          gerr = NULL;

          break;

        default:

          g_warning ("Abnormal exit from write loop.");

          g_assert(FALSE && "iochannel-test failed");

          break;

      }

    do

      status = g_io_channel_flush (gio_w, &gerr);

    while (status == G_IO_STATUS_AGAIN);

    if (status == G_IO_STATUS_ERROR)

      {

        g_warning (gerr->message);

        g_assert(FALSE && "iochannel-test failed");

        g_error_free (gerr);

        gerr = NULL;

      }

#ifdef VERBOSE

    g_print ("read %d bytes, wrote %ld bytes\n", rlength, wlength);

#endif

    g_io_channel_unref(gio_r);

    g_io_channel_unref(gio_w);

    test_small_writes ();

   	#if __SYMBIAN32__

  	testResultXml("iochannel-test");

  	#endif /* EMULATOR */

    return 0;

}