1 /* GLIB - Library of useful routines for C programming
2 * Copyright (C) 2000 Tor Lillqvist
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Lesser General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Lesser General Public License for more details.
14 * You should have received a copy of the GNU Lesser General Public
15 * License along with this library; if not, write to the
16 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
17 * Boston, MA 02111-1307, USA.
20 /* A test program for the main loop and IO channel code.
21 * Just run it. Optional parameter is number of sub-processes.
24 #undef G_DISABLE_ASSERT
49 static GMainLoop *main_loop;
51 #define BUFSIZE 5000 /* Larger than the circular buffer in
52 * giowin32.c on purpose.
71 GIOError error = G_IO_ERROR_NONE;
74 /* g_io_channel_read() doesn't necessarily return all the
75 * data we want at once.
80 error = g_io_channel_read (channel, bufp, left, &nb);
82 if (error != G_IO_ERROR_NONE)
84 g_print ("gio-test: ...from %d: G_IO_ERROR_%s\n", fd,
85 (error == G_IO_ERROR_AGAIN ? "AGAIN" :
86 (error == G_IO_ERROR_INVAL ? "INVAL" :
87 (error == G_IO_ERROR_UNKNOWN ? "UNKNOWN" : "???"))));
88 if (error == G_IO_ERROR_AGAIN)
102 shutdown_source (gpointer data)
104 if (g_source_remove (*(guint *) data))
108 g_main_loop_quit (main_loop);
113 recv_message (GIOChannel *channel,
117 gint fd = g_io_channel_unix_get_fd (channel);
118 gboolean retval = TRUE;
121 g_print ("gio-test: ...from %d:%s%s%s%s\n", fd,
122 (cond & G_IO_ERR) ? " ERR" : "",
123 (cond & G_IO_HUP) ? " HUP" : "",
124 (cond & G_IO_IN) ? " IN" : "",
125 (cond & G_IO_PRI) ? " PRI" : "");
128 if (cond & (G_IO_ERR | G_IO_HUP))
130 shutdown_source (data);
142 error = read_all (fd, channel, (gchar *) &seq, sizeof (seq), &nb);
143 if (error == G_IO_ERROR_NONE)
148 g_print ("gio-test: ...from %d: EOF\n", fd);
150 shutdown_source (data);
154 g_assert (nb == sizeof (nbytes));
156 for (i = 0; i < nkiddies; i++)
157 if (seqtab[i].fd == fd)
159 if (seq != seqtab[i].seq)
161 g_print ("gio-test: ...from %d: invalid sequence number %d, expected %d\n",
162 fd, seq, seqtab[i].seq);
163 g_assert_not_reached ();
169 error = read_all (fd, channel, (gchar *) &nbytes, sizeof (nbytes), &nb);
172 if (error != G_IO_ERROR_NONE)
178 g_print ("gio-test: ...from %d: EOF\n", fd);
180 shutdown_source (data);
184 g_assert (nb == sizeof (nbytes));
186 if (nbytes >= BUFSIZE)
188 g_print ("gio-test: ...from %d: nbytes = %d (%#x)!\n", fd, nbytes, nbytes);
189 g_assert_not_reached ();
191 g_assert (nbytes >= 0 && nbytes < BUFSIZE);
193 g_print ("gio-test: ...from %d: %d bytes\n", fd, nbytes);
197 error = read_all (fd, channel, buf, nbytes, &nb);
199 if (error != G_IO_ERROR_NONE)
205 g_print ("gio-test: ...from %d: EOF\n", fd);
207 shutdown_source (data);
211 for (j = 0; j < nbytes; j++)
212 if (buf[j] != ' ' + ((nbytes + j) % 95))
214 g_print ("gio-test: ...from %d: buf[%d] == '%c', should be '%c'\n",
215 fd, j, buf[j], 'a' + ((nbytes + j) % 32));
216 g_assert_not_reached ();
219 g_print ("gio-test: ...from %d: OK\n", fd);
229 recv_windows_message (GIOChannel *channel,
239 error = g_io_channel_read (channel, &msg, sizeof (MSG), &nb);
241 if (error != G_IO_ERROR_NONE)
243 g_print ("gio-test: ...reading Windows message: G_IO_ERROR_%s\n",
244 (error == G_IO_ERROR_AGAIN ? "AGAIN" :
245 (error == G_IO_ERROR_INVAL ? "INVAL" :
246 (error == G_IO_ERROR_UNKNOWN ? "UNKNOWN" : "???"))));
247 if (error == G_IO_ERROR_AGAIN)
253 g_print ("gio-test: ...Windows message for %#x: %d,%d,%d\n",
254 msg.hwnd, msg.message, msg.wParam, msg.lParam);
260 window_procedure (HWND hwnd,
265 g_print ("gio-test: window_procedure for %#x: %d,%d,%d\n",
266 hwnd, message, wparam, lparam);
267 return DefWindowProc (hwnd, message, wparam, lparam);
280 GIOChannel *my_read_channel;
291 GIOChannel *windows_messages_channel;
294 nkiddies = (argc == 1 ? 1 : atoi(argv[1]));
295 seqtab = g_malloc (nkiddies * 2 * sizeof (int));
299 wcl.lpfnWndProc = window_procedure;
302 wcl.hInstance = GetModuleHandle (NULL);
305 wcl.hbrBackground = NULL;
306 wcl.lpszMenuName = NULL;
307 wcl.lpszClassName = "gio-test";
309 klass = RegisterClass (&wcl);
313 g_print ("gio-test: RegisterClass failed\n");
317 hwnd = CreateWindow (MAKEINTATOM(klass), "gio-test", 0, 0, 0, 10, 10,
318 NULL, NULL, wcl.hInstance, NULL);
321 g_print ("gio-test: CreateWindow failed\n");
325 windows_messages_channel = g_io_channel_win32_new_messages ((guint)hwnd);
326 g_io_add_watch (windows_messages_channel, G_IO_IN, recv_windows_message, 0);
329 for (i = 0; i < nkiddies; i++)
331 int pipe_to_sub[2], pipe_from_sub[2];
333 if (pipe (pipe_to_sub) == -1 ||
334 pipe (pipe_from_sub) == -1)
335 perror ("pipe"), exit (1);
337 seqtab[i].fd = pipe_from_sub[0];
340 my_read_channel = g_io_channel_unix_new (pipe_from_sub[0]);
342 id = g_new (guint, 1);
344 g_io_add_watch (my_read_channel,
345 G_IO_IN | G_IO_PRI | G_IO_ERR | G_IO_HUP,
352 cmdline = g_strdup_printf ("%d:%d:%d",
356 _spawnl (_P_NOWAIT, argv[0], argv[0], "--child", cmdline, NULL);
358 cmdline = g_strdup_printf ("%s --child %d:%d &", argv[0],
359 pipe_to_sub[0], pipe_from_sub[1]);
363 close (pipe_to_sub[0]);
364 close (pipe_from_sub [1]);
367 g_get_current_time (&start);
368 g_io_channel_win32_make_pollfd (my_read_channel, G_IO_IN, &pollfd);
369 pollresult = g_io_channel_win32_poll (&pollfd, 1, 100);
370 g_get_current_time (&end);
371 if (end.tv_usec < start.tv_usec)
372 end.tv_sec--, end.tv_usec += 1000000;
373 g_print ("gio-test: had to wait %ld.%03ld s, result:%d\n",
374 end.tv_sec - start.tv_sec,
375 (end.tv_usec - start.tv_usec) / 1000,
380 main_loop = g_main_loop_new (NULL, FALSE);
382 g_main_loop_run (main_loop);
398 g_get_current_time (&tv);
400 sscanf (argv[2], "%d:%d%n", &readfd, &writefd, &n);
403 sscanf (argv[2] + n, ":%d", &hwnd);
406 srand (tv.tv_sec ^ (tv.tv_usec / 1000) ^ readfd ^ (writefd << 4));
408 for (i = 0; i < 20 + rand() % 20; i++)
410 g_usleep (100 + (rand() % 10) * 5000);
411 buflen = rand() % BUFSIZE;
412 for (j = 0; j < buflen; j++)
413 buf[j] = ' ' + ((buflen + j) % 95);
415 g_print ("gio-test: child writing %d+%d bytes to %d\n",
416 (int)(sizeof(i) + sizeof(buflen)), buflen, writefd);
418 write (writefd, &i, sizeof (i));
419 write (writefd, &buflen, sizeof (buflen));
420 write (writefd, buf, buflen);
423 if (rand() % 100 < 5)
425 int msg = WM_USER + (rand() % 100);
426 WPARAM wparam = rand ();
427 LPARAM lparam = rand ();
428 g_print ("gio-test: child posting message %d,%d,%d to %#x\n",
429 msg, wparam, lparam, hwnd);
430 PostMessage (hwnd, msg, wparam, lparam);
435 g_print ("gio-test: child exiting, closing %d\n", writefd);