Don't touch consumers that work in the other (non disconnect) session.

amdei · Dec 26, 2016 · 05d9325 · 05d9325
1 parent 9796515
commit 05d9325
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/queue/abstract.lua b/queue/abstract.lua
@@ -245,6 +245,10 @@ function method._on_consumer_disconnect()
         if waiter == nil then
             break
         end
+        -- Don't touch the other consumers
+        if waiter[1] ~= id then
+            break
+        end
         box.space._queue_consumers:delete{ waiter[1], waiter[2] }
         fb = fiber.find(waiter[2])
         if fb ~= nil and fb:status() ~= 'dead' then