[mirror_frr.git] / pbrd / pbr_map.c

/*
 * PBR-map Code
 * Copyright (C) 2018 Cumulus Networks, Inc.
 *               Donald Sharp
 *
 * FRR is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License as published by the
 * Free Software Foundation; either version 2, or (at your option) any
 * later version.
 *
 * FRR is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; see the file COPYING; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
 */
#include <zebra.h>

#include "thread.h"
#include "linklist.h"
#include "prefix.h"
#include "table.h"
#include "vrf.h"
#include "nexthop.h"
#include "nexthop_group.h"
#include "memory.h"
#include "log.h"
#include "vty.h"

#include "pbr_nht.h"
#include "pbr_map.h"
#include "pbr_zebra.h"
#include "pbr_memory.h"
#include "pbr_debug.h"

DEFINE_MTYPE_STATIC(PBRD, PBR_MAP, "PBR Map")
DEFINE_MTYPE_STATIC(PBRD, PBR_MAP_SEQNO, "PBR Map Sequence")
DEFINE_MTYPE_STATIC(PBRD, PBR_MAP_INTERFACE, "PBR Map Interface")

static uint32_t pbr_map_sequence_unique;

static inline int pbr_map_compare(const struct pbr_map *pbrmap1,
				  const struct pbr_map *pbrmap2);

RB_GENERATE(pbr_map_entry_head, pbr_map, pbr_map_entry, pbr_map_compare)

struct pbr_map_entry_head pbr_maps = RB_INITIALIZER(&pbr_maps);

DEFINE_QOBJ_TYPE(pbr_map_sequence)

static inline int pbr_map_compare(const struct pbr_map *pbrmap1,
				  const struct pbr_map *pbrmap2)
{
	return strcmp(pbrmap1->name, pbrmap2->name);
}

static int pbr_map_sequence_compare(const struct pbr_map_sequence *pbrms1,
				    const struct pbr_map_sequence *pbrms2)
{
	if (pbrms1->seqno == pbrms2->seqno)
		return 0;

	if (pbrms1->seqno < pbrms2->seqno)
		return -1;

	return 1;
}

static void pbr_map_sequence_delete(struct pbr_map_sequence *pbrms)
{
	if (pbrms->internal_nhg_name)
		XFREE(MTYPE_TMP, pbrms->internal_nhg_name);

	XFREE(MTYPE_PBR_MAP_SEQNO, pbrms);
}

static int pbr_map_interface_compare(const struct pbr_map_interface *pmi1,
				     const struct pbr_map_interface *pmi2)
{
	return strcmp(pmi1->ifp->name, pmi2->ifp->name);
}

static void pbr_map_interface_list_delete(struct pbr_map_interface *pmi)
{
	struct pbr_map_interface *pmi_int;
	struct listnode *node, *nnode;
	struct pbr_map *pbrm;

	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
		for (ALL_LIST_ELEMENTS(pbrm->incoming, node, nnode, pmi_int)) {
			if (pmi == pmi_int) {
				pbr_map_policy_delete(pbrm, pmi);
				return;
			}
		}
	}
}

static const char *pbr_map_reason_str[] = {
	"Invalid NH-group",     "Invalid NH",	 "No Nexthops",
	"Both NH and NH-Group", "Invalid Src or Dst", "Deleting Sequence",
};

void pbr_map_reason_string(unsigned int reason, char *buf, int size)
{
	unsigned int bit;
	int len = 0;

	if (!buf)
		return;

	for (bit = 0; bit < array_size(pbr_map_reason_str); bit++) {
		if ((reason & (1 << bit)) && (len < size)) {
			len += snprintf((buf + len), (size - len), "%s%s",
					(len > 0) ? ", " : "",
					pbr_map_reason_str[bit]);
		}
	}
}


void pbr_map_interface_delete(struct pbr_map *pbrm, struct interface *ifp_del)
{

	struct listnode *node;
	struct pbr_map_interface *pmi;

	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, node, pmi)) {
		if (ifp_del == pmi->ifp)
			break;
	}

	if (pmi)
		pbr_map_policy_delete(pbrm, pmi);
}

void pbr_map_add_interface(struct pbr_map *pbrm, struct interface *ifp_add)
{
	struct listnode *node;
	struct pbr_map_interface *pmi;

	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, node, pmi)) {
		if (ifp_add == pmi->ifp)
			return;
	}

	pmi = XCALLOC(MTYPE_PBR_MAP_INTERFACE, sizeof(*pmi));
	pmi->ifp = ifp_add;
	pmi->pbrm = pbrm;
	listnode_add_sort(pbrm->incoming, pmi);

	bf_assign_index(pbrm->ifi_bitfield, pmi->install_bit);
	pbr_map_check_valid(pbrm->name);
	if (pbrm->valid)
		pbr_map_install(pbrm);
}

void pbr_map_write_interfaces(struct vty *vty, struct interface *ifp)
{
	struct pbr_interface *pbr_ifp = ifp->info;

	if (pbr_ifp
	    && strncmp(pbr_ifp->mapname, "", sizeof(pbr_ifp->mapname)) != 0)
		vty_out(vty, " pbr-policy %s\n", pbr_ifp->mapname);
}

struct pbr_map *pbrm_find(const char *name)
{
	struct pbr_map pbrm;

	strlcpy(pbrm.name, name, sizeof(pbrm.name));

	return RB_FIND(pbr_map_entry_head, &pbr_maps, &pbrm);
}

