diff mbox series

[ovs-dev,RFC,6/7] northd-ddlog: Split sb::Out_Load_Balancer relation.

Message ID 20211125213524.11165.87574.stgit@dceara.remote.csb
State RFC
Headers show
Series northd-ddlog: Benchmark and improve Load Balancer performance. | expand

Commit Message

Dumitru Ceara Nov. 25, 2021, 9:35 p.m. UTC 
TODO: this improves performance significantly.  Not exactly sure why..
Is it related to FlatMap called "inline"?  Is it related to group_by()?

Signed-off-by: Dumitru Ceara <dceara@redhat.com>
---
 northd/ovn_northd.dl |   29 +++++++++++------------------
 1 file changed, 11 insertions(+), 18 deletions(-)
diff mbox series

Patch

diff --git a/northd/ovn_northd.dl b/northd/ovn_northd.dl
index 7f5288d14..90558a7c4 100644
--- a/northd/ovn_northd.dl
+++ b/northd/ovn_northd.dl
@@ -8875,21 +8875,17 @@  relation PortExists(name: istring)
 PortExists(name) :- &nb::Logical_Switch_Port(.name = name).
 PortExists(name) :- &nb::Logical_Router_Port(.name = name).
 
-sb::Out_Load_Balancer(._uuid = lb._uuid,
-                      .name = lb.name,
-                      .vips = lb.vips,
-                      .protocol = lb.protocol,
-                      .datapaths = datapaths,
-                      .external_ids = [i"lb_id" -> uuid2str(lb_uuid).intern()],
-                      .options = options) :-
+relation Pre_Out_Load_Balancer(lb_uuid: uuid, dp_uuid: uuid)
+
+Pre_Out_Load_Balancer(lb_uuid, ls_uuid) :-
     nb in &nb::Logical_Switch(._uuid = ls_uuid, .load_balancer = lb_uuids),
-    var lb_uuid = FlatMap(lb_uuids),
-    var datapaths = ls_uuid.group_by(lb_uuid).to_set(),
-    lb in &nb::Load_Balancer(._uuid = lb_uuid),
-    /* Store the fact that northd provides the original (destination IP +
-     * transport port) tuple.
-     */
-    var options = lb.options.insert_imm(i"hairpin_orig_tuple", i"true").
+    var lb_uuid = FlatMap(lb_uuids).
+
+Pre_Out_Load_Balancer(lb_uuid, ls_uuid) :-
+    nb in &nb::Logical_Switch(._uuid = ls_uuid, .load_balancer_group = lbg_uuids),
+    var lbg_uuid = FlatMap(lbg_uuids),
+    lbg in &nb::Load_Balancer_Group(._uuid = lbg_uuid, .load_balancer = lb_uuids),
+    var lb_uuid = FlatMap(lb_uuids).
 
 sb::Out_Load_Balancer(._uuid = lb._uuid,
                       .name = lb.name,
@@ -8898,10 +8894,7 @@  sb::Out_Load_Balancer(._uuid = lb._uuid,
                       .datapaths = datapaths,
                       .external_ids = [i"lb_id" -> uuid2str(lb_uuid).intern()],
                       .options = options) :-
-    nb in &nb::Logical_Switch(._uuid = ls_uuid, .load_balancer_group = lbg_uuids),
-    var lbg_uuid = FlatMap(lbg_uuids),
-    lbg in &nb::Load_Balancer_Group(._uuid = lbg_uuid, .load_balancer = lb_uuids),
-    var lb_uuid = FlatMap(lb_uuids),
+    Pre_Out_Load_Balancer(lb_uuid, ls_uuid),
     var datapaths = ls_uuid.group_by(lb_uuid).to_set(),
     lb in &nb::Load_Balancer(._uuid = lb_uuid),
     /* Store the fact that northd provides the original (destination IP +