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);
56 if ((l->sock = socket(info->ai_family, info->ai_socktype, info->ai_protocol)) < 0) {
57 dragonnet_perror("socket");
64 l->address = dragonnet_addr2str(info->ai_addr, info->ai_addrlen);
66 l->on_disconnect = NULL;
68 l->on_recv_type = calloc(sizeof *l->on_recv_type, dragonnet_num_types);
71 if (setsockopt(l->sock, SOL_SOCKET, SO_REUSEADDR, (void *) &so_reuseaddr,
72 sizeof so_reuseaddr) < 0) {
73 dragonnet_perror("setsockopt");
75 dragonnet_listener_delete(l);
79 if (bind(l->sock, info->ai_addr, info->ai_addrlen) < 0) {
80 dragonnet_perror("bind");
82 dragonnet_listener_delete(l);
88 if (listen(l->sock, 10) < 0) {
89 dragonnet_perror("listen");
90 dragonnet_listener_delete(l);
97 static void *listener_main(void *g_listener)
100 pthread_setname_np(pthread_self(), "listen");
103 DragonnetListener *l = (DragonnetListener *) g_listener;
106 struct sockaddr_storage clt_addr;
107 socklen_t clt_addrlen = sizeof clt_addr;
109 int clt_sock = accept(l->sock, (struct sockaddr *) &clt_addr, &clt_addrlen);
111 if (!dragonnet_isintrerr())
112 dragonnet_perror("accept");
116 char *clt_addstr = dragonnet_addr2str((struct sockaddr *) &clt_addr, clt_addrlen);
117 DragonnetPeer *p = dragonnet_peer_accept(clt_sock, clt_addstr, l);
121 void (*on_connect)(DragonnetPeer *) = l->on_connect;
123 if (on_connect != NULL)
126 dragonnet_peer_run(p);
132 void dragonnet_listener_run(DragonnetListener *l)
134 pthread_create(&l->accept_thread, NULL, &listener_main, l);
137 void dragonnet_listener_close(DragonnetListener *l)
141 pthread_kill(l->accept_thread, SIGINT);
142 pthread_join(l->accept_thread, NULL);
145 void dragonnet_listener_delete(DragonnetListener *l)
147 free(l->on_recv_type);