Skip to content

Commit 9a60c49

Browse files
committed
LMDB Storage: add batch remove
1 parent f4c50fa commit 9a60c49

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

src/lib/lmdb_storage/generic.ml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -237,4 +237,8 @@ module Read_write (F_func : F) = struct
237237

238238
let remove ~env:t db key =
239239
with_env t ~perm:Rw ~default:() ~f:(fun env -> remove_impl ~env db key)
240+
241+
let batch_remove ~env:t db keys =
242+
with_env t ~perm:Rw ~default:() ~f:(fun env ->
243+
Queue.iter keys ~f:(remove_impl ~env db) )
240244
end

src/lib/lmdb_storage/generic.mli

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,8 @@ module Read_write : functor (F_func : F) -> sig
5656

5757
val remove : env:t -> ('k, 'v) Db.t -> 'k -> unit
5858

59+
val batch_remove : env:t -> ('k, 'v) Db.t -> 'k Core_kernel.Queue.t -> unit
60+
5961
val with_txn :
6062
?perm:[ `Read | `Write ] Lmdb.perm
6163
-> f:(Db.getter -> Db.setter -> 'r)

0 commit comments

Comments
 (0)