diff --git a/.ci/linux-build.sh b/.ci/linux-build.sh

index 99850a943..8227a5748 100755

--- a/.ci/linux-build.sh

+++ b/.ci/linux-build.sh

@@ -82,6 +82,10 @@ if [ "$DPDK" ] || [ "$DPDK_SHARED" ]; then

     install_dpdk

 fi

+if [ "$STD" ]; then

+    CFLAGS_FOR_OVS="${CFLAGS_FOR_OVS} -std=$STD"

+fi

+

 if [ "$CC" = "clang" ]; then

     CFLAGS_FOR_OVS="${CFLAGS_FOR_OVS} -Wno-error=unused-command-line-argument"

 elif [ "$M32" ]; then

diff --git a/.github/workflows/build-and-test.yml b/.github/workflows/build-and-test.yml

index 47d239f10..bc5494e86 100644

--- a/.github/workflows/build-and-test.yml

+++ b/.github/workflows/build-and-test.yml

@@ -85,6 +85,7 @@ jobs:

       LIBS:        ${{ matrix.libs }}

       M32:         ${{ matrix.m32 }}

       OPTS:        ${{ matrix.opts }}

+      STD:         ${{ matrix.std }}

       TESTSUITE:   ${{ matrix.testsuite }}

     name: linux ${{ join(matrix.*, ' ') }}

@@ -100,6 +101,11 @@ jobs:

           - compiler:     clang

             opts:         --disable-ssl

+          - compiler:     gcc

+            std:          c99

+          - compiler:     clang

+            std:          c99

+

           - compiler:     gcc

             testsuite:    test

           - compiler:     clang

diff --git a/.readthedocs.yaml b/.readthedocs.yaml

new file mode 100644

index 000000000..e481e64f1

--- /dev/null

+++ b/.readthedocs.yaml

@@ -0,0 +1,24 @@

+# .readthedocs.yaml

+# Read the Docs configuration file.

+# See https://docs.readthedocs.io/en/stable/config-file/v2.html for details.

+

+# Required.

+version: 2

+

+# Set the OS, Python version, etc.

+build:

+  os: ubuntu-22.04

+  tools:

+    python: "3.12"

+

+# Build documentation in the "Documentation/" directory with Sphinx.

+sphinx:

+  configuration: Documentation/conf.py

+

+# Build all formats: HTML, PDF, ePub.

+formats: all

+

+# Declare the Python requirements.

+python:

+  install:

+  - requirements: Documentation/requirements.txt

diff --git a/Documentation/ref/ovs-actions.7.rst b/Documentation/ref/ovs-actions.7.rst

index d13895655..36adcc5db 100644

--- a/Documentation/ref/ovs-actions.7.rst

+++ b/Documentation/ref/ovs-actions.7.rst

@@ -694,7 +694,8 @@ encapsulated in an OpenFlow ``packet-in`` message.  The supported options are:

     Limit to *max_len* the number of bytes of the packet to send in the

     ``packet-in.``  A *max_len* of 0 prevents any of the packet from being

     sent (thus, only metadata is included).  By default, the entire packet is

-    sent, equivalent to a *max_len* of 65535.

+    sent, equivalent to a *max_len* of 65535.  This option has no effect in

+    Open vSwith 2.7 and later: the entire packet will always be sent.

   ``reason=``\ *reason*

     Specify *reason* as the reason for sending the message in the

@@ -733,6 +734,12 @@ encapsulated in an OpenFlow ``packet-in`` message.  The supported options are:

   options require the Open vSwitch ``NXAST_CONTROLLER`` extension action added

   in Open vSwitch 1.6.

+  Open vSwitch 2.7 and later is configured to not buffer packets for the

+  packet-in event.  As a result, the full packet is always sent to

+  controllers.  This means that the ``max_len`` option has no effect on the

+  ``controller`` action, and all values (even 0) are equivalent to the default

+  value of 65535.

+

 The ``enqueue`` action

 ----------------------

diff --git a/Documentation/requirements.txt b/Documentation/requirements.txt

index 77130c6e0..77f44bd76 100644

--- a/Documentation/requirements.txt

+++ b/Documentation/requirements.txt

@@ -1,2 +1,2 @@

-sphinx>=1.1,<2.0

+sphinx>=1.1

 ovs_sphinx_theme>=1.0,<1.1

diff --git a/Makefile.am b/Makefile.am

index db341504d..94f488d18 100644

--- a/Makefile.am

+++ b/Makefile.am

@@ -84,6 +84,7 @@ EXTRA_DIST = \

 	.cirrus.yml \

 	.editorconfig \

 	.github/workflows/build-and-test.yml \

+	.readthedocs.yaml \

 	appveyor.yml \

 	boot.sh \

 	poc/builders/Vagrantfile \

@@ -368,7 +369,7 @@ ALL_LOCAL += manpage-check

 manpage-check: $(man_MANS) $(dist_man_MANS) $(noinst_man_MANS)

 	@error=false; \

 	for manpage in $?; do \

-	  LANG=en_US.UTF-8 groff -w mac -w delim -w escape -w input -w missing -w tab -T utf8 -man -p -z $$manpage >$@.tmp 2>&1; \

