RIOT-OS/RIOT
RIOT-OS/RIOT
1
0
Fork 0
mirror of https://github.com/RIOT-OS/RIOT.git synced 2024-12-29 04:50:03 +01:00
Code Releases Activity

tools/zep_dispatch: preliminary dual-stack support

Browse Source
This commit is contained in:
Benjamin Valentin 2021-12-08 22:17:40 +01:00 committed by Benjamin Valentin
parent b96f94bfb8
commit a2ff71cfcb
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dist/tools/zep_dispatch/main.c vendored
View File

@ -51,7 +51,7 @@ static void _send_flat(void *ctx, void *buffer, size_t len,
/* remove client if sending fails */ /* remove client if sending fails */
} }
else if (sendto(sock, buffer, len, 0, (struct sockaddr *)addr, sizeof(*addr)) < 0) { else if (sendto(sock, buffer, len, 0, (struct sockaddr *)addr, sizeof(*addr)) < 0) {
inet_ntop(AF_INET6, &addr->sin6_addr, addr_str, INET6_ADDRSTRLEN); inet_ntop(src_addr->sin6_family, &addr->sin6_addr, addr_str, INET6_ADDRSTRLEN);
printf("removing [%s]:%d\n", addr_str, ntohs(addr->sin6_port)); printf("removing [%s]:%d\n", addr_str, ntohs(addr->sin6_port));
prev->next = n->next; prev->next = n->next;
free(n); free(n);
@ -63,7 +63,7 @@ static void _send_flat(void *ctx, void *buffer, size_t len,
/* if the client new, add it to the broadcast list */ /* if the client new, add it to the broadcast list */
if (!known_node) { if (!known_node) {
inet_ntop(AF_INET6, &src_addr->sin6_addr, addr_str, INET6_ADDRSTRLEN); inet_ntop(src_addr->sin6_family, &src_addr->sin6_addr, addr_str, INET6_ADDRSTRLEN);
printf("adding [%s]:%d\n", addr_str, ntohs(src_addr->sin6_port)); printf("adding [%s]:%d\n", addr_str, ntohs(src_addr->sin6_port));
zep_client_t *client = malloc(sizeof(zep_client_t)); zep_client_t *client = malloc(sizeof(zep_client_t));
memcpy(&client->addr, src_addr, sizeof(*src_addr)); memcpy(&client->addr, src_addr, sizeof(*src_addr));
@ -101,7 +101,7 @@ static void dispatch_loop(int sock, dispatch_cb_t dispatch, void *ctx)
ssize_t bytes_in = recvfrom(sock, buffer, sizeof(buffer), 0, ssize_t bytes_in = recvfrom(sock, buffer, sizeof(buffer), 0,
(struct sockaddr *)&src_addr, &addr_len); (struct sockaddr *)&src_addr, &addr_len);
if (bytes_in <= 0 || addr_len != sizeof(src_addr)) { if (bytes_in <= 0) {
continue; continue;
} }
@ -190,7 +190,7 @@ int main(int argc, char **argv)
} }
struct addrinfo hint = { struct addrinfo hint = {
.ai_family = AF_INET6, .ai_family = AF_UNSPEC,
.ai_socktype = SOCK_DGRAM, .ai_socktype = SOCK_DGRAM,
.ai_protocol = IPPROTO_UDP, .ai_protocol = IPPROTO_UDP,
.ai_flags = AI_NUMERICHOST, .ai_flags = AI_NUMERICHOST,