1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
#include "servers.h"
#include "conf.h"
#include <gio/gio.h>
GSList *servers = NULL;
gboolean server_sync(struct server *server) {
GError *error = NULL;
GSocketConnectable *addr;
GSocketAddressEnumerator *enumerator;
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);
g_object_unref(addr);
client = g_socket_client_new();
while(conn == NULL && (sockaddr = g_socket_address_enumerator_next(enumerator, NULL, &error))) {
conn = g_socket_client_connect(client, (GSocketConnectable*)sockaddr, NULL, &error);
g_object_unref(sockaddr);
}
if(conn == NULL) {
g_warning(error->message);
g_error_free(error);
return FALSE;
}
GSocket *socket = g_socket_connection_get_socket(conn);
g_debug("connected");
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);
}
g_timer_destroy(timer);
g_socket_close(socket, NULL);
return TRUE;
}
gboolean server_add(const gchar *host, const guint16 port) {
struct server *server = g_new0(struct server, 1);
if(server == NULL) {
g_warning("server_add: g_new0 returned NULL");
return FALSE;
}
server->host = g_strdup(host);
server->port = port;
servers = g_slist_prepend(servers, server);
return TRUE;
}
gboolean server_remove(struct server *server) {
gint pos = g_slist_index(servers, server);
if(pos == -1) {
return FALSE;
}
servers = g_slist_remove(servers, server);
return TRUE;
}
void servers_init() {
gsize length;
gchar **s = conf_get_string_list("audist", "servers", &length);
for(int i = 0; i < length; i++) {
server_add(s[i], 7681);
g_debug(" server %d: %s", i, s[i]);
}
}
void servers_free() {
for(GSList *node = servers; node; node = g_slist_next(node)) {
struct server *s = node->data;
g_free(s->host);
}
g_slist_free(servers);
servers = NULL;
}
|