extern void pbr_map_delete(struct pbr_map_sequence *pbrms)
{
	struct pbr_map *pbrm;
	struct listnode *inode;
	struct pbr_map_interface *pmi;

	pbrm = pbrms->parent;

	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi))
		pbr_send_pbr_map(pbrms, pmi, false);

	if (pbrms->nhg)
		pbr_nht_delete_individual_nexthop(pbrms);

	listnode_delete(pbrm->seqnumbers, pbrms);

	if (pbrm->seqnumbers->count == 0) {
		RB_REMOVE(pbr_map_entry_head, &pbr_maps, pbrm);

		bf_free(pbrm->ifi_bitfield);
		XFREE(MTYPE_PBR_MAP, pbrm);
	}
}

void pbr_map_delete_nexthop_group(struct pbr_map_sequence *pbrms)
{
	struct pbr_map *pbrm = pbrms->parent;
	struct listnode *node;
	struct pbr_map_interface *pmi;

	if (pbrm->valid && pbrms->nhs_installed && pbrm->incoming->count) {
		for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, node, pmi))
			pbr_send_pbr_map(pbrms, pmi, false);
	}

	pbrm->valid = false;
	pbrms->nhs_installed = false;
	pbrms->reason |= PBR_MAP_INVALID_NO_NEXTHOPS;
	pbrms->nhgrp_name = NULL;
}

struct pbr_map_sequence *pbrms_lookup_unique(uint32_t unique, ifindex_t ifindex,
					     struct pbr_map_interface **ppmi)
{
	struct pbr_map_sequence *pbrms;
	struct listnode *snode, *inode;
	struct pbr_map_interface *pmi;
	struct pbr_map *pbrm;

	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
		for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi)) {
			if (pmi->ifp->ifindex != ifindex)
				continue;

			if (ppmi)
				*ppmi = pmi;

			for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, snode,
						  pbrms)) {
				DEBUGD(&pbr_dbg_map, "%s: Comparing %u to %u",
				       __PRETTY_FUNCTION__, pbrms->unique,
				       unique);
				if (pbrms->unique == unique)
					return pbrms;
			}
		}
	}

	return NULL;
}

static void pbr_map_add_interfaces(struct pbr_map *pbrm)
{
	struct interface *ifp;
	struct pbr_interface *pbr_ifp;
	struct vrf *vrf;

	RB_FOREACH (vrf, vrf_name_head, &vrfs_by_name) {
		FOR_ALL_INTERFACES (vrf, ifp) {
			if (ifp->info) {
				pbr_ifp = ifp->info;
				if (strcmp(pbrm->name, pbr_ifp->mapname) == 0)
					pbr_map_add_interface(pbrm, ifp);
			}
		}
	}
}

struct pbr_map_sequence *pbrms_get(const char *name, uint32_t seqno)
{
	struct pbr_map *pbrm;
	struct pbr_map_sequence *pbrms;
	struct listnode *node;

	pbrm = pbrm_find(name);
	if (!pbrm) {
		pbrm = XCALLOC(MTYPE_PBR_MAP, sizeof(*pbrm));
		snprintf(pbrm->name, sizeof(pbrm->name), "%s", name);

		pbrm->seqnumbers = list_new();
		pbrm->seqnumbers->cmp =
			(int (*)(void *, void *))pbr_map_sequence_compare;
		pbrm->seqnumbers->del =
			 (void (*)(void *))pbr_map_sequence_delete;

		pbrm->incoming = list_new();
		pbrm->incoming->cmp =
			(int (*)(void *, void *))pbr_map_interface_compare;
		pbrm->incoming->del =
			(void (*)(void *))pbr_map_interface_list_delete;

		RB_INSERT(pbr_map_entry_head, &pbr_maps, pbrm);

		bf_init(pbrm->ifi_bitfield, 64);
		pbr_map_add_interfaces(pbrm);
	}

	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
		if (pbrms->seqno == seqno)
			break;

	}

	if (!pbrms) {
		pbrms = XCALLOC(MTYPE_PBR_MAP_SEQNO, sizeof(*pbrms));
		pbrms->unique = pbr_map_sequence_unique++;
		pbrms->seqno = seqno;
		pbrms->ruleno = pbr_nht_get_next_rule(seqno);
		pbrms->parent = pbrm;
		pbrms->reason =
			PBR_MAP_INVALID_SRCDST |
			PBR_MAP_INVALID_NO_NEXTHOPS;

		QOBJ_REG(pbrms, pbr_map_sequence);
		listnode_add_sort(pbrm->seqnumbers, pbrms);
	}

	return pbrms;
}

static void
pbr_map_sequence_check_nexthops_valid(struct pbr_map_sequence *pbrms)
{
	/*
	 * Check validness of the nexthop or nexthop-group
	 */
	if (!pbrms->nhg && !pbrms->nhgrp_name)
		pbrms->reason |= PBR_MAP_INVALID_NO_NEXTHOPS;

	if (pbrms->nhg && pbrms->nhgrp_name)
		pbrms->reason |= PBR_MAP_INVALID_BOTH_NHANDGRP;

	if (pbrms->nhg &&
	    !pbr_nht_nexthop_group_valid(pbrms->internal_nhg_name))
		pbrms->reason |= PBR_MAP_INVALID_NEXTHOP;

	if (pbrms->nhgrp_name) {
		if (!pbr_nht_nexthop_group_valid(pbrms->nhgrp_name))
			pbrms->reason |= PBR_MAP_INVALID_NEXTHOP_GROUP;
		else
			pbrms->nhs_installed = true;
	}
}

