Add API dump call for vrf/vni mapping to vpp-api-test
[vpp.git] / vpp-api-test / vat / api_format.c
index dd42896..84e9c4f 100644 (file)
@@ -45,6 +45,7 @@
 #include <vnet/cop/cop.h>
 #include <vnet/ip/ip6_hop_by_hop.h>
 #include <vnet/policer/xlate.h>
+#include <vnet/policer/policer.h>
 
 #include "vat/json_format.h"
 
@@ -416,6 +417,37 @@ unformat_policer_type (unformat_input_t * input, va_list * args)
   return 1;
 }
 
+uword
+unformat_dscp (unformat_input_t * input, va_list * va)
+{
+  u8 * r = va_arg (*va, u8 *);
+
+  if (0) ;
+#define _(v,f,str) else if (unformat (input, str)) *r = VNET_DSCP_##f;
+      foreach_vnet_dscp
+#undef _
+  else
+    return 0;
+  return 1;
+}
+
+uword
+unformat_policer_action_type (unformat_input_t * input, va_list * va)
+{
+  sse2_qos_pol_action_params_st * a
+    = va_arg (*va, sse2_qos_pol_action_params_st *);
+
+  if (unformat (input, "drop"))
+    a->action_type = SSE2_QOS_ACTION_DROP;
+  else if (unformat (input, "transmit"))
+    a->action_type = SSE2_QOS_ACTION_TRANSMIT;
+  else if (unformat (input, "mark-and-transmit %U", unformat_dscp, &a->dscp))
+    a->action_type = SSE2_QOS_ACTION_MARK_AND_TRANSMIT;
+  else
+    return 0;
+  return 1;
+}
+
 u8 * format_ip4_address (u8 * s, va_list * args)
 {
   u8 * a = va_arg (*args, u8 *);
@@ -526,6 +558,15 @@ void increment_v6_address (ip6_address_t * a)
     a->as_u64[1] = clib_net_to_host_u64 (v1);
 }
 
+void increment_mac_address (u64 *mac)
+{
+    u64 tmp = *mac;
+
+    tmp = clib_net_to_host_u64(tmp);
+    tmp += 1<<16; /* skip unused (least significant) octets */
+    tmp = clib_host_to_net_u64 (tmp);
+    *mac = tmp;
+}
 
 static void vl_api_create_loopback_reply_t_handler 
 (vl_api_create_loopback_reply_t * mp)
@@ -2006,6 +2047,36 @@ vl_api_lisp_local_eid_table_details_t_handler (
     vec_free(prefix);
 }
 
+static void
+vl_api_lisp_eid_table_map_details_t_handler (
+    vl_api_lisp_eid_table_map_details_t *mp)
+{
+    vat_main_t *vam = &vat_main;
+
+    u8 * line = format(0, "%=10d%=10d",
+                       clib_net_to_host_u32 (mp->vni),
+                       clib_net_to_host_u32 (mp->vrf));
+    fformat(vam->ofp, "%v\n", line);
+    vec_free(line);
+}
+
+static void
+vl_api_lisp_eid_table_map_details_t_handler_json (
+    vl_api_lisp_eid_table_map_details_t *mp)
+{
+    vat_main_t *vam = &vat_main;
+    vat_json_node_t *node = NULL;
+
+    if (VAT_JSON_ARRAY != vam->json_tree.type) {
+        ASSERT(VAT_JSON_NONE == vam->json_tree.type);
+        vat_json_init_array(&vam->json_tree);
+    }
+    node = vat_json_array_add(&vam->json_tree);
+    vat_json_init_object(node);
+    vat_json_object_add_uint(node, "vrf", clib_net_to_host_u32 (mp->vrf));
+    vat_json_object_add_uint(node, "vni", clib_net_to_host_u32 (mp->vni));
+}
+
 static void
 vl_api_lisp_local_eid_table_details_t_handler_json (
     vl_api_lisp_local_eid_table_details_t *mp)
@@ -2306,15 +2377,63 @@ static u8 * format_policer_round_type (u8 * s, va_list * va)
   return s;
 }
 
