From 191c95c1c2e747fb3279a03326e7ca3d7c13df05 Mon Sep 17 00:00:00 2001 From: Benjamin Franzke Date: Fri, 10 Feb 2012 08:58:01 +0100 Subject: s/ctx/cm/g; s/struct cmumble_context/struct cmumlbe/g --- src/connection.c | 44 ++++++++++++++++++++++---------------------- 1 file changed, 22 insertions(+), 22 deletions(-) (limited to 'src/connection.c') diff --git a/src/connection.c b/src/connection.c index 73cd973..7fefdb3 100644 --- a/src/connection.c +++ b/src/connection.c @@ -8,11 +8,11 @@ static gboolean read_cb(GObject *pollable_stream, gpointer data) { GPollableInputStream *input = G_POLLABLE_INPUT_STREAM(pollable_stream); - struct cmumble_context *ctx = data; + struct cmumlbe *cm = data; gint count; do { - count = cmumble_recv_msg(ctx); + count = cmumble_recv_msg(cm); } while (count && g_pollable_input_stream_is_readable(input)); return TRUE; @@ -21,15 +21,15 @@ read_cb(GObject *pollable_stream, gpointer data) static void connection_ready(GObject *source_object, GAsyncResult *res, gpointer user_data) { - struct cmumble_context *ctx = user_data; - struct cmumble_connection *con = &ctx->con; + struct cmumlbe *cm = user_data; + struct cmumble_connection *con = &cm->con; GError *error = NULL; con->conn = g_socket_client_connect_to_host_finish (con->sock_client, res, &error); if (error) { g_printerr("connect failed: %s\n", error->message); - g_main_loop_quit(ctx->loop); + g_main_loop_quit(cm->loop); g_error_free(error); return; } @@ -41,23 +41,23 @@ connection_ready(GObject *source_object, GAsyncResult *res, gpointer user_data) if (!G_IS_POLLABLE_INPUT_STREAM(con->input) || !g_pollable_input_stream_can_poll(con->input)) { g_printerr("Error: GSocketConnection is not pollable\n"); - g_main_loop_quit(ctx->loop); + g_main_loop_quit(cm->loop); return; } con->source = g_pollable_input_stream_create_source(con->input, NULL); - g_source_set_callback(con->source, (GSourceFunc) read_cb, ctx, NULL); + g_source_set_callback(con->source, (GSourceFunc) read_cb, cm, NULL); g_source_attach(con->source, NULL); g_source_unref(con->source); - cmumble_protocol_init(ctx); + cmumble_protocol_init(cm); } int -cmumble_connection_init(struct cmumble_context *ctx, +cmumble_connection_init(struct cmumlbe *cm, const char *host, int port) { - struct cmumble_connection *con = &ctx->con; + struct cmumble_connection *con = &cm->con; con->sock_client = g_socket_client_new(); g_socket_client_set_tls(con->sock_client, TRUE); @@ -71,27 +71,27 @@ cmumble_connection_init(struct cmumble_context *ctx, g_socket_client_connect_to_host_async(con->sock_client, host, port, NULL, - connection_ready, ctx); + connection_ready, cm); return 0; } int -cmumble_connection_fini(struct cmumble_context *ctx) +cmumble_connection_fini(struct cmumlbe *cm) { - if (ctx->con.source) { - g_source_remove(g_source_get_id(ctx->con.source)); - g_source_unref(ctx->con.source); + if (cm->con.source) { + g_source_remove(g_source_get_id(cm->con.source)); + g_source_unref(cm->con.source); } - if (ctx->con.conn) { - g_object_unref(G_OBJECT(ctx->con.input)); - g_object_unref(G_OBJECT(ctx->con.output)); - g_io_stream_close(G_IO_STREAM(ctx->con.conn), NULL, NULL); - g_object_unref(G_OBJECT(ctx->con.conn)); + if (cm->con.conn) { + g_object_unref(G_OBJECT(cm->con.input)); + g_object_unref(G_OBJECT(cm->con.output)); + g_io_stream_close(G_IO_STREAM(cm->con.conn), NULL, NULL); + g_object_unref(G_OBJECT(cm->con.conn)); } - if (ctx->con.sock_client) - g_object_unref(G_OBJECT(ctx->con.sock_client)); + if (cm->con.sock_client) + g_object_unref(G_OBJECT(cm->con.sock_client)); return 0; } -- cgit