Changes in uspace/srv/net/inetsrv/addrobj.c [a1a101d:feeac0d] in mainline

File:

• uspace/srv/net/inetsrv/addrobj.c (modified) (6 diffs)

uspace/srv/net/inetsrv/addrobj.c

@@ -42 +42 @@
 #include <stdlib.h>
 #include <str.h>
-
+#include <net/socket_codes.h>
 #include "addrobj.h"
 #include "inetsrv.h"
 #include "inet_link.h"
-#include "inet_util.h"
+#include "ndp.h"
 
 static inet_addrobj_t *inet_addrobj_find_by_name_locked(const char *, inet_link_t *);
@@ -106 +106 @@
 /** Find address object matching address @a addr.
  *
- * @param addr  Address
- * @oaram find  iaf_net to find network (using mask),
- *              iaf_addr to find local address (exact match)
+ * @param addr Address
+ * @oaram find iaf_net to find network (using mask),
+ *             iaf_addr to find local address (exact match)
+ *
  */
 inet_addrobj_t *inet_addrobj_find(inet_addr_t *addr, inet_addrobj_find_t find)
 {
-        uint32_t mask;
-
-        log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_addrobj_find(%x)", (unsigned)addr->ipv4);
-
-        fibril_mutex_lock(&addr_list_lock);
-
-        list_foreach(addr_list, link) {
-                inet_addrobj_t *naddr = list_get_instance(link,
-                    inet_addrobj_t, addr_list);
-
-                mask = inet_netmask(naddr->naddr.bits);
-                if ((naddr->naddr.ipv4 & mask) == (addr->ipv4 & mask)) {
-                        fibril_mutex_unlock(&addr_list_lock);
-                        log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_addrobj_find: found %p",
-                            naddr);
-                        return naddr;
+        fibril_mutex_lock(&addr_list_lock);
+        
+        list_foreach(addr_list, addr_list, inet_addrobj_t, naddr) {
+                switch (find) {
+                case iaf_net:
+                        if (inet_naddr_compare_mask(&naddr->naddr, addr)) {
+                                fibril_mutex_unlock(&addr_list_lock);
+                                log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_addrobj_find: found %p",
+                                    naddr);
+                                return naddr;
+                        }
+                        break;
+                case iaf_addr:
+                        if (inet_naddr_compare(&naddr->naddr, addr)) {
+                                fibril_mutex_unlock(&addr_list_lock);
+                                log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_addrobj_find: found %p",
+                                    naddr);
+                                return naddr;
+                        }
+                        break;
                 }
         }
-
+        
         log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_addrobj_find: Not found");
         fibril_mutex_unlock(&addr_list_lock);
-
+        
         return NULL;
 }
@@ -150 +155 @@
             name, ilink->svc_name);
 
-        list_foreach(addr_list, link) {
-                inet_addrobj_t *naddr = list_get_instance(link,
-                    inet_addrobj_t, addr_list);
-
+        list_foreach(addr_list, addr_list, inet_addrobj_t, naddr) {
                 if (naddr->ilink == ilink && str_cmp(naddr->name, name) == 0) {
                         log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_addrobj_find_by_name_locked: found %p",
@@ -198 +200 @@
         fibril_mutex_lock(&addr_list_lock);
 
-        list_foreach(addr_list, link) {
-                inet_addrobj_t *naddr = list_get_instance(link,
-                    inet_addrobj_t, addr_list);
-
+        list_foreach(addr_list, addr_list, inet_addrobj_t, naddr) {
                 if (naddr->id == id) {
                         fibril_mutex_unlock(&addr_list_lock);
@@ -218 +217 @@
 {
         inet_addr_t lsrc_addr;
-        inet_addr_t *ldest_addr;
-
-        lsrc_addr.ipv4 = addr->naddr.ipv4;
-        ldest_addr = &dgram->dest;
-
-        return inet_link_send_dgram(addr->ilink, &lsrc_addr, ldest_addr, dgram,
-            proto, ttl, df);
+        inet_naddr_addr(&addr->naddr, &lsrc_addr);
+        
+        addr32_t lsrc_v4;
+        addr128_t lsrc_v6;
+        uint16_t lsrc_af = inet_addr_get(&lsrc_addr, &lsrc_v4, &lsrc_v6);
+        
+        addr32_t ldest_v4;
+        addr128_t ldest_v6;
+        uint16_t ldest_af = inet_addr_get(ldest, &ldest_v4, &ldest_v6);
+        
+        if (lsrc_af != ldest_af)
+                return EINVAL;
+        
+        int rc;
+        addr48_t ldest_mac;
+        
+        switch (ldest_af) {
+        case AF_INET:
+                return inet_link_send_dgram(addr->ilink, lsrc_v4, ldest_v4,
+                    dgram, proto, ttl, df);
+        case AF_INET6:
+                /*
+                 * Translate local destination IPv6 address.
+                 */
+                rc = ndp_translate(lsrc_v6, ldest_v6, ldest_mac, addr->ilink);
+                if (rc != EOK)
+                        return rc;
+                
+                return inet_link_send_dgram6(addr->ilink, ldest_mac, dgram,
+                    proto, ttl, df);
+        }
+        
+        return ENOTSUP;
 }
 
@@ -243 +268 @@
 
         i = 0;
-        list_foreach(addr_list, link) {
-                inet_addrobj_t *addr = list_get_instance(link,
-                    inet_addrobj_t, addr_list);
-
+        list_foreach(addr_list, addr_list, inet_addrobj_t, addr) {
                 id_list[i++] = addr->id;
         }