http://hg.omfa.de/prosody-hg/ en-us prosody-hg: util/async.lua history util/async.lua revision history util.async: Clip long line [luacheck] http://hg.omfa.de/prosody-hg/log/5e258164d214/util/async.lua Kim Alvefur <zash@zash.se> Tue, 21 Nov 2023 22:18:17 +0100 util.async: Expose default runner function http://hg.omfa.de/prosody-hg/log/fa4143163e01/util/async.lua
This is purely for informational purposes, so it's possible to determine
externally whether a runner is using the default runner function (which
executes functions as work items) or a custom runner function.]]> Matthew Wild <mwild1@gmail.com> Tue, 21 Nov 2023 18:14:51 +0000 util.async: Record current work item in the runner object http://hg.omfa.de/prosody-hg/log/17cb965e55b7/util/async.lua
Mostly expected to be useful for debugging purposes.]]> Matthew Wild <mwild1@gmail.com> Tue, 21 Nov 2023 18:13:42 +0000 util.async: Improve debug logging in a few places http://hg.omfa.de/prosody-hg/log/5206314d6c70/util/async.lua
Knowing the state of the coroutine as well as the runner state can be helpful.]]> Matthew Wild <mwild1@gmail.com> Tue, 21 Nov 2023 18:12:49 +0000 util.async: Export a table of currently-waiting runners http://hg.omfa.de/prosody-hg/log/49ecfb070240/util/async.lua
This can be used for debugging and introspection.]]> Matthew Wild <mwild1@gmail.com> Tue, 21 Nov 2023 18:11:40 +0000 util: Prefix module imports with prosody namespace http://hg.omfa.de/prosody-hg/log/d10957394a3c/util/async.lua Kim Alvefur <zash@zash.se> Fri, 17 Mar 2023 16:23:16 +0100 util.async: Optionally allow too many 'done' callbacks http://hg.omfa.de/prosody-hg/log/91af1697ddd8/util/async.lua
Sometimes, like in mod_c2s and mod_s2s during shutdown, all you want is
to wait for the first done() and not complicate things.]]> Kim Alvefur <zash@zash.se> Tue, 22 Feb 2022 14:17:10 +0100 util.async: Add next-tick configuration http://hg.omfa.de/prosody-hg/log/9a70a543c727/util/async.lua
Running woken runners in the next iteration of the event loop prevents
unexpected recursion, unexpected tracebacks, and is generally more
predictable.

The pattern is borrowed from util.promise, where we're now doing the same.]]> Matthew Wild <mwild1@gmail.com> Mon, 29 Nov 2021 14:14:30 +0000 util.async: Add sleep() method with configurable scheduling backend http://hg.omfa.de/prosody-hg/log/542a9a503073/util/async.lua
No scheduler set by default, so it will error (we plan to initialize it in
util.startup).

