blob: cbf490f1a55e38828c93acd052ebe0cfe3e82975 (
plain)
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
|
static void
client_free (Client *client)
{
delete (peer);
close (client->fd);
main_context_free (client->context);
connection_destroy (client->connection);
g_free (client);
}
static void
on_connection_event (connection)
{
Client *client = lac_connection_get_data (client);
switch (event)
{
case READ:
read_the_stuff();
process_it();
break;
case ERROR:
connection_close();
break;
case CLOSED:
client_free ();
break;
}
process_stuff ();
connection_write_stuff ();
}
static void
on_connection (LacListener *listener, int fd, LacAddress *peer, gpointer data)
{
Server *server = lac_listener_get_data (listener);
Client *client = g_new (Client, 1);
client->peer = peer;
client->fd = fd;
client->context = context_new (server->executor, server->poll, client);
client->connection = connection_new (fd, on_connection_event);
}
Server *
server_new (int port)
{
server->poll = epll_new();
server->executor = executor_new ();
server->port = port;
create_listener (port, on_connection, server);
return server;
}
|