Parallelised merge, backup phase.

1 files changed, 15 insertions, 2 deletions

diff --git a/tools/compileconfig.py b/tools/compileconfig.py
index aea7ace..47fd19a 100755
--- a/tools/compileconfig.py
+++ b/tools/compileconfig.py
@@ -186,12 +186,17 @@ def allowed_servers_frontend(signingnodenames, storagenodenames):
         ("/plop/v1/signing/sct", signingnodenames),
     ]
 
-def allowed_servers_primarymerge(frontendnodenames):
+def allowed_servers_primarymerge(frontendnodenames, secondarymergenames):
     return [
         ("/plop/v1/frontend/verify-entries", frontendnodenames),
         ("/plop/v1/frontend/sendlog", frontendnodenames),
         ("/plop/v1/frontend/sendentry", frontendnodenames),
         ("/plop/v1/frontend/publish-sth", frontendnodenames),
+        ("/plop/v1/merge/verifiedsize", secondarymergenames),
+        ("/plop/v1/merge/verifyroot", secondarymergenames),
+        ("/plop/v1/merge/setverifiedsize", secondarymergenames),
+        ("/plop/v1/merge/sendlog", secondarymergenames),
+        ("/plop/v1/merge/sendentry", secondarymergenames),
     ]
 
 def parse_ratelimit_expression(expression):
@@ -352,15 +357,23 @@ def gen_config(nodename, config, localconfig):
         reloadableplopconfig.append((Symbol("storage_nodes_quorum"), config["storage-quorum-size"]))
         services.add(Symbol("ht"))
         if nodename == primarymergenodename:
+            mergesecondarynames = [node["name"] for node in config["mergenodes"] if node["name"] != primarymergenodename]
+            mergesecondaryaddresses = ["https://%s/plop/v1/merge/" % node["address"] for node in config["mergenodes"] if node["name"] != primarymergenodename]
             merge = localconfig["merge"]
             plopconfig.append((Symbol("db_backend_opt"), [(Symbol("write_flag"), Symbol("read"))]))
             plopconfig.append((Symbol("merge_delay"), merge["min-delay"]))
             plopconfig.append((Symbol("merge_dist_winsize"), merge["dist-window-size"]))
             plopconfig.append((Symbol("merge_dist_sendlog_chunksize"), merge["dist-sendlog-chunksize"]))
             plopconfig.append((Symbol("merge_dist_sendentries_chunksize"), merge["dist-sendentries-chunksize"]))
+            reloadableplopconfig.append((Symbol("merge_backup_winsize"), merge["backup-window-size"]))
+            reloadableplopconfig.append((Symbol("merge_backup_sendlog_chunksize"), merge["backup-sendlog-chunksize"]))
+            reloadableplopconfig.append((Symbol("merge_backup_sendentries_chunksize"), merge["backup-sendentries-chunksize"]))
             plopconfig.append((Symbol("frontend_nodes"), frontendnodeaddresses))
+            reloadableplopconfig.append((Symbol("merge_secondaries"), zip(mergesecondarynames, mergesecondaryaddresses)))
             plopconfig.append((Symbol("sth_path"), paths["mergedb"] + "/sth"))
-            allowed_servers += allowed_servers_primarymerge(frontendnodenames)
+            plopconfig.append((Symbol("fetched_path"), paths["mergedb"] + "/fetched"))
+            plopconfig.append((Symbol("verified_path"), paths["mergedb"] + "/verified"))
+            allowed_servers += allowed_servers_primarymerge(frontendnodenames, mergesecondarynames)
         else:
             allowed_clients += allowed_clients_mergesecondary(primarymergenodename)