static void pbr_map_sequence_check_src_dst_valid(struct pbr_map_sequence *pbrms)
{
	if (!pbrms->src && !pbrms->dst)
		pbrms->reason |= PBR_MAP_INVALID_SRCDST;
}

/*
 * Checks to see if we think that the pbmrs is valid.  If we think
 * the config is valid return true.
 */
static void pbr_map_sequence_check_valid(struct pbr_map_sequence *pbrms)
{
	pbr_map_sequence_check_nexthops_valid(pbrms);

	pbr_map_sequence_check_src_dst_valid(pbrms);
}

static bool pbr_map_check_valid_internal(struct pbr_map *pbrm)
{
	struct pbr_map_sequence *pbrms;
	struct listnode *node;

	pbrm->valid = true;
	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
		pbrms->reason = 0;
		pbr_map_sequence_check_valid(pbrms);
		/*
		 * A pbr_map_sequence that is invalid causes
		 * the whole shebang to be invalid
		 */
		if (pbrms->reason != 0)
			pbrm->valid = false;
	}

	return pbrm->valid;
}

/*
 * For a given PBR-MAP check to see if we think it is a
 * valid config or not.  If so note that it is and return
 * that we are valid.
 */
bool pbr_map_check_valid(const char *name)
{
	struct pbr_map *pbrm;

	pbrm = pbrm_find(name);
	if (!pbrm) {
		DEBUGD(&pbr_dbg_map,
		       "%s: Specified PBR-MAP(%s) does not exist?",
		       __PRETTY_FUNCTION__, name);
		return false;
	}

	pbr_map_check_valid_internal(pbrm);
	return pbrm->valid;
}

void pbr_map_schedule_policy_from_nhg(const char *nh_group)
{
	struct pbr_map_sequence *pbrms;
	struct pbr_map *pbrm;
	struct listnode *node;

	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
		DEBUGD(&pbr_dbg_map, "%s: Looking at %s", __PRETTY_FUNCTION__,
		       pbrm->name);
		for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
			DEBUGD(&pbr_dbg_map, "\tNH Grp name: %s",
			       pbrms->nhgrp_name ? pbrms->nhgrp_name : "NULL");

			if (pbrms->nhgrp_name
			    && (strcmp(nh_group, pbrms->nhgrp_name) == 0)) {
				pbrms->nhs_installed = true;

				pbr_map_check(pbrms);
			}

			if (pbrms->nhg
			    && (strcmp(nh_group, pbrms->internal_nhg_name)
				== 0)) {
				pbrms->nhs_installed = true;

				pbr_map_check(pbrms);
			}
		}
	}
}

void pbr_map_policy_install(const char *name)
{
	struct pbr_map_sequence *pbrms;
	struct pbr_map *pbrm;
	struct listnode *node, *inode;
	struct pbr_map_interface *pmi;

	DEBUGD(&pbr_dbg_map, "%s: for %s", __PRETTY_FUNCTION__, name);
	pbrm = pbrm_find(name);
	if (!pbrm)
		return;

	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
		DEBUGD(&pbr_dbg_map,
		       "%s: Looking at what to install %s(%u) %d %d",
		       __PRETTY_FUNCTION__, name, pbrms->seqno, pbrm->valid,
		       pbrms->nhs_installed);

		if (pbrm->valid && pbrms->nhs_installed && pbrm->incoming->count) {
			DEBUGD(&pbr_dbg_map, "\tInstalling %s %u",
			       pbrm->name, pbrms->seqno);
			for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi))
				pbr_send_pbr_map(pbrms, pmi, true);
		}
	}
}

void pbr_map_policy_delete(struct pbr_map *pbrm, struct pbr_map_interface *pmi)
{
	struct listnode *node;
	struct pbr_map_sequence *pbrms;


	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms))
		pbr_send_pbr_map(pbrms, pmi, false);

	listnode_delete(pbrm->incoming, pmi);
	pmi->pbrm = NULL;

	bf_release_index(pbrm->ifi_bitfield, pmi->install_bit);
	XFREE(MTYPE_PBR_MAP_INTERFACE, pmi);
}

/*
 * For a nexthop group specified, see if any of the pbr-maps
 * are using it and if so, check to see that we are still
 * valid for usage.  If we are valid then schedule the installation/deletion
 * of the pbr-policy.
 */
void pbr_map_check_nh_group_change(const char *nh_group)
{
	struct pbr_map_sequence *pbrms;
	struct pbr_map *pbrm;
	struct listnode *node, *inode;
	struct pbr_map_interface *pmi;
	bool found_name;

	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
		for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
			found_name = false;
			if (pbrms->nhgrp_name)
				found_name =
					!strcmp(nh_group, pbrms->nhgrp_name);
			else if (pbrms->nhg)
				found_name = !strcmp(nh_group,
						     pbrms->internal_nhg_name);

			if (found_name) {
				bool original = pbrm->valid;

				pbr_map_check_valid_internal(pbrm);

				if (pbrm->valid && (original != pbrm->valid))
					pbr_map_install(pbrm);

				if (pbrm->valid == false)
					for (ALL_LIST_ELEMENTS_RO(
						     pbrm->incoming, inode,
						     pmi))
						pbr_send_pbr_map(pbrms, pmi,
								 false);
			}
		}
	}
}

