Reworked server_sync() and renamed to server_ping().

This function now returns TRUE when the server is reachable and responds.

1 files changed, 9 insertions, 8 deletions

diff --git a/server_communication.c b/server_communication.c
index f2f5946..ee854d3 100644
--- a/server_communication.c
+++ b/server_communication.c
@@ -1,6 +1,7 @@
 #include "server_communication.h"
 
 #include <gio/gio.h>
+#include <string.h>
 
 static GSocket *server_connect(struct server *server) {
 	GError *error = NULL, *conn_error = NULL;
@@ -9,7 +10,6 @@ static GSocket *server_connect(struct server *server) {
 	GSocketAddress *sockaddr;
 	GSocketConnection *conn = NULL;
 	GSocketClient *client;
-	GTimer *timer = g_timer_new();
 
 	addr = g_network_address_new(server->host, server->port);
 	enumerator = g_socket_connectable_enumerate(addr);
@@ -46,26 +46,27 @@ static GSocket *server_connect(struct server *server) {
 	return socket;
 }
 
-gboolean server_sync(struct server *server) {
+gboolean server_ping(struct server *server) {
+	GTimer *timer = g_timer_new();
 	GSocket *socket = server_connect(server);
 
 	if(socket == NULL) {
 		return FALSE;
 	}
 
+	gboolean result = FALSE;
 	g_socket_send(socket, "ping\n", 5, NULL, NULL);
 	gchar buffer[0x400];
-	g_socket_receive(socket, buffer, 0x400, NULL, NULL);
-	if(buffer[4] == '\n') {
-		buffer[4] = '\0';
-		g_debug("got response: %s", buffer);
-		g_debug("time: %f ms", g_timer_elapsed(timer, NULL) * 1000);
+	gssize size = g_socket_receive(socket, buffer, 0x400, NULL, NULL);
+	if(size == 5 && strncmp(buffer, "pong", 4) == 0) {
+		g_debug("ping response: %f ms", g_timer_elapsed(timer, NULL) * 1000);
+		result = TRUE;
 	}
 
 	g_timer_destroy(timer);
 
 	g_socket_close(socket, NULL);
 
-	return TRUE;
+	return result;
 }