#include <gtk/gtk.h>
-#include "x11/gdkx.h"
-#include <unistd.h>
+#include <string.h>
#include <stdlib.h>
#include <stdio.h>
+int n_children = 0;
+
+GSList *sockets = NULL;
+
GtkWidget *window;
GtkWidget *vbox;
-GtkWidget *lastsocket = NULL;
+
+typedef struct
+{
+ GtkWidget *box;
+ GtkWidget *frame;
+ GtkWidget *socket;
+} Socket;
+
+extern guint32 create_child_plug (guint32 xid,
+ gboolean local);
static void
quit_cb (gpointer callback_data,
{ "/File/_Quit", "<control>Q", quit_cb, 0 },
};
+static void
+socket_destroyed (GtkWidget *widget,
+ Socket *socket)
+{
+ sockets = g_slist_remove (sockets, socket);
+ g_free (socket);
+}
+
+static void
+plug_added (GtkWidget *widget,
+ Socket *socket)
+{
+ g_print ("Plug added to socket\n");
+
+ gtk_widget_show (socket->socket);
+ gtk_widget_hide (socket->frame);
+}
+
+static gboolean
+plug_removed (GtkWidget *widget,
+ Socket *socket)
+{
+ g_print ("Plug removed from socket\n");
+
+ gtk_widget_hide (socket->socket);
+ gtk_widget_show (socket->frame);
+
+ return TRUE;
+}
+
+static Socket *
+create_socket (void)
+{
+ GtkWidget *label;
+
+ Socket *socket = g_new (Socket, 1);
+
+ socket->box = gtk_vbox_new (FALSE, 0);
+
+ socket->socket = gtk_socket_new ();
+
+ gtk_box_pack_start (GTK_BOX (socket->box), socket->socket, TRUE, TRUE, 0);
+
+ socket->frame = gtk_frame_new (NULL);
+ gtk_frame_set_shadow_type (GTK_FRAME (socket->frame), GTK_SHADOW_IN);
+ gtk_box_pack_start (GTK_BOX (socket->box), socket->frame, TRUE, TRUE, 0);
+ gtk_widget_show (socket->frame);
+
+ label = gtk_label_new (NULL);
+ gtk_label_set_markup (GTK_LABEL (label), "<span color=\"red\">Empty</span>");
+ gtk_container_add (GTK_CONTAINER (socket->frame), label);
+ gtk_widget_show (label);
+
+ sockets = g_slist_prepend (sockets, socket);
+
+
+ g_signal_connect (G_OBJECT (socket->socket), "destroy",
+ G_CALLBACK (socket_destroyed), socket);
+ g_signal_connect (G_OBJECT (socket->socket), "plug_added",
+ G_CALLBACK (plug_added), socket);
+ g_signal_connect (G_OBJECT (socket->socket), "plug_removed",
+ G_CALLBACK (plug_removed), socket);
+
+ return socket;
+}
+
void
steal (GtkWidget *window, GtkEntry *entry)
{
guint32 xid;
const gchar *text;
- GtkWidget *socket;
+ Socket *socket;
text = gtk_entry_get_text (entry);
return;
}
- socket = gtk_socket_new ();
- gtk_box_pack_start (GTK_BOX (vbox), socket, TRUE, TRUE, 0);
- gtk_widget_show (socket);
+ socket = create_socket ();
+ gtk_box_pack_start (GTK_BOX (vbox), socket->box, TRUE, TRUE, 0);
+ gtk_widget_show (socket->box);
- gtk_socket_steal (GTK_SOCKET (socket), xid);
+ gtk_socket_steal (GTK_SOCKET (socket->socket), xid);
}
void
remove_child (GtkWidget *window)
{
- if(lastsocket)
- gtk_widget_destroy (lastsocket);
- lastsocket = NULL;
+ if (sockets)
+ {
+ Socket *socket = sockets->data;
+ gtk_widget_destroy (socket->box);
+ }
+}
+
+static gboolean
+child_read_watch (GIOChannel *channel, GIOCondition cond, gpointer data)
+{
+ GIOStatus status;
+ GError *error = NULL;
+ char *line;
+ gsize term;
+ int xid;
+
+ status = g_io_channel_read_line (channel, &line, NULL, &term, &error);
+ switch (status)
+ {
+ case G_IO_STATUS_NORMAL:
+ line[term] = '\0';
+ xid = strtol (line, NULL, 0);
+ if (xid == 0)
+ {
+ fprintf (stderr, "Invalid window id '%s'\n", line);
+ }
+ else
+ {
+ Socket *socket = create_socket ();
+ gtk_box_pack_start (GTK_BOX (vbox), socket->box, TRUE, TRUE, 0);
+ gtk_widget_show (socket->box);
+
+ gtk_socket_add_id (GTK_SOCKET (socket->socket), xid);
+ }
+ g_free (line);
+ return TRUE;
+ case G_IO_STATUS_AGAIN:
+ return TRUE;
+ case G_IO_STATUS_EOF:
+ n_children--;
+ g_io_channel_close (channel);
+ return FALSE;
+ case G_IO_STATUS_ERROR:
+ fprintf (stderr, "Error reading fd from child: %s\n", error->message);
+ exit (1);
+ return FALSE;
+ default:
+ g_assert_not_reached ();
+ return FALSE;
+ }
+
}
void
-add_child (GtkWidget *window)
+add_child (GtkWidget *window,
+ gboolean active)
{
- GtkWidget *socket;
+ Socket *socket;
char *argv[3] = { "./testsocket_child", NULL, NULL };
char buffer[20];
+ int out_fd;
+ GIOChannel *channel;
GError *error = NULL;
- socket = gtk_socket_new ();
- gtk_box_pack_start (GTK_BOX (vbox), socket, TRUE, TRUE, 0);
- gtk_widget_show (socket);
-
- lastsocket = socket;
-
- sprintf(buffer, "%#lx", GDK_WINDOW_XWINDOW (socket->window));
- argv[1] = buffer;
+ if (active)
+ {
+ socket = create_socket ();
+ gtk_box_pack_start (GTK_BOX (vbox), socket->box, TRUE, TRUE, 0);
+ gtk_widget_show (socket->box);
+ sprintf(buffer, "%#lx", (gulong) gtk_socket_get_id (GTK_SOCKET (socket->socket)));
+ argv[1] = buffer;
+ }
-#if 1
- if (!g_spawn_async (NULL, argv, NULL, 0, NULL, NULL, NULL, &error))
+ if (!g_spawn_async_with_pipes (NULL, argv, NULL, 0, NULL, NULL, NULL, NULL, &out_fd, NULL, &error))
{
fprintf (stderr, "Can't exec testsocket_child: %s\n", error->message);
exit (1);
}
-#else
- fprintf(stderr,"%s\n", buffer);
-#endif
+
+ n_children++;
+ channel = g_io_channel_unix_new (out_fd);
+ g_io_channel_set_flags (channel, G_IO_FLAG_NONBLOCK, &error);
+ if (error)
+ {
+ fprintf (stderr, "Error making channel non-blocking: %s\n", error->message);
+ exit (1);
+ }
+
+ g_io_add_watch (channel, G_IO_IN | G_IO_HUP, child_read_watch, NULL);
+}
+
+void
+add_active_child (GtkWidget *window)
+{
+ add_child (window, TRUE);
+}
+
+void
+add_passive_child (GtkWidget *window)
+{
+ add_child (window, FALSE);
+}
+
+void
+add_local_child (GtkWidget *window)
+{
+ Socket *socket;
+
+ socket = create_socket ();
+ gtk_box_pack_start (GTK_BOX (vbox), socket->box, TRUE, TRUE, 0);
+ gtk_widget_show (socket->box);
+
+ create_child_plug (gtk_socket_get_id (GTK_SOCKET (socket->socket)), TRUE);
}
int
gtk_item_factory_get_widget (item_factory, "<main>"),
FALSE, FALSE, 0);
- button = gtk_button_new_with_label ("Add Child");
+ button = gtk_button_new_with_label ("Add Active Child");
gtk_box_pack_start (GTK_BOX(vbox), button, FALSE, FALSE, 0);
gtk_signal_connect_object (GTK_OBJECT(button), "clicked",
- GTK_SIGNAL_FUNC(add_child),
+ GTK_SIGNAL_FUNC(add_active_child),
+ GTK_OBJECT(vbox));
+
+ button = gtk_button_new_with_label ("Add Passive Child");
+ gtk_box_pack_start (GTK_BOX(vbox), button, FALSE, FALSE, 0);
+
+ gtk_signal_connect_object (GTK_OBJECT(button), "clicked",
+ GTK_SIGNAL_FUNC(add_passive_child),
+ GTK_OBJECT(vbox));
+
+ button = gtk_button_new_with_label ("Add Local Child");
+ gtk_box_pack_start (GTK_BOX(vbox), button, FALSE, FALSE, 0);
+
+ gtk_signal_connect_object (GTK_OBJECT(button), "clicked",
+ GTK_SIGNAL_FUNC(add_local_child),
GTK_OBJECT(vbox));
button = gtk_button_new_with_label ("Remove Last Child");
gtk_main ();
- return 0;
-}
+ if (n_children)
+ {
+ g_print ("Waiting for children to exit\n");
+ while (n_children)
+ g_main_iteration (TRUE);
+ }
+ return 0;
+}
projects / ~andy / gtk / blobdiff