+static u8 * format_policer_action_type (u8 * s, va_list * va)
+{
+    u32 i = va_arg (*va, u32);
+
+    if (i == SSE2_QOS_ACTION_DROP)
+        s = format (s, "drop");
+    else if (i == SSE2_QOS_ACTION_TRANSMIT)
+        s = format (s, "transmit");
+    else if (i == SSE2_QOS_ACTION_MARK_AND_TRANSMIT)
+        s = format (s, "mark-and-transmit");
+    else
+        s = format (s, "ILLEGAL");
+    return s;
+}
+
+static u8 * format_dscp (u8 * s, va_list * va)
+{
+  u32 i = va_arg (*va, u32);
+  char * t = 0;
+
+  switch (i) {
+  #define _(v,f,str) case VNET_DSCP_##f: t = str; break;
+    foreach_vnet_dscp
+  #undef _
+    default:
+      return format (s, "ILLEGAL");
+  }
+  s = format (s, "%s", t);
+  return s;
+}
+
 static void vl_api_policer_details_t_handler
 (vl_api_policer_details_t * mp)
 {
     vat_main_t * vam = &vat_main;
+    u8 *conform_dscp_str, *exceed_dscp_str, *violate_dscp_str;
+
+    if (mp->conform_action_type == SSE2_QOS_ACTION_MARK_AND_TRANSMIT)
+        conform_dscp_str = format(0, "%U", format_dscp, mp->conform_dscp);
+    else
+        conform_dscp_str = format(0, "");
+
+    if (mp->exceed_action_type == SSE2_QOS_ACTION_MARK_AND_TRANSMIT)
+        exceed_dscp_str = format(0, "%U", format_dscp, mp->exceed_dscp);
+    else
+        exceed_dscp_str = format(0, "");
+
+    if (mp->violate_action_type == SSE2_QOS_ACTION_MARK_AND_TRANSMIT)
+        violate_dscp_str = format(0, "%U", format_dscp, mp->violate_dscp);
+    else
+        violate_dscp_str = format(0, "");
 
     fformat (vam->ofp, "Name \"%s\", type %U, cir %u, eir %u, cb %u, eb %u, "
              "rate type %U, round type %U, %s rate, %s color-aware, "
              "cir %u tok/period, pir %u tok/period, scale %u, cur lim %u, "
-             "cur bkt %u, ext lim %u, ext bkt %u, last update %llu\n",
+             "cur bkt %u, ext lim %u, ext bkt %u, last update %llu"
+             "conform action %U%s, exceed action %U%s, violate action %U%s\n",
              mp->name,
              format_policer_type, mp->type,
              ntohl(mp->cir),
@@ -2332,7 +2451,17 @@ static void vl_api_policer_details_t_handler
              ntohl(mp->current_bucket),
              ntohl(mp->extended_limit),
              ntohl(mp->extended_bucket),
-             clib_net_to_host_u64(mp->last_update_time));
+             clib_net_to_host_u64(mp->last_update_time),
+             format_policer_action_type, mp->conform_action_type,
+             conform_dscp_str,
+             format_policer_action_type, mp->exceed_action_type,
+             exceed_dscp_str,
+             format_policer_action_type, mp->violate_action_type,
+             violate_dscp_str);
+
+    vec_free(conform_dscp_str);
+    vec_free(exceed_dscp_str);
+    vec_free(violate_dscp_str);
 }
 
 static void vl_api_policer_details_t_handler_json
@@ -2341,10 +2470,17 @@ static void vl_api_policer_details_t_handler_json
     vat_main_t * vam = &vat_main;
     vat_json_node_t *node;
     u8 *rate_type_str, *round_type_str, *type_str;
+    u8 *conform_action_str, *exceed_action_str, *violate_action_str;
 
     rate_type_str = format(0, "%U", format_policer_rate_type, mp->rate_type);
     round_type_str = format(0, "%U", format_policer_round_type, mp->round_type);
     type_str = format(0, "%U", format_policer_type, mp->type);
+    conform_action_str = format(0, "%U", format_policer_action_type,
+                                mp->conform_action_type);
+    exceed_action_str = format(0, "%U", format_policer_action_type,
+                                mp->exceed_action_type);
+    violate_action_str = format(0, "%U", format_policer_action_type,
+                                mp->violate_action_type);
 
     if (VAT_JSON_ARRAY != vam->json_tree.type) {
         ASSERT(VAT_JSON_NONE == vam->json_tree.type);
@@ -2375,10 +2511,31 @@ static void vl_api_policer_details_t_handler_json
                              ntohl(mp->extended_bucket));
     vat_json_object_add_uint(node, "last_update_time",
                              ntohl(mp->last_update_time));
