Browse Source

conn: add function to find the best source address

...and use it in POSIX sendto() function.
cc430
Oleg Hahm 7 years ago
parent
commit
b366e59c87
  1. 14
      sys/include/net/conn.h
  2. 8
      sys/net/gnrc/conn/gnrc_conn.c
  3. 14
      sys/posix/sockets/posix_sockets.c

14
sys/include/net/conn.h

@ -31,6 +31,7 @@
* @brief Application connection API definitions
*
* @author Martine Lenders <mlenders@inf.fu-berlin.de>
* @author Oliver Hahm <oliver.hahm@inria.fr>
*/
#ifndef NET_CONN_H_
#define NET_CONN_H_
@ -38,11 +39,24 @@
#include "net/conn/ip.h"
#include "net/conn/tcp.h"
#include "net/conn/udp.h"
#include "net/ipv6/addr.h"
#ifdef __cplusplus
extern "C" {
#endif
/**
* @brief Find the best matching source address for a given prefix
*
* @param[in] dst Pointer to the IPv6 address to find a match for
* Must not be NULL
*
* @return NULL if no matching address on any interface could be found
* @return pointer to an IPv6 address configured on an interface with the best
* match to @p dst
*/
ipv6_addr_t *conn_find_best_source(const ipv6_addr_t *dst);
#ifdef __cplusplus
}
#endif

8
sys/net/gnrc/conn/gnrc_conn.c

@ -11,6 +11,7 @@
*
* @file
* @author Martine Lenders <mlenders@inf.fu-berlin.de>
* @author Oliver Hahm <oliver.hahm@inria.fr>
*/
#include "net/conn.h"
@ -85,6 +86,13 @@ bool gnrc_conn6_set_local_addr(uint8_t *conn_addr, const ipv6_addr_t *addr)
}
return true;
}
ipv6_addr_t *conn_find_best_source(const ipv6_addr_t *dst)
{
ipv6_addr_t *local = NULL;
gnrc_ipv6_netif_find_by_prefix(&local, dst);
return local;
}
#endif
/** @} */

14
sys/posix/sockets/posix_sockets.c

@ -1,5 +1,6 @@
/*
* Copyright (C) 2015 Freie Universität Berlin
* Copyright (C) 2015 INRIA
*
* This file is subject to the terms and conditions of the GNU Lesser
* General Public License v2.1. See the file LICENSE in the top level
@ -11,6 +12,7 @@
* @file
* @brief Providing implementation for POSIX socket wrapper.
* @author Martine Lenders <mlenders@inf.fu-berlin.de>
* @author Oliver Hahm <oliver.hahm@inria.fr>
* @todo
*/
@ -862,11 +864,15 @@ ssize_t sendto(int socket, const void *buffer, size_t length, int flags,
sport, byteorder_ntohs(port));
}
else if (address != NULL) {
ipv6_addr_t local;
ipv6_addr_t unspec;
ipv6_addr_t *best_match;
s->src_port = (uint16_t)genrand_uint32_range(1LU << 10U, 1LU << 16U);
/* implicitly bind the socket here */
ipv6_addr_set_unspecified(&local);
if ((res = conn_udp_create(&s->conn.udp, &local, sizeof(local),
/* find the best matching source address */
if ((best_match = conn_find_best_source(addr)) == NULL) {
ipv6_addr_set_unspecified(&unspec);
best_match = &unspec;
}
if ((res = conn_udp_create(&s->conn.udp, best_match, sizeof(unspec),
s->domain, s->src_port)) < 0) {
errno = -res;
return -1;

Loading…
Cancel
Save