void pbr_map_check(struct pbr_map_sequence *pbrms)
{
	struct pbr_map *pbrm;
	struct listnode *inode;
	struct pbr_map_interface *pmi;
	bool install;

	pbrm = pbrms->parent;
	DEBUGD(&pbr_dbg_map, "%s: for %s(%u)", __PRETTY_FUNCTION__,
	       pbrm->name, pbrms->seqno);
	if (pbr_map_check_valid(pbrm->name))
		DEBUGD(&pbr_dbg_map, "We are totally valid %s\n",
		       pbrm->name);

	DEBUGD(&pbr_dbg_map, "%s: Installing %s(%u) reason: %" PRIu64,
	       __PRETTY_FUNCTION__, pbrm->name, pbrms->seqno, pbrms->reason);

	if (pbrms->reason == PBR_MAP_VALID_SEQUENCE_NUMBER) {
		install = true;
		DEBUGD(&pbr_dbg_map, "%s: Installing %s(%u) reason: %" PRIu64,
		       __PRETTY_FUNCTION__, pbrm->name, pbrms->seqno,
		       pbrms->reason);
		DEBUGD(&pbr_dbg_map,
		       "\tSending PBR_MAP_POLICY_INSTALL event");
	} else {
		install = false;
		DEBUGD(&pbr_dbg_map,
		       "%s: Removing %s(%u) reason: %" PRIu64,
		       __PRETTY_FUNCTION__, pbrm->name,
		       pbrms->seqno, pbrms->reason);
	}

	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi)) {
		pbr_send_pbr_map(pbrms, pmi, install);
	}
}

void pbr_map_install(struct pbr_map *pbrm)
{
	struct listnode *node, *inode;
	struct pbr_map_sequence *pbrms;
	struct pbr_map_interface *pmi;

	if (!pbrm->incoming->count)
		return;

	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms))
		for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi))
			pbr_send_pbr_map(pbrms, pmi, true);
}

void pbr_map_init(void)
{
	RB_INIT(pbr_map_entry_head, &pbr_maps);

	pbr_map_sequence_unique = 1;
}
Commit	Line	Data
e5c83d9b DS	1	/*
	2	* PBR-map Code
	3	* Copyright (C) 2018 Cumulus Networks, Inc.
	4	* Donald Sharp
	5	*
	6	* FRR is free software; you can redistribute it and/or modify it
	7	* under the terms of the GNU General Public License as published by the
	8	* Free Software Foundation; either version 2, or (at your option) any
	9	* later version.
	10	*
	11	* FRR is distributed in the hope that it will be useful, but
	12	* WITHOUT ANY WARRANTY; without even the implied warranty of
	13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	14	* General Public License for more details.
	15	*
	16	* You should have received a copy of the GNU General Public License along
	17	* with this program; see the file COPYING; if not, write to the Free Software
	18	* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
	19	*/
	20	#include <zebra.h>
	21
	22	#include "thread.h"
	23	#include "linklist.h"
	24	#include "prefix.h"
	25	#include "table.h"
	26	#include "vrf.h"
	27	#include "nexthop.h"
	28	#include "nexthop_group.h"
	29	#include "memory.h"
	30	#include "log.h"
	31	#include "vty.h"
	32
	33	#include "pbr_nht.h"
	34	#include "pbr_map.h"
e5c83d9b DS	35	#include "pbr_zebra.h"
	36	#include "pbr_memory.h"
	37	#include "pbr_debug.h"
	38
	39	DEFINE_MTYPE_STATIC(PBRD, PBR_MAP, "PBR Map")
	40	DEFINE_MTYPE_STATIC(PBRD, PBR_MAP_SEQNO, "PBR Map Sequence")
	41	DEFINE_MTYPE_STATIC(PBRD, PBR_MAP_INTERFACE, "PBR Map Interface")
	42
	43	static uint32_t pbr_map_sequence_unique;
	44
d3765386 DS	45	static inline int pbr_map_compare(const struct pbr_map *pbrmap1,
d3765386 DS	46	const struct pbr_map *pbrmap2);
e5c83d9b DS	47
	48	RB_GENERATE(pbr_map_entry_head, pbr_map, pbr_map_entry, pbr_map_compare)
	49
	50	struct pbr_map_entry_head pbr_maps = RB_INITIALIZER(&pbr_maps);
	51
	52	DEFINE_QOBJ_TYPE(pbr_map_sequence)
	53
d3765386 DS	54	static inline int pbr_map_compare(const struct pbr_map *pbrmap1,
d3765386 DS	55	const struct pbr_map *pbrmap2)
e5c83d9b DS	56	{
	57	return strcmp(pbrmap1->name, pbrmap2->name);
	58	}
	59
	60	static int pbr_map_sequence_compare(const struct pbr_map_sequence *pbrms1,
	61	const struct pbr_map_sequence *pbrms2)
	62	{
	63	if (pbrms1->seqno == pbrms2->seqno)
	64	return 0;
	65
	66	if (pbrms1->seqno < pbrms2->seqno)
	67	return -1;
	68
	69	return 1;
	70	}
	71
	72	static void pbr_map_sequence_delete(struct pbr_map_sequence *pbrms)
	73	{
	74	if (pbrms->internal_nhg_name)
	75	XFREE(MTYPE_TMP, pbrms->internal_nhg_name);
	76
	77	XFREE(MTYPE_PBR_MAP_SEQNO, pbrms);
	78	}
	79
	80	static int pbr_map_interface_compare(const struct pbr_map_interface *pmi1,
	81	const struct pbr_map_interface *pmi2)
	82	{
	83	return strcmp(pmi1->ifp->name, pmi2->ifp->name);
	84	}
	85