+    vat_json_object_add_string_copy(node, "conform_action", conform_action_str);
+    if (mp->conform_action_type == SSE2_QOS_ACTION_MARK_AND_TRANSMIT) {
+        u8 *dscp_str = format(0, "%U", format_dscp, mp->conform_dscp);
+        vat_json_object_add_string_copy(node, "conform_dscp", dscp_str);
+        vec_free(dscp_str);
+    }
+    vat_json_object_add_string_copy(node, "exceed_action", exceed_action_str);
+    if (mp->exceed_action_type == SSE2_QOS_ACTION_MARK_AND_TRANSMIT) {
+        u8 *dscp_str = format(0, "%U", format_dscp, mp->exceed_dscp);
+        vat_json_object_add_string_copy(node, "exceed_dscp", dscp_str);
+        vec_free(dscp_str);
+    }
+    vat_json_object_add_string_copy(node, "violate_action", violate_action_str);
+    if (mp->violate_action_type == SSE2_QOS_ACTION_MARK_AND_TRANSMIT) {
+        u8 *dscp_str = format(0, "%U", format_dscp, mp->violate_dscp);
+        vat_json_object_add_string_copy(node, "violate_dscp", dscp_str);
+        vec_free(dscp_str);
+    }
 
     vec_free(rate_type_str);
     vec_free(round_type_str);
     vec_free(type_str);
+    vec_free(conform_action_str);
+    vec_free(exceed_action_str);
+    vec_free(violate_action_str);
 }
 
 static void vl_api_classify_table_ids_reply_t_handler (vl_api_classify_table_ids_reply_t * mp)
@@ -2832,6 +2989,7 @@ _(LISP_EID_TABLE_ADD_DEL_MAP_REPLY, lisp_eid_table_add_del_map_reply)   \
 _(LISP_GPE_ADD_DEL_IFACE_REPLY, lisp_gpe_add_del_iface_reply)           \
 _(LISP_LOCATOR_SET_DETAILS, lisp_locator_set_details)                   \
 _(LISP_LOCAL_EID_TABLE_DETAILS, lisp_local_eid_table_details)           \
+_(LISP_EID_TABLE_MAP_DETAILS, lisp_eid_table_map_details)               \
 _(LISP_GPE_TUNNEL_DETAILS, lisp_gpe_tunnel_details)                     \
 _(LISP_MAP_RESOLVER_DETAILS, lisp_map_resolver_details)                 \
 _(LISP_ENABLE_DISABLE_STATUS_DETAILS,                                   \
@@ -3909,6 +4067,9 @@ static int api_l2fib_add_del (vat_main_t * vam)
     u8 static_mac = 0;
     u8 filter_mac = 0;
     u8 bvi_mac = 0;
+    int count = 1;
+    f64 before = 0;
+    int j;
 
     /* Parse args required to build the message */
     while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT) {
@@ -3920,22 +4081,24 @@ static int api_l2fib_add_del (vat_main_t * vam)
             sw_if_index_set = 1;       
        else if (unformat (i, "sw_if")) {
            if (unformat_check_input (i) != UNFORMAT_END_OF_INPUT) {
-                if (unformat (i, "%U", unformat_sw_if_index, vam, &sw_if_index))
-                    sw_if_index_set = 1;
+               if (unformat (i, "%U", unformat_sw_if_index, vam, &sw_if_index))
+                   sw_if_index_set = 1;
            } else
                break;
        } else if (unformat (i, "static"))
-               static_mac = 1;
+           static_mac = 1;
        else if (unformat (i, "filter")) {
-               filter_mac = 1;
-               static_mac = 1;
-    } else if (unformat (i, "bvi")) {
-        bvi_mac = 1;
-        static_mac = 1;
+           filter_mac = 1;
+           static_mac = 1;
+       } else if (unformat (i, "bvi")) {
+           bvi_mac = 1;
+           static_mac = 1;
        } else if (unformat (i, "del"))
-               is_add = 0;
+           is_add = 0;
+        else if (unformat (i, "count %d", &count))
+           ;
        else
-            break;
+           break;
     }
 
     if (mac_set == 0) {
@@ -3953,22 +4116,66 @@ static int api_l2fib_add_del (vat_main_t * vam)
         return -99;
     }
 
-    M(L2FIB_ADD_DEL, l2fib_add_del);
+    if (count > 1) {
+        /* Turn on async mode */
+        vam->async_mode = 1;
+        vam->async_errors = 0;
+        before = vat_time_now(vam);
+    }
 
