u32 sw_if_index,
const ip46_address_t *nh)
{
+ const ip46_address_t *conn, *source;
const ip_adjacency_t *adj;
- ip46_address_t *conn;
adj_index_t ai;
if (vec_len(adj_gleans[proto]) <= sw_if_index ||
if (nh)
pfx.fp_addr = *nh;
+ /*
+ * An interface can have more than one glean address. Where
+ * possible we want to return a source address from the same
+ * subnet as the destination. If this is not possible then any address
+ * will do.
+ */
+ source = NULL;
+
hash_foreach_mem(conn, ai, adj_gleans[proto][sw_if_index],
({
adj = adj_get(ai);
if (adj->sub_type.glean.rx_pfx.fp_len > 0)
{
+ source = &adj->sub_type.glean.rx_pfx.fp_addr;
+
/* if no destination is specified use the just glean */
if (NULL == nh)
- return (&adj->sub_type.glean.rx_pfx.fp_addr);
+ return (source);
/* check the clean covers the desintation */
if (fib_prefix_is_cover(&adj->sub_type.glean.rx_pfx, &pfx))
- return (&adj->sub_type.glean.rx_pfx.fp_addr);
+ return (source);
}
}));
- return (NULL);
+ return (source);
}
void
from framework import VppTestCase
from util import ppp
-from vpp_ip_route import VppIpInterfaceAddress
+from vpp_ip_route import VppIpInterfaceAddress, VppIpRoute, VppRoutePath
from vpp_neighbor import VppNeighbor
""" TestPing is a subclass of VPPTestCase classes.
for p in out:
icmp = self.verify_ping_request(p, "10.0.0.1", nbr_addr, icmp_seq)
icmp_seq = icmp_seq + 1
+
+ def test_ping_fib_routed_dst(self):
+ """ ping destination routed according to FIB table """
+
+ try:
+ self.pg1.generate_remote_hosts(1)
+ self.pg_enable_capture(self.pg_interfaces)
+ self.pg_start()
+ routed_dst = "10.0.2.0"
+ self.logger.info(self.vapi.cli("show ip4 neighbors"))
+ VppIpRoute(self, routed_dst, 24,
+ [VppRoutePath(self.pg1.remote_hosts[0].ip4,
+ self.pg1.sw_if_index)]).add_vpp_config()
+ ping_cmd = "ping %s interval 0.01 repeat 3" % routed_dst
+ ret = self.vapi.cli(ping_cmd)
+ self.logger.info(ret)
+ out = self.pg1.get_capture(3)
+ icmp_seq = 1
+ for p in out:
+ self.verify_ping_request(p, self.pg1.local_ip4, routed_dst,
+ icmp_seq)
+ icmp_seq = icmp_seq + 1
+ finally:
+ self.vapi.cli("show error")