b13e5ad6	86	static void pbr_map_interface_list_delete(struct pbr_map_interface *pmi)
e5c83d9b	87	{
b13e5ad6 DS	88	struct pbr_map_interface *pmi_int;
	89	struct listnode node, nnode;
	90	struct pbr_map *pbrm;
	91
	92	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
	93	for (ALL_LIST_ELEMENTS(pbrm->incoming, node, nnode, pmi_int)) {
	94	if (pmi == pmi_int) {
	95	pbr_map_policy_delete(pbrm, pmi);
	96	return;
	97	}
	98	}
	99	}
e5c83d9b DS	100	}
	101
	102	static const char *pbr_map_reason_str[] = {
	103	"Invalid NH-group", "Invalid NH", "No Nexthops",
	104	"Both NH and NH-Group", "Invalid Src or Dst", "Deleting Sequence",
	105	};
	106
	107	void pbr_map_reason_string(unsigned int reason, char *buf, int size)
	108	{
	109	unsigned int bit;
	110	int len = 0;
	111
	112	if (!buf)
	113	return;
	114
	115	for (bit = 0; bit < array_size(pbr_map_reason_str); bit++) {
	116	if ((reason & (1 << bit)) && (len < size)) {
	117	len += snprintf((buf + len), (size - len), "%s%s",
	118	(len > 0) ? ", " : "",
	119	pbr_map_reason_str[bit]);
	120	}
	121	}
	122	}
	123
	124
	125	void pbr_map_interface_delete(struct pbr_map pbrm, struct interface ifp_del)
	126	{
	127
	128	struct listnode *node;
	129	struct pbr_map_interface *pmi;
e5c83d9b DS	130
	131	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, node, pmi)) {
	132	if (ifp_del == pmi->ifp)
	133	break;
	134	}
	135
b13e5ad6 DS	136	if (pmi)
b13e5ad6 DS	137	pbr_map_policy_delete(pbrm, pmi);
e5c83d9b DS	138	}
	139
	140	void pbr_map_add_interface(struct pbr_map pbrm, struct interface ifp_add)
	141	{
	142	struct listnode *node;
	143	struct pbr_map_interface *pmi;
e5c83d9b DS	144
	145	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, node, pmi)) {
	146	if (ifp_add == pmi->ifp)
	147	return;
	148	}
	149
	150	pmi = XCALLOC(MTYPE_PBR_MAP_INTERFACE, sizeof(*pmi));
	151	pmi->ifp = ifp_add;
	152	pmi->pbrm = pbrm;
	153	listnode_add_sort(pbrm->incoming, pmi);
	154
37c606ff	155	bf_assign_index(pbrm->ifi_bitfield, pmi->install_bit);
b13e5ad6	156	pbr_map_check_valid(pbrm->name);
d02e9432	157	if (pbrm->valid)
b13e5ad6	158	pbr_map_install(pbrm);
e5c83d9b DS	159	}
	160
	161	void pbr_map_write_interfaces(struct vty vty, struct interface ifp)
	162	{
	163	struct pbr_interface *pbr_ifp = ifp->info;
	164
f1c3fe1b QY	165	if (pbr_ifp
f1c3fe1b QY	166	&& strncmp(pbr_ifp->mapname, "", sizeof(pbr_ifp->mapname)) != 0)
e5c83d9b DS	167	vty_out(vty, " pbr-policy %s\n", pbr_ifp->mapname);
	168	}
	169
	170	struct pbr_map pbrm_find(const char name)
	171	{
	172	struct pbr_map pbrm;
	173
	174	strlcpy(pbrm.name, name, sizeof(pbrm.name));
	175
	176	return RB_FIND(pbr_map_entry_head, &pbr_maps, &pbrm);
	177	}
	178
b13e5ad6	179	extern void pbr_map_delete(struct pbr_map_sequence *pbrms)
e5c83d9b DS	180	{
e5c83d9b DS	181	struct pbr_map *pbrm;
b13e5ad6 DS	182	struct listnode *inode;
b13e5ad6 DS	183	struct pbr_map_interface *pmi;
e5c83d9b	184
b13e5ad6	185	pbrm = pbrms->parent;
e5c83d9b	186
b13e5ad6 DS	187	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi))
b13e5ad6 DS	188	pbr_send_pbr_map(pbrms, pmi, false);
e5c83d9b	189
b13e5ad6 DS	190	if (pbrms->nhg)
b13e5ad6 DS	191	pbr_nht_delete_individual_nexthop(pbrms);
e5c83d9b	192
b13e5ad6	193	listnode_delete(pbrm->seqnumbers, pbrms);
e5c83d9b DS	194
	195	if (pbrm->seqnumbers->count == 0) {
	196	RB_REMOVE(pbr_map_entry_head, &pbr_maps, pbrm);
37c606ff DS	197
37c606ff DS	198	bf_free(pbrm->ifi_bitfield);
e5c83d9b DS	199	XFREE(MTYPE_PBR_MAP, pbrm);
	200	}
	201	}
	202
