[mirror_frr.git] / lib / mlag.c

/* mlag generic code.
 * Copyright (C) 2018 Cumulus Networks, Inc.
 *                    Donald Sharp
 *
 * This file is part of FRR.
 *
 * 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 FRR; see the file COPYING.  If not, write to the Free
 * Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
 * 02111-1307, USA.
 */
#include <zebra.h>

#include <mlag.h>

char *mlag_role2str(enum mlag_role role, char *buf, size_t size)
{
	switch (role) {
	case MLAG_ROLE_NONE:
		snprintf(buf, size, "NONE");
		break;
	case MLAG_ROLE_PRIMARY:
		snprintf(buf, size, "PRIMARY");
		break;
	case MLAG_ROLE_SECONDARY:
		snprintf(buf, size, "SECONDARY");
		break;
	}

	return buf;
}

char *mlag_lib_msgid_to_str(enum mlag_msg_type msg_type, char *buf, size_t size)
{
	switch (msg_type) {
	case MLAG_REGISTER:
		snprintf(buf, size, "Register");
		break;
	case MLAG_DEREGISTER:
		snprintf(buf, size, "De-Register");
		break;
	case MLAG_MROUTE_ADD:
		snprintf(buf, size, "Mroute add");
		break;
	case MLAG_MROUTE_DEL:
		snprintf(buf, size, "Mroute del");
		break;
	case MLAG_DUMP:
		snprintf(buf, size, "Mlag Replay");
		break;
	case MLAG_MROUTE_ADD_BULK:
		snprintf(buf, size, "Mroute Add Batch");
		break;
	case MLAG_MROUTE_DEL_BULK:
		snprintf(buf, size, "Mroute Del Batch");
		break;
	case MLAG_STATUS_UPDATE:
		snprintf(buf, size, "Mlag Status");
		break;
	case MLAG_VXLAN_UPDATE:
		snprintf(buf, size, "Mlag vxlan update");
		break;
	case MLAG_PEER_FRR_STATUS:
		snprintf(buf, size, "Mlag Peer FRR Status");
		break;
	default:
		snprintf(buf, size, "Unknown %d", msg_type);
		break;
	}
	return buf;
}


int mlag_lib_decode_mlag_hdr(struct stream *s, struct mlag_msg *msg,
			     size_t *length)
{
#define LIB_MLAG_HDR_LENGTH 8
	if (s == NULL || msg == NULL)
		return -1;

	*length = stream_get_endp(s);

	if (*length < LIB_MLAG_HDR_LENGTH)
		return -1;

	*length -= LIB_MLAG_HDR_LENGTH;

	STREAM_GETL(s, msg->msg_type);
	STREAM_GETW(s, msg->data_len);
	STREAM_GETW(s, msg->msg_cnt);

	return 0;
stream_failure:
	return -1;
}

#define MLAG_MROUTE_ADD_LENGTH                                                 \
	(VRF_NAMSIZ + INTERFACE_NAMSIZ + 4 + 4 + 4 + 4 + 1 + 1 + 4)

int mlag_lib_decode_mroute_add(struct stream *s, struct mlag_mroute_add *msg,
			       size_t *length)
{
	if (s == NULL || msg == NULL || *length < MLAG_MROUTE_ADD_LENGTH)
		return -1;

	STREAM_GET(msg->vrf_name, s, VRF_NAMSIZ);
	STREAM_GETL(s, msg->source_ip);
	STREAM_GETL(s, msg->group_ip);
	STREAM_GETL(s, msg->cost_to_rp);
	STREAM_GETL(s, msg->owner_id);
	STREAM_GETC(s, msg->am_i_dr);
	STREAM_GETC(s, msg->am_i_dual_active);
	STREAM_GETL(s, msg->vrf_id);
	STREAM_GET(msg->intf_name, s, INTERFACE_NAMSIZ);

	return 0;
stream_failure:
	return -1;
}

#define MLAG_MROUTE_DEL_LENGTH (VRF_NAMSIZ + INTERFACE_NAMSIZ + 4 + 4 + 4 + 4)

int mlag_lib_decode_mroute_del(struct stream *s, struct mlag_mroute_del *msg,
			       size_t *length)
{
	if (s == NULL || msg == NULL || *length < MLAG_MROUTE_DEL_LENGTH)
		return -1;

	STREAM_GET(msg->vrf_name, s, VRF_NAMSIZ);
	STREAM_GETL(s, msg->source_ip);
	STREAM_GETL(s, msg->group_ip);
	STREAM_GETL(s, msg->owner_id);
	STREAM_GETL(s, msg->vrf_id);
	STREAM_GET(msg->intf_name, s, INTERFACE_NAMSIZ);

	return 0;
stream_failure:
	return -1;
}

