|
Packit Service |
d3d246 |
#undef G_DISABLE_ASSERT
|
|
Packit Service |
d3d246 |
#undef G_LOG_DOMAIN
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#include <errno.h>
|
|
Packit Service |
d3d246 |
#include <stdlib.h>
|
|
Packit Service |
d3d246 |
#include <unistd.h>
|
|
Packit Service |
d3d246 |
#include <stdio.h>
|
|
Packit Service |
d3d246 |
#include <sys/time.h>
|
|
Packit Service |
d3d246 |
#include <sys/resource.h>
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#include <glib.h>
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static int n_children = 3;
|
|
Packit Service |
d3d246 |
static int n_active_children;
|
|
Packit Service |
d3d246 |
static int n_iters = 10000;
|
|
Packit Service |
d3d246 |
static GMainLoop *loop;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static void
|
|
Packit Service |
d3d246 |
io_pipe (GIOChannel **channels)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
int fds[2];
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (pipe(fds) < 0)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
int errsv = errno;
|
|
Packit Service |
d3d246 |
fprintf (stderr, "Cannot create pipe %s\n", g_strerror (errsv));
|
|
Packit Service |
d3d246 |
exit (1);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
channels[0] = g_io_channel_unix_new (fds[0]);
|
|
Packit Service |
d3d246 |
channels[1] = g_io_channel_unix_new (fds[1]);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static gboolean
|
|
Packit Service |
d3d246 |
read_all (GIOChannel *channel, char *buf, int len)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
gsize bytes_read = 0;
|
|
Packit Service |
d3d246 |
gsize count;
|
|
Packit Service |
d3d246 |
GIOError err;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
while (bytes_read < len)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
err = g_io_channel_read (channel, buf + bytes_read, len - bytes_read, &count);
|
|
Packit Service |
d3d246 |
if (err)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
if (err != G_IO_ERROR_AGAIN)
|
|
Packit Service |
d3d246 |
return FALSE;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
else if (count == 0)
|
|
Packit Service |
d3d246 |
return FALSE;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
bytes_read += count;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return TRUE;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static gboolean
|
|
Packit Service |
d3d246 |
write_all (GIOChannel *channel, char *buf, int len)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
gsize bytes_written = 0;
|
|
Packit Service |
d3d246 |
gsize count;
|
|
Packit Service |
d3d246 |
GIOError err;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
while (bytes_written < len)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
err = g_io_channel_write (channel, buf + bytes_written, len - bytes_written, &count);
|
|
Packit Service |
d3d246 |
if (err && err != G_IO_ERROR_AGAIN)
|
|
Packit Service |
d3d246 |
return FALSE;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
bytes_written += count;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return TRUE;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static void
|
|
Packit Service |
d3d246 |
run_child (GIOChannel *in_channel, GIOChannel *out_channel)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
int i;
|
|
Packit Service |
d3d246 |
int val = 1;
|
|
Packit Service |
d3d246 |
GTimer *timer = g_timer_new();
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
for (i = 0; i < n_iters; i++)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
write_all (out_channel, (char *)&val, sizeof (val));
|
|
Packit Service |
d3d246 |
read_all (in_channel, (char *)&val, sizeof (val));
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
val = 0;
|
|
Packit Service |
d3d246 |
write_all (out_channel, (char *)&val, sizeof (val));
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
val = g_timer_elapsed (timer, NULL) * 1000;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
write_all (out_channel, (char *)&val, sizeof (val));
|
|
Packit Service |
d3d246 |
g_timer_destroy (timer);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
exit (0);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static gboolean
|
|
Packit Service |
d3d246 |
input_callback (GIOChannel *source,
|
|
Packit Service |
d3d246 |
GIOCondition condition,
|
|
Packit Service |
d3d246 |
gpointer data)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
int val;
|
|
Packit Service |
d3d246 |
GIOChannel *dest = (GIOChannel *)data;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (!read_all (source, (char *)&val, sizeof(val)))
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
fprintf (stderr, "Unexpected EOF\n");
|
|
Packit Service |
d3d246 |
exit (1);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (val)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
write_all (dest, (char *)&val, sizeof(val));
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return TRUE;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
else
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_io_channel_close (source);
|
|
Packit Service |
d3d246 |
g_io_channel_close (dest);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_io_channel_unref (source);
|
|
Packit Service |
d3d246 |
g_io_channel_unref (dest);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
n_active_children--;
|
|
Packit Service |
d3d246 |
if (n_active_children == 0)
|
|
Packit Service |
d3d246 |
g_main_loop_quit (loop);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return FALSE;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static void
|
|
Packit Service |
d3d246 |
create_child (void)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
int pid, errsv;
|
|
Packit Service |
d3d246 |
GIOChannel *in_channels[2];
|
|
Packit Service |
d3d246 |
GIOChannel *out_channels[2];
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
io_pipe (in_channels);
|
|
Packit Service |
d3d246 |
io_pipe (out_channels);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
pid = fork ();
|
|
Packit Service |
d3d246 |
errsv = errno;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (pid > 0) /* Parent */
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_io_channel_close (in_channels[0]);
|
|
Packit Service |
d3d246 |
g_io_channel_unref (in_channels[0]);
|
|
Packit Service |
d3d246 |
g_io_channel_close (out_channels[1]);
|
|
Packit Service |
d3d246 |
g_io_channel_unref (out_channels[1]);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_io_add_watch (out_channels[0], G_IO_IN | G_IO_HUP,
|
|
Packit Service |
d3d246 |
input_callback, in_channels[1]);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
else if (pid == 0) /* Child */
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_io_channel_close (in_channels[1]);
|
|
Packit Service |
d3d246 |
g_io_channel_close (out_channels[0]);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
setsid ();
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
run_child (in_channels[0], out_channels[1]);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
else /* Error */
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
fprintf (stderr, "Cannot fork: %s\n", g_strerror (errsv));
|
|
Packit Service |
d3d246 |
exit (1);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static double
|
|
Packit Service |
d3d246 |
difftimeval (struct timeval *old, struct timeval *new)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
return
|
|
Packit Service |
d3d246 |
(new->tv_sec - old->tv_sec) * 1000. + (new->tv_usec - old->tv_usec) / 1000;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
int
|
|
Packit Service |
d3d246 |
main (int argc, char **argv)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
int i;
|
|
Packit Service |
d3d246 |
struct rusage old_usage;
|
|
Packit Service |
d3d246 |
struct rusage new_usage;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (argc > 1)
|
|
Packit Service |
d3d246 |
n_children = atoi(argv[1]);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (argc > 2)
|
|
Packit Service |
d3d246 |
n_iters = atoi(argv[2]);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
printf ("Children: %d Iters: %d\n", n_children, n_iters);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
n_active_children = n_children;
|
|
Packit Service |
d3d246 |
for (i = 0; i < n_children; i++)
|
|
Packit Service |
d3d246 |
create_child ();
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
getrusage (RUSAGE_SELF, &old_usage);
|
|
Packit Service |
d3d246 |
loop = g_main_loop_new (NULL, FALSE);
|
|
Packit Service |
d3d246 |
g_main_loop_run (loop);
|
|
Packit Service |
d3d246 |
getrusage (RUSAGE_SELF, &new_usage);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
printf ("Elapsed user: %g\n",
|
|
Packit Service |
d3d246 |
difftimeval (&old_usage.ru_utime, &new_usage.ru_utime));
|
|
Packit Service |
d3d246 |
printf ("Elapsed system: %g\n",
|
|
Packit Service |
d3d246 |
difftimeval (&old_usage.ru_stime, &new_usage.ru_stime));
|
|
Packit Service |
d3d246 |
printf ("Elapsed total: %g\n",
|
|
Packit Service |
d3d246 |
difftimeval (&old_usage.ru_utime, &new_usage.ru_utime) +
|
|
Packit Service |
d3d246 |
difftimeval (&old_usage.ru_stime, &new_usage.ru_stime));
|
|
Packit Service |
d3d246 |
printf ("total / iteration: %g\n",
|
|
Packit Service |
d3d246 |
(difftimeval (&old_usage.ru_utime, &new_usage.ru_utime) +
|
|
Packit Service |
d3d246 |
difftimeval (&old_usage.ru_stime, &new_usage.ru_stime)) /
|
|
Packit Service |
d3d246 |
(n_iters * n_children));
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_main_loop_unref (loop);
|
|
Packit Service |
d3d246 |
return 0;
|
|
Packit Service |
d3d246 |
}
|