b13e5ad6 DS	203	void pbr_map_delete_nexthop_group(struct pbr_map_sequence *pbrms)
	204	{
	205	struct pbr_map *pbrm = pbrms->parent;
	206	struct listnode *node;
	207	struct pbr_map_interface *pmi;
	208
	209	if (pbrm->valid && pbrms->nhs_installed && pbrm->incoming->count) {
	210	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, node, pmi))
	211	pbr_send_pbr_map(pbrms, pmi, false);
	212	}
	213
	214	pbrm->valid = false;
	215	pbrms->nhs_installed = false;
b13e5ad6 DS	216	pbrms->reason \|= PBR_MAP_INVALID_NO_NEXTHOPS;
	217	pbrms->nhgrp_name = NULL;
	218	}
	219
37c606ff DS	220	struct pbr_map_sequence *pbrms_lookup_unique(uint32_t unique, ifindex_t ifindex,
37c606ff DS	221	struct pbr_map_interface **ppmi)
e5c83d9b DS	222	{
	223	struct pbr_map_sequence *pbrms;
	224	struct listnode snode, inode;
	225	struct pbr_map_interface *pmi;
	226	struct pbr_map *pbrm;
	227
	228	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
	229	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi)) {
	230	if (pmi->ifp->ifindex != ifindex)
	231	continue;
	232
37c606ff DS	233	if (ppmi)
	234	*ppmi = pmi;
	235
e5c83d9b DS	236	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, snode,
	237	pbrms)) {
	238	DEBUGD(&pbr_dbg_map, "%s: Comparing %u to %u",
	239	__PRETTY_FUNCTION__, pbrms->unique,
	240	unique);
	241	if (pbrms->unique == unique)
	242	return pbrms;
	243	}
	244	}
	245	}
	246
	247	return NULL;
	248	}
	249
b13e5ad6 DS	250	static void pbr_map_add_interfaces(struct pbr_map *pbrm)
	251	{
	252	struct interface *ifp;
	253	struct pbr_interface *pbr_ifp;
	254	struct vrf *vrf;
	255
	256	RB_FOREACH (vrf, vrf_name_head, &vrfs_by_name) {
	257	FOR_ALL_INTERFACES (vrf, ifp) {
	258	if (ifp->info) {
	259	pbr_ifp = ifp->info;
	260	if (strcmp(pbrm->name, pbr_ifp->mapname) == 0)
	261	pbr_map_add_interface(pbrm, ifp);
	262	}
	263	}
	264	}
	265	}
	266
d3765386	267	struct pbr_map_sequence pbrms_get(const char name, uint32_t seqno)
e5c83d9b DS	268	{
	269	struct pbr_map *pbrm;
	270	struct pbr_map_sequence *pbrms;
	271	struct listnode *node;
e5c83d9b DS	272
	273	pbrm = pbrm_find(name);
	274	if (!pbrm) {
	275	pbrm = XCALLOC(MTYPE_PBR_MAP, sizeof(*pbrm));
6612590d	276	snprintf(pbrm->name, sizeof(pbrm->name), "%s", name);
e5c83d9b DS	277
	278	pbrm->seqnumbers = list_new();
	279	pbrm->seqnumbers->cmp =
	280	(int ()(void , void *))pbr_map_sequence_compare;
	281	pbrm->seqnumbers->del =
	282	(void ()(void ))pbr_map_sequence_delete;
	283
	284	pbrm->incoming = list_new();
	285	pbrm->incoming->cmp =
	286	(int ()(void , void *))pbr_map_interface_compare;
	287	pbrm->incoming->del =
	288	(void ()(void ))pbr_map_interface_list_delete;
	289
	290	RB_INSERT(pbr_map_entry_head, &pbr_maps, pbrm);
	291
37c606ff	292	bf_init(pbrm->ifi_bitfield, 64);
b13e5ad6 DS	293	pbr_map_add_interfaces(pbrm);
b13e5ad6 DS	294	}
e5c83d9b DS	295
	296	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
	297	if (pbrms->seqno == seqno)
	298	break;
	299
	300	}
	301
	302	if (!pbrms) {
	303	pbrms = XCALLOC(MTYPE_PBR_MAP_SEQNO, sizeof(*pbrms));
	304	pbrms->unique = pbr_map_sequence_unique++;
	305	pbrms->seqno = seqno;
	306	pbrms->ruleno = pbr_nht_get_next_rule(seqno);
	307	pbrms->parent = pbrm;
	308	pbrms->reason =
	309	PBR_MAP_INVALID_SRCDST \|
	310	PBR_MAP_INVALID_NO_NEXTHOPS;
	311
	312	QOBJ_REG(pbrms, pbr_map_sequence);
	313	listnode_add_sort(pbrm->seqnumbers, pbrms);
e5c83d9b DS	314	}
e5c83d9b DS	315
e5c83d9b DS	316	return pbrms;
	317	}
	318
	319	static void
	320	pbr_map_sequence_check_nexthops_valid(struct pbr_map_sequence *pbrms)
	321	{
	322	/*
	323	* Check validness of the nexthop or nexthop-group
	324	*/
	325	if (!pbrms->nhg && !pbrms->nhgrp_name)
	326	pbrms->reason \|= PBR_MAP_INVALID_NO_NEXTHOPS;
	327
	328	if (pbrms->nhg && pbrms->nhgrp_name)
	329	pbrms->reason \|= PBR_MAP_INVALID_BOTH_NHANDGRP;
	330
	331	if (pbrms->nhg &&
	332	!pbr_nht_nexthop_group_valid(pbrms->internal_nhg_name))
	333	pbrms->reason \|= PBR_MAP_INVALID_NEXTHOP;
	334
	335	if (pbrms->nhgrp_name) {
	336	if (!pbr_nht_nexthop_group_valid(pbrms->nhgrp_name))
	337	pbrms->reason \|= PBR_MAP_INVALID_NEXTHOP_GROUP;
	338	else
	339	pbrms->nhs_installed = true;
	340	}
	341	}
	342
	343	static void pbr_map_sequence_check_src_dst_valid(struct pbr_map_sequence *pbrms)
	344	{
	345	if (!pbrms->src && !pbrms->dst)
	346	pbrms->reason \|= PBR_MAP_INVALID_SRCDST;
	347	}
	348
	349	/*
	350	* Checks to see if we think that the pbmrs is valid. If we think
	351	* the config is valid return true.
	352	*/
	353	static void pbr_map_sequence_check_valid(struct pbr_map_sequence *pbrms)
	354	{
	355	pbr_map_sequence_check_nexthops_valid(pbrms);
	356
	357	pbr_map_sequence_check_src_dst_valid(pbrms);
	358	}
	359
	360	static bool pbr_map_check_valid_internal(struct pbr_map *pbrm)
	361	{
	362	struct pbr_map_sequence *pbrms;
	363	struct listnode *node;
	364
	365	pbrm->valid = true;
	366	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
	367	pbrms->reason = 0;
	368	pbr_map_sequence_check_valid(pbrms);
	369	/*
	370	* A pbr_map_sequence that is invalid causes
	371	* the whole shebang to be invalid
	372	*/
	373	if (pbrms->reason != 0)
	374	pbrm->valid = false;
	375	}
	376
	377	return pbrm->valid;
	378	}
	379
