blob: d1f308011b8fcb6925eecbb91864ed424a8dd0a3 [file] [log] [blame]
/*
* Copyright (c) 2015 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 __included_vnet_flow_report_h__
#define __included_vnet_flow_report_h__
#include <vlib/vlib.h>
#include <vnet/vnet.h>
#include <vnet/ethernet/ethernet.h>
#include <vnet/ethernet/packet.h>
#include <vnet/ip/ip_packet.h>
#include <vnet/ip/ip4_packet.h>
#include <vnet/ip/ip6_packet.h>
#include <vnet/udp/udp_packet.h>
#include <vlib/cli.h>
#include <vppinfra/error.h>
#include <vppinfra/hash.h>
#include <vppinfra/cache.h>
#include <vnet/ipfix-export/ipfix_packet.h>
/* ipfix field definitions for a particular report */
typedef struct
{
u32 info_element;
u32 size;
} ipfix_report_element_t;
/* Used to build the rewrite */
typedef struct
{
ip4_header_t ip4;
udp_header_t udp;
ipfix_template_packet_t ipfix;
} ip4_ipfix_template_packet_t;
struct flow_report_main;
struct flow_report;
typedef vlib_frame_t *(vnet_flow_data_callback_t) (struct flow_report_main *,
struct flow_report *,
vlib_frame_t *, u32 *,
u32);
typedef u8 *(vnet_flow_rewrite_callback_t) (struct flow_report_main *,
struct flow_report *,
ip4_address_t *,
ip4_address_t *, u16,
ipfix_report_element_t * elts,
u32 n_elts, u32 * stream_index);
u8 *vnet_flow_rewrite_generic_callback (struct flow_report_main *,
struct flow_report *,
ip4_address_t *,
ip4_address_t *, u16,
ipfix_report_element_t * elts,
u32 n_elts, u32 * stream_index);
typedef union
{
void *as_ptr;
uword as_uword;
} opaque_t;
typedef struct
{
u32 domain_id;
u32 sequence_number;
u16 src_port;
u16 n_reports;
u16 next_template_no;
} flow_report_stream_t;
typedef struct flow_report
{
/* ipfix rewrite, set by callback */
u8 *rewrite;
u16 template_id;
u32 stream_index;
f64 last_template_sent;
int update_rewrite;
/* Bitmap of fields to send */
uword *fields_to_send;
/* Opaque data */
opaque_t opaque;
/* build-the-template-packet rewrite callback */
vnet_flow_rewrite_callback_t *rewrite_callback;
ipfix_report_element_t *report_elements;
u32 n_report_elements;
u32 *stream_indexp;
/* Send-flow-data callback */
vnet_flow_data_callback_t *flow_data_callback;
} flow_report_t;
/*
* The maximum number of ipfix exporters we can have at once
*/
#define IPFIX_EXPORTERS_MAX 5
/*
* We support multiple exporters. Each one has its own configured
* destination, and its own set of reports and streams.
*/
typedef struct ipfix_exporter
{
flow_report_t *reports;
flow_report_stream_t *streams;
/* ipfix collector ip address, port, our ip address, fib index */
ip4_address_t ipfix_collector;
u16 collector_port;
ip4_address_t src_address;
u32 fib_index;
/* Path MTU */
u32 path_mtu;
/* time interval in seconds after which to resend templates */
u32 template_interval;
/* UDP checksum calculation enable flag */
u8 udp_checksum;
} ipfix_exporter_t;
typedef struct flow_report_main
{
/*
* A pool of the exporters. Entry 0 is always there for backwards
* compatability reasons. Entries 1 and above have to be created by
* the users.
*/
ipfix_exporter_t *exporters;
/* time scale transform. Joy. */
u32 unix_time_0;
f64 vlib_time_0;
/* convenience variables */
vlib_main_t *vlib_main;
vnet_main_t *vnet_main;
u16 msg_id_base;
} flow_report_main_t;
extern flow_report_main_t flow_report_main;
extern vlib_node_registration_t flow_report_process_node;
typedef struct
{
vnet_flow_data_callback_t *flow_data_callback;
vnet_flow_rewrite_callback_t *rewrite_callback;
ipfix_report_element_t *report_elements;
u32 n_report_elements;
opaque_t opaque;
int is_add;
u32 domain_id;
u16 src_port;
u32 *stream_indexp;
} vnet_flow_report_add_del_args_t;
int vnet_flow_report_add_del (flow_report_main_t * frm,
vnet_flow_report_add_del_args_t * a,
u16 * template_id);
clib_error_t *flow_report_add_del_error_to_clib_error (int error);
void vnet_flow_reports_reset (flow_report_main_t * frm);
void vnet_stream_reset (flow_report_main_t * frm, u32 stream_index);
int vnet_stream_change (flow_report_main_t * frm,
u32 old_domain_id, u16 old_src_port,
u32 new_domain_id, u16 new_src_port);
#endif /* __included_vnet_flow_report_h__ */
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/