Software `/` code `/` prosody

Annotate

util/smqueue.lua @ 13273:a1c927323f06

mod_tokenauth: Delete grants without tokens after period Generally it is expected that a grant would have at least one token as long as the grant is in active use. Refresh tokens issued by mod_http_oauth2 have a lifetime of one week by default, so the idea here is that if that refresh token expired and another week goes by without the grant being used, then the whole grant can be removed.

author	Kim Alvefur <zash@zash.se>
date	Mon, 16 Oct 2023 23:51:52 +0200
parent	12975:d10957394a3c

rev	line source
12975 d10957394a3c util: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12058 diff changeset	1 local queue = require("prosody.util.queue");
12055 daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	2
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	3 local lib = { smqueue = {} }
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	4
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	5 local smqueue = lib.smqueue;
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	6
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	7 function smqueue:push(v)
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	8 self._head = self._head + 1;
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	9
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	10 assert(self._queue:push(v));
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	11 end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	12
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	13 function smqueue:ack(h)
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	14 if h < self._tail then
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	15 return nil, "tail"
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	16 elseif h > self._head then
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	17 return nil, "head"
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	18 end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	19
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	20 local acked = {};
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	21 self._tail = h;
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	22 local expect = self._head - self._tail;
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	23 while expect < self._queue:count() do
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	24 local v = self._queue:pop();
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	25 if not v then return nil, "pop" end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	26 table.insert(acked, v);
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	27 end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	28 return acked
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	29 end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	30
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	31 function smqueue:count_unacked() return self._head - self._tail end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	32
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	33 function smqueue:count_acked() return self._tail end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	34
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	35 function smqueue:resumable() return self._queue:count() >= (self._head - self._tail) end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	36
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	37 function smqueue:resume() return self._queue:items() end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	38
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	39 function smqueue:consume() return self._queue:consume() end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	40
12058 4860da718e87 util.smqueue: Simplify compat table, fix dependent modules (thanks Martin) Kim Alvefur <zash@zash.se> parents: 12055 diff changeset	41 function smqueue:table()
4860da718e87 util.smqueue: Simplify compat table, fix dependent modules (thanks Martin) Kim Alvefur <zash@zash.se> parents: 12055 diff changeset	42 local t = {};
4860da718e87 util.smqueue: Simplify compat table, fix dependent modules (thanks Martin) Kim Alvefur <zash@zash.se> parents: 12055 diff changeset	43 for i, v in self:resume() do t[i] = v; end
4860da718e87 util.smqueue: Simplify compat table, fix dependent modules (thanks Martin) Kim Alvefur <zash@zash.se> parents: 12055 diff changeset	44 return t
12055 daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	45 end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	46
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	47 local function freeze(q) return { head = q._head; tail = q._tail } end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	48
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	49 local queue_mt = { __name = "smqueue"; __index = smqueue; __len = smqueue.count_unacked; __freeze = freeze }
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	50
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	51 function lib.new(size)
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	52 assert(size > 0);
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	53 return setmetatable({ _head = 0; _tail = 0; _queue = queue.new(size, true) }, queue_mt)
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	54 end
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	55
daced16154fa util.smqueue: Abstract queue with acknowledgements and overflow Kim Alvefur <zash@zash.se> parents: diff changeset	56 return lib

prosody

a1c927323f06

util/smqueue.lua

Software / code / prosody

Annotate

util/smqueue.lua @ 13273:a1c927323f06

Software `/` code `/` prosody