380	/*
381	* For a given PBR-MAP check to see if we think it is a
382	* valid config or not. If so note that it is and return
383	* that we are valid.
384	*/
d3765386	385	bool pbr_map_check_valid(const char *name)
e5c83d9b DS	386	{
	387	struct pbr_map *pbrm;
	388
	389	pbrm = pbrm_find(name);
	390	if (!pbrm) {
	391	DEBUGD(&pbr_dbg_map,
	392	"%s: Specified PBR-MAP(%s) does not exist?",
	393	__PRETTY_FUNCTION__, name);
	394	return false;
	395	}
	396
	397	pbr_map_check_valid_internal(pbrm);
	398	return pbrm->valid;
	399	}
	400
d3765386	401	void pbr_map_schedule_policy_from_nhg(const char *nh_group)
e5c83d9b DS	402	{
e5c83d9b DS	403	struct pbr_map_sequence *pbrms;
e5c83d9b DS	404	struct pbr_map *pbrm;
	405	struct listnode *node;
	406
	407	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
	408	DEBUGD(&pbr_dbg_map, "%s: Looking at %s", __PRETTY_FUNCTION__,
	409	pbrm->name);
	410	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
	411	DEBUGD(&pbr_dbg_map, "\tNH Grp name: %s",
	412	pbrms->nhgrp_name ? pbrms->nhgrp_name : "NULL");
	413
	414	if (pbrms->nhgrp_name
	415	&& (strcmp(nh_group, pbrms->nhgrp_name) == 0)) {
	416	pbrms->nhs_installed = true;
	417
b13e5ad6	418	pbr_map_check(pbrms);
e5c83d9b DS	419	}
	420
	421	if (pbrms->nhg
	422	&& (strcmp(nh_group, pbrms->internal_nhg_name)
	423	== 0)) {
	424	pbrms->nhs_installed = true;
	425
b13e5ad6	426	pbr_map_check(pbrms);
e5c83d9b DS	427	}
	428	}
	429	}
	430	}
	431
d3765386	432	void pbr_map_policy_install(const char *name)
e5c83d9b DS	433	{
	434	struct pbr_map_sequence *pbrms;
	435	struct pbr_map *pbrm;
b13e5ad6 DS	436	struct listnode node, inode;
b13e5ad6 DS	437	struct pbr_map_interface *pmi;
e5c83d9b DS	438
	439	DEBUGD(&pbr_dbg_map, "%s: for %s", __PRETTY_FUNCTION__, name);
	440	pbrm = pbrm_find(name);
	441	if (!pbrm)
	442	return;
	443
e5c83d9b DS	444	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
	445	DEBUGD(&pbr_dbg_map,
	446	"%s: Looking at what to install %s(%u) %d %d",
	447	__PRETTY_FUNCTION__, name, pbrms->seqno, pbrm->valid,
	448	pbrms->nhs_installed);
e5c83d9b	449
b13e5ad6 DS	450	if (pbrm->valid && pbrms->nhs_installed && pbrm->incoming->count) {
	451	DEBUGD(&pbr_dbg_map, "\tInstalling %s %u",
	452	pbrm->name, pbrms->seqno);
	453	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi))
	454	pbr_send_pbr_map(pbrms, pmi, true);
	455	}
e5c83d9b DS	456	}
	457	}
	458
b13e5ad6	459	void pbr_map_policy_delete(struct pbr_map pbrm, struct pbr_map_interface pmi)
e5c83d9b	460	{
b13e5ad6 DS	461	struct listnode *node;
b13e5ad6 DS	462	struct pbr_map_sequence *pbrms;
e5c83d9b	463
e5c83d9b	464
b13e5ad6 DS	465	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms))
	466	pbr_send_pbr_map(pbrms, pmi, false);
	467
	468	listnode_delete(pbrm->incoming, pmi);
	469	pmi->pbrm = NULL;
