diff options
| -rw-r--r-- | hicn-plugin/src/faces/app/face_prod.c | 40 | ||||
| -rw-r--r-- | utils/src/hiperf.cc | 8 |
2 files changed, 28 insertions, 20 deletions
diff --git a/hicn-plugin/src/faces/app/face_prod.c b/hicn-plugin/src/faces/app/face_prod.c index 834b35da9..7e6117b84 100644 --- a/hicn-plugin/src/faces/app/face_prod.c +++ b/hicn-plugin/src/faces/app/face_prod.c @@ -131,7 +131,8 @@ hicn_face_prod_add (hicn_prefix_t * prefix, u32 sw_if, u32 * cs_reserved, hicn_main_t *hm = &hicn_main; - ip46_address_t app_ip; + ip46_address_t local_app_ip; + ip46_address_t remote_app_ip; u32 if_flags = 0; if (!hm->is_enabled) @@ -195,7 +196,7 @@ hicn_face_prod_add (hicn_prefix_t * prefix, u32 sw_if, u32 * cs_reserved, */ face->shared.flags &= HICN_FACE_FLAGS_DELETED; hicn_face_prod_t *prod_face = (hicn_face_prod_t *) face->data; - app_ip = prod_face->ip_face.local_addr; + local_app_ip = prod_face->ip_face.local_addr; } } else @@ -207,31 +208,38 @@ hicn_face_prod_add (hicn_prefix_t * prefix, u32 sw_if, u32 * cs_reserved, * Otherwise retrieve an ip address to assign as a * local ip addr. */ - ip4_address_t app_ip4 = get_ip4_address (); + ip4_address_t local_app_ip4; + ip4_address_t remote_app_ip4; + get_two_ip4_addresses (&local_app_ip4, &remote_app_ip4); ip4_add_del_interface_address (vm, sw_if, - &app_ip4, 32, 0 /* is_del */ ); - app_ip = to_ip46 ( /* isv6 */ 0, app_ip4.as_u8); + &local_app_ip4, 31, 0 /* is_del */ ); + local_app_ip = to_ip46 ( /* isv6 */ 0, local_app_ip4.as_u8); + remote_app_ip = to_ip46 ( /* isv6 */ 0, remote_app_ip4.as_u8); + + ret = + hicn_face_ip_add (&local_app_ip, &remote_app_ip, sw_if, faceid); } else { - ip6_address_t app_ip6 = get_ip6_address (); + ip6_address_t local_app_ip6; + ip6_address_t remote_app_ip6; + get_two_ip6_addresses (&local_app_ip6, &remote_app_ip6); u8 *s0; - s0 = format (0, "Prefix %U", format_ip6_address, &app_ip6); + s0 = format (0, "Prefix %U", format_ip6_address, &local_app_ip6); vlib_cli_output (vm, "Setting ip address %s\n", s0); ip6_add_del_interface_address (vm, sw_if, - &app_ip6, 128, 0 /* is_del */ ); - app_ip = to_ip46 ( /* isv6 */ 1, app_ip6.as_u8); - } + &local_app_ip6, 127, + 0 /* is_del */ ); + local_app_ip = to_ip46 ( /* isv6 */ 1, local_app_ip6.as_u8); + remote_app_ip = to_ip46 ( /* isv6 */ 1, remote_app_ip6.as_u8); - /* - * Special case: the nh_addr in the face is the appif ip - * address - */ - ret = hicn_face_ip_add (&app_ip, &(prefix->name), sw_if, faceid); + ret = + hicn_face_ip_add (&local_app_ip, &remote_app_ip, sw_if, faceid); + } face = hicn_dpoi_get_from_idx (*faceid); @@ -259,7 +267,7 @@ hicn_face_prod_add (hicn_prefix_t * prefix, u32 sw_if, u32 * cs_reserved, ret = hicn_route_add (faceid, 1, &(prefix->name), prefix->len); } - *prod_addr = app_ip; + *prod_addr = local_app_ip; /* Cleanup in case of something went wrong. */ if (ret) diff --git a/utils/src/hiperf.cc b/utils/src/hiperf.cc index 425b91bca..d546cfca9 100644 --- a/utils/src/hiperf.cc +++ b/utils/src/hiperf.cc @@ -100,7 +100,7 @@ class Rate { std::chrono::microseconds getMicrosecondsForPacket(std::size_t packet_size) { return std::chrono::microseconds( - packet_size * long(std::round(1000.0 * 8.0 / rate_kbps_))); + (uint32_t)std::round(packet_size * 1000.0 * 8.0 / (double)rate_kbps_)); } private: @@ -551,15 +551,15 @@ class HIperfServer { void sendRTCContentObjectCallback(std::error_code ec) { if (!ec) { - auto payload = - content_objects_[content_objects_index_++ & mask_]->getPayload(); - producer_socket_->produce(payload->data(), payload->length()); rtc_timer_.expires_from_now( configuration_.production_rate_.getMicrosecondsForPacket( configuration_.payload_size_)); rtc_timer_.async_wait( std::bind(&HIperfServer::sendRTCContentObjectCallback, this, std::placeholders::_1)); + auto payload = + content_objects_[content_objects_index_++ & mask_]->getPayload(); + producer_socket_->produce(payload->data(), payload->length()); } } |