+	  LANG=en_US.UTF-8 groff -t -w mac -w delim -w escape -w input -w missing -w tab -T utf8 -man -p -z $$manpage >$@.tmp 2>&1; \

 	  if grep warning: $@.tmp; then error=:; fi; \

 	  rm -f $@.tmp; \

 	done; \

@@ -415,7 +416,7 @@ endif

 CLEANFILES += flake8-check

 -include manpages.mk

-manpages.mk: $(MAN_ROOTS) build-aux/sodepends.py python/build/soutil.py

+manpages.mk: $(MAN_ROOTS) build-aux/sodepends.py python/ovs_build_helpers/soutil.py

 	@PYTHONPATH=$$PYTHONPATH$(psep)$(srcdir)/python $(PYTHON3) $(srcdir)/build-aux/sodepends.py -I. -I$(srcdir) $(MAN_ROOTS) >$(@F).tmp

 	@if cmp -s $(@F).tmp $@; then \

 	  touch $@; \

diff --git a/NEWS b/NEWS

index a3a5c2e4a..eb7a9b1ba 100644

--- a/NEWS

+++ b/NEWS

@@ -1,3 +1,10 @@

+v3.2.2 - xx xxx xxxx

+--------------------

+

+v3.2.1 - 17 Oct 2023

+--------------------

+   - Bug fixes

+

 v3.2.0 - 17 Aug 2023

 --------------------

    - OVSDB:

diff --git a/build-aux/extract-ofp-fields b/build-aux/extract-ofp-fields

index efec59c25..05d3e1df3 100755

--- a/build-aux/extract-ofp-fields

+++ b/build-aux/extract-ofp-fields

@@ -4,9 +4,9 @@ import getopt

 import sys

 import os.path

 import xml.dom.minidom

-import build.nroff

