Changeset 8d48c7e in mainline for uspace/lib/nettl/src/amap.c

Timestamp:

2015-06-02T16:00:42Z (9 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.

File:

• uspace/lib/nettl/src/amap.c (modified) (1 diff)

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;
 }