diff options
| author | Kim Alvefur <zash@zash.se> | 2019-05-27 19:00:32 +0200 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2019-05-27 19:00:32 +0200 |
| commit | f11e984c3083a170d9b87655a51565fe24ddcf24 (patch) | |
| tree | db3205f9d2ddf06d44510b7457c3047887e7df8c | |
| parent | 3bf9f59c008d66f9995ff93eb204514ad852c454 (diff) | |
| download | prosody-f11e984c3083a170d9b87655a51565fe24ddcf24.tar.gz prosody-f11e984c3083a170d9b87655a51565fe24ddcf24.zip | |
mod_mam: Cache last date that archive owner has messages to reduce writes (fixes #1368)
| -rw-r--r-- | plugins/mod_mam/mod_mam.lua | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/plugins/mod_mam/mod_mam.lua b/plugins/mod_mam/mod_mam.lua index a8c2689d..8900a2be 100644 --- a/plugins/mod_mam/mod_mam.lua +++ b/plugins/mod_mam/mod_mam.lua @@ -348,8 +348,14 @@ if cleanup_after ~= "never" then -- messages, we collect the union of sets of users from dates that fall -- outside the cleanup range. + local last_date = require "util.cache".new(module:get_option_number("archive_cleanup_date_cache_size", 1000)); function schedule_cleanup(username, date) - cleanup_map:set(date or datestamp(), username, true); + date = date or datestamp(); + if last_date:get(username) == date then return end + local ok = cleanup_map:set(date, username, true); + if ok then + last_date:set(username, date); + end end cleanup_runner = require "util.async".runner(function () |