zebra: Adding a new dataplane using protobuf

Makefile.am

@@ -181,6 +181,7 @@ include zebra/subdir.am
 include watchfrr/subdir.am
 include qpb/subdir.am
 include fpm/subdir.am
+include dplaneserver/subdir.am
 include grpc/subdir.am
 include tools/subdir.am
 
@@ -272,6 +273,7 @@ EXTRA_DIST += \
 	doc/user/Makefile \
 	eigrpd/Makefile \
 	fpm/Makefile \
+	dplaneserver/Makefile \
 	grpc/Makefile \
 	isisd/Makefile \
 	ldpd/Makefile \

configure.ac

@@ -802,6 +802,8 @@ AC_ARG_ENABLE([pcre2posix],
   AS_HELP_STRING([--enable-pcre2posix], [enable using PCRE2 Posix libs for regex functions]))
 AC_ARG_ENABLE([fpm],
   AS_HELP_STRING([--enable-fpm], [enable Forwarding Plane Manager support]))
+AC_ARG_ENABLE([enable_dplane_pb],
+  AS_HELP_STRING([--enable-dplane-pb], [enable Forwarding Plane Manager (FPM) protobuf support]))
 AC_ARG_ENABLE([werror],
   AS_HELP_STRING([--enable-werror], [enable -Werror (recommended for developers only)]))
 AC_ARG_ENABLE([cumulus],
@@ -2795,6 +2797,7 @@ AM_CONDITIONAL([VRRPD], [test "$enable_vrrpd" != "no"])
 AM_CONDITIONAL([PATHD], [test "$enable_pathd" != "no"])
 AM_CONDITIONAL([PATHD_PCEP], [test "$enable_pathd" != "no"])
 AM_CONDITIONAL([DP_DPDK], [test "$enable_dp_dpdk" = "yes"])
+AM_CONDITIONAL([DPLANE_PB],[test "$enable_dplane_pb" != "no"])
 
 AC_CONFIG_FILES([Makefile],[
 	test "$enable_dev_build" = "yes" && makefile_devbuild="--dev-build"

debian/frr.install

@@ -11,11 +11,13 @@ usr/lib/*/frr/libfrrospfapiclient.*
 usr/lib/*/frr/libmgmt_be_nb.*
 usr/lib/*/frr/modules/bgpd_bmp.so
 usr/lib/*/frr/modules/dplane_fpm_nl.so
+usr/lib/*/frr/modules/dplane_fpm_pb.so
 usr/lib/*/frr/modules/zebra_cumulus_mlag.so
 usr/lib/*/frr/modules/zebra_fpm.so
 usr/lib/*/frr/modules/pathd_pcep.so
 usr/lib/frr/*.sh
 usr/lib/frr/*d
+usr/lib/frr/dplaneserver
 usr/lib/frr/watchfrr
 usr/lib/frr/zebra
 usr/share/man/

doc/developer/fpm.rst

@@ -37,6 +37,7 @@ advantages over Netlink:
 
    * ``fpm``
    * ``dplane_fpm_nl``
+   * ``dplane_fpm_pb``
 
 fpm
 ^^^
@@ -55,6 +56,23 @@ netlink functions to translate route event snapshots into formatted binary
 data.
 
 
+dplane_fpm_pb
+^^^^^^^^^^^^^
+
+It has the same implementation as ``dplane_fpm_nl``, using ``zebra``'s data
+plane framework as a plugin. It supports transmitting data in protobuf format.
+
+To add a new data type:
+
+- Add a new data structure to :file:`fpm/fpm.proto`.
+
+.. c:function:: Fpm__Message *create_fpm_message(qpb_allocator_t *allocator,struct zebra_dplane_ctx *ctx);
+
+- This function in :file:`zebra/dplane_fpm_pb.c` will create encoded fpm message.
+  Assign values to data based on opcode.
+- Use the same proto file to decode on the server side.
+
+
 Protocol Specification
 ----------------------
 

doc/user/zebra.rst

@@ -1224,13 +1224,15 @@ as well. We refer to the component that programs the forwarding plane
 
 The relevant zebra code kicks in when zebra is configured with the
 :option:`--enable-fpm` flag and started with the module (``-M fpm``
-or ``-M dplane_fpm_nl``).
+or ``-M dplane_fpm_nl`` or ``-M dplane_fpm_pb``).
 
 .. note::
 
    The ``fpm`` implementation attempts to connect to ``127.0.0.1`` port ``2620``
-   by default without configurations. The ``dplane_fpm_nl`` only attempts to
-   connect to a server if configured.
+   by default without configurations. The ``dplane_fpm_nl`` only attempts
+   to connect to a server if configured. The ``dplane_fpm_pb`` attempts to
+   connect to ``127.0.0.1`` port ``2620`` by default. It can be changed or
+   canceled by configuring.
 
 Zebra periodically attempts to connect to the well-known FPM port (``2620``).
 Once the connection is up, zebra starts sending messages containing routes
@@ -1244,6 +1246,7 @@ with the module load-time option. The modules accept the following options:
 
 - ``fpm``: ``netlink`` and ``protobuf``.
 - ``dplane_fpm_nl``: none, it only implements netlink.
+- ``dplane_fpm_pb``: none, it only implements protobuf.
 
 The zebra FPM interface uses replace semantics. That is, if a 'route
 add' message for a prefix is followed by another 'route add' message,
@@ -1308,8 +1311,8 @@ FPM Commands
    optional Forwarding Plane Manager (FPM) component.
 
 
-``dplane_fpm_nl`` implementation
---------------------------------
+``dplane_fpm_nl`` or ``dplane_fpm_pb`` implementation
+-----------------------------------------------------
 
 .. clicmd:: fpm address <A.B.C.D|X:X::X:X> [port (1-65535)]
 

dplaneserver/Makefile

@@ -0,0 +1,10 @@
+all: ALWAYS
+	@$(MAKE) -s -C .. dplaneserver/dplaneserver
+%: ALWAYS
+	@$(MAKE) -s -C .. dplaneserver/$@
+
+Makefile:
+	#nothing
+ALWAYS:
+.PHONY: ALWAYS makefiles
+.SUFFIXES: