16 static bool dragonnet_peer_init_accepted(DragonnetPeer *p, int sock,
17 char *addr, DragonnetListener *l)
19 pthread_mutex_init(&p->mtx, NULL);
23 p->on_disconnect = l->on_disconnect;
24 p->on_recv = l->on_recv;
25 p->on_recv_type = l->on_recv_type;
30 static DragonnetPeer *dragonnet_peer_accept(int sock, char *addr,
33 DragonnetPeer *p = malloc(sizeof *p);
34 if (!dragonnet_peer_init_accepted(p, sock, addr, l)) {
35 pthread_mutex_destroy(&p->mtx);
48 DragonnetListener *dragonnet_listener_new(char *addr)
50 struct addrinfo *info = dragonnet_str2addr(addr);
54 DragonnetListener *l = malloc(sizeof *l);
57 l->sock = socket(info->ai_family, info->ai_socktype, info->ai_protocol);
58 l->address = dragonnet_addr2str(info->ai_addr, info->ai_addrlen);
60 l->on_disconnect = NULL;
62 l->on_recv_type = calloc(sizeof *l->on_recv_type, dragonnet_num_types);
65 if (setsockopt(l->sock, SOL_SOCKET, SO_REUSEADDR, (void *) &so_reuseaddr,
66 sizeof so_reuseaddr) < 0) {
69 dragonnet_listener_delete(l);
73 if (bind(l->sock, info->ai_addr, info->ai_addrlen) < 0) {
76 dragonnet_listener_delete(l);
82 if (listen(l->sock, 10) < 0) {
84 dragonnet_listener_delete(l);
91 static void *listener_main(void *g_listener)
94 pthread_setname_np(pthread_self(), "listen");
97 DragonnetListener *l = (DragonnetListener *) g_listener;
100 struct sockaddr_storage clt_addr;
101 socklen_t clt_addrlen = sizeof clt_addr;
103 int clt_sock = accept(l->sock, (struct sockaddr *) &clt_addr, &clt_addrlen);
110 char *clt_addstr = dragonnet_addr2str((struct sockaddr *) &clt_addr, clt_addrlen);
111 DragonnetPeer *p = dragonnet_peer_accept(clt_sock, clt_addstr, l);
115 void (*on_connect)(DragonnetPeer *) = l->on_connect;
117 if (on_connect != NULL)
120 dragonnet_peer_run(p);
126 void dragonnet_listener_run(DragonnetListener *l)
128 pthread_create(&l->accept_thread, NULL, &listener_main, l);
131 void dragonnet_listener_close(DragonnetListener *l)
135 pthread_kill(l->accept_thread, SIGINT);
136 pthread_join(l->accept_thread, NULL);
139 void dragonnet_listener_delete(DragonnetListener *l)
141 free(l->on_recv_type);