#include #include #ifdef HAVE_CONFIG_H #include "config.h" #endif struct { char *file; int line; } debug_context_loc = {NULL, 0}; gboolean game_source_callback(gpointer user_data) { return TRUE; } gboolean accept_incoming(GSocketService *service, GSocketConnection *connection, GObject source_object, gpointer user_data) { g_printf("New connection!\n"); return TRUE; } gboolean rl_sec_elapsed(gpointer user_data) { g_printf("RL sec elapsed.\n"); return TRUE; } #ifdef DEBUG void debug_context(char *file, int line) { if (debug_context_loc.file != NULL) g_free(debug_context_loc.file); debug_context_loc.file = g_strdup(file); debug_context_loc.line = line; } #define DebugContext debug_context(__FILE__, __LINE__) #else #define DebugContext #endif int main(int argc, char **argv) { GMainContext *game_context; GMainLoop *game_loop; GSource *timeout_source, *game_net_source4 = NULL, *game_net_source6 = NULL; guint timeout_id; GError *err = NULL; GSocket *game_socket6, *game_socket4; gboolean need_ipv4_socket = TRUE; GSocketService *game_service; g_type_init(); g_printf("Starting up...\n"); game_context = g_main_context_new(); game_loop = g_main_loop_new(game_context, FALSE); timeout_source = g_timeout_source_new(1000); g_source_set_callback(timeout_source, rl_sec_elapsed, NULL, NULL); timeout_id = g_source_attach(timeout_source, game_context); g_source_unref(timeout_source); game_service = g_threaded_socket_service_new(-1); /* The following snippet is borrowed from GLib 2.30's gsocketlistener.c * code, to create the necessary sockets to listen on both IPv4 and * IPv6 address */ if ((game_socket6 = g_socket_new(G_SOCKET_FAMILY_IPV6, G_SOCKET_TYPE_STREAM, G_SOCKET_PROTOCOL_DEFAULT, &err)) != NULL) { GInetAddress *inet_address; GSocketAddress *address; gboolean result; inet_address = g_inet_address_new_any(G_SOCKET_FAMILY_IPV6); address = g_inet_socket_address_new(inet_address, 4000); g_object_unref(inet_address); g_socket_set_listen_backlog(game_socket6, 10); result = g_socket_bind(game_socket6, address, TRUE, &err) && g_socket_listen(game_socket6, &err); g_object_unref(address); if (!result) { g_object_unref(game_socket6); g_printf("Unable to create listener IPv6 socket!\n"); return 1; } if (g_socket_speaks_ipv4(game_socket6)) need_ipv4_socket = FALSE; game_net_source6 = g_socket_create_source(game_socket6, G_IO_IN, NULL); g_socket_listener_add_socket(G_SOCKET_LISTENER(game_service), game_socket6, NULL, &err); } if (need_ipv4_socket) { if ((game_socket4 = g_socket_new(G_SOCKET_FAMILY_IPV4, G_SOCKET_TYPE_STREAM, G_SOCKET_PROTOCOL_DEFAULT, &err)) != NULL) { GInetAddress *inet_address; GSocketAddress *address; gboolean result; inet_address = g_inet_address_new_any(G_SOCKET_FAMILY_IPV4); address = g_inet_socket_address_new(inet_address, 4000); g_object_unref(inet_address); g_socket_set_listen_backlog(game_socket4, 10); result = g_socket_bind(game_socket4, address, TRUE, &err) && g_socket_listen(game_socket4, &err); g_object_unref(address); if (!result) { g_object_unref(game_socket4); if (!game_socket6) g_object_unref(game_socket6); g_printf("Unable to create listener IPv4 socket!\n"); return 1; } game_net_source4 = g_socket_create_source(game_socket4, G_IO_IN, NULL); g_socket_listener_add_socket(G_SOCKET_LISTENER(game_service), game_socket4, NULL, &err); } } else { if (game_socket6 != NULL) g_clear_error(&err); else return 1; } if (game_net_source6) { g_source_set_callback(game_net_source6, game_source_callback, NULL, NULL); g_source_attach(game_net_source6, game_context); } if (game_net_source4) { g_source_set_callback(game_net_source4, game_source_callback, NULL, NULL); g_source_attach(game_net_source4, game_context); } g_socket_service_start(game_service); g_signal_connect(G_OBJECT(game_service), "incoming", G_CALLBACK(accept_incoming), NULL); g_printf("Startup finished\n"); g_main_loop_run(game_loop); return 0; }