-    mp->mac = mac;
-    mp->bd_id = ntohl(bd_id);
-    mp->is_add = is_add;
+    for (j = 0; j < count; j++) {
+       M(L2FIB_ADD_DEL, l2fib_add_del);
+       
+       mp->mac = mac;
+       mp->bd_id = ntohl(bd_id);
+       mp->is_add = is_add;
+       
+       if (is_add) {
+           mp->sw_if_index = ntohl(sw_if_index);
+           mp->static_mac = static_mac;
+           mp->filter_mac = filter_mac;
+           mp->bvi_mac = bvi_mac;
+       }
+       increment_mac_address (&mac);
+       /* send it... */
+        S;
+    }
 
-    if (is_add) {
-        mp->sw_if_index = ntohl(sw_if_index);
-        mp->static_mac = static_mac;
-        mp->filter_mac = filter_mac;
-        mp->bvi_mac = bvi_mac;
+    if (count > 1) {
+        vl_api_control_ping_t * mp;
+        f64 after;
+
+        /* Shut off async mode */
+        vam->async_mode = 0;
+
+        M(CONTROL_PING, control_ping);
+        S;
+
+        timeout = vat_time_now(vam) + 1.0;
+        while (vat_time_now (vam) < timeout)
+            if (vam->result_ready == 1)
+                goto out;
+        vam->retval = -99;
+
+    out:
+        if (vam->retval == -99)
+            errmsg ("timeout\n");
+
+        if (vam->async_errors > 0) {
+            errmsg ("%d asynchronous errors\n", vam->async_errors);
+            vam->retval = -98;
+        }
+        vam->async_errors = 0;
+        after = vat_time_now(vam);
+
+        fformat(vam->ofp, "%d routes in %.6f secs, %.2f routes/sec\n",
+                count, after - before, count / (after - before));
+    } else {
+        /* Wait for a reply... */
+        W;
     }
-    
-    S; W;
-    /* NOTREACHED */
-    return 0;
+    /* Return the good/bad news */
+    return (vam->retval);
 }
 
 static int api_l2_flags (vat_main_t * vam)
@@ -10790,15 +10997,13 @@ api_lisp_add_del_adjacency (vat_main_t * vam)
     vl_api_lisp_add_del_adjacency_t *mp;
     f64 timeout = ~0;
     u32 vni = 0;
-    ip4_address_t seid4, deid4, rloc4;
-    ip6_address_t seid6, deid6, rloc6;
+    ip4_address_t seid4, deid4;
+    ip6_address_t seid6, deid6;
     u8 deid_mac[6] = {0};
     u8 seid_mac[6] = {0};
     u8 deid_type, seid_type;
     u32 seid_len = 0, deid_len = 0, len;
     u8 is_add = 1;
-    u32 action = ~0, p, w;
-    rloc_t * rlocs = 0, rloc, * curr_rloc = 0;
 
     seid_type = deid_type =  (u8)~0;
 
@@ -10832,25 +11037,6 @@ api_lisp_add_del_adjacency (vat_main_t * vam)
             seid_type = 2; /* mac */
         } else if (unformat(input, "vni %d", &vni)) {
             ;
-        } else if (unformat(input, "p %d w %d", &p, &w)) {
-            if (!curr_rloc) {
-              errmsg ("No RLOC configured for setting priority/weight!");
-              return -99;
-            }
-            curr_rloc->priority = p;
-            curr_rloc->weight = w;
-        } else if (unformat(input, "rloc %U", unformat_ip4_address, &rloc4)) {
-            rloc.is_ip4 = 1;
-            clib_memcpy (&rloc.addr, &rloc4, sizeof (rloc4));
-            vec_add1 (rlocs, rloc);
-            curr_rloc = &rlocs[vec_len (rlocs) - 1];
-        } else if (unformat(input, "rloc %U", unformat_ip6_address, &rloc6)) {
-            rloc.is_ip4 = 0;
-            clib_memcpy (&rloc.addr, &rloc6, sizeof (rloc6));
-            vec_add1 (rlocs, rloc);
-            curr_rloc = &rlocs[vec_len (rlocs) - 1];
-        } else if (unformat(input, "action %d", &action)) {
-            ;
         } else {
             errmsg ("parse error '%U'", format_unformat_error, input);
             return -99;
@@ -10867,17 +11053,10 @@ api_lisp_add_del_adjacency (vat_main_t * vam)
         return -99;
     }
 
-    if (is_add && (~0 == action)
-        && 0 == vec_len (rlocs)) {
-          errmsg ("no action set for negative map-reply!");
-          return -99;
-    }
-
     M(LISP_ADD_DEL_ADJACENCY, lisp_add_del_adjacency);
     mp->is_add = is_add;
     mp->vni = htonl (vni);
     mp->seid_len = seid_len;