37c606ff DS	470
37c606ff DS	471	bf_release_index(pbrm->ifi_bitfield, pmi->install_bit);
b13e5ad6	472	XFREE(MTYPE_PBR_MAP_INTERFACE, pmi);
e5c83d9b DS	473	}
	474
	475	/*
	476	* For a nexthop group specified, see if any of the pbr-maps
	477	* are using it and if so, check to see that we are still
	478	* valid for usage. If we are valid then schedule the installation/deletion
	479	* of the pbr-policy.
	480	*/
d3765386	481	void pbr_map_check_nh_group_change(const char *nh_group)
e5c83d9b DS	482	{
	483	struct pbr_map_sequence *pbrms;
	484	struct pbr_map *pbrm;
ff9799c3 DS	485	struct listnode node, inode;
ff9799c3 DS	486	struct pbr_map_interface *pmi;
e5c83d9b DS	487	bool found_name;
e5c83d9b DS	488
e5c83d9b DS	489	RB_FOREACH (pbrm, pbr_map_entry_head, &pbr_maps) {
	490	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms)) {
	491	found_name = false;
	492	if (pbrms->nhgrp_name)
	493	found_name =
	494	!strcmp(nh_group, pbrms->nhgrp_name);
	495	else if (pbrms->nhg)
	496	found_name = !strcmp(nh_group,
	497	pbrms->internal_nhg_name);
	498
	499	if (found_name) {
	500	bool original = pbrm->valid;
e5c83d9b DS	501
	502	pbr_map_check_valid_internal(pbrm);
	503
ff9799c3	504	if (pbrm->valid && (original != pbrm->valid))
b13e5ad6	505	pbr_map_install(pbrm);
ff9799c3 DS	506
	507	if (pbrm->valid == false)
	508	for (ALL_LIST_ELEMENTS_RO(
	509	pbrm->incoming, inode,
	510	pmi))
	511	pbr_send_pbr_map(pbrms, pmi,
	512	false);
e5c83d9b DS	513	}
	514	}
	515	}
	516	}
	517
b13e5ad6	518	void pbr_map_check(struct pbr_map_sequence *pbrms)
e5c83d9b	519	{
e5c83d9b	520	struct pbr_map *pbrm;
b13e5ad6 DS	521	struct listnode *inode;
	522	struct pbr_map_interface *pmi;
	523	bool install;
e5c83d9b	524
b13e5ad6 DS	525	pbrm = pbrms->parent;
	526	DEBUGD(&pbr_dbg_map, "%s: for %s(%u)", __PRETTY_FUNCTION__,
	527	pbrm->name, pbrms->seqno);
	528	if (pbr_map_check_valid(pbrm->name))
	529	DEBUGD(&pbr_dbg_map, "We are totally valid %s\n",
	530	pbrm->name);
e5c83d9b	531
b13e5ad6 DS	532	DEBUGD(&pbr_dbg_map, "%s: Installing %s(%u) reason: %" PRIu64,
b13e5ad6 DS	533	__PRETTY_FUNCTION__, pbrm->name, pbrms->seqno, pbrms->reason);
e5c83d9b	534
b13e5ad6 DS	535	if (pbrms->reason == PBR_MAP_VALID_SEQUENCE_NUMBER) {
b13e5ad6 DS	536	install = true;
e5c83d9b	537	DEBUGD(&pbr_dbg_map, "%s: Installing %s(%u) reason: %" PRIu64,
b13e5ad6 DS	538	__PRETTY_FUNCTION__, pbrm->name, pbrms->seqno,
b13e5ad6 DS	539	pbrms->reason);
e5c83d9b	540	DEBUGD(&pbr_dbg_map,
b13e5ad6 DS	541	"\tSending PBR_MAP_POLICY_INSTALL event");
	542	} else {
	543	install = false;
e5c83d9b	544	DEBUGD(&pbr_dbg_map,
b13e5ad6 DS	545	"%s: Removing %s(%u) reason: %" PRIu64,
	546	__PRETTY_FUNCTION__, pbrm->name,
	547	pbrms->seqno, pbrms->reason);
e5c83d9b DS	548	}
e5c83d9b DS	549
2fb7892e	550	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi)) {
b13e5ad6	551	pbr_send_pbr_map(pbrms, pmi, install);
2fb7892e	552	}
e5c83d9b DS	553	}
e5c83d9b DS	554
b13e5ad6	555	void pbr_map_install(struct pbr_map *pbrm)
e5c83d9b	556	{
b13e5ad6 DS	557	struct listnode node, inode;
	558	struct pbr_map_sequence *pbrms;
	559	struct pbr_map_interface *pmi;
e5c83d9b	560
b13e5ad6	561	if (!pbrm->incoming->count)
e5c83d9b	562	return;
e5c83d9b	563
b13e5ad6 DS	564	for (ALL_LIST_ELEMENTS_RO(pbrm->seqnumbers, node, pbrms))
	565	for (ALL_LIST_ELEMENTS_RO(pbrm->incoming, inode, pmi))
	566	pbr_send_pbr_map(pbrms, pmi, true);
e5c83d9b DS	567	}
e5c83d9b DS	568
d3765386	569	void pbr_map_init(void)
e5c83d9b DS	570	{
	571	RB_INIT(pbr_map_entry_head, &pbr_maps);
	572
	573	pbr_map_sequence_unique = 1;
	574	}