6 #include "deps/dragonnet/listen.h"
7 #include "dnet-types.h"
9 static DragonnetListener *l;
11 static void connect_func(DragonnetPeer *p)
13 char *str_addr = dragonnet_addr_str(p->raddr);
14 printf("new connection from %s\n", str_addr);
18 static void handle_pingpacket(DragonnetPeer *p, PingPacket *ping)
20 printf("PingPacket number: 0x%08x\n", ping->number);
22 dragonnet_peer_send_PongPacket(p, &(PongPacket) {
23 .number = ping->number
26 dragonnet_listener_close(l);
27 dragonnet_listener_delete(l);
30 dragonnet_peer_close(p);
31 dragonnet_peer_delete(p);
34 static void handle_pongpacket(DragonnetPeer *p, PongPacket *pong)
36 printf("PongPacket number: 0x%08x\n", pong->number);
38 dragonnet_peer_close(p);
39 dragonnet_peer_delete(p);
42 static void *srv_func(__attribute((unused)) void *unused)
44 l = dragonnet_listener_new("[::1]:50000", &connect_func);
47 dragonnet_listener_set_recv_hook(l, DRAGONNET_TYPE_PINGPACKET,
48 (void (*)(DragonnetPeer *, void *)) &handle_pingpacket);
49 dragonnet_listener_run(l);
53 static void *clt_func(__attribute((unused)) void *unused)
57 DragonnetPeer *p = dragonnet_connect("[::1]:50000");
60 dragonnet_peer_set_recv_hook(p, DRAGONNET_TYPE_PONGPACKET,
61 (void (*)(DragonnetPeer *, void *)) &handle_pongpacket);
62 dragonnet_peer_run(p);
64 dragonnet_peer_send_PingPacket(p, &(PingPacket) {
71 int main(__attribute((unused)) int argc, __attribute((unused)) char **argv)
73 pthread_t srv_thread, clt_thread;
74 pthread_create(&srv_thread, NULL, &srv_func, NULL);
75 pthread_create(&clt_thread, NULL, &clt_func, NULL);
77 pthread_join(clt_thread, NULL);
78 pthread_join(srv_thread, NULL);