From b6aa90594b77c10c5b12a89bd9a31c745a45bba1 Mon Sep 17 00:00:00 2001 From: Timo Sirainen Date: Tue, 28 Sep 2021 15:33:47 +0300 Subject: [PATCH] driver-sqlpool: Implement sql_wait() --- src/lib-sql/driver-sqlpool.c | 10 ++++++++++ 1 file changed, 10 insertions(+) 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, -- 2.47.3