int mlag_lib_decode_mlag_status(struct stream *s, struct mlag_status *msg)
{
	if (s == NULL || msg == NULL)
		return -1;

	STREAM_GET(msg->peerlink_rif, s, INTERFACE_NAMSIZ);
	STREAM_GETL(s, msg->my_role);
	STREAM_GETL(s, msg->peer_state);
	return 0;
stream_failure:
	return -1;
}

int mlag_lib_decode_vxlan_update(struct stream *s, struct mlag_vxlan *msg)
{
	if (s == NULL || msg == NULL)
		return -1;

	STREAM_GETL(s, msg->anycast_ip);
	STREAM_GETL(s, msg->local_ip);
	return 0;

stream_failure:
	return -1;
}

int mlag_lib_decode_frr_status(struct stream *s, struct mlag_frr_status *msg)
{
	if (s == NULL || msg == NULL)
		return -1;

	STREAM_GETL(s, msg->frr_state);
	return 0;
stream_failure:
	return -1;
}
Commit	Line	Data
6edbb8b2 DS	1	/* mlag generic code.
	2	* Copyright (C) 2018 Cumulus Networks, Inc.
	3	* Donald Sharp
	4	*
	5	* This file is part of FRR.
	6	*
	7	* FRR is free software; you can redistribute it and/or modify it
	8	* under the terms of the GNU General Public License as published by the
	9	* Free Software Foundation; either version 2, or (at your option) any
	10	* later version.
	11	*
	12	* FRR is distributed in the hope that it will be useful, but
	13	* WITHOUT ANY WARRANTY; without even the implied warranty of
	14	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	15	* General Public License for more details.
	16	*
	17	* You should have received a copy of the GNU General Public License
	18	* along with FRR; see the file COPYING. If not, write to the Free
	19	* Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
	20	* 02111-1307, USA.
	21	*/
	22	#include <zebra.h>
	23
	24	#include <mlag.h>
	25
	26	char mlag_role2str(enum mlag_role role, char buf, size_t size)
	27	{
	28	switch (role) {
	29	case MLAG_ROLE_NONE:
	30	snprintf(buf, size, "NONE");
	31	break;
	32	case MLAG_ROLE_PRIMARY:
	33	snprintf(buf, size, "PRIMARY");
	34	break;
	35	case MLAG_ROLE_SECONDARY:
	36	snprintf(buf, size, "SECONDARY");
	37	break;
	38	}
	39
	40	return buf;
	41	}
46c2687c	42
1e76492b	43	char mlag_lib_msgid_to_str(enum mlag_msg_type msg_type, char buf, size_t size)
46c2687c SK	44	{
	45	switch (msg_type) {
	46	case MLAG_REGISTER:
	47	snprintf(buf, size, "Register");
	48	break;
	49	case MLAG_DEREGISTER:
	50	snprintf(buf, size, "De-Register");
	51	break;
	52	case MLAG_MROUTE_ADD:
	53	snprintf(buf, size, "Mroute add");
	54	break;
	55	case MLAG_MROUTE_DEL:
	56	snprintf(buf, size, "Mroute del");
	57	break;
	58	case MLAG_DUMP:
	59	snprintf(buf, size, "Mlag Replay");
	60	break;
	61	case MLAG_MROUTE_ADD_BULK:
	62	snprintf(buf, size, "Mroute Add Batch");
	63	break;
	64	case MLAG_MROUTE_DEL_BULK:
	65	snprintf(buf, size, "Mroute Del Batch");
	66	break;
	67	case MLAG_STATUS_UPDATE:
	68	snprintf(buf, size, "Mlag Status");
	69	break;
	70	case MLAG_VXLAN_UPDATE:
	71	snprintf(buf, size, "Mlag vxlan update");
	72	break;
	73	case MLAG_PEER_FRR_STATUS:
	74	snprintf(buf, size, "Mlag Peer FRR Status");
	75	break;
	76	default:
	77	snprintf(buf, size, "Unknown %d", msg_type);
	78	break;
	79	}
	80	return buf;
	81	}
	82
	83
