Changeset 8d48c7e in mainline for uspace/lib/nettl

Timestamp:

2015-06-02T16:00:42Z (10 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

2c4bb828

Parents:

ab6326bc

Message:

Find the association to deliver the datagram using amap.

Location:

uspace/lib/nettl

Files:

• include/nettl/amap.h (modified) (1 diff)
• include/nettl/portrng.h (modified) (2 diffs)
• src/amap.c (modified) (1 diff)
• src/portrng.c (modified) (2 diffs)

uspace/lib/nettl/include/nettl/amap.h

@@ -96 +96 @@
     inet_ep2_t *);
 extern void amap_remove(amap_t *, inet_ep2_t *);
-extern int amap_find(amap_t *, inet_ep2_t *, void **);
+extern int amap_find_match(amap_t *, inet_ep2_t *, void **);
 
 #endif

uspace/lib/nettl/include/nettl/portrng.h

@@ -46 +46 @@
         /** Port number */
         uint16_t pn;
+        /** User argument */
+        void *arg;
 } portrng_port_t;
 
@@ -60 +62 @@
 extern int portrng_alloc(portrng_t *, uint16_t, void *,
     portrng_flags_t, uint16_t *);
+extern int portrng_find_port(portrng_t *, uint16_t, void **);
 extern void portrng_free_port(portrng_t *, uint16_t);
 extern bool portrng_empty(portrng_t *);

uspace/lib/nettl/src/amap.c

@@ -510 +510 @@
 }
 
-int amap_find(amap_t *map, inet_ep2_t *epp, void **rarg)
-{
-        log_msg(LOG_DEFAULT, LVL_NOTE, "amap_find()");
-        return EOK;
+/** Find association matching an endpoint pair.
+ *
+ * Used to find which association to deliver a datagram to.
+ *
+ * @param map   Association map
+ * @param epp   Endpoint pair
+ * @param rarg  Place to store user argument for the matching association.
+ *
+ * @return      EOK on success, ENOENT if not found.
+ */
+int amap_find_match(amap_t *map, inet_ep2_t *epp, void **rarg)
+{
+        int rc;
+        amap_repla_t *repla;
+        amap_laddr_t *laddr;
+        amap_llink_t *llink;
+
+        log_msg(LOG_DEFAULT, LVL_NOTE, "amap_find_match(llink=%zu)",
+            epp->local_link);
+
+        /* Remode endpoint, local address */
+        rc = amap_repla_find(map, &epp->remote, &epp->local.addr, &repla);
+        if (rc == EOK) {
+                rc = portrng_find_port(repla->portrng, epp->local.port,
+                    rarg);
+                if (rc == EOK) {
+                        log_msg(LOG_DEFAULT, LVL_NOTE, "Matched repla / "
+                            "port %" PRIu16, epp->local.port);
+                        return EOK;
+                }
+        }
+
+        /* Local address */
+        rc = amap_laddr_find(map, &epp->local.addr, &laddr);
+        if (rc == EOK) {
+                rc = portrng_find_port(laddr->portrng, epp->local.port,
+                    rarg);
+                if (rc == EOK) {
+                        log_msg(LOG_DEFAULT, LVL_NOTE, "Matched laddr / "
+                            "port %" PRIu16, epp->local.port);
+                        return EOK;
+                }
+        }
+
+        /* Local link */
+        rc = amap_llink_find(map, epp->local_link, &llink);
+        if (epp->local_link != 0 && rc == EOK) {
+                rc = portrng_find_port(llink->portrng, epp->local.port,
+                    rarg);
+                if (rc == EOK) {
+                        log_msg(LOG_DEFAULT, LVL_NOTE, "Matched llink / "
+                            "port %" PRIu16, epp->local.port);
+                        return EOK;
+                }
+        }
+
+        /* Unspecified */
+        rc = portrng_find_port(map->unspec, epp->local.port, rarg);
+        if (rc == EOK) {
+                log_msg(LOG_DEFAULT, LVL_NOTE, "Matched unspec / port %" PRIu16,
+                    epp->local.port);
+                return EOK;
+        }
+
+        log_msg(LOG_DEFAULT, LVL_NOTE, "No match.");
+        return ENOENT;
 }
 

uspace/lib/nettl/src/portrng.c

@@ -118 +118 @@
 
         p->pn = pnum;
+        p->arg = arg;
         list_append(&p->lprng, &pr->used);
         *apnum = pnum;
@@ -123 +124 @@
             pnum);
         return EOK;
+}
+
+int portrng_find_port(portrng_t *pr, uint16_t pnum, void **rarg)
+{
+        list_foreach(pr->used, lprng, portrng_port_t, port) {
+                if (port->pn == pnum) {
+                        *rarg = port->arg;
+                        return EOK;
+                }
+        }
+
+        return ENOENT;
 }