Fixes method :bury for time64 id

Author: ochaton

example-tube/init.lua

@@ -118,6 +118,24 @@ do
 	end
 end
 
+box.space.utube:put {
+	tube    = "tube-1",
+	payload = {
+		ctime = require 'clock'.realtime64(),
+	},
+	nice = 0,
+}
+
+do
+	local task = box.space.utube:take(0)
+	test:ok(task, ":take returned task from queue")
+	box.space.utube:bury({ task.id })
+
+	task = box.space.utube:get{task.id}
+
+	test:ok(task.status, "B", "task was successfully buried")
+end
+
 -- clears queue:
 box.space.utube:truncate()
 

xqueue.lua

@@ -1360,26 +1360,30 @@ function methods:ack(key, attr)
 	return t
 end
 
-function methods:bury(task, attr)
-	local xq   = self.xq
-	local key  = xq:getkey(task)
-	local peer = box.session.storage.peer
-	local sid  = box.session.id()
-	attr       = attr or {}
+function methods:bury(key, attr)
+	attr = attr or {}
 
-	if xq.debug then
-		log.info("Bury {%s} by %s, sid=%s, fid=%s", key, peer, sid, fiber.id())
-	end
+	local xq = self.xq
+	key = xq:getkey(key)
+	local t = xq:check_owner(key)
 
 	local update = {}
 	if attr.update then
 		for _,v in pairs(attr.update) do table.insert(update,v) end
 	end
 	table.insert(update, { '=', xq.fields.status, 'B' })
 
-	self:update({key}, update)
+	xq:atomic(key,function()
+		t = self:update({key}, update)
 
-	xq:putback(key, attr)
+		xq:wakeup(t)
+		if xq.have_runat then
+			xq.runat_chan:put(true,0)
+		end
+		log.info("Bury {%s} by %s, sid=%s, fid=%s", key, box.session.storage.peer, box.session.id(), fiber.id())
+	end)
+
+	xq:putback(t)
 end
 
 local function kick_task(self, key, attr)