search

moonlibs / xqueue

Imbue tarantool space with power of queue
15 stars 12 forks source link

shutdown runat and worker when node is in ro state #14

Closed ochaton closed 4 years ago

ochaton commented 4 years ago
  1. We should disable background fibers on ro nodes
  2. We need to setup self.ready channel before we create background fibers because after reload space.xq already defined so fibers skip xq.ready:get() check.

It seems that it is possible to take same task twice during reload when runat fiber collect more than 1 task. New runat doesn't wait until the old fiber is done, so it can collect same tasks.