From: Timo Sirainen <timo.sirainen@open-xchange.com>
Date: Tue, 28 Sep 2021 12:33:47 +0000 (+0300)
Subject: driver-sqlpool: Implement sql_wait()
X-Git-Tag: 2.3.17~24
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=b6aa90594b77c10c5b12a89bd9a31c745a45bba1;p=thirdparty%2Fdovecot%2Fcore.git

driver-sqlpool: Implement sql_wait()
---

diff --git a/src/lib-sql/driver-sqlpool.c b/src/lib-sql/driver-sqlpool.c
index 78b372c035..6a7d43a30b 100644
--- a/src/lib-sql/driver-sqlpool.c
+++ b/src/lib-sql/driver-sqlpool.c
@@ -885,6 +885,15 @@ driver_sqlpool_escape_blob(struct sql_db *_db,
 	return sql_escape_blob(conns[0].db, data, size);
 }
 
+static void driver_sqlpool_wait(struct sql_db *_db)
+{
+	struct sqlpool_db *db = (struct sqlpool_db *)_db;
+	const struct sqlpool_connection *conn;
+
+	array_foreach(&db->all_connections, conn)
+		sql_wait(conn->db);
+}
+
 struct sql_db driver_sqlpool_db = {
 	"",
 
@@ -897,6 +906,7 @@ struct sql_db driver_sqlpool_db = {
 		.exec = driver_sqlpool_exec,
 		.query = driver_sqlpool_query,
 		.query_s = driver_sqlpool_query_s,
+		.wait = driver_sqlpool_wait,
 
 		.transaction_begin = driver_sqlpool_transaction_begin,
 		.transaction_commit = driver_sqlpool_transaction_commit,