g_socket_set_blocking (data->current_socket, TRUE);
connection = g_socket_connection_factory_create_connection (data->current_socket);
+ g_object_unref (data->current_socket);
g_simple_async_result_set_op_res_gpointer (data->result,
connection,
g_object_unref);
g_simple_async_result_complete (data->result);
g_object_unref (data->result);
+ g_object_unref (data->enumerator);
+ g_slice_free (GSocketClientAsyncConnectData, data);
}
{
req->resolve_func (req, error);
g_mutex_unlock (req->mutex);
+
+ g_threaded_resolver_request_complete (req, FALSE);
+ g_threaded_resolver_request_unref (req);
return;
}
{
req->async_result = g_simple_async_result_new (G_OBJECT (gtr),
callback, user_data, tag);
- g_simple_async_result_set_op_res_gpointer (req->async_result, req, NULL);
+ g_simple_async_result_set_op_res_gpointer (req->async_result, req,
+ (GDestroyNotify)g_threaded_resolver_request_unref);
g_thread_pool_push (gtr->thread_pool, req, NULL);
g_mutex_unlock (req->mutex);
}
}
client = g_socket_client_new ();
- connection = g_socket_client_connect_to_host (client,
- argv[1],
- 7777,
- cancellable, &error);
+
+ if (async)
+ {
+ GAsyncResult *res;
+ g_socket_client_connect_to_host_async (client, argv[1], 7777,
+ cancellable, async_cb, &res);
+ g_main_loop_run (loop);
+ connection = g_socket_client_connect_to_host_finish (client, res, &error);
+ g_object_unref (res);
+ }
+ else
+ {
+ connection = g_socket_client_connect_to_host (client,
+ argv[1],
+ 7777,
+ cancellable, &error);
+ }
if (connection == NULL)
{
g_printerr ("%s can't connect: %s\n", argv[0], error->message);
return 1;
}
+ g_object_unref (client);
address = g_socket_connection_get_remote_address (connection, &error);
if (!address)
while (fgets(buffer, sizeof (buffer), stdin) != NULL)
{
+ /* FIXME if (async) */
if (!g_output_stream_write_all (out, buffer, strlen (buffer),
NULL, cancellable, &error))
{
}
}
+ g_object_unref (connection);
+
return 0;
}
g_object_unref (address);
}
g_object_unref (enumerator);
+ g_object_unref (connectable);
g_print ("Connected to %s\n",
socket_address_to_string (address));
}
g_object_unref (G_OBJECT (socket));
+ g_object_unref (G_OBJECT (address));
return 0;
}
g_printerr ("Can't bind socket: %s\n", error->message);
return 1;
}
+ g_object_unref (src_address);
if (!use_udp)
{