diff options
Diffstat (limited to 'src/vnet/qos')
| -rw-r--r-- | src/vnet/qos/qos.api | 100 | ||||
| -rw-r--r-- | src/vnet/qos/qos_api.c | 161 | ||||
| -rw-r--r-- | src/vnet/qos/qos_egress_map.c | 262 | ||||
| -rw-r--r-- | src/vnet/qos/qos_egress_map.h | 82 | ||||
| -rw-r--r-- | src/vnet/qos/qos_mark.c | 447 | ||||
| -rw-r--r-- | src/vnet/qos/qos_mark.h | 39 | ||||
| -rw-r--r-- | src/vnet/qos/qos_record.c | 326 | ||||
| -rw-r--r-- | src/vnet/qos/qos_record.h | 32 | ||||
| -rw-r--r-- | src/vnet/qos/qos_types.c | 59 | ||||
| -rw-r--r-- | src/vnet/qos/qos_types.h | 78 |
10 files changed, 1586 insertions, 0 deletions
diff --git a/src/vnet/qos/qos.api b/src/vnet/qos/qos.api new file mode 100644 index 00000000000..a7bd19acc9e --- /dev/null +++ b/src/vnet/qos/qos.api @@ -0,0 +1,100 @@ +/* + * Copyright (c) 2016 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** \file + + This file defines QoS record and mark API messages which are generally + called through a shared memory interface. +*/ + +option version = "1.0.0"; + +/** \brief Enable/Disable QoS recording + The QoS bits from the packet at the specified input layer are copied + into the packet. Recording should be used in conjunction with marking + @param sw_if_index - The interface on which recording is enabled. + @param enable - enable=1 or disable the feautre + @param input_source - The input source/layer at which the QoS bits + are copied from the packet. See qos_source_t. +*/ +autoreply define qos_record_enable_disable +{ + u32 client_index; + u32 context; + u32 sw_if_index; + u8 input_source; + u8 enable; +}; + +/** \brief A row within a QoS map + Each value translates from an input value to an output. +*/ +typeonly define qos_egress_map_row +{ + u8 outputs[256]; +}; + +/** \brief Update a QoS Map + A QoS map, translates from the QoS value in the packet set by the 'record' + feature, to the value used for output in the 'mark' feature. + There is one row in the map for each input/record source. + The MAP is then applied to the egress interface at for a given output source + @param map_id - client provided identifier for the map + @param rows - one row (per-input source) of output values +*/ +autoreply define qos_egress_map_update +{ + u32 client_index; + u32 context; + u32 map_id; + vl_api_qos_egress_map_row_t rows[4]; +}; + +/** \brief Delete a Qos Map + @param map_id - ID of the map to delete +*/ +autoreply define qos_egress_map_delete +{ + u32 client_index; + u32 context; + u32 map_id; +}; + +/** \brief Enable/Disable QoS marking + The QoS bits from the packet are mapped (using the desired egress map) + into the header of the 'output-source'. Marking should be used in + conjunction with recording + @param sw_if_index - The interface on which recording is enabled. + @param enable - enable=1 or disable the feautre + @param output_source - The output source/layer at which the QoS bits + are written into the packet. See qos_source_t. + @param map_id - The ID of the MAP in which the translation from input + to output is performed. +*/ +autoreply define qos_mark_enable_disable +{ + u32 client_index; + u32 context; + u32 map_id; + u32 sw_if_index; + u8 output_source; + u8 enable; +}; + +/* + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_api.c b/src/vnet/qos/qos_api.c new file mode 100644 index 00000000000..cdb9e46ea36 --- /dev/null +++ b/src/vnet/qos/qos_api.c @@ -0,0 +1,161 @@ +/* + *------------------------------------------------------------------ + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + *------------------------------------------------------------------ + */ + +#include <vnet/vnet.h> +#include <vlibmemory/api.h> +#include <vnet/api_errno.h> + +#include <vnet/qos/qos_record.h> +#include <vnet/qos/qos_mark.h> +#include <vnet/qos/qos_egress_map.h> + +#include <vnet/vnet_msg_enum.h> + +#define vl_typedefs /* define message structures */ +#include <vnet/vnet_all_api_h.h> +#undef vl_typedefs + +#define vl_endianfun /* define message structures */ +#include <vnet/vnet_all_api_h.h> +#undef vl_endianfun + +/* instantiate all the print functions we know about */ +#define vl_print(handle, ...) vlib_cli_output (handle, __VA_ARGS__) +#define vl_printfun +#include <vnet/vnet_all_api_h.h> +#undef vl_printfun + +#include <vlibapi/api_helper_macros.h> + + +#define foreach_qos_api_msg \ + _(QOS_RECORD_ENABLE_DISABLE, qos_record_enable_disable) \ + _(QOS_EGRESS_MAP_DELETE, qos_egress_map_delete) \ + _(QOS_EGRESS_MAP_UPDATE, qos_egress_map_update) \ + _(QOS_MARK_ENABLE_DISABLE, qos_mark_enable_disable) + +void +vl_api_qos_record_enable_disable_t_handler (vl_api_qos_record_enable_disable_t + * mp) +{ + vl_api_qos_record_enable_disable_reply_t *rmp; + int rv = 0; + + if (mp->input_source > QOS_N_SOURCES) + rv = VNET_API_ERROR_INVALID_VALUE; + else + { + if (mp->enable) + rv = qos_record_enable (ntohl (mp->sw_if_index), mp->input_source); + else + rv = qos_record_disable (ntohl (mp->sw_if_index), mp->input_source); + } + + REPLY_MACRO (VL_API_QOS_RECORD_ENABLE_DISABLE_REPLY); +} + +void +vl_api_qos_egress_map_update_t_handler (vl_api_qos_egress_map_update_t * mp) +{ + vl_api_qos_egress_map_update_reply_t *rmp; + qos_source_t qs; + int rv = 0; + + FOR_EACH_QOS_SOURCE (qs) + { + qos_egress_map_update (ntohl (mp->map_id), qs, &mp->rows[qs].outputs[0]); + } + + REPLY_MACRO (VL_API_QOS_EGRESS_MAP_UPDATE_REPLY); +} + +void +vl_api_qos_egress_map_delete_t_handler (vl_api_qos_egress_map_delete_t * mp) +{ + vl_api_qos_egress_map_delete_reply_t *rmp; + int rv = 0; + + qos_egress_map_delete (ntohl (mp->map_id)); + + REPLY_MACRO (VL_API_QOS_EGRESS_MAP_DELETE_REPLY); +} + +void + vl_api_qos_mark_enable_disable_t_handler + (vl_api_qos_mark_enable_disable_t * mp) +{ + vl_api_qos_mark_enable_disable_reply_t *rmp; + int rv = 0; + + if (mp->output_source > QOS_N_SOURCES) + rv = VNET_API_ERROR_INVALID_VALUE; + else + { + if (mp->enable) + rv = qos_mark_enable (ntohl (mp->sw_if_index), + mp->output_source, ntohl (mp->map_id)); + else + rv = qos_mark_disable (ntohl (mp->sw_if_index), mp->output_source); + } + + REPLY_MACRO (VL_API_QOS_MARK_ENABLE_DISABLE_REPLY); +} + +#define vl_msg_name_crc_list +#include <vnet/qos/qos.api.h> +#undef vl_msg_name_crc_list + +static void +setup_message_id_table (api_main_t * am) +{ +#define _(id,n,crc) vl_msg_api_add_msg_name_crc (am, #n "_" #crc, id); + foreach_vl_msg_name_crc_qos; +#undef _ +} + +static clib_error_t * +qos_api_hookup (vlib_main_t * vm) +{ + api_main_t *am = &api_main; + +#define _(N,n) \ + vl_msg_api_set_handlers(VL_API_##N, #n, \ + vl_api_##n##_t_handler, \ + vl_noop_handler, \ + vl_api_##n##_t_endian, \ + vl_api_##n##_t_print, \ + sizeof(vl_api_##n##_t), 1); + foreach_qos_api_msg; +#undef _ + + /* + * Set up the (msg_name, crc, message-id) table + */ + setup_message_id_table (am); + + return 0; +} + +VLIB_API_INIT_FUNCTION (qos_api_hookup); + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_egress_map.c b/src/vnet/qos/qos_egress_map.c new file mode 100644 index 00000000000..365643995ba --- /dev/null +++ b/src/vnet/qos/qos_egress_map.c @@ -0,0 +1,262 @@ +/* + *------------------------------------------------------------------ + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + *------------------------------------------------------------------ + */ + +#include <vnet/qos/qos_egress_map.h> +#include <vnet/qos/qos_mark.h> + +/** + * Pool from which to allocate table + */ +qos_egress_map_t *qem_pool; + +/** + * DB to map user table-IDs to internal table indicies. + */ +uword *qem_db; + +index_t +qos_egress_map_find (qos_egress_map_id_t mid) +{ + uword *p = NULL; + + p = hash_get (qem_db, mid); + + if (NULL != p) + return p[0]; + + return (INDEX_INVALID); +} + +qos_egress_map_t * +qos_egress_map_find_i (qos_egress_map_id_t mid) +{ + index_t qemi; + + qemi = qos_egress_map_find (mid); + + if (INDEX_INVALID != qemi) + { + return (pool_elt_at_index (qem_pool, qemi)); + } + + return (NULL); +} + +static qos_egress_map_t * +qos_egress_map_find_or_create (qos_egress_map_id_t mid) +{ + qos_egress_map_t *qem; + + /* + * Find the existing or create a new table + */ + qem = qos_egress_map_find_i (mid); + + if (NULL == qem) + { + index_t qemi; + + pool_get_aligned (qem_pool, qem, CLIB_CACHE_LINE_BYTES); + qemi = qem - qem_pool; + + memset (qem, 0, sizeof (*qem)); + hash_set (qem_db, mid, qemi); + } + + return (qem); +} + +void +qos_egress_map_update (qos_egress_map_id_t mid, + qos_source_t input_source, qos_bits_t * values) +{ + qos_egress_map_t *qem; + + qem = qos_egress_map_find_or_create (mid); + + clib_memcpy (qem->qem_output[input_source], + values, sizeof (qem->qem_output[input_source])); +} + +void +qos_egress_map_delete (qos_egress_map_id_t mid) +{ + qos_egress_map_t *qem; + + qem = qos_egress_map_find_i (mid); + hash_unset (qem_db, mid); + + if (NULL != qem) + { + pool_put (qem_pool, qem); + } +} + +static clib_error_t * +qos_egress_map_update_cli (vlib_main_t * vm, + unformat_input_t * input, vlib_cli_command_t * cmd) +{ + qos_egress_map_id_t map_id; + qos_egress_map_t *qem; + u8 add; + + add = 1; + map_id = ~0; + qem = NULL; + + while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) + { + if (unformat (input, "delete") || unformat (input, "del")) + add = 0; + else if (unformat (input, "id %d", &map_id)) + qem = qos_egress_map_find_or_create (map_id); + else + { + int qs, qi, qo; + + if (NULL == qem) + return clib_error_return (0, "map-id must be specified"); + + while (unformat + (input, "[%U][%d]=%d", unformat_qos_source, &qs, &qi, &qo)) + qem->qem_output[qs][qi] = qo; + break; + } + } + + if (!add) + qos_egress_map_delete (map_id); + + return (NULL); +} + +/*? + * Update a Egress Qos Map table + * + * @cliexpar + * @cliexcmd{qos egress map id 0 [ip][4]=4} + ?*/ +/* *INDENT-OFF* */ +VLIB_CLI_COMMAND (qos_egress_map_update_command, static) = { + .path = "qos egress map", + .short_help = "qos egress map id %d [delete] {[SOURCE][INPUT]=OUTPUT}", + .function = qos_egress_map_update_cli, + .is_mp_safe = 1, +}; +/* *INDENT-ON* */ + +u8 * +format_qos_egress_map (u8 * s, va_list * args) +{ + qos_egress_map_t *qem = va_arg (*args, qos_egress_map_t *); + u32 indent = va_arg (*args, u32); + int qs; + u32 ii; + + FOR_EACH_QOS_SOURCE (qs) + { + s = format (s, "%U%U:[", + format_white_space, indent, format_qos_source, qs); + + for (ii = 0; ii < ARRAY_LEN (qem->qem_output[qs]) - 1; ii++) + { + s = format (s, "%d,", qem->qem_output[qs][ii]); + } + s = format (s, "%d]\n", qem->qem_output[qs][ii]); + } + + return (s); +} + +static clib_error_t * +qos_egress_map_show (vlib_main_t * vm, + unformat_input_t * input, vlib_cli_command_t * cmd) +{ + qos_egress_map_id_t map_id; + qos_egress_map_t *qem; + clib_error_t *error; + + map_id = ~0; + qem = NULL; + error = NULL; + + while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) + { + if (unformat (input, "id %d", &map_id)) + ; + else + { + error = unformat_parse_error (input); + goto done; + } + } + + if (~0 == map_id) + { + index_t qemi; + + /* *INDENT-OFF* */ + hash_foreach(map_id, qemi, qem_db, + ({ + vlib_cli_output (vm, " Map-ID:%d\n%U", + map_id, + format_qos_egress_map, + pool_elt_at_index(qem_pool, qemi), 2); + })); + /* *INDENT-ON* */ + } + else + { + qem = qos_egress_map_find_i (map_id); + + if (NULL == qem) + { + error = clib_error_return (0, "No Map for ID %d", map_id); + } + else + { + vlib_cli_output (vm, " Map-ID:%d\n%U", + map_id, format_qos_egress_map, qem, 2); + } + } + +done: + return (error); +} + +/*? + * Show Egress Qos Maps + * + * @cliexpar + * @cliexcmd{show qos egress map} + ?*/ +/* *INDENT-OFF* */ +VLIB_CLI_COMMAND (qos_egress_map_show_command, static) = { + .path = "show qos egress map", + .short_help = "show qos egress map id %d", + .function = qos_egress_map_show, + .is_mp_safe = 1, +}; +/* *INDENT-ON* */ + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_egress_map.h b/src/vnet/qos/qos_egress_map.h new file mode 100644 index 00000000000..f4b282cb7ba --- /dev/null +++ b/src/vnet/qos/qos_egress_map.h @@ -0,0 +1,82 @@ +/* + *------------------------------------------------------------------ + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + *------------------------------------------------------------------ + */ + +/** + * A QOS egress map translates from the COS bits stored in the packet's + * meta-data into a per-protocol COS value + */ + +#ifndef __QOS_EGRESS_MAP_H__ +#define __QOS_EGRESS_MAP_H__ + +#include <vnet/qos/qos_types.h> +#include <vnet/dpo/dpo.h> + +/** + * An attempt at type safety + */ +typedef u32 qos_egress_map_id_t; + +/** + * For a given output source a table maps each value of every input sorce. + */ +typedef struct qos_egress_map_t_ +{ + /** + * The array of output mapped values; + * output = eq_qos[input-source][input-value] + */ + qos_bits_t qem_output[QOS_N_SOURCES][256]; +} qos_egress_map_t; + +extern u8 *format_qos_egress_map (u8 * s, va_list * args); + +/** + * Add a qos-egress map to an interface. If sw_if_index = ~0 + * then the configuration is for the 'default' table. + * If the table is ~0, this is a removal. + * the egress mapping is applied. For example, is output is MPLS then + * the QoS markings will occur for MPLS pakcets. + */ +extern void qos_egress_map_update (qos_egress_map_id_t tid, + qos_source_t input_source, + qos_bits_t * values); +extern void qos_egress_map_delete (qos_egress_map_id_t tid); + +/** + * Get the VPP QoS map index from the user's map-ID + */ +extern index_t qos_egress_map_find (qos_egress_map_id_t tid); + +/** + * Data-plane functions + */ + +/** + * Pool from which to allocate map + */ +extern qos_egress_map_t *qem_pool; + +#endif + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_mark.c b/src/vnet/qos/qos_mark.c new file mode 100644 index 00000000000..cec7192b018 --- /dev/null +++ b/src/vnet/qos/qos_mark.c @@ -0,0 +1,447 @@ +/* + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include <vnet/ip/ip.h> +#include <vnet/feature/feature.h> +#include <vnet/qos/qos_egress_map.h> +#include <vnet/qos/qos_mark.h> + +/** + * per-interface vector of which MAP is used by which interface + * for each output source + */ +index_t *qos_mark_configs[QOS_N_SOURCES]; + +void +qos_mark_ip_enable_disable (u32 sw_if_index, u8 enable) +{ + vnet_feature_enable_disable ("ip6-output", "ip6-qos-mark", + sw_if_index, enable, NULL, 0); + vnet_feature_enable_disable ("ip4-output", "ip4-qos-mark", + sw_if_index, enable, NULL, 0); +} + +void +qos_mark_vlan_enable_disable (u32 sw_if_index, u8 enable) +{ + vnet_feature_enable_disable ("interface-output", "vlan-qos-mark", + sw_if_index, enable, NULL, 0); +} + +void +qos_mark_mpls_enable_disable (u32 sw_if_index, u8 enable) +{ + vnet_feature_enable_disable ("mpls-output", "mpls-qos-mark", + sw_if_index, enable, NULL, 0); +} + +static void +qos_egress_map_feature_config (u32 sw_if_index, qos_source_t qs, u8 enable) +{ + switch (qs) + { + case QOS_SOURCE_EXT: + ASSERT (0); + break; + case QOS_SOURCE_VLAN: + qos_mark_vlan_enable_disable (sw_if_index, enable); + break; + case QOS_SOURCE_MPLS: + qos_mark_mpls_enable_disable (sw_if_index, enable); + break; + case QOS_SOURCE_IP: + qos_mark_ip_enable_disable (sw_if_index, enable); + break; + } +} + +always_inline qos_egress_map_t * +qos_egress_map_interface (u32 sw_if_index, qos_source_t output_source) +{ + ASSERT (vec_len (qos_mark_configs[output_source]) > sw_if_index); + + return pool_elt_at_index (qem_pool, + qos_mark_configs[output_source][sw_if_index]); +} + +/** + * per-packet trace data + */ +typedef struct qos_mark_trace_t_ +{ + /* per-pkt trace data */ + qos_bits_t bits; + qos_source_t input; + u32 used; +} qos_mark_trace_t; + +static inline uword +qos_mark_inline (vlib_main_t * vm, + vlib_node_runtime_t * node, + vlib_frame_t * frame, qos_source_t output_source, int is_ip6) +{ + u32 n_left_from, *from, *to_next, next_index; + + next_index = 0; + n_left_from = frame->n_vectors; + from = vlib_frame_vector_args (frame); + + while (n_left_from > 0) + { + u32 n_left_to_next; + + vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next); + + while (n_left_from > 0 && n_left_to_next > 0) + { + qos_source_t input_source0; + ethernet_vlan_header_t *vlan0; + u32 sw_if_index0, next0, bi0; + qos_egress_map_t *qem0; + ip4_header_t *ip4_0; + ip6_header_t *ip6_0; + vlib_buffer_t *b0; + qos_bits_t qos0; + u8 *mpls_bytes_0; + u8 eos0; + + next0 = 0; + bi0 = from[0]; + to_next[0] = bi0; + from += 1; + to_next += 1; + n_left_from -= 1; + n_left_to_next -= 1; + + b0 = vlib_get_buffer (vm, bi0); + sw_if_index0 = vnet_buffer (b0)->sw_if_index[VLIB_TX]; + input_source0 = vnet_buffer2 (b0)->qos.source; + + qem0 = qos_egress_map_interface (sw_if_index0, output_source); + qos0 = qem0->qem_output[input_source0][vnet_buffer2 (b0)->qos.bits]; + + if (PREDICT_TRUE (b0->flags & VNET_BUFFER_F_QOS_DATA_VALID)) + { + /* there is a source of QoS recording for this packet */ + if (QOS_SOURCE_IP == output_source) + { + if (is_ip6) + { + ip6_0 = (vlib_buffer_get_current (b0) + + vnet_buffer (b0)->ip.save_rewrite_length); + + ip6_set_traffic_class_network_order (ip6_0, qos0); + } + else + { + ip4_0 = (vlib_buffer_get_current (b0) + + vnet_buffer (b0)->ip.save_rewrite_length); + if (PREDICT_FALSE (qos0 != ip4_0->tos)) + { + ip4_0->tos = qos0; + ip4_0->checksum = ip4_header_checksum (ip4_0); + } + } + } + else if (QOS_SOURCE_MPLS == output_source) + { + mpls_bytes_0 = (vlib_buffer_get_current (b0) + + vnet_buffer (b0)->mpls.save_rewrite_length); + + /* apply to all the labels in the stack */ + do + { + /* clear out the old COS bts */ + mpls_bytes_0[2] &= 0xf1; + /* OR in 3 bits of the mapped value */ + mpls_bytes_0[2] |= (qos0 & 0x7) << 1; + eos0 = mpls_bytes_0[2] & 0x1; + mpls_bytes_0 += 4; + } + while (!eos0); + } + else if (QOS_SOURCE_VLAN == output_source) + { + vlan0 = (vlib_buffer_get_current (b0) + + sizeof (ethernet_header_t)); + + ethernet_vlan_header_set_priority_net_order (vlan0, qos0); + } + } + vnet_feature_next (sw_if_index0, &next0, b0); + + if (PREDICT_FALSE (b0->flags & VLIB_BUFFER_IS_TRACED)) + { + qos_mark_trace_t *t = + vlib_add_trace (vm, node, b0, sizeof (*t)); + t->bits = qos0; + t->input = input_source0; + t->used = (b0->flags & VNET_BUFFER_F_QOS_DATA_VALID); + } + + /* verify speculative enqueue, maybe switch current next frame */ + vlib_validate_buffer_enqueue_x1 (vm, node, next_index, + to_next, n_left_to_next, + bi0, next0); + } + + vlib_put_next_frame (vm, node, next_index, n_left_to_next); + } + + return frame->n_vectors; +} + +/* packet trace format function */ +static u8 * +format_qos_mark_trace (u8 * s, va_list * args) +{ + CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *); + CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *); + qos_mark_trace_t *t = va_arg (*args, qos_mark_trace_t *); + + s = format (s, "source:%U qos:%d used:%s", + format_qos_source, t->input, t->bits, (t->used ? "yes" : "no")); + + return s; +} + +static inline uword +ip4_qos_mark (vlib_main_t * vm, vlib_node_runtime_t * node, + vlib_frame_t * frame) +{ + return (qos_mark_inline (vm, node, frame, QOS_SOURCE_IP, 0)); +} + +static inline uword +ip6_qos_mark (vlib_main_t * vm, vlib_node_runtime_t * node, + vlib_frame_t * frame) +{ + return (qos_mark_inline (vm, node, frame, QOS_SOURCE_IP, 1)); +} + +static inline uword +mpls_qos_mark (vlib_main_t * vm, vlib_node_runtime_t * node, + vlib_frame_t * frame) +{ + return (qos_mark_inline (vm, node, frame, QOS_SOURCE_MPLS, 0)); +} + +static inline uword +vlan_qos_mark (vlib_main_t * vm, vlib_node_runtime_t * node, + vlib_frame_t * frame) +{ + return (qos_mark_inline (vm, node, frame, QOS_SOURCE_VLAN, 0)); +} + +/* *INDENT-OFF* */ +VLIB_REGISTER_NODE (ip4_qos_mark_node) = { + .function = ip4_qos_mark, + .name = "ip4-qos-mark", + .vector_size = sizeof (u32), + .format_trace = format_qos_mark_trace, + .type = VLIB_NODE_TYPE_INTERNAL, + + .n_errors = 0, + .n_next_nodes = 1, + + .next_nodes = { + [0] = "ip4-drop", + }, +}; + +VLIB_NODE_FUNCTION_MULTIARCH (ip4_qos_mark_node, ip4_qos_mark); + +VNET_FEATURE_INIT (ip4_qos_mark_node, static) = { + .arc_name = "ip4-output", + .node_name = "ip4-qos-mark", +}; + +VLIB_REGISTER_NODE (ip6_qos_mark_node) = { + .function = ip6_qos_mark, + .name = "ip6-qos-mark", + .vector_size = sizeof (u32), + .format_trace = format_qos_mark_trace, + .type = VLIB_NODE_TYPE_INTERNAL, + + .n_errors = 0, + .n_next_nodes = 1, + + .next_nodes = { + [0] = "ip6-drop", + }, +}; + +VLIB_NODE_FUNCTION_MULTIARCH (ip6_qos_mark_node, ip6_qos_mark); + +VNET_FEATURE_INIT (ip6_qos_mark_node, static) = { + .arc_name = "ip6-output", + .node_name = "ip6-qos-mark", +}; + +VLIB_REGISTER_NODE (mpls_qos_mark_node) = { + .function = mpls_qos_mark, + .name = "mpls-qos-mark", + .vector_size = sizeof (u32), + .format_trace = format_qos_mark_trace, + .type = VLIB_NODE_TYPE_INTERNAL, + + .n_errors = 0, + .n_next_nodes = 1, + + .next_nodes = { + [0] = "mpls-drop", + }, +}; + +VLIB_NODE_FUNCTION_MULTIARCH (mpls_qos_mark_node, mpls_qos_mark); + +VNET_FEATURE_INIT (mpls_qos_mark_node, static) = { + .arc_name = "mpls-output", + .node_name = "mpls-qos-mark", +}; +VLIB_REGISTER_NODE (vlan_qos_mark_node) = { + .function = vlan_qos_mark, + .name = "vlan-qos-mark", + .vector_size = sizeof (u32), + .format_trace = format_qos_mark_trace, + .type = VLIB_NODE_TYPE_INTERNAL, + + .n_errors = 0, + .n_next_nodes = 1, + + .next_nodes = { + [0] = "error-drop", + }, +}; + +VLIB_NODE_FUNCTION_MULTIARCH (vlan_qos_mark_node, vlan_qos_mark); + +VNET_FEATURE_INIT (vlan_qos_mark_node, static) = { + .arc_name = "interface-output", + .node_name = "vlan-qos-mark", +}; +/* *INDENT-ON* */ + +int +qos_mark_enable (u32 sw_if_index, + qos_source_t output_source, qos_egress_map_id_t mid) +{ + index_t qemi; + + vec_validate_init_empty (qos_mark_configs[output_source], + sw_if_index, INDEX_INVALID); + + qemi = qos_egress_map_find (mid); + + if (INDEX_INVALID == qemi) + return VNET_API_ERROR_NO_SUCH_TABLE; + + if (INDEX_INVALID == qos_mark_configs[output_source][sw_if_index]) + { + qos_egress_map_feature_config (sw_if_index, output_source, 1); + } + + qos_mark_configs[output_source][sw_if_index] = qemi; + + return (0); +} + +int +qos_mark_disable (u32 sw_if_index, qos_source_t output_source) +{ + if (vec_len (qos_mark_configs[output_source]) < sw_if_index) + return VNET_API_ERROR_NO_MATCHING_INTERFACE; + if (INDEX_INVALID == qos_mark_configs[output_source][sw_if_index]) + return VNET_API_ERROR_VALUE_EXIST; + + if (INDEX_INVALID != qos_mark_configs[output_source][sw_if_index]) + { + qos_egress_map_feature_config (sw_if_index, output_source, 0); + } + + qos_mark_configs[output_source][sw_if_index] = INDEX_INVALID; + + return (0); +} + +static clib_error_t * +qos_mark_cli (vlib_main_t * vm, + unformat_input_t * input, vlib_cli_command_t * cmd) +{ + qos_egress_map_id_t map_id; + u32 sw_if_index, qs; + vnet_main_t *vnm; + int rv, enable; + + vnm = vnet_get_main (); + map_id = ~0; + qs = 0xff; + enable = 1; + + while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) + { + if (unformat (input, "id %d", &map_id)) + ; + else if (unformat (input, "disable")) + enable = 0; + else if (unformat (input, "%U", unformat_qos_source, &qs)) + ; + else if (unformat (input, "%U", + unformat_vnet_sw_interface, vnm, &sw_if_index)) + ; + else + break; + } + + if (~0 == sw_if_index) + return clib_error_return (0, "interface must be specified"); + if (0xff == qs) + return clib_error_return (0, "output location must be specified"); + + if (enable) + rv = qos_mark_enable (sw_if_index, qs, map_id); + else + rv = qos_mark_disable (sw_if_index, qs); + + if (0 == rv) + return (NULL); + + return clib_error_return (0, "Failed to map interface"); +} + +/*? + * Apply a QoS egress mapping table to an interface for QoS marking packets + * at the given output protocol. + * + * @cliexpar + * @cliexcmd{qos egress interface GigEthernet0/9/0 id 0 output ip} + ?*/ +/* *INDENT-OFF* */ +VLIB_CLI_COMMAND (qos_egress_map_interface_command, static) = { + .path = "qos mark", + .short_help = "qos mark <SOURCE> <INTERFACE> id <MAP>", + .function = qos_mark_cli, + .is_mp_safe = 1, +}; +/* *INDENT-ON* */ + +/* + * fd.io coding-style-patch-verification: ON + * +* Local Variables: +* eval: (c-set-style "gnu") +* End: +* +*/ diff --git a/src/vnet/qos/qos_mark.h b/src/vnet/qos/qos_mark.h new file mode 100644 index 00000000000..f1705d1bb33 --- /dev/null +++ b/src/vnet/qos/qos_mark.h @@ -0,0 +1,39 @@ +/* + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef __QOS_MARK_H__ +#define __QOS_MARK_H__ + +#include <vnet/qos/qos_egress_map.h> + +/** + * enable QoS marking by associating a MAP with an interface. + * The output_source specifies which protocol/header the QoS value + * will be written into + */ +extern int qos_mark_enable (u32 sw_if_index, + qos_source_t output_source, + qos_egress_map_id_t tid); +extern int qos_mark_disable (u32 sw_if_index, qos_source_t output_source); + +#endif + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_record.c b/src/vnet/qos/qos_record.c new file mode 100644 index 00000000000..047bd25cda4 --- /dev/null +++ b/src/vnet/qos/qos_record.c @@ -0,0 +1,326 @@ +/* + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include <vnet/qos/qos_record.h> +#include <vnet/ip/ip.h> +#include <vnet/ip/ip6_to_ip4.h> +#include <vnet/feature/feature.h> +#include <vnet/qos/qos_types.h> + +/** + * Per-interface, per-protocol vector of feature on/off configurations + */ +static u8 *qos_record_configs[QOS_N_SOURCES]; + +static void +qos_record_feature_config (u32 sw_if_index, + qos_source_t input_source, u8 enable) +{ + switch (input_source) + { + case QOS_SOURCE_IP: + vnet_feature_enable_disable ("ip6-unicast", "ip6-qos-record", + sw_if_index, enable, NULL, 0); + vnet_feature_enable_disable ("ip6-multicast", "ip6-qos-record", + sw_if_index, enable, NULL, 0); + vnet_feature_enable_disable ("ip4-unicast", "ip4-qos-record", + sw_if_index, enable, NULL, 0); + vnet_feature_enable_disable ("ip4-multicast", "ip4-qos-record", + sw_if_index, enable, NULL, 0); + break; + case QOS_SOURCE_MPLS: + case QOS_SOURCE_VLAN: + case QOS_SOURCE_EXT: + // not implemented yet + break; + } +} + +int +qos_record_enable (u32 sw_if_index, qos_source_t input_source) +{ + vec_validate (qos_record_configs[input_source], sw_if_index); + + if (0 == qos_record_configs[input_source][sw_if_index]) + { + qos_record_feature_config (sw_if_index, input_source, 1); + } + + qos_record_configs[input_source][sw_if_index]++; + return (0); +} + +int +qos_record_disable (u32 sw_if_index, qos_source_t input_source) +{ + if (vec_len (qos_record_configs[input_source]) < sw_if_index) + return VNET_API_ERROR_NO_MATCHING_INTERFACE; + + if (0 == qos_record_configs[input_source][sw_if_index]) + return VNET_API_ERROR_VALUE_EXIST; + + qos_record_configs[input_source][sw_if_index]--; + + if (0 == qos_record_configs[input_source][sw_if_index]) + { + qos_record_feature_config (sw_if_index, input_source, 0); + } + + return (0); +} + +/* + * Disable recording feautre for all protocols when the interface + * is deleted + */ +static clib_error_t * +qos_record_ip_interface_add_del (vnet_main_t * vnm, + u32 sw_if_index, u32 is_add) +{ + if (!is_add) + { + qos_source_t qs; + + FOR_EACH_QOS_SOURCE (qs) + { + qos_record_disable (sw_if_index, qs); + } + } + + return (NULL); +} + +VNET_SW_INTERFACE_ADD_DEL_FUNCTION (qos_record_ip_interface_add_del); + +/** + * per-packet trace data + */ +typedef struct qos_record_trace_t_ +{ + /* per-pkt trace data */ + qos_bits_t bits; +} qos_record_trace_t; + +static inline uword +qos_record_inline (vlib_main_t * vm, + vlib_node_runtime_t * node, + vlib_frame_t * frame, int is_ip6) +{ + u32 n_left_from, *from, *to_next, next_index; + + next_index = 0; + n_left_from = frame->n_vectors; + from = vlib_frame_vector_args (frame); + + while (n_left_from > 0) + { + u32 n_left_to_next; + + vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next); + + while (n_left_from > 0 && n_left_to_next > 0) + { + ip4_header_t *ip4_0; + ip6_header_t *ip6_0; + vlib_buffer_t *b0; + u32 sw_if_index0, next0, bi0; + qos_bits_t qos0; + + next0 = 0; + bi0 = from[0]; + to_next[0] = bi0; + from += 1; + to_next += 1; + n_left_from -= 1; + n_left_to_next -= 1; + + b0 = vlib_get_buffer (vm, bi0); + if (is_ip6) + { + ip6_0 = vlib_buffer_get_current (b0); + qos0 = ip6_traffic_class_network_order (ip6_0); + } + else + { + ip4_0 = vlib_buffer_get_current (b0); + qos0 = ip4_0->tos; + } + vnet_buffer2 (b0)->qos.bits = qos0; + vnet_buffer2 (b0)->qos.source = QOS_SOURCE_IP; + b0->flags |= VNET_BUFFER_F_QOS_DATA_VALID; + sw_if_index0 = vnet_buffer (b0)->sw_if_index[VLIB_RX]; + + vnet_feature_next (sw_if_index0, &next0, b0); + + if (PREDICT_FALSE ((node->flags & VLIB_NODE_FLAG_TRACE) && + (b0->flags & VLIB_BUFFER_IS_TRACED))) + { + qos_record_trace_t *t = + vlib_add_trace (vm, node, b0, sizeof (*t)); + t->bits = qos0; + } + + /* verify speculative enqueue, maybe switch current next frame */ + vlib_validate_buffer_enqueue_x1 (vm, node, next_index, + to_next, n_left_to_next, + bi0, next0); + } + + vlib_put_next_frame (vm, node, next_index, n_left_to_next); + } + + return frame->n_vectors; +} + +/* packet trace format function */ +static u8 * +format_qos_record_trace (u8 * s, va_list * args) +{ + CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *); + CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *); + qos_record_trace_t *t = va_arg (*args, qos_record_trace_t *); + + s = format (s, "qos:%d", t->bits); + + return s; +} + +static inline uword +ip4_qos_record (vlib_main_t * vm, vlib_node_runtime_t * node, + vlib_frame_t * frame) +{ + return (qos_record_inline (vm, node, frame, 0)); +} + +static inline uword +ip6_qos_record (vlib_main_t * vm, vlib_node_runtime_t * node, + vlib_frame_t * frame) +{ + return (qos_record_inline (vm, node, frame, 1)); +} + +/* *INDENT-OFF* */ +VLIB_REGISTER_NODE (ip4_qos_record_node) = { + .function = ip4_qos_record, + .name = "ip4-qos-record", + .vector_size = sizeof (u32), + .format_trace = format_qos_record_trace, + .type = VLIB_NODE_TYPE_INTERNAL, + + .n_errors = 0, + .n_next_nodes = 1, + + .next_nodes = { + [0] = "ip4-drop", + }, +}; + +VLIB_NODE_FUNCTION_MULTIARCH (ip4_qos_record_node, ip4_qos_record); + +VNET_FEATURE_INIT (ip4_qos_record_node, static) = { + .arc_name = "ip4-unicast", + .node_name = "ip4-qos-record", +}; + +VLIB_REGISTER_NODE (ip6_qos_record_node) = { + .function = ip6_qos_record, + .name = "ip6-qos-record", + .vector_size = sizeof (u32), + .format_trace = format_qos_record_trace, + .type = VLIB_NODE_TYPE_INTERNAL, + + .n_errors = 0, + .n_next_nodes = 1, + + .next_nodes = { + [0] = "ip6-drop", + }, +}; + +VLIB_NODE_FUNCTION_MULTIARCH (ip6_qos_record_node, ip6_qos_record); + +VNET_FEATURE_INIT (ip6_qos_record_node, static) = { + .arc_name = "ip6-unicast", + .node_name = "ip6-qos-record", +}; +/* *INDENT-ON* */ + + +static clib_error_t * +qos_record_cli (vlib_main_t * vm, + unformat_input_t * input, vlib_cli_command_t * cmd) +{ + vnet_main_t *vnm = vnet_get_main (); + u32 sw_if_index, qs; + u8 enable; + + qs = 0xff; + enable = 1; + sw_if_index = ~0; + + while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) + { + if (unformat (input, "%U", unformat_vnet_sw_interface, + vnm, &sw_if_index)) + ; + else if (unformat (input, "%U", unformat_qos_source, &qs)) + ; + else if (unformat (input, "enable")) + enable = 1; + else if (unformat (input, "disable")) + enable = 0; + else + break; + } + + if (~0 == sw_if_index) + return clib_error_return (0, "interface must be specified"); + if (0xff == qs) + return clib_error_return (0, "input location must be specified"); + + if (enable) + qos_record_enable (sw_if_index, qs); + else + qos_record_disable (sw_if_index, qs); + + return (NULL); +} + +/*? + * Enable QoS bit recording on an interface using the packet's input DSCP bits + * Which input QoS bits to use are either; IP, MPLS or VLAN. If more than + * one protocol is chosen (which is foolish) the higer layers override the + * lower. + * + * @cliexpar + * @cliexcmd{qos record ip GigEthernet0/1/0} + ?*/ +/* *INDENT-OFF* */ +VLIB_CLI_COMMAND (qos_record_command, static) = { + .path = "qos record", + .short_help = "qos record <record-source> <INTERFACE> [disable]", + .function = qos_record_cli, + .is_mp_safe = 1, +}; +/* *INDENT-ON* */ + + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_record.h b/src/vnet/qos/qos_record.h new file mode 100644 index 00000000000..e5726d650a7 --- /dev/null +++ b/src/vnet/qos/qos_record.h @@ -0,0 +1,32 @@ +/* + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef __QOS_RECORD_H__ +#define __QOS_RECORD_H__ + +#include <vnet/qos/qos_types.h> + +extern int qos_record_disable (u32 sw_if_index, qos_source_t input_source); +extern int qos_record_enable (u32 sw_if_index, qos_source_t input_source); + +#endif + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_types.c b/src/vnet/qos/qos_types.c new file mode 100644 index 00000000000..9fe10cb483d --- /dev/null +++ b/src/vnet/qos/qos_types.c @@ -0,0 +1,59 @@ +/* + *------------------------------------------------------------------ + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + *------------------------------------------------------------------ + */ + +/** + * QoS tyeps + */ + +#include <vnet/qos/qos_types.h> + +static const char *qos_source_names[] = QOS_SOURCE_NAMES; + +u8 * +format_qos_source (u8 * s, va_list * args) +{ + int qs = va_arg (*args, int); + + return (format (s, "%s", qos_source_names[qs])); +} + +uword +unformat_qos_source (unformat_input_t * input, va_list * args) +{ + int *qs = va_arg (*args, int *); + + if (unformat (input, "ip")) + *qs = QOS_SOURCE_IP; + else if (unformat (input, "mpls")) + *qs = QOS_SOURCE_MPLS; + else if (unformat (input, "ext")) + *qs = QOS_SOURCE_EXT; + else if (unformat (input, "vlan")) + *qs = QOS_SOURCE_VLAN; + else + return 0; + + return 1; +} + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ diff --git a/src/vnet/qos/qos_types.h b/src/vnet/qos/qos_types.h new file mode 100644 index 00000000000..6934d041cd8 --- /dev/null +++ b/src/vnet/qos/qos_types.h @@ -0,0 +1,78 @@ +/* + *------------------------------------------------------------------ + * Copyright (c) 2018 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + *------------------------------------------------------------------ + */ + +/** + * QoS tyeps + */ + +#ifndef __QOS_TYPES_H__ +#define __QOS_TYPES_H__ + +#include <vnet/vnet.h> + +/** + * Sources for the QoS bits in the packet + */ +typedef enum qos_source_t_ +{ + /** + * Some external source, e.g. a plugin. + */ + QOS_SOURCE_EXT, + QOS_SOURCE_VLAN, + QOS_SOURCE_MPLS, + QOS_SOURCE_IP, +} __attribute__ ((packed)) qos_source_t; + +/** + * The maximum number of sources. defined outside the enum so switch + * statements don't need to handle a non-value nor use a default label + */ +#define QOS_N_SOURCES (QOS_SOURCE_IP + 1) + +#define QOS_SOURCE_NAMES { \ + [QOS_SOURCE_EXT] = "ext", \ + [QOS_SOURCE_IP] = "IP", \ + [QOS_SOURCE_MPLS] = "MPLS", \ + [QOS_SOURCE_VLAN] = "VLAN", \ +} + +#define FOR_EACH_QOS_SOURCE(_src) \ + for (_src = QOS_SOURCE_EXT; \ + _src <= QOS_SOURCE_IP; \ + _src++) + +/** + * format/unformat QoS source types + */ +extern u8 *format_qos_source (u8 * s, va_list * args); +extern uword unformat_qos_source (unformat_input_t * input, va_list * args); + +/** + * Type, er, safety for us water based entities + */ +typedef u8 qos_bits_t; + +#endif + +/* + * fd.io coding-style-patch-verification: ON + * + * Local Variables: + * eval: (c-set-style "gnu") + * End: + */ |