-from build.extract_ofp_fields import (

+from ovs_build_helpers import nroff

+from ovs_build_helpers.extract_ofp_fields import (

     extract_ofp_fields,

     PREREQS,

     OXM_CLASSES,

@@ -216,7 +216,7 @@ def field_to_xml(field_node, f, body, summary):

         """.PP

 \\fB%s Field\\fR

 .TS

-tab(;);

+tab(;),nowarn;

 l lx.

 """

         % title

@@ -297,7 +297,7 @@ l lx.

     body += [".TE\n"]

     body += [".PP\n"]

-    body += [build.nroff.block_xml_to_nroff(field_node.childNodes)]

+    body += [nroff.block_xml_to_nroff(field_node.childNodes)]

 def group_xml_to_nroff(group_node, fields):

@@ -310,14 +310,14 @@ def group_xml_to_nroff(group_node, fields):

             id_ = node.attributes["id"].nodeValue

             field_to_xml(node, fields[id_], body, summary)

         else:

-            body += [build.nroff.block_xml_to_nroff([node])]

+            body += [nroff.block_xml_to_nroff([node])]

     content = [

         ".bp\n",

-        '.SH "%s"\n' % build.nroff.text_to_nroff(title.upper() + " FIELDS"),

+        '.SH "%s"\n' % nroff.text_to_nroff(title.upper() + " FIELDS"),

         '.SS "Summary:"\n',

         ".TS\n",

-        "tab(;);\n",

+        "tab(;),nowarn;\n",

         "l l l l l l l.\n",

         "Name;Bytes;Mask;RW?;Prereqs;NXM/OXM Support\n",

         "\_;\_;\_;\_;\_;\_\n",

@@ -329,7 +329,7 @@ def group_xml_to_nroff(group_node, fields):

 def make_oxm_classes_xml(document):

-    s = """tab(;);

+    s = """tab(;),nowarn;

 l l l.

 Prefix;Vendor;Class

 \_;\_;\_

@@ -422,7 +422,7 @@ ovs\-fields \- protocol header fields in OpenFlow and Open vSwitch

         elif node.nodeType == node.COMMENT_NODE:

             pass

         else:

-            s += build.nroff.block_xml_to_nroff([node])

+            s += nroff.block_xml_to_nroff([node])

     for f in fields:

         if "used" not in f:

diff --git a/build-aux/gen_ofp_field_decoders b/build-aux/gen_ofp_field_decoders

index 0b797ee8c..0cb6108c2 100755

--- a/build-aux/gen_ofp_field_decoders

+++ b/build-aux/gen_ofp_field_decoders

@@ -2,7 +2,7 @@

 import argparse

-import build.extract_ofp_fields as extract_fields

+from ovs_build_helpers.extract_ofp_fields import extract_ofp_fields

 def main():

@@ -19,7 +19,7 @@ def main():

     args = parser.parse_args()

-    fields = extract_fields.extract_ofp_fields(args.metaflow)

+    fields = extract_ofp_fields(args.metaflow)

     field_decoders = {}

     aliases = {}

diff --git a/build-aux/sodepends.py b/build-aux/sodepends.py

index 45812bcbd..ac8dd61a4 100755

--- a/build-aux/sodepends.py

+++ b/build-aux/sodepends.py

@@ -14,9 +14,10 @@

 # See the License for the specific language governing permissions and

 # limitations under the License.

-from build import soutil

 import sys

+from ovs_build_helpers import soutil

+

 def sodepends(include_dirs, filenames, dst):

     ok = True

diff --git a/build-aux/soexpand.py b/build-aux/soexpand.py

index 00adcf47a..7d4dc0486 100755

--- a/build-aux/soexpand.py

+++ b/build-aux/soexpand.py

@@ -14,9 +14,10 @@

 # See the License for the specific language governing permissions and

 # limitations under the License.

-from build import soutil

 import sys

+from ovs_build_helpers import soutil

+

 def soexpand(include_dirs, src, dst):

     ok = True

diff --git a/build-aux/xml2nroff b/build-aux/xml2nroff

index ee5553f45..3e937910b 100755

--- a/build-aux/xml2nroff

+++ b/build-aux/xml2nroff

@@ -18,7 +18,7 @@ import getopt

 import sys

 import xml.dom.minidom

-import build.nroff

+from ovs_build_helpers import nroff

 argv0 = sys.argv[0]

@@ -90,10 +90,10 @@ def manpage_to_nroff(xml_file, subst, include_path, version=None):

 .  I "\\$1"

 .  RE

 ..

-''' % (build.nroff.text_to_nroff(program), build.nroff.text_to_nroff(section),

-       build.nroff.text_to_nroff(title), build.nroff.text_to_nroff(version))

+''' % (nroff.text_to_nroff(program), nroff.text_to_nroff(section),

+       nroff.text_to_nroff(title), nroff.text_to_nroff(version))

-    s += build.nroff.block_xml_to_nroff(doc.childNodes) + "\n"

+    s += nroff.block_xml_to_nroff(doc.childNodes) + "\n"

     return s

@@ -139,7 +139,7 @@ if __name__ == "__main__":

     try:

         s = manpage_to_nroff(args[0], subst, include_path, version)

-    except build.nroff.error.Error as e:

+    except nroff.error.Error as e:

         sys.stderr.write("%s: %s\n" % (argv0, e.msg))

         sys.exit(1)

     for line in s.splitlines():

diff --git a/configure.ac b/configure.ac

index 320509c5f..764479514 100644

--- a/configure.ac

+++ b/configure.ac

@@ -13,7 +13,7 @@

 # limitations under the License.

 AC_PREREQ(2.63)

-AC_INIT(openvswitch, 3.2.0, bugs@openvswitch.org)

+AC_INIT(openvswitch, 3.2.2, bugs@openvswitch.org)

 AC_CONFIG_SRCDIR([vswitchd/ovs-vswitchd.c])

 AC_CONFIG_MACRO_DIR([m4])

 AC_CONFIG_AUX_DIR([build-aux])

@@ -21,7 +21,11 @@ AC_CONFIG_HEADERS([config.h])

 AC_CONFIG_TESTDIR([tests])

 AM_INIT_AUTOMAKE([tar-pax])

-AC_PROG_CC_C99

+# AC_PROG_CC doesn't try enabling C99 in autoconf 2.69 and below, but

+# AC_PROG_CC_C99 is deprecated in newer ones.  In autoconf 2.70+ both

+# will try enabling features up to C11.

+m4_version_prereq([2.70], [AC_PROG_CC], [AC_PROG_CC_C99])

+

 AM_PROG_CC_C_O

 AC_PROG_CXX

 AC_PROG_CPP

diff --git a/debian/changelog b/debian/changelog

index 8757e5cb2..780d1e2d8 100644

--- a/debian/changelog

+++ b/debian/changelog

@@ -1,3 +1,15 @@

+openvswitch (3.2.2-1) unstable; urgency=low

+   [ Open vSwitch team ]

+   * New upstream version

+

+ -- Open vSwitch team <dev@openvswitch.org>  Tue, 17 Oct 2023 13:02:27 +0200

+

+openvswitch (3.2.1-1) unstable; urgency=low

+   [ Open vSwitch team ]

+   * New upstream version

+

+ -- Open vSwitch team <dev@openvswitch.org>  Tue, 17 Oct 2023 13:02:27 +0200

+

 openvswitch (3.2.0-1) unstable; urgency=low

    * New upstream version

diff --git a/include/openvswitch/compiler.h b/include/openvswitch/compiler.h

index cf009f826..52614a5ac 100644

--- a/include/openvswitch/compiler.h

+++ b/include/openvswitch/compiler.h

@@ -37,6 +37,16 @@

 #define OVS_NO_RETURN

 #endif

+#ifndef typeof

+#define typeof __typeof__

+#endif

+

+#ifndef __cplusplus

+#ifndef asm

+#define asm __asm__

+#endif

+#endif

+

 #if __GNUC__ && !__CHECKER__

 #define OVS_UNUSED __attribute__((__unused__))

 #define OVS_PRINTF_FORMAT(FMT, ARG1) __attribute__((__format__(printf, FMT, ARG1)))

diff --git a/lib/automake.mk b/lib/automake.mk

index e64ee76ce..24b0ffefe 100644

--- a/lib/automake.mk

+++ b/lib/automake.mk

@@ -451,7 +451,7 @@ lib_libsflow_la_SOURCES = \

 	lib/sflow_poller.c \

 	lib/sflow_receiver.c

 lib_libsflow_la_CPPFLAGS = $(AM_CPPFLAGS)

-lib_libsflow_la_CFLAGS = $(AM_CFLAGS)

+lib_libsflow_la_CFLAGS = $(AM_CFLAGS) -D_BSD_SOURCE -D_DEFAULT_SOURCE

 if HAVE_WNO_UNUSED

 lib_libsflow_la_CFLAGS += -Wno-unused

 endif

diff --git a/lib/db-ctl-base.c b/lib/db-ctl-base.c

index 5d2635946..3a8068b12 100644

--- a/lib/db-ctl-base.c

+++ b/lib/db-ctl-base.c

@@ -820,6 +820,7 @@ check_condition(const struct ovsdb_idl_table_class *table,

         type.value.type = OVSDB_TYPE_VOID;

         error = ovsdb_datum_from_string(&b, &type, value_string, symtab);

         if (error) {

+            ovsdb_atom_destroy(&want_key, column->type.key.type);

             goto out;

         }

@@ -1374,6 +1375,7 @@ set_column(const struct ovsdb_idl_table_class *table,

         error = ovsdb_atom_from_string(&value, NULL, &column->type.value,

                                        value_string, symtab);

         if (error) {

+            ovsdb_atom_destroy(&key, column->type.key.type);

             goto out;

         }

diff --git a/lib/dpif-netdev.c b/lib/dpif-netdev.c

index 9730e0eec..157694bcf 100644

--- a/lib/dpif-netdev.c

+++ b/lib/dpif-netdev.c

@@ -3380,14 +3380,13 @@ static inline void

 netdev_flow_key_init(struct netdev_flow_key *key,

                      const struct flow *flow)

 {

-    uint64_t *dst = miniflow_values(&key->mf);

     uint32_t hash = 0;

     uint64_t value;

     miniflow_map_init(&key->mf, flow);

     miniflow_init(&key->mf, flow);

-    size_t n = dst - miniflow_get_values(&key->mf);

+    size_t n = miniflow_n_values(&key->mf);

     FLOW_FOR_EACH_IN_MAPS (value, flow, key->mf.map) {

         hash = hash_add64(hash, value);

diff --git a/lib/fatal-signal.c b/lib/fatal-signal.c

index 77f0c87dd..953150074 100644

--- a/lib/fatal-signal.c

+++ b/lib/fatal-signal.c

@@ -138,10 +138,6 @@ fatal_signal_init(void)

         backtrace_capture(&dummy_bt);

-        if (!dummy_bt.n_frames) {

-            VLOG_DBG("Capturing of dummy backtrace has failed.");

-        }

-

         fatal_signal_create_wakeup_events();

 #ifdef _WIN32

diff --git a/lib/meta-flow.xml b/lib/meta-flow.xml

index bdd12f6a7..ac72a44bc 100644

--- a/lib/meta-flow.xml

+++ b/lib/meta-flow.xml

@@ -3517,23 +3517,24 @@ actions=clone(load:0->NXM_OF_IN_PORT[],output:123)

     <tbl>

+tab(;);

 r r r r r.

-Criteria        OpenFlow 1.0    OpenFlow 1.1    OpenFlow 1.2+   NXM

-\_      \_      \_      \_      \_

-[1]     \fL????\fR/\fL1\fR,\fL??\fR/\fL?\fR     \fL????\fR/\fL1\fR,\fL??\fR/\fL?\fR     \fL0000\fR/\fL0000\fR,\fL--\fR  \fL0000\fR/\fL0000\fR

-[2]     \fLffff\fR/\fL0\fR,\fL??\fR/\fL?\fR     \fLffff\fR/\fL0\fR,\fL??\fR/\fL?\fR     \fL0000\fR/\fLffff\fR,\fL--\fR  \fL0000\fR/\fLffff\fR

-[3]     \fL0xxx\fR/\fL0\fR,\fL??\fR/\fL1\fR     \fL0xxx\fR/\fL0\fR,\fL??\fR/\fL1\fR     \fL1xxx\fR/\fLffff\fR,\fL--\fR  \fL1xxx\fR/\fL1fff\fR

-[4]     \fL????\fR/\fL1\fR,\fL0y\fR/\fL0\fR     \fLfffe\fR/\fL0\fR,\fL0y\fR/\fL0\fR     \fL1000\fR/\fL1000\fR,\fL0y\fR  \fLz000\fR/\fLf000\fR

-[5]     \fL0xxx\fR/\fL0\fR,\fL0y\fR/\fL0\fR     \fL0xxx\fR/\fL0\fR,\fL0y\fR/\fL0\fR     \fL1xxx\fR/\fLffff\fR,\fL0y\fR  \fLzxxx\fR/\fLffff\fR

+Criteria;OpenFlow 1.0;OpenFlow 1.1;OpenFlow 1.2+;NXM

+\_;\_;\_;\_;\_

+[1];\fL????\fR/\fL1\fR,\fL??\fR/\fL?\fR;\fL????\fR/\fL1\fR,\fL??\fR/\fL?\fR;\fL0000\fR/\fL0000\fR,\fL--\fR;\fL0000\fR/\fL0000\fR

+[2];\fLffff\fR/\fL0\fR,\fL??\fR/\fL?\fR;\fLffff\fR/\fL0\fR,\fL??\fR/\fL?\fR;\fL0000\fR/\fLffff\fR,\fL--\fR;\fL0000\fR/\fLffff\fR

+[3];\fL0xxx\fR/\fL0\fR,\fL??\fR/\fL1\fR;\fL0xxx\fR/\fL0\fR,\fL??\fR/\fL1\fR;\fL1xxx\fR/\fLffff\fR,\fL--\fR;\fL1xxx\fR/\fL1fff\fR

+[4];\fL????\fR/\fL1\fR,\fL0y\fR/\fL0\fR;\fLfffe\fR/\fL0\fR,\fL0y\fR/\fL0\fR;\fL1000\fR/\fL1000\fR,\fL0y\fR;\fLz000\fR/\fLf000\fR

+[5];\fL0xxx\fR/\fL0\fR,\fL0y\fR/\fL0\fR;\fL0xxx\fR/\fL0\fR,\fL0y\fR/\fL0\fR;\fL1xxx\fR/\fLffff\fR,\fL0y\fR;\fLzxxx\fR/\fLffff\fR

 .T&

-r r c c r.

-[6]     (none)  (none)  \fL1001\fR/\fL1001\fR,\fL--\fR  \fL1001\fR/\fL1001\fR

+r c c r r.

+[6];(none);(none);\fL1001\fR/\fL1001\fR,\fL--\fR;\fL1001\fR/\fL1001\fR

 .T&

-r r c c c.

-[7]     (none)  (none)  (none)  \fL3000\fR/\fL3000\fR

-[8]     (none)  (none)  (none)  \fL0000\fR/\fL0fff\fR

-[9]     (none)  (none)  (none)  \fL0000\fR/\fLf000\fR

-[10]    (none)  (none)  (none)  \fL0000\fR/\fLefff\fR

+r c c c r.

+[7];(none);(none);(none);\fL3000\fR/\fL3000\fR

+[8];(none);(none);(none);\fL0000\fR/\fL0fff\fR

+[9];(none);(none);(none);\fL0000\fR/\fLf000\fR

+[10];(none);(none);(none);\fL0000\fR/\fLefff\fR

     </tbl>

diff --git a/lib/netdev-dpdk.c b/lib/netdev-dpdk.c

index 8f1361e21..55700250d 100644

--- a/lib/netdev-dpdk.c

+++ b/lib/netdev-dpdk.c

@@ -1312,6 +1312,16 @@ dpdk_eth_dev_init(struct netdev_dpdk *dev)

         dev->hw_ol_features &= ~NETDEV_RX_HW_SCATTER;

     }

+    if (!strcmp(info.driver_name, "net_tap")) {

+        /* FIXME: L4 checksum offloading is broken in DPDK net/tap driver.

+         * This workaround can be removed once the fix makes it to a DPDK

+         * LTS release used by OVS. */

+        VLOG_INFO("%s: disabled Tx L4 checksum offloads for a net/tap port.",

+                  netdev_get_name(&dev->up));

+        info.tx_offload_capa &= ~RTE_ETH_TX_OFFLOAD_UDP_CKSUM;

+        info.tx_offload_capa &= ~RTE_ETH_TX_OFFLOAD_TCP_CKSUM;

+    }

+

     if (info.tx_offload_capa & RTE_ETH_TX_OFFLOAD_IPV4_CKSUM) {

         dev->hw_ol_features |= NETDEV_TX_IPV4_CKSUM_OFFLOAD;

     } else {

@@ -2431,6 +2441,7 @@ netdev_dpdk_prep_hwol_packet(struct netdev_dpdk *dev, struct rte_mbuf *mbuf)

     if (!(mbuf->ol_flags & (RTE_MBUF_F_TX_IP_CKSUM | RTE_MBUF_F_TX_L4_MASK

                             | RTE_MBUF_F_TX_TCP_SEG))) {

+        mbuf->ol_flags &= ~(RTE_MBUF_F_TX_IPV4 | RTE_MBUF_F_TX_IPV6);

         return true;

     }

diff --git a/lib/netdev-offload-dpdk.c b/lib/netdev-offload-dpdk.c

index 14bc87771..992627fa2 100644

--- a/lib/netdev-offload-dpdk.c

+++ b/lib/netdev-offload-dpdk.c

@@ -2537,15 +2537,15 @@ out:

     return ret;

 }

-static int

-netdev_offload_dpdk_flow_flush(struct netdev *netdev)

+static void

+flush_netdev_flows_in_related(struct netdev *netdev, struct netdev *related)

 {

-    struct cmap *map = offload_data_map(netdev);

-    struct ufid_to_rte_flow_data *data;

     unsigned int tid = netdev_offload_thread_id();

+    struct cmap *map = offload_data_map(related);

+    struct ufid_to_rte_flow_data *data;

     if (!map) {

-        return -1;

+        return;

     }

     CMAP_FOR_EACH (data, node, map) {

@@ -2556,6 +2556,31 @@ netdev_offload_dpdk_flow_flush(struct netdev *netdev)

             netdev_offload_dpdk_flow_destroy(data);

         }

     }

+}

+

+static bool

+flush_in_vport_cb(struct netdev *vport,

+                  odp_port_t odp_port OVS_UNUSED,

+                  void *aux)

+{

+    struct netdev *netdev = aux;

+

+    /* Only vports are related to physical devices. */

+    if (netdev_vport_is_vport_class(vport->netdev_class)) {

+        flush_netdev_flows_in_related(netdev, vport);

+    }

+

+    return false;

+}

+

+static int

+netdev_offload_dpdk_flow_flush(struct netdev *netdev)

+{

+    flush_netdev_flows_in_related(netdev, netdev);

+

+    if (!netdev_vport_is_vport_class(netdev->netdev_class)) {

+        netdev_ports_traverse(netdev->dpif_type, flush_in_vport_cb, netdev);

+    }

     return 0;

 }

diff --git a/lib/netlink-conntrack.c b/lib/netlink-conntrack.c

index 4fcde9ba1..492bfcffb 100644

--- a/lib/netlink-conntrack.c

+++ b/lib/netlink-conntrack.c

@@ -579,7 +579,8 @@ nl_ct_put_tuple_proto(struct ofpbuf *buf, const struct ct_dpif_tuple *tuple)

         nl_msg_put_u8(buf, CTA_PROTO_ICMPV6_TYPE, tuple->icmp_type);

         nl_msg_put_u8(buf, CTA_PROTO_ICMPV6_CODE, tuple->icmp_code);

     } else if (tuple->ip_proto == IPPROTO_TCP ||

-               tuple->ip_proto == IPPROTO_UDP) {

+               tuple->ip_proto == IPPROTO_UDP ||

+               tuple->ip_proto == IPPROTO_SCTP) {

         nl_msg_put_be16(buf, CTA_PROTO_SRC_PORT, tuple->src_port);

         nl_msg_put_be16(buf, CTA_PROTO_DST_PORT, tuple->dst_port);

     } else {

diff --git a/lib/tc.c b/lib/tc.c

index f49048cda..6b38925c3 100644

--- a/lib/tc.c

+++ b/lib/tc.c

@@ -3851,15 +3851,13 @@ log_tc_flower_match(const char *msg,

         ds_put_cstr(&s, "\nExpected Actions:\n");

         for (i = 0, action = a->actions; i < a->action_count; i++, action++) {

-            ds_put_cstr(&s, " - ");

-            ds_put_hex(&s, action, sizeof *action);

-            ds_put_cstr(&s, "\n");

+            ds_put_format(&s, " - %d -\n", i);

+            ds_put_sparse_hex_dump(&s, action, sizeof *action, 0, false);

         }

-        ds_put_cstr(&s, "Received Actions:\n");

+        ds_put_cstr(&s, "\nReceived Actions:\n");

         for (i = 0, action = b->actions; i < b->action_count; i++, action++) {

-            ds_put_cstr(&s, " - ");

-            ds_put_hex(&s, action, sizeof *action);

-            ds_put_cstr(&s, "\n");

+            ds_put_format(&s, " - %d -\n", i);

+            ds_put_sparse_hex_dump(&s, action, sizeof *action, 0, false);

         }

     } else {

         /* Only dump the delta in actions. */

@@ -3868,12 +3866,13 @@ log_tc_flower_match(const char *msg,

         for (int i = 0; i < a->action_count; i++, action_a++, action_b++) {

             if (memcmp(action_a, action_b, sizeof *action_a)) {

-                ds_put_format(&s,

-                              "\nAction %d mismatch:\n - Expected Action: ",

-                              i);

-                ds_put_hex(&s, action_a, sizeof *action_a);

-                ds_put_cstr(&s, "\n - Received Action: ");

-                ds_put_hex(&s, action_b, sizeof *action_b);

+                ds_put_format(&s, "\nAction %d mismatch:\n"

+                                  " - Expected Action:\n", i);

+                ds_put_sparse_hex_dump(&s, action_a, sizeof *action_a,

+                                       0, false);

+                ds_put_cstr(&s, " - Received Action:\n");

+                ds_put_sparse_hex_dump(&s, action_b, sizeof *action_b,

+                                       0, false);

             }

         }

     }

diff --git a/ofproto/connmgr.c b/ofproto/connmgr.c

index b092e9e04..f7f7b1279 100644

--- a/ofproto/connmgr.c

+++ b/ofproto/connmgr.c

@@ -1209,7 +1209,7 @@ ofconn_create(struct ofservice *ofservice, struct rconn *rconn,

     hmap_init(&ofconn->bundles);

     ofconn->next_bundle_expiry_check = time_msec() + BUNDLE_EXPIRY_INTERVAL;

-    ofconn_set_rate_limit(ofconn, settings->rate_limit, settings->burst_limit);

+    ofservice_reconfigure(ofservice, settings);

     ovs_mutex_unlock(&ofproto_mutex);

 }

@@ -1915,10 +1915,7 @@ connmgr_count_hidden_rules(const struct connmgr *mgr)

 }

 /* Creates a new ofservice for 'target' in 'mgr'.  Returns 0 if successful,

- * otherwise a positive errno value.

- *

- * ofservice_reconfigure() must be called to fully configure the new

- * ofservice. */

+ * otherwise a positive errno value. */

 static void

 ofservice_create(struct connmgr *mgr, const char *target,

                  const struct ofproto_controller *c)

@@ -1928,7 +1925,8 @@ ofservice_create(struct connmgr *mgr, const char *target,

     struct rconn *rconn = NULL;

     if (!vconn_verify_name(target)) {

         char *name = ofconn_make_name(mgr, target);

-        rconn = rconn_create(5, 8, c->dscp, c->allowed_versions);

+        rconn = rconn_create(c->probe_interval, c->max_backoff,

+                             c->dscp, c->allowed_versions);

         rconn_connect(rconn, target, name);

         free(name);

     } else if (!pvconn_verify_name(target)) {

@@ -1951,7 +1949,6 @@ ofservice_create(struct connmgr *mgr, const char *target,

     ofservice->rconn = rconn;

     ofservice->pvconn = pvconn;

     ofservice->s = *c;

-    ofservice_reconfigure(ofservice, c);

     VLOG_INFO("%s: added %s controller \"%s\"",

               mgr->name, ofconn_type_to_string(ofservice->type), target);

diff --git a/ofproto/ofproto-dpif-upcall.c b/ofproto/ofproto-dpif-upcall.c

index 04b583f81..292500f21 100644

--- a/ofproto/ofproto-dpif-upcall.c

+++ b/ofproto/ofproto-dpif-upcall.c

@@ -988,7 +988,7 @@ udpif_revalidator(void *arg)

             udpif->reval_exit = latch_is_set(&udpif->exit_latch);

             start_time = time_msec();

-            if (!udpif->reval_exit) {

+            if (!udpif->reval_exit && !udpif->pause) {

                 bool terse_dump;

                 terse_dump = udpif_use_ufid(udpif);

@@ -998,10 +998,15 @@ udpif_revalidator(void *arg)

             }

         }

-        /* Wait for the leader to start the flow dump. */

+        /* Wait for the leader to reach this point. */

         ovs_barrier_block(&udpif->reval_barrier);

         if (udpif->pause) {

             revalidator_pause(revalidator);

+            if (!udpif->reval_exit) {

+                /* The main thread resumed all validators, but the leader

+                 * didn't start the dump, go to next iteration. */

+                continue;

+            }

         }

         if (udpif->reval_exit) {

@@ -3195,11 +3200,19 @@ upcall_unixctl_purge(struct unixctl_conn *conn, int argc OVS_UNUSED,

     struct udpif *udpif;

     LIST_FOR_EACH (udpif, list_node, &all_udpifs) {

+        bool wake_up = false;

         int n;

+        if (!latch_is_set(&udpif->pause_latch)) {

+            udpif_pause_revalidators(udpif);

+            wake_up = true;

+        }

         for (n = 0; n < udpif->n_revalidators; n++) {

             revalidator_purge(&udpif->revalidators[n]);

         }

+        if (wake_up) {

+            udpif_resume_revalidators(udpif);

+        }

     }

     unixctl_command_reply(conn, "");

 }

diff --git a/ofproto/ofproto-dpif-xlate-cache.c b/ofproto/ofproto-dpif-xlate-cache.c

index 9224ee2e6..2e1fcb3a6 100644

--- a/ofproto/ofproto-dpif-xlate-cache.c

+++ b/ofproto/ofproto-dpif-xlate-cache.c

@@ -125,7 +125,7 @@ xlate_push_stats_entry(struct xc_entry *entry,

     case XC_LEARN: {

         enum ofperr error;

         error = ofproto_flow_mod_learn(entry->learn.ofm, true,

-                                       entry->learn.limit, NULL);

+                                       entry->learn.limit, NULL, stats->used);

         if (error) {

             static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5);

             VLOG_WARN_RL(&rl, "xcache LEARN action execution failed.");

diff --git a/ofproto/ofproto-dpif-xlate.c b/ofproto/ofproto-dpif-xlate.c

index 47ea0f47e..be4bd6657 100644

--- a/ofproto/ofproto-dpif-xlate.c

+++ b/ofproto/ofproto-dpif-xlate.c

@@ -1615,7 +1615,8 @@ xlate_lookup_ofproto_(const struct dpif_backer *backer,

         }

         ofp_port_t in_port = recirc_id_node->state.metadata.in_port;

-        if (in_port != OFPP_NONE && in_port != OFPP_CONTROLLER) {

+        if (in_port != OFPP_NONE && in_port != OFPP_CONTROLLER &&

+            !uuid_is_zero(&recirc_id_node->state.xport_uuid)) {

             struct uuid xport_uuid = recirc_id_node->state.xport_uuid;

             xport = xport_lookup_by_uuid(xcfg, &xport_uuid);

             if (xport && xport->xbridge && xport->xbridge->ofproto) {

@@ -1626,11 +1627,19 @@ xlate_lookup_ofproto_(const struct dpif_backer *backer,

              * that the packet originated from the controller via an OpenFlow

              * "packet-out".  The right thing to do is to find just the

              * ofproto.  There is no xport, which is OK.

+             * Also a zeroed xport_uuid with a valid in_port, means that

+             * the packet originated from OFPP_CONTROLLER passed

+             * through a patch port.

              *

              * OFPP_NONE can also indicate that a bond caused recirculation. */

             struct uuid uuid = recirc_id_node->state.ofproto_uuid;

             const struct xbridge *bridge = xbridge_lookup_by_uuid(xcfg, &uuid);

+

             if (bridge && bridge->ofproto) {

+                if (in_port != OFPP_CONTROLLER && in_port != OFPP_NONE &&

+                    !get_ofp_port(bridge, in_port)) {

+                    goto xport_lookup;

+                }

                 if (errorp) {

                     *errorp = NULL;

                 }

@@ -1643,6 +1652,7 @@ xlate_lookup_ofproto_(const struct dpif_backer *backer,

         }

     }

+xport_lookup:

     xport = xport_lookup(xcfg, tnl_port_should_receive(flow)

                          ? tnl_port_receive(flow)

                          : odp_port_to_ofport(backer, flow->in_port.odp_port));

@@ -5700,8 +5710,16 @@ xlate_learn_action(struct xlate_ctx *ctx, const struct ofpact_learn *learn)

         if (!error) {

             bool success = true;

             if (ctx->xin->allow_side_effects) {

+                long long int last_used;

+

+                if (ctx->xin->resubmit_stats) {

+                    last_used = ctx->xin->resubmit_stats->used;

+                } else {

+                    last_used = time_msec();

+                }

                 error = ofproto_flow_mod_learn(ofm, ctx->xin->xcache != NULL,

-                                               learn->limit, &success);

+                                               learn->limit, &success,

+                                               last_used);

             } else if (learn->limit) {

                 if (!ofm->temp_rule

                     || ofm->temp_rule->state != RULE_INSERTED) {

diff --git a/ofproto/ofproto-dpif.c b/ofproto/ofproto-dpif.c

index e22ca757a..ba5706f6a 100644

--- a/ofproto/ofproto-dpif.c

+++ b/ofproto/ofproto-dpif.c

@@ -4880,7 +4880,7 @@ packet_xlate(struct ofproto *ofproto_, struct ofproto_packet_out *opo)

             if (entry->type == XC_LEARN) {

                 struct ofproto_flow_mod *ofm = entry->learn.ofm;

-                error = ofproto_flow_mod_learn_refresh(ofm);

+                error = ofproto_flow_mod_learn_refresh(ofm, time_msec());

                 if (error) {

                     goto error_out;

                 }

diff --git a/ofproto/ofproto-provider.h b/ofproto/ofproto-provider.h

index 143ded690..9f7b8b6e8 100644

--- a/ofproto/ofproto-provider.h

+++ b/ofproto/ofproto-provider.h

@@ -2027,9 +2027,11 @@ enum ofperr ofproto_flow_mod_init_for_learn(struct ofproto *,

                                             struct ofproto_flow_mod *)

     OVS_EXCLUDED(ofproto_mutex);

 enum ofperr ofproto_flow_mod_learn(struct ofproto_flow_mod *, bool keep_ref,

-                                   unsigned limit, bool *below_limit)

+                                   unsigned limit, bool *below_limit,

+                                   long long int last_used)

     OVS_EXCLUDED(ofproto_mutex);

-enum ofperr ofproto_flow_mod_learn_refresh(struct ofproto_flow_mod *ofm);

+enum ofperr ofproto_flow_mod_learn_refresh(struct ofproto_flow_mod *ofm,

+                                           long long int last_used);

 enum ofperr ofproto_flow_mod_learn_start(struct ofproto_flow_mod *ofm)

     OVS_REQUIRES(ofproto_mutex);

 void ofproto_flow_mod_learn_revert(struct ofproto_flow_mod *ofm)

diff --git a/ofproto/ofproto.c b/ofproto/ofproto.c

index dbf4958bc..e78c80d11 100644

--- a/ofproto/ofproto.c

+++ b/ofproto/ofproto.c

@@ -5472,7 +5472,8 @@ ofproto_flow_mod_init_for_learn(struct ofproto *ofproto,

 }

 enum ofperr

-ofproto_flow_mod_learn_refresh(struct ofproto_flow_mod *ofm)

+ofproto_flow_mod_learn_refresh(struct ofproto_flow_mod *ofm,

+                               long long int last_used)

 {

     enum ofperr error = 0;

@@ -5493,9 +5494,37 @@ ofproto_flow_mod_learn_refresh(struct ofproto_flow_mod *ofm)

      * this function is executed the rule will be reinstated. */

     if (rule->state == RULE_REMOVED) {

         struct cls_rule cr;

+        struct oftable *table = &rule->ofproto->tables[rule->table_id];

+        ovs_version_t tables_version = rule->ofproto->tables_version;

+

+        if (!cls_rule_visible_in_version(&rule->cr, tables_version)) {

+            const struct cls_rule *curr_cls_rule;

+

+            /* Only check for matching classifier rules and their modified

+             * time, instead of also checking all rule metadata, with the goal

+             * of suppressing a learn action update that would replace a more

+             * recent rule in the classifier. */

+            curr_cls_rule = classifier_find_rule_exactly(&table->cls,

+                                                         &rule->cr,

+                                                         tables_version);

+            if (curr_cls_rule) {

+                struct rule *curr_rule = rule_from_cls_rule(curr_cls_rule);

+                long long int curr_last_used;

+

+                ovs_mutex_lock(&curr_rule->mutex);

+                curr_last_used = curr_rule->modified;

+                ovs_mutex_unlock(&curr_rule->mutex);

+

+                if (curr_last_used > last_used) {

+                    /* In the case of a newer visible rule, don't recreate the

+                     *  current rule. */

+                    return 0;

+                }

+            }

+        }

-        cls_rule_clone(&cr, &rule->cr);

         ovs_mutex_lock(&rule->mutex);