Make sure any linda operation that can raise an error won't ever leave a mutex unreleased

1 files changed, 28 insertions, 0 deletions

diff --git a/tests/deadlock.lua b/tests/deadlock.lua
new file mode 100644
index 0000000..8ccae89
--- /dev/null
+++ b/tests/deadlock.lua
@@ -0,0 +1,28 @@
+local lanes = require('lanes').configure()
+local linda = lanes.linda "deadlock_linda"
+
+local do_extra_stuff = true
+
+if do_extra_stuff then
+        -- just something to make send() succeed and receive() fail:
+        local payload = { lanes.require('socket').connect }
+
+        -- lane generator
+        local g = lanes.gen('*', function()
+                set_debug_threadname "deadlock_lane"
+                print("In lane 1:", table.unpack{pcall(linda.receive, linda, 'tmp')})
+                print("In lane 2:", table.unpack{pcall(linda.receive, linda, 'tmp')})
+                return 33, 55
+        end)
+
+        -- send payload twice
+        linda:send('tmp', payload, payload)
+        local h = g()
+        local err, stack = h:join()
+        print('we reach here and then deadlock', err, stack)
+end
+-- start lane
+
+-- wait some
+lanes.sleep(2)
+print('we never reach here')
\ No newline at end of file