-    mp->action = (u8) action;
     mp->deid_len = deid_len;
     mp->eid_type = deid_type;
 
@@ -10899,10 +11078,6 @@ api_lisp_add_del_adjacency (vat_main_t * vam)
         return 0;
     }
 
-    mp->rloc_num = vec_len (rlocs);
-    clib_memcpy (mp->rlocs, rlocs, (sizeof (rloc_t) * vec_len (rlocs)));
-    vec_free (rlocs);
-
     /* send it... */
     S;
 
@@ -11048,6 +11223,34 @@ api_lisp_locator_set_dump(vat_main_t *vam)
     return 0;
 }
 
+static int
+api_lisp_eid_table_map_dump(vat_main_t *vam)
+{
+    vl_api_lisp_eid_table_map_dump_t *mp;
+    f64 timeout = ~0;
+
+    if (!vam->json_output) {
+        fformat (vam->ofp, "%=10s%=10s\n", "VNI", "VRF");
+    }
+
+    M(LISP_EID_TABLE_MAP_DUMP, lisp_eid_table_map_dump);
+
+    /* send it... */
+    S;
+
+    /* Use a control ping for synchronization */
+    {
+        vl_api_control_ping_t * mp;
+        M(CONTROL_PING, control_ping);
+        S;
+    }
+    /* Wait for a reply... */
+    W;
+
+    /* NOTREACHED */
+    return 0;
+}
+
 static int
 api_lisp_local_eid_table_dump(vat_main_t *vam)
 {
@@ -11327,6 +11530,7 @@ api_policer_add_del (vat_main_t * vam)
     u8 rate_type = 0;
     u8 round_type = 0;
     u8 type = 0;
+    sse2_qos_pol_action_params_st conform_action, exceed_action, violate_action;
 
     while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT) {
         if (unformat (i, "del"))
@@ -11349,6 +11553,15 @@ api_policer_add_del (vat_main_t * vam)
             ;
         else if (unformat (i, "type %U", unformat_policer_type, &type))
             ;
+        else if (unformat (i, "conform_action %U", unformat_policer_action_type,
+                           &conform_action))
+            ;
+        else if (unformat (i, "exceed_action %U", unformat_policer_action_type,
+                           &exceed_action))
+            ;
+        else if (unformat (i, "violate_action %U", unformat_policer_action_type,
+                           &violate_action))
+            ;
         else
           break;
     }
@@ -11375,6 +11588,12 @@ api_policer_add_del (vat_main_t * vam)
     mp->rate_type = rate_type;
     mp->round_type = round_type;
     mp->type = type;
+    mp->conform_action_type = conform_action.action_type;
+    mp->conform_dscp = conform_action.dscp;
+    mp->exceed_action_type = exceed_action.action_type;
+    mp->exceed_dscp = exceed_action.dscp;
+    mp->violate_action_type = violate_action.action_type;
+    mp->violate_dscp = violate_action.dscp;
 
     S; W;
     /* NOTREACHED */
@@ -12246,7 +12465,7 @@ _(bridge_domain_add_del,                                                \
   "bd_id <bridge-domain-id> [flood 1|0] [uu-flood 1|0] [forward 1|0] [learn 1|0] [arp-term 1|0] [del]\n")\
 _(bridge_domain_dump, "[bd_id <bridge-domain-id>]\n")     \
 _(l2fib_add_del,                                                        \
-  "mac <mac-addr> bd_id <bridge-domain-id> [del] | sw_if <intfc> | sw_if_index <id> [static] [filter] [bvi]\n") \
+  "mac <mac-addr> bd_id <bridge-domain-id> [del] | sw_if <intfc> | sw_if_index <id> [static] [filter] [bvi] [count <nn>]\n") \
 _(l2_flags,                                                             \
   "sw_if <intfc> | sw_if_index <id> [learn] [forward] [uu-flood] [flood]\n")       \
 _(bridge_flags,                                                         \
@@ -12460,6 +12679,7 @@ _(lisp_add_del_map_request_itr_rlocs, "<loc-set-name> [del]")           \
 _(lisp_eid_table_add_del_map, "[del] vni <vni> vrf <vrf>")              \
 _(lisp_locator_set_dump, "")                                            \
 _(lisp_local_eid_table_dump, "")                                        \
+_(lisp_eid_table_map_dump, "")                                          \
 _(lisp_gpe_tunnel_dump, "")                                             \
 _(lisp_map_resolver_dump, "")                                           \
 _(lisp_enable_disable_status_dump, "")                                  \