From 8c87fbed461b9c5d301c93a1ae330774c5039a56 Mon Sep 17 00:00:00 2001
From: Jason Volk <jason@zemos.net>
Date: Tue, 8 May 2018 00:15:18 -0700
Subject: [PATCH] modules/federation: Add various conf items for flush
 high-watermarks.

---
 modules/federation/backfill.cc | 14 +++++++++++++-
 modules/federation/state.cc    | 14 +++++++++++++-
 2 files changed, 26 insertions(+), 2 deletions(-)

diff --git a/modules/federation/backfill.cc b/modules/federation/backfill.cc
index fe6ddb6ce..e2ba5b6cf 100644
--- a/modules/federation/backfill.cc
+++ b/modules/federation/backfill.cc
@@ -56,6 +56,13 @@ backfill_limit_default
 	{ "default",  64L                                      },
 };
 
+conf::item<size_t>
+backfill_flush_hiwat
+{
+	{ "name",     "ircd.federation.backfill.flush.hiwat" },
+	{ "default",  16384L                                 },
+};
+
 resource::response
 get__backfill(client &client,
               const resource::request &request)
@@ -92,13 +99,18 @@ get__backfill(client &client,
 		client, http::OK
 	};
 
-	json::stack out{buf, [&response]
+	const auto flush{[&response]
 	(const const_buffer &buf)
 	{
 		response.write(buf);
 		return buf;
 	}};
 
+	json::stack out
+	{
+		buf, flush, size_t(backfill_flush_hiwat)
+	};
+
 	json::stack::object top{out};
 	json::stack::member pdus_m
 	{
diff --git a/modules/federation/state.cc b/modules/federation/state.cc
index b94cf3caa..c44c22348 100644
--- a/modules/federation/state.cc
+++ b/modules/federation/state.cc
@@ -26,6 +26,13 @@ state_resource
 	}
 };
 
+conf::item<size_t>
+state_flush_hiwat
+{
+	{ "name",     "ircd.federation.state.flush.hiwat" },
+	{ "default",  16384L                              },
+};
+
 resource::response
 get__state(client &client,
            const resource::request &request)
@@ -59,13 +66,18 @@ get__state(client &client,
 		client, http::OK
 	};
 
-	json::stack out{buf, [&response]
+	const auto flush{[&response]
 	(const const_buffer &buf)
 	{
 		response.write(buf);
 		return buf;
 	}};
 
+	json::stack out
+	{
+		buf, flush, size_t(state_flush_hiwat)
+	};
+
 	json::stack::object top{out};
 	json::stack::member pdus_m
 	{