driver-sqlpool: Implement sql_wait()

diff --git a/src/lib-sql/driver-sqlpool.c b/src/lib-sql/driver-sqlpool.c
index 78b372c0350104e70b66341b7cc1e184991da1ef..6a7d43a30b29adf383290ab1726815ad2dfb6e83 100644 (file)
--- 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,