We wanted to avoid a hard dependency on util.timer (which in turn depends on
network backends, etc.), and we didn't add timer.sleep() because we didn't
want to add a hard dependency on util.async for things that don't need it.]]> Matthew Wild <mwild1@gmail.com> Mon, 29 Nov 2021 14:11:24 +0000 util.async: Don't attempt to close thread if not created yet http://hg.omfa.de/prosody-hg/log/558f0555ba02/util/async.lua Matthew Wild <mwild1@gmail.com> Sun, 14 Jun 2020 09:40:08 +0100 util.async: Call coroutine.close() on dead threads (Lua 5.4) http://hg.omfa.de/prosody-hg/log/69a4b0e3565f/util/async.lua Matthew Wild <mwild1@gmail.com> Sun, 14 Jun 2020 08:49:32 +0100 util.async: Rename wait -> wait_for (w/compat) http://hg.omfa.de/prosody-hg/log/79faf5b98395/util/async.lua
Agreed this name is clearer and wait_for(thing) reads well in code.]]> Matthew Wild <mwild1@gmail.com> Sat, 13 Jun 2020 08:01:57 +0100 util.async: Add function for waiting on promises and unpacking the results http://hg.omfa.de/prosody-hg/log/7b48b620164c/util/async.lua Kim Alvefur <zash@zash.se> Sun, 29 Sep 2019 18:42:35 +0200 Many things: switch from hacky multi-arg xpcall implementations to a standard util.xpcall http://hg.omfa.de/prosody-hg/log/acf74ad0b795/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 26 Oct 2018 19:32:00 +0100 util.async: Remove sleep function http://hg.omfa.de/prosody-hg/log/83e7ad5818d3/util/async.lua
Dependency on util.timer indirectly caused net.server to be initialized
before the config was read, so server_select was always chosen.]]> Kim Alvefur <zash@zash.se> Sun, 12 Aug 2018 23:52:39 +0200 util.{async,timer}: Move sleep() to reduce dependencies of util.timer http://hg.omfa.de/prosody-hg/log/2e6f7ab97794/util/async.lua Kim Alvefur <zash@zash.se> Sun, 08 Jul 2018 00:37:01 +0200 MUC: Add config option to allow members to invite other members to the room (previously only owners/admins could do this) http://hg.omfa.de/prosody-hg/log/92f0876b9230/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 06 Jul 2018 15:33:46 +0100 util.async: Copy hooks from main thread into coroutines http://hg.omfa.de/prosody-hg/log/ed0891383e78/util/async.lua Matthew Wild <mwild1@gmail.com> Mon, 25 Jun 2018 13:53:17 +0100 util.async: Move runner id into log tag http://hg.omfa.de/prosody-hg/log/7a9b680a79fb/util/async.lua
Avoids string concatenation in every logger call]]> Kim Alvefur <zash@zash.se> Fri, 04 May 2018 00:10:17 +0200 util.async: Add helper methods for setting watchers http://hg.omfa.de/prosody-hg/log/01264bc60c2b/util/async.lua Matthew Wild <mwild1@gmail.com> Mon, 30 Apr 2018 12:53:53 +0100 util.timer: Move sleep() here from util.async http://hg.omfa.de/prosody-hg/log/2548111e71d6/util/async.lua
This is to solve a indirect dependency issue where net.server was initialized before the config was read]]> Kim Alvefur <zash@zash.se> Fri, 23 Mar 2018 21:18:15 +0100 util.async: Remove last trace of async.once [luacheck] http://hg.omfa.de/prosody-hg/log/801f253ef52d/util/async.lua Kim Alvefur <zash@zash.se> Fri, 23 Mar 2018 20:57:34 +0100 util.async: Remove async.once(), can now be replaced by runner():run(func) http://hg.omfa.de/prosody-hg/log/867ac771fb6e/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 23 Mar 2018 14:22:01 +0000 util.async: Make parameters to async.runner() optional http://hg.omfa.de/prosody-hg/log/0c077800cd70/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 23 Mar 2018 14:02:33 +0000 util.async: Use wrapper for once runner (thanks luacheck) http://hg.omfa.de/prosody-hg/log/2aa85b0cd2b8/util/async.lua Kim Alvefur <zash@zash.se> Thu, 22 Mar 2018 23:15:04 +0100 util.async: Allow nil as a guard key http://hg.omfa.de/prosody-hg/log/ba6a6a04b46c/util/async.lua Matthew Wild <mwild1@gmail.com> Thu, 22 Mar 2018 16:26:09 +0000 util.async: Add sleep() method http://hg.omfa.de/prosody-hg/log/1b7c5933b215/util/async.lua Matthew Wild <mwild1@gmail.com> Thu, 22 Mar 2018 13:02:00 +0000 util.async: Add once() to create temporary runners http://hg.omfa.de/prosody-hg/log/9246f64d6f1e/util/async.lua Matthew Wild <mwild1@gmail.com> Thu, 22 Mar 2018 07:56:01 +0000 util.async: Add ready() to check whether running in async context http://hg.omfa.de/prosody-hg/log/ca710a71d730/util/async.lua Matthew Wild <mwild1@gmail.com> Thu, 22 Mar 2018 07:46:23 +0000 util.async: Bump log warnings to error level http://hg.omfa.de/prosody-hg/log/ddb04cacb8b1/util/async.lua Matthew Wild <mwild1@gmail.com> Mon, 19 Mar 2018 11:51:40 +0000 util.async: Split runner_continue into smaller functions for easier testing and safety http://hg.omfa.de/prosody-hg/log/24b59a62acce/util/async.lua Matthew Wild <mwild1@gmail.com> Sun, 18 Mar 2018 12:05:38 +0000 util.async: Remove redundant line committed by mistake (Zash, luacheck) http://hg.omfa.de/prosody-hg/log/08bf4df6fdb7/util/async.lua Matthew Wild <mwild1@gmail.com> Sat, 17 Mar 2018 22:03:08 +0000 util.async: ensure change in e77b37de482e applies after out-of-loop resume also http://hg.omfa.de/prosody-hg/log/a15c891c6232/util/async.lua Matthew Wild <mwild1@gmail.com> Sat, 17 Mar 2018 17:28:07 +0000 util.async: Behaviour change: continue to process queued items after errors http://hg.omfa.de/prosody-hg/log/e77b37de482e/util/async.lua Matthew Wild <mwild1@gmail.com> Sat, 17 Mar 2018 14:54:48 +0000 util.async: Convert asserts to a return false (same as other unexpected behaviour) http://hg.omfa.de/prosody-hg/log/dbb4788db8e3/util/async.lua Matthew Wild <mwild1@gmail.com> Sat, 17 Mar 2018 11:46:21 +0000 util.async: Add comment http://hg.omfa.de/prosody-hg/log/937de0c39279/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 22:31:12 +0000 util.async: You can never have too many asserts! http://hg.omfa.de/prosody-hg/log/b03c7884fade/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 22:30:25 +0000 util.async: Ensure runner is left in correct state after out-of-main-loop error (+tests) http://hg.omfa.de/prosody-hg/log/9f6ab206d741/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 22:26:15 +0000 util.async: Log the non-error state as well when there is an error being processed http://hg.omfa.de/prosody-hg/log/1c8c7fd259c8/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 17:13:20 +0000 util.async: Bugfix, don't continue main loop while there is a pending error http://hg.omfa.de/prosody-hg/log/dc5f3302a642/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 17:12:36 +0000 util.async: Fix order of statements so queue count makes more sense http://hg.omfa.de/prosody-hg/log/9901deadc068/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 17:12:09 +0000 util.async: Log warning when unexpected state is reached http://hg.omfa.de/prosody-hg/log/ce5b16e13573/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 17:11:23 +0000 util.async: Add per-runner ids and add runner:log() method http://hg.omfa.de/prosody-hg/log/96f20cf92b84/util/async.lua Matthew Wild <mwild1@gmail.com> Fri, 16 Mar 2018 14:59:41 +0000 util.async: Fix thread check to work correctly in Lua 5.2 http://hg.omfa.de/prosody-hg/log/b751bee6a829/util/async.lua
coroutine.running() now returns the main thread and a boolean true if
called from the main thread, as opposed to nil in 5.1]]> Kim Alvefur <zash@zash.se> Tue, 21 Nov 2017 21:48:43 +0100 util.async: Factor out thread check into a function http://hg.omfa.de/prosody-hg/log/f652e1ea2f69/util/async.lua Kim Alvefur <zash@zash.se> Tue, 21 Nov 2017 21:48:14 +0100 util.async: Fix documentation URL http://hg.omfa.de/prosody-hg/log/f81cd9aaf994/util/async.lua Waqas Hussain <waqas20@gmail.com> Fri, 15 Sep 2017 17:17:07 -0400 util.async: Add annotation to ignore warning [luacheck] http://hg.omfa.de/prosody-hg/log/f928695a2af1/util/async.lua Kim Alvefur <zash@zash.se> Sat, 19 Nov 2016 01:11:28 +0100 util.async: Rename variable to avoid name clash [luacheck] http://hg.omfa.de/prosody-hg/log/20a69ef5570c/util/async.lua Kim Alvefur <zash@zash.se> Sat, 19 Nov 2016 01:11:53 +0100 util.async: Add some more comments for clarity http://hg.omfa.de/prosody-hg/log/649b89b2c840/util/async.lua Matthew Wild <mwild1@gmail.com> Sun, 22 May 2016 20:06:12 +0100 Update every link to the documentation to use HTTPS http://hg.omfa.de/prosody-hg/log/a5a080c12c96/util/async.lua Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> Sat, 16 Apr 2016 21:08:05 +0100 util.async: Make guarder() local http://hg.omfa.de/prosody-hg/log/a493b79cfad0/util/async.lua Matthew Wild <mwild1@gmail.com> Tue, 13 Aug 2013 23:38:50 +0100 util.async: Add guarder method, to create guards to ensure only a single runner can pass through a section of code at a time http://hg.omfa.de/prosody-hg/log/0b66cb959161/util/async.lua Matthew Wild <mwild1@gmail.com> Tue, 13 Aug 2013 21:26:53 +0100 util.async: Fix logic bug that prevented error watcher being called for runners http://hg.omfa.de/prosody-hg/log/66c3ad5d29ad/util/async.lua Matthew Wild <mwild1@gmail.com> Tue, 13 Aug 2013 19:23:00 +0100 util.async: waiter: Throw error if done() called too many times http://hg.omfa.de/prosody-hg/log/e8c79796ead9/util/async.lua Kim Alvefur <zash@zash.se> Mon, 12 Aug 2013 13:22:27 +0200 util.async: waiter: Remove restriction about wait() being called before done() http://hg.omfa.de/prosody-hg/log/aac4c6147647/util/async.lua Matthew Wild <mwild1@gmail.com> Mon, 12 Aug 2013 12:08:51 +0100 util.async: runner: Fix check for new state to recognise transition to 'waiting' http://hg.omfa.de/prosody-hg/log/2c98061b6b1e/util/async.lua Matthew Wild <mwild1@gmail.com> Mon, 12 Aug 2013 11:50:27 +0100 util.async: Make functions local http://hg.omfa.de/prosody-hg/log/959163e4d631/util/async.lua Matthew Wild <mwild1@gmail.com> Mon, 12 Aug 2013 10:27:08 +0100 util.async: New library to provide support around coroutine-based non-blocking functions http://hg.omfa.de/prosody-hg/log/3556f338caa3/util/async.lua Matthew Wild <mwild1@gmail.com> Sun, 11 Aug 2013 14:46:07 +0100