1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/ossrv/glib/tests/gio-test.c Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,555 @@
1.4 +/* GLIB - Library of useful routines for C programming
1.5 + * Copyright (C) 2000 Tor Lillqvist
1.6 + * Portion Copyright © 2008-09 Nokia Corporation and/or its subsidiary(-ies). All rights reserved.
1.7 + * This library is free software; you can redistribute it and/or
1.8 + * modify it under the terms of the GNU Lesser General Public
1.9 + * License as published by the Free Software Foundation; either
1.10 + * version 2 of the License, or (at your option) any later version.
1.11 + *
1.12 + * This library is distributed in the hope that it will be useful,
1.13 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
1.14 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
1.15 + * Lesser General Public License for more details.
1.16 + *
1.17 + * You should have received a copy of the GNU Lesser General Public
1.18 + * License along with this library; if not, write to the
1.19 + * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
1.20 + * Boston, MA 02111-1307, USA.
1.21 + */
1.22 +
1.23 +/* A test program for the main loop and IO channel code.
1.24 + * Just run it. Optional parameter is number of sub-processes.
1.25 + */
1.26 +
1.27 +#undef G_DISABLE_ASSERT
1.28 +#undef G_LOG_DOMAIN
1.29 +
1.30 +#include "config.h"
1.31 +
1.32 +#include <glib.h>
1.33 +
1.34 +#include <stdio.h>
1.35 +#include <stdlib.h>
1.36 +#include <math.h>
1.37 +#include <time.h>
1.38 +
1.39 +#ifdef __SYMBIAN32__
1.40 +// #define VERBOSE
1.41 + #include <pthread.h>
1.42 + #include "mrt2_glib2_test.h"
1.43 + void *child_function(void*);
1.44 + gboolean child_terminated = FALSE;
1.45 + int from_descriptor, to_descriptor;
1.46 +#endif /*__SYMBIAN32__*/
1.47 +#ifdef G_OS_WIN32
1.48 + #include <io.h>
1.49 + #include <fcntl.h>
1.50 + #include <process.h>
1.51 + #define STRICT
1.52 + #include <windows.h>
1.53 + #define pipe(fds) _pipe(fds, 4096, _O_BINARY)
1.54 +#else
1.55 + #ifdef HAVE_UNISTD_H
1.56 + #include <unistd.h>
1.57 + #endif
1.58 +#endif
1.59 +
1.60 +static int nrunning;
1.61 +static GMainLoop *main_loop;
1.62 +
1.63 +#define BUFSIZE 5000 /* Larger than the circular buffer in
1.64 + * giowin32.c on purpose.
1.65 + */
1.66 +
1.67 +static int nkiddies;
1.68 +
1.69 +static struct {
1.70 + int fd;
1.71 + int seq;
1.72 +} *seqtab;
1.73 +
1.74 +static GIOError
1.75 +read_all (int fd,
1.76 + GIOChannel *channel,
1.77 + char *buffer,
1.78 + guint nbytes,
1.79 + guint *bytes_read)
1.80 +{
1.81 + guint left = nbytes;
1.82 + gsize nb;
1.83 + GIOError error = G_IO_ERROR_NONE;
1.84 + char *bufp = buffer;
1.85 +#ifdef VERBOSE
1.86 + g_print ("gio-test: ...entering read_all()");
1.87 +#endif
1.88 +
1.89 + /* g_io_channel_read() doesn't necessarily return all the
1.90 + * data we want at once.
1.91 + */
1.92 + *bytes_read = 0;
1.93 + while (left)
1.94 + {
1.95 + error = g_io_channel_read (channel, bufp, left, &nb);
1.96 +
1.97 + if (error != G_IO_ERROR_NONE)
1.98 + {
1.99 + g_print ("gio-test: ...from %d: G_IO_ERROR_%s\n", fd,
1.100 + (error == G_IO_ERROR_AGAIN ? "AGAIN" :
1.101 + (error == G_IO_ERROR_INVAL ? "INVAL" :
1.102 + (error == G_IO_ERROR_UNKNOWN ? "UNKNOWN" : "???"))));
1.103 + if (error == G_IO_ERROR_AGAIN)
1.104 + continue;
1.105 + break;
1.106 + }
1.107 + if (nb == 0)
1.108 + return error;
1.109 + left -= nb;
1.110 + bufp += nb;
1.111 + *bytes_read += nb;
1.112 + }
1.113 + return error;
1.114 +}
1.115 +
1.116 +static void
1.117 +shutdown_source (gpointer data)
1.118 +{
1.119 +#ifdef VERBOSE
1.120 + g_print ("gio-test: ...entering shutdown_source()");
1.121 +#endif
1.122 +
1.123 + if (g_source_remove (*(guint *) data))
1.124 + {
1.125 + nrunning--;
1.126 + if (nrunning == 0)
1.127 + g_main_loop_quit (main_loop);
1.128 + }
1.129 +}
1.130 +
1.131 +static gboolean
1.132 +recv_message (GIOChannel *channel,
1.133 + GIOCondition cond,
1.134 + gpointer data)
1.135 +{
1.136 + gint fd = g_io_channel_unix_get_fd (channel);
1.137 + gboolean retval = TRUE;
1.138 +
1.139 +#ifdef VERBOSE
1.140 + g_print ("gio-test: ...entering recv_message()");
1.141 + g_print ("gio-test: ...from %d:%s%s%s%s\n", fd,
1.142 + (cond & G_IO_ERR) ? " ERR" : "",
1.143 + (cond & G_IO_HUP) ? " HUP" : "",
1.144 + (cond & G_IO_IN) ? " IN" : "",
1.145 + (cond & G_IO_PRI) ? " PRI" : "");
1.146 +#endif
1.147 +
1.148 + if (cond & (G_IO_ERR | G_IO_HUP))
1.149 + {
1.150 + shutdown_source (data);
1.151 + retval = FALSE;
1.152 + }
1.153 +
1.154 + if (cond & G_IO_IN)
1.155 + {
1.156 + char buf[BUFSIZE];
1.157 + guint nbytes;
1.158 + guint nb;
1.159 + int i, j, seq;
1.160 + GIOError error;
1.161 +
1.162 + error = read_all (fd, channel, (gchar *) &seq, sizeof (seq), &nb);
1.163 + if (error == G_IO_ERROR_NONE)
1.164 + {
1.165 + if (nb == 0)
1.166 + {
1.167 +#ifdef VERBOSE
1.168 + g_print ("gio-test: ...from %d: EOF\n", fd);
1.169 +#endif
1.170 + shutdown_source (data);
1.171 + return FALSE;
1.172 + }
1.173 +
1.174 + g_assert (nb == sizeof (nbytes));
1.175 +
1.176 + for (i = 0; i < nkiddies; i++)
1.177 + if (seqtab[i].fd == fd)
1.178 + {
1.179 + if (seq != seqtab[i].seq)
1.180 + {
1.181 + g_print ("gio-test: ...from %d: invalid sequence number %d, expected %d\n",
1.182 + fd, seq, seqtab[i].seq);
1.183 + g_assert_not_reached ();
1.184 +
1.185 + g_assert(FALSE && "gio-test failed");
1.186 + }
1.187 + seqtab[i].seq++;
1.188 + break;
1.189 + }
1.190 +
1.191 + error = read_all (fd, channel, (gchar *) &nbytes, sizeof (nbytes), &nb);
1.192 + }
1.193 +
1.194 + if (error != G_IO_ERROR_NONE)
1.195 + return FALSE;
1.196 +
1.197 + if (nb == 0)
1.198 + {
1.199 +#ifdef VERBOSE
1.200 + g_print ("gio-test: ...from %d: EOF\n", fd);
1.201 +#endif
1.202 + shutdown_source (data);
1.203 + return FALSE;
1.204 + }
1.205 +
1.206 + g_assert (nb == sizeof (nbytes));
1.207 +
1.208 + if (nbytes >= BUFSIZE)
1.209 + {
1.210 + g_print ("gio-test: ...from %d: nbytes = %d (%#x)!\n", fd, nbytes, nbytes);
1.211 + g_assert_not_reached ();
1.212 + g_assert(FALSE && "gio-test failed");
1.213 + }
1.214 + g_assert (nbytes >= 0 && nbytes < BUFSIZE);
1.215 +#ifdef VERBOSE
1.216 + g_print ("gio-test: ...from %d: %d bytes\n", fd, nbytes);
1.217 +#endif
1.218 + if (nbytes > 0)
1.219 + {
1.220 + error = read_all (fd, channel, buf, nbytes, &nb);
1.221 + if(child_terminated)
1.222 + shutdown_source (data);
1.223 +
1.224 +
1.225 + if (error != G_IO_ERROR_NONE)
1.226 + return FALSE;
1.227 +
1.228 + if (nb == 0)
1.229 + {
1.230 +#ifdef VERBOSE
1.231 + g_print ("gio-test: ...from %d: EOF\n", fd);
1.232 +#endif
1.233 + shutdown_source (data);
1.234 + return FALSE;
1.235 + }
1.236 +
1.237 + for (j = 0; j < nbytes; j++)
1.238 + if (buf[j] != ' ' + ((nbytes + j) % 95))
1.239 + {
1.240 + g_print ("gio-test: ...from %d: buf[%d] == '%c', should be '%c'\n",
1.241 + fd, j, buf[j], 'a' + ((nbytes + j) % 32));
1.242 + g_assert_not_reached ();
1.243 + g_assert(FALSE && "gio-test failed");
1.244 + }
1.245 +#ifdef VERBOSE
1.246 + g_print ("gio-test: ...from %d: OK\n", fd);
1.247 +#endif
1.248 + }
1.249 + }
1.250 + return retval;
1.251 +}
1.252 +
1.253 +#ifdef G_OS_WIN32
1.254 +
1.255 +static gboolean
1.256 +recv_windows_message (GIOChannel *channel,
1.257 + GIOCondition cond,
1.258 + gpointer data)
1.259 +{
1.260 + GIOError error;
1.261 + MSG msg;
1.262 + guint nb;
1.263 +
1.264 + while (1)
1.265 + {
1.266 + error = g_io_channel_read (channel, &msg, sizeof (MSG), &nb);
1.267 +
1.268 + if (error != G_IO_ERROR_NONE)
1.269 + {
1.270 + g_print ("gio-test: ...reading Windows message: G_IO_ERROR_%s\n",
1.271 + (error == G_IO_ERROR_AGAIN ? "AGAIN" :
1.272 + (error == G_IO_ERROR_INVAL ? "INVAL" :
1.273 + (error == G_IO_ERROR_UNKNOWN ? "UNKNOWN" : "???"))));
1.274 + if (error == G_IO_ERROR_AGAIN)
1.275 + continue;
1.276 + }
1.277 + break;
1.278 + }
1.279 +
1.280 + g_print ("gio-test: ...Windows message for %#x: %d,%d,%d\n",
1.281 + msg.hwnd, msg.message, msg.wParam, msg.lParam);
1.282 +
1.283 + return TRUE;
1.284 +}
1.285 +
1.286 +LRESULT CALLBACK
1.287 +window_procedure (HWND hwnd,
1.288 + UINT message,
1.289 + WPARAM wparam,
1.290 + LPARAM lparam)
1.291 +{
1.292 + g_print ("gio-test: window_procedure for %#x: %d,%d,%d\n",
1.293 + hwnd, message, wparam, lparam);
1.294 + return DefWindowProc (hwnd, message, wparam, lparam);
1.295 +}
1.296 +
1.297 +#endif
1.298 +
1.299 +int
1.300 +main (int argc,
1.301 + char **argv)
1.302 +{
1.303 +
1.304 + #ifdef __SYMBIAN32__
1.305 + /*GLIB_INIT();*/
1.306 + pthread_t thread_child;
1.307 + int rc,t;
1.308 + 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);
1.309 + g_set_print_handler(mrtPrintHandler);
1.310 + #endif /*__SYMBIAN32__*/
1.311 +
1.312 + #ifdef VERBOSE
1.313 +printf("started tests\n");
1.314 +#endif
1.315 + if (argc < 3)
1.316 + {
1.317 + /* Parent */
1.318 +
1.319 + GIOChannel *my_read_channel;
1.320 + gchar *cmdline;
1.321 + guint *id;
1.322 + int i;
1.323 +#ifdef G_OS_WIN32
1.324 + GTimeVal start, end;
1.325 + GPollFD pollfd;
1.326 + int pollresult;
1.327 + ATOM klass;
1.328 + static WNDCLASS wcl;
1.329 + HWND hwnd;
1.330 + GIOChannel *windows_messages_channel;
1.331 +#endif
1.332 +
1.333 + nkiddies = (argc == 1 ? 1 : atoi(argv[1]));
1.334 + seqtab = g_malloc (nkiddies * 2 * sizeof (int));
1.335 +
1.336 +#ifdef G_OS_WIN32
1.337 + wcl.style = 0;
1.338 + wcl.lpfnWndProc = window_procedure;
1.339 + wcl.cbClsExtra = 0;
1.340 + wcl.cbWndExtra = 0;
1.341 + wcl.hInstance = GetModuleHandle (NULL);
1.342 + wcl.hIcon = NULL;
1.343 + wcl.hCursor = NULL;
1.344 + wcl.hbrBackground = NULL;
1.345 + wcl.lpszMenuName = NULL;
1.346 + wcl.lpszClassName = "gio-test";
1.347 +
1.348 + klass = RegisterClass (&wcl);
1.349 +
1.350 + if (!klass)
1.351 + {
1.352 + g_print ("gio-test: RegisterClass failed\n");
1.353 + exit (1);
1.354 + }
1.355 +
1.356 + hwnd = CreateWindow (MAKEINTATOM(klass), "gio-test", 0, 0, 0, 10, 10,
1.357 + NULL, NULL, wcl.hInstance, NULL);
1.358 + if (!hwnd)
1.359 + {
1.360 + g_print ("gio-test: CreateWindow failed\n");
1.361 + exit (1);
1.362 + }
1.363 +
1.364 + windows_messages_channel = g_io_channel_win32_new_messages ((guint)hwnd);
1.365 + g_io_add_watch (windows_messages_channel, G_IO_IN, recv_windows_message, 0);
1.366 +#endif
1.367 +
1.368 + for (i = 0; i < nkiddies; i++)
1.369 + {
1.370 + int pipe_to_sub[2], pipe_from_sub[2];
1.371 +
1.372 + if (pipe (pipe_to_sub) == -1 ||
1.373 + pipe (pipe_from_sub) == -1)
1.374 + perror ("pipe"), exit (1);
1.375 +
1.376 + seqtab[i].fd = pipe_from_sub[0];
1.377 + seqtab[i].seq = 0;
1.378 +
1.379 + my_read_channel = g_io_channel_unix_new (pipe_from_sub[0]);
1.380 +
1.381 + id = g_new (guint, 1);
1.382 + *id =
1.383 + g_io_add_watch (my_read_channel,
1.384 + G_IO_IN | G_IO_PRI | G_IO_ERR | G_IO_HUP,
1.385 + recv_message,
1.386 + id);
1.387 +
1.388 + nrunning++;
1.389 +
1.390 +#ifdef G_OS_WIN32
1.391 + cmdline = g_strdup_printf ("%d:%d:%d",
1.392 + pipe_to_sub[0],
1.393 + pipe_from_sub[1],
1.394 + hwnd);
1.395 + _spawnl (_P_NOWAIT, argv[0], argv[0], "--child", cmdline, NULL);
1.396 +#else
1.397 + cmdline = g_strdup_printf ("%s --child %d:%d &", argv[0],
1.398 + pipe_to_sub[0], pipe_from_sub[1]);
1.399 +
1.400 +#ifndef __SYMBIAN32__
1.401 + system (cmdline);
1.402 +#else
1.403 + from_descriptor = pipe_to_sub[0];
1.404 + to_descriptor = pipe_from_sub[1];
1.405 + rc = pthread_create(&thread_child,NULL,child_function,NULL);
1.406 +
1.407 +
1.408 + if(rc)
1.409 + {
1.410 + g_print("Failed to create thread.\n");
1.411 + exit(1);
1.412 + }
1.413 +#endif /*__SYMBIAN32__*/
1.414 +
1.415 +#endif
1.416 +
1.417 +#ifndef __SYMBIAN32__
1.418 + close (pipe_to_sub[0]);
1.419 + close (pipe_from_sub [1]);
1.420 +#endif
1.421 +
1.422 +#ifdef G_OS_WIN32
1.423 + g_get_current_time (&start);
1.424 + g_io_channel_win32_make_pollfd (my_read_channel, G_IO_IN, &pollfd);
1.425 + pollresult = g_io_channel_win32_poll (&pollfd, 1, 100);
1.426 + g_get_current_time (&end);
1.427 + if (end.tv_usec < start.tv_usec)
1.428 + end.tv_sec--, end.tv_usec += 1000000;
1.429 + g_print ("gio-test: had to wait %ld.%03ld s, result:%d\n",
1.430 + end.tv_sec - start.tv_sec,
1.431 + (end.tv_usec - start.tv_usec) / 1000,
1.432 + pollresult);
1.433 +#endif
1.434 + }
1.435 +
1.436 + main_loop = g_main_loop_new (NULL, FALSE);
1.437 +
1.438 + g_main_loop_run (main_loop);
1.439 + }
1.440 + else if (argc == 3)
1.441 + {
1.442 + /* Child */
1.443 +
1.444 + int readfd, writefd;
1.445 +#ifdef G_OS_WIN32
1.446 + HWND hwnd;
1.447 +#endif
1.448 + int i, j;
1.449 + char buf[BUFSIZE];
1.450 + int buflen;
1.451 + GTimeVal tv;
1.452 + int n;
1.453 +
1.454 + g_get_current_time (&tv);
1.455 +
1.456 + sscanf (argv[2], "%d:%d%n", &readfd, &writefd, &n);
1.457 +
1.458 +#ifdef G_OS_WIN32
1.459 + sscanf (argv[2] + n, ":%d", &hwnd);
1.460 +#endif
1.461 +
1.462 + srand (tv.tv_sec ^ (tv.tv_usec / 1000) ^ readfd ^ (writefd << 4));
1.463 +
1.464 + for (i = 0; i < 20 + rand() % 20; i++)
1.465 + {
1.466 + g_usleep (100 + (rand() % 10) * 5000);
1.467 + buflen = rand() % BUFSIZE;
1.468 + for (j = 0; j < buflen; j++)
1.469 + buf[j] = ' ' + ((buflen + j) % 95);
1.470 +#ifdef VERBOSE
1.471 + g_print ("gio-test: child writing %d+%d bytes to %d\n",
1.472 + (int)(sizeof(i) + sizeof(buflen)), buflen, writefd);
1.473 +#endif
1.474 + write (writefd, &i, sizeof (i));
1.475 + write (writefd, &buflen, sizeof (buflen));
1.476 + write (writefd, buf, buflen);
1.477 +
1.478 +#ifdef G_OS_WIN32
1.479 + if (rand() % 100 < 5)
1.480 + {
1.481 + int msg = WM_USER + (rand() % 100);
1.482 + WPARAM wparam = rand ();
1.483 + LPARAM lparam = rand ();
1.484 + g_print ("gio-test: child posting message %d,%d,%d to %#x\n",
1.485 + msg, wparam, lparam, hwnd);
1.486 + PostMessage (hwnd, msg, wparam, lparam);
1.487 + }
1.488 +#endif
1.489 + }
1.490 +#ifdef VERBOSE
1.491 + g_print ("gio-test: child exiting, closing %d\n", writefd);
1.492 +#endif
1.493 + close (writefd);
1.494 + }
1.495 + else
1.496 + g_print ("Huh?\n");
1.497 +
1.498 +
1.499 +#ifdef __SYMBIAN32__
1.500 + close(from_descriptor);
1.501 + close(to_descriptor);
1.502 +#endif
1.503 +
1.504 + #if __SYMBIAN32__
1.505 + testResultXml("gio-test");
1.506 + #endif /* EMULATOR */
1.507 +
1.508 +#ifdef VERBOSE
1.509 +printf("Completed tests\n");
1.510 +#endif
1.511 +
1.512 + return 0;
1.513 +}
1.514 +
1.515 +#ifdef __SYMBIAN32__
1.516 +void *child_function(void* t)
1.517 +{
1.518 + int readfd, writefd;
1.519 +
1.520 + int i, j;
1.521 + char buf[BUFSIZE];
1.522 + int buflen;
1.523 + GTimeVal tv;
1.524 + int n;
1.525 +#ifdef VERBOSE
1.526 + g_print ("gio-test: ...entering child_function()");
1.527 +#endif
1.528 + g_get_current_time (&tv);
1.529 +
1.530 +
1.531 + readfd=from_descriptor;
1.532 + writefd=to_descriptor;
1.533 +
1.534 + srand (tv.tv_sec ^ (tv.tv_usec / 1000) ^ readfd ^ (writefd << 4));
1.535 +
1.536 + for (i = 0; i < 5; i++)
1.537 + {
1.538 + if(i==4)
1.539 + child_terminated = TRUE;
1.540 + g_usleep (100 + (rand() % 10) * 5000);
1.541 + buflen = rand() % BUFSIZE;
1.542 + for (j = 0; j < buflen; j++)
1.543 + buf[j] = ' ' + ((buflen + j) % 95);
1.544 +#ifdef VERBOSE
1.545 + g_print ("gio-test: child writing %d+%d bytes to %d\n",
1.546 + (int)(sizeof(i) + sizeof(buflen)), buflen, writefd);
1.547 +#endif
1.548 + write (writefd, &i, sizeof (i));
1.549 + write (writefd, &buflen, sizeof (buflen));
1.550 + write (writefd, buf, buflen);
1.551 + }
1.552 +#ifdef VERBOSE
1.553 + g_print ("gio-test: child exiting, closing %d\n", writefd);
1.554 +#endif
1.555 + close (writefd);
1.556 +
1.557 +}
1.558 +#endif