|
Packit Service |
d3d246 |
#undef G_DISABLE_ASSERT
|
|
Packit Service |
d3d246 |
#undef G_LOG_DOMAIN
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#include <sys/types.h>
|
|
Packit Service |
d3d246 |
#include <sys/stat.h>
|
|
Packit Service |
d3d246 |
#include <fcntl.h>
|
|
Packit Service |
d3d246 |
#include <glib.h>
|
|
Packit Service |
d3d246 |
#include <string.h>
|
|
Packit Service |
d3d246 |
#include <stdio.h>
|
|
Packit Service |
d3d246 |
#include <stdlib.h>
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#define BUFFER_SIZE 1024
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static void
|
|
Packit Service |
d3d246 |
test_small_writes (void)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
GIOChannel *io;
|
|
Packit Service |
d3d246 |
GIOStatus status = G_IO_STATUS_ERROR;
|
|
Packit Service |
d3d246 |
guint cnt;
|
|
Packit Service |
d3d246 |
gchar tmp;
|
|
Packit Service |
d3d246 |
GError *error = NULL;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
io = g_io_channel_new_file ("iochannel-test-outfile", "w", &error);
|
|
Packit Service |
d3d246 |
if (error)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_warning ("Unable to open file %s: %s",
|
|
Packit Service |
d3d246 |
"iochannel-test-outfile",
|
|
Packit Service |
d3d246 |
error->message);
|
|
Packit Service |
d3d246 |
g_clear_error (&error);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
exit (1);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_io_channel_set_encoding (io, NULL, NULL);
|
|
Packit Service |
d3d246 |
g_io_channel_set_buffer_size (io, 1022);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
cnt = 2 * g_io_channel_get_buffer_size (io);
|
|
Packit Service |
d3d246 |
tmp = 0;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
while (cnt)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
status = g_io_channel_write_chars (io, &tmp, 1, NULL, NULL);
|
|
Packit Service |
d3d246 |
if (status == G_IO_STATUS_ERROR)
|
|
Packit Service |
d3d246 |
break;
|
|
Packit Service |
d3d246 |
if (status == G_IO_STATUS_NORMAL)
|
|
Packit Service |
d3d246 |
cnt--;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_assert (status == G_IO_STATUS_NORMAL);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_io_channel_unref (io);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
gint main (gint argc, gchar * argv[])
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
GIOChannel *gio_r, *gio_w ;
|
|
Packit Service |
d3d246 |
GError *gerr = NULL;
|
|
Packit Service |
d3d246 |
GString *buffer;
|
|
Packit Service |
d3d246 |
char *filename;
|
|
Packit Service |
d3d246 |
gint rlength = 0;
|
|
Packit Service |
d3d246 |
glong wlength = 0;
|
|
Packit Service |
d3d246 |
gsize length_out;
|
|
Packit Service |
d3d246 |
const gchar encoding[] = "EUC-JP";
|
|
Packit Service |
d3d246 |
GIOStatus status;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_test_init (&argc, &argv, NULL);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
filename = g_test_build_filename (G_TEST_DIST, "iochannel-test-infile", NULL);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
setbuf (stdout, NULL); /* For debugging */
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
gio_r = g_io_channel_new_file (filename, "r", &gerr);
|
|
Packit Service |
d3d246 |
if (gerr)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_warning ("Unable to open file %s: %s", filename, gerr->message);
|
|
Packit Service |
d3d246 |
g_clear_error (&gerr);
|
|
Packit Service |
d3d246 |
return 1;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
gio_w = g_io_channel_new_file ("iochannel-test-outfile", "w", &gerr);
|
|
Packit Service |
d3d246 |
if (gerr)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_warning ("Unable to open file %s: %s", "iochannel-test-outfile", gerr->message);
|
|
Packit Service |
d3d246 |
g_clear_error (&gerr);
|
|
Packit Service |
d3d246 |
return 1;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_io_channel_set_encoding (gio_r, encoding, &gerr);
|
|
Packit Service |
d3d246 |
if (gerr)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_warning ("%s", gerr->message);
|
|
Packit Service |
d3d246 |
/* Keep going if this is just a case of iconv not supporting EUC-JP, see bug 428048 */
|
|
Packit Service |
d3d246 |
if (gerr->code != G_CONVERT_ERROR_NO_CONVERSION)
|
|
Packit Service |
d3d246 |
return 1;
|
|
Packit Service |
d3d246 |
g_clear_error (&gerr);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_io_channel_set_buffer_size (gio_r, BUFFER_SIZE);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
status = g_io_channel_set_flags (gio_r, G_IO_FLAG_NONBLOCK, &gerr);
|
|
Packit Service |
d3d246 |
if (status == G_IO_STATUS_ERROR)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_warning ("%s", gerr->message);
|
|
Packit Service |
d3d246 |
g_clear_error (&gerr);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
buffer = g_string_sized_new (BUFFER_SIZE);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
while (TRUE)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
do
|
|
Packit Service |
d3d246 |
status = g_io_channel_read_line_string (gio_r, buffer, NULL, &gerr);
|
|
Packit Service |
d3d246 |
while (status == G_IO_STATUS_AGAIN);
|
|
Packit Service |
d3d246 |
if (status != G_IO_STATUS_NORMAL)
|
|
Packit Service |
d3d246 |
break;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
rlength += buffer->len;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
do
|
|
Packit Service |
d3d246 |
status = g_io_channel_write_chars (gio_w, buffer->str, buffer->len,
|
|
Packit Service |
d3d246 |
&length_out, &gerr);
|
|
Packit Service |
d3d246 |
while (status == G_IO_STATUS_AGAIN);
|
|
Packit Service |
d3d246 |
if (status != G_IO_STATUS_NORMAL)
|
|
Packit Service |
d3d246 |
break;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
wlength += length_out;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (length_out < buffer->len)
|
|
Packit Service |
d3d246 |
g_warning ("Only wrote part of the line.");
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#ifdef VERBOSE
|
|
Packit Service |
d3d246 |
g_print ("%s", buffer->str);
|
|
Packit Service |
d3d246 |
#endif
|
|
Packit Service |
d3d246 |
g_string_truncate (buffer, 0);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
switch (status)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
case G_IO_STATUS_EOF:
|
|
Packit Service |
d3d246 |
break;
|
|
Packit Service |
d3d246 |
case G_IO_STATUS_ERROR:
|
|
Packit Service |
d3d246 |
g_warning ("%s", gerr->message);
|
|
Packit Service |
d3d246 |
g_clear_error (&gerr);
|
|
Packit Service |
d3d246 |
break;
|
|
Packit Service |
d3d246 |
default:
|
|
Packit Service |
d3d246 |
g_warning ("Abnormal exit from write loop.");
|
|
Packit Service |
d3d246 |
break;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
do
|
|
Packit Service |
d3d246 |
status = g_io_channel_flush (gio_w, &gerr);
|
|
Packit Service |
d3d246 |
while (status == G_IO_STATUS_AGAIN);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (status == G_IO_STATUS_ERROR)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_warning ("%s", gerr->message);
|
|
Packit Service |
d3d246 |
g_clear_error (&gerr);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#ifdef VERBOSE
|
|
Packit Service |
d3d246 |
g_print ("read %d bytes, wrote %ld bytes\n", rlength, wlength);
|
|
Packit Service |
d3d246 |
#endif
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_io_channel_unref(gio_r);
|
|
Packit Service |
d3d246 |
g_io_channel_unref(gio_w);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
test_small_writes ();
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_free (filename);
|
|
Packit Service |
d3d246 |
g_string_free (buffer, TRUE);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return 0;
|
|
Packit Service |
d3d246 |
}
|