Software / code / prosody-modules
Changeset
1983:f7fc5088b340
mod_storage_lmdb: Allow passing a transaction flag so we can run get operations in a read-only transaction
| author | Kim Alvefur <zash@zash.se> |
|---|---|
| date | Sat, 19 Dec 2015 00:34:55 +0100 |
| parents | 1982:bb0b2eae5563 |
| children | 1984:2ed6f6eeeaba |
| files | mod_storage_lmdb/mod_storage_lmdb.lua |
| diffstat | 1 files changed, 4 insertions(+), 4 deletions(-) [+] |
line wrap: on
line diff
--- a/mod_storage_lmdb/mod_storage_lmdb.lua Sat Dec 19 00:25:30 2015 +0100 +++ b/mod_storage_lmdb/mod_storage_lmdb.lua Sat Dec 19 00:34:55 2015 +0100 @@ -20,9 +20,9 @@ local serialize = serialization.serialize; local deserialize = serialization.deserialize; -local function transaction(env, func, ...) +local function transaction(env, flag, func, ...) local args, n_args = {...}, select("#", ...); - local t = env:txn_begin(nil, 0); + local t = env:txn_begin(nil, flag); local function f() return func(t, unpack(args, 1, n_args)); end local success, a, b, c = xpcall(f, traceback); if not success then @@ -66,11 +66,11 @@ if value ~= nil then value = serialize(value); end - return transaction(self.env, keyvalue_set, self.db, key, value); + return transaction(self.env, 0, keyvalue_set, self.db, key, value); end function keyval:get(key) - local ok, data = transaction(self.env, keyvalue_get, self.db, key); + local ok, data = transaction(self.env, lmdb.MDB_RDONLY, keyvalue_get, self.db, key); if not ok then return ok, data; end return deserialize(data); end