83f8a12b SK	84	int mlag_lib_decode_mlag_hdr(struct stream s, struct mlag_msg msg,
83f8a12b SK	85	size_t *length)
46c2687c	86	{
83f8a12b	87	#define LIB_MLAG_HDR_LENGTH 8
d1ba1814 DS	88	if (s == NULL \|\| msg == NULL)
	89	return -1;
	90
83f8a12b SK	91	*length = stream_get_endp(s);
83f8a12b SK	92
d1ba1814	93	if (*length < LIB_MLAG_HDR_LENGTH)
46c2687c SK	94	return -1;
46c2687c SK	95
83f8a12b SK	96	*length -= LIB_MLAG_HDR_LENGTH;
83f8a12b SK	97
46c2687c SK	98	STREAM_GETL(s, msg->msg_type);
	99	STREAM_GETW(s, msg->data_len);
	100	STREAM_GETW(s, msg->msg_cnt);
83f8a12b	101
46c2687c SK	102	return 0;
	103	stream_failure:
	104	return -1;
	105	}
	106
83f8a12b SK	107	#define MLAG_MROUTE_ADD_LENGTH \
	108	(VRF_NAMSIZ + INTERFACE_NAMSIZ + 4 + 4 + 4 + 4 + 1 + 1 + 4)
	109
	110	int mlag_lib_decode_mroute_add(struct stream s, struct mlag_mroute_add msg,
	111	size_t *length)
46c2687c	112	{
83f8a12b	113	if (s == NULL \|\| msg == NULL \|\| *length < MLAG_MROUTE_ADD_LENGTH)
46c2687c SK	114	return -1;
	115
	116	STREAM_GET(msg->vrf_name, s, VRF_NAMSIZ);
	117	STREAM_GETL(s, msg->source_ip);
	118	STREAM_GETL(s, msg->group_ip);
	119	STREAM_GETL(s, msg->cost_to_rp);
	120	STREAM_GETL(s, msg->owner_id);
	121	STREAM_GETC(s, msg->am_i_dr);
	122	STREAM_GETC(s, msg->am_i_dual_active);
	123	STREAM_GETL(s, msg->vrf_id);
	124	STREAM_GET(msg->intf_name, s, INTERFACE_NAMSIZ);
83f8a12b	125
46c2687c SK	126	return 0;
	127	stream_failure:
	128	return -1;
	129	}
	130
83f8a12b SK	131	#define MLAG_MROUTE_DEL_LENGTH (VRF_NAMSIZ + INTERFACE_NAMSIZ + 4 + 4 + 4 + 4)
	132
	133	int mlag_lib_decode_mroute_del(struct stream s, struct mlag_mroute_del msg,
	134	size_t *length)
46c2687c	135	{
83f8a12b	136	if (s == NULL \|\| msg == NULL \|\| *length < MLAG_MROUTE_DEL_LENGTH)
46c2687c SK	137	return -1;
	138
	139	STREAM_GET(msg->vrf_name, s, VRF_NAMSIZ);
	140	STREAM_GETL(s, msg->source_ip);
	141	STREAM_GETL(s, msg->group_ip);
	142	STREAM_GETL(s, msg->owner_id);
	143	STREAM_GETL(s, msg->vrf_id);
	144	STREAM_GET(msg->intf_name, s, INTERFACE_NAMSIZ);
83f8a12b	145
46c2687c SK	146	return 0;
	147	stream_failure:
	148	return -1;
	149	}
	150
1e76492b	151	int mlag_lib_decode_mlag_status(struct stream s, struct mlag_status msg)
46c2687c SK	152	{
	153	if (s == NULL \|\| msg == NULL)
	154	return -1;
	155
	156	STREAM_GET(msg->peerlink_rif, s, INTERFACE_NAMSIZ);
	157	STREAM_GETL(s, msg->my_role);
	158	STREAM_GETL(s, msg->peer_state);
	159	return 0;
	160	stream_failure:
	161	return -1;
	162	}
	163
1e76492b	164	int mlag_lib_decode_vxlan_update(struct stream s, struct mlag_vxlan msg)
46c2687c SK	165	{
	166	if (s == NULL \|\| msg == NULL)
	167	return -1;
	168
	169	STREAM_GETL(s, msg->anycast_ip);
	170	STREAM_GETL(s, msg->local_ip);
	171	return 0;
	172
	173	stream_failure:
	174	return -1;
	175	}
	176
1e76492b	177	int mlag_lib_decode_frr_status(struct stream s, struct mlag_frr_status msg)
46c2687c SK	178	{
	179	if (s == NULL \|\| msg == NULL)
	180	return -1;
	181
	182	STREAM_GETL(s, msg->frr_state);
	183	return 0;
	184	stream_failure:
	185	return -1;
	186	}