Branch data Line data Source code
1 : : /* #included into both socket-testclient.c and socket-testserver.c */
2 : :
3 : : #ifdef G_OS_UNIX
4 : : static const char *unix_socket_address_types[] = {
5 : : "invalid",
6 : : "anonymous",
7 : : "path",
8 : : "abstract",
9 : : "padded"
10 : : };
11 : : #endif
12 : :
13 : : static char *
14 : 0 : socket_address_to_string (GSocketAddress *address)
15 : : {
16 : 0 : char *res = NULL;
17 : :
18 [ # # # # : 0 : if (G_IS_INET_SOCKET_ADDRESS (address))
# # # # ]
19 : : {
20 : : GInetAddress *inet_address;
21 : : char *str;
22 : : int port;
23 : :
24 : 0 : inet_address = g_inet_socket_address_get_address (G_INET_SOCKET_ADDRESS (address));
25 : 0 : str = g_inet_address_to_string (inet_address);
26 : 0 : port = g_inet_socket_address_get_port (G_INET_SOCKET_ADDRESS (address));
27 : 0 : res = g_strdup_printf ("%s:%d", str, port);
28 : 0 : g_free (str);
29 : : }
30 : : #ifdef G_OS_UNIX
31 [ # # # # : 0 : else if (G_IS_UNIX_SOCKET_ADDRESS (address))
# # # # ]
32 : : {
33 : 0 : GUnixSocketAddress *uaddr = G_UNIX_SOCKET_ADDRESS (address);
34 : :
35 : 0 : res = g_strdup_printf ("%s:%s",
36 : 0 : unix_socket_address_types[g_unix_socket_address_get_address_type (uaddr)],
37 : : g_unix_socket_address_get_path (uaddr));
38 : : }
39 : : #endif
40 : :
41 : 0 : return res;
42 : : }
43 : :
44 : : static GSocketAddress *
45 : 0 : socket_address_from_string (const char *name)
46 : : {
47 : : #ifdef G_OS_UNIX
48 : : gsize i, len;
49 : :
50 [ # # ]: 0 : for (i = 0; i < G_N_ELEMENTS (unix_socket_address_types); i++)
51 : : {
52 : 0 : len = strlen (unix_socket_address_types[i]);
53 [ # # ]: 0 : if (!strncmp (name, unix_socket_address_types[i], len) &&
54 [ # # ]: 0 : name[len] == ':')
55 : : {
56 : 0 : return g_unix_socket_address_new_with_type (name + len + 1, -1,
57 : : (GUnixSocketAddressType)i);
58 : : }
59 : : }
60 : : #endif
61 : 0 : return NULL;
62 : : }
63 : :
64 : : static gboolean
65 : 0 : source_ready (GPollableInputStream *stream,
66 : : gpointer data)
67 : : {
68 : 0 : g_main_loop_quit (loop);
69 : 0 : return FALSE;
70 : : }
71 : :
72 : : static void
73 : 0 : ensure_socket_condition (GSocket *socket,
74 : : GIOCondition condition,
75 : : GCancellable *cancellable)
76 : : {
77 : : GSource *source;
78 : :
79 [ # # ]: 0 : if (!non_blocking)
80 : 0 : return;
81 : :
82 : 0 : source = g_socket_create_source (socket, condition, cancellable);
83 : 0 : g_source_set_callback (source,
84 : : (GSourceFunc) source_ready,
85 : : NULL, NULL);
86 : 0 : g_source_attach (source, NULL);
87 : 0 : g_source_unref (source);
88 : 0 : g_main_loop_run (loop);
89 : : }
90 : :
91 : : static void
92 : 0 : ensure_connection_condition (GIOStream *stream,
93 : : GIOCondition condition,
94 : : GCancellable *cancellable)
95 : : {
96 : : GSource *source;
97 : :
98 [ # # ]: 0 : if (!non_blocking)
99 : 0 : return;
100 : :
101 [ # # ]: 0 : if (condition & G_IO_IN)
102 : 0 : source = g_pollable_input_stream_create_source (G_POLLABLE_INPUT_STREAM (g_io_stream_get_input_stream (stream)), cancellable);
103 : : else
104 : 0 : source = g_pollable_output_stream_create_source (G_POLLABLE_OUTPUT_STREAM (g_io_stream_get_output_stream (stream)), cancellable);
105 : :
106 : 0 : g_source_set_callback (source,
107 : : (GSourceFunc) source_ready,
108 : : NULL, NULL);
109 : 0 : g_source_attach (source, NULL);
110 : 0 : g_source_unref (source);
111 : 0 : g_main_loop_run (loop);
112 : : }
113 : :
114 : : static gpointer
115 : 0 : cancel_thread (gpointer data)
116 : : {
117 : 0 : GCancellable *cancellable = data;
118 : :
119 : 0 : g_usleep (1000*1000*cancel_timeout);
120 : 0 : g_print ("Cancelling\n");
121 : 0 : g_cancellable_cancel (cancellable);
122 : 0 : return NULL;
123 : : }
|
