Contents

-- This scripts conducts a heartbeat for a job, and returns
-- either the new expiration or False if the lock has been
-- given to another node
--
-- Args:
--    1) jid
--    2) worker
--    3) now
--    4) [data]

if #KEYS > 0 then error('Heartbeat(): No Keys should be provided') end

local jid    = assert(ARGV[1]          , 'Heartbeat(): Arg "jid" missing')
local worker = assert(ARGV[2]          , 'Heartbeat(): Arg "worker" missing')
local now    = assert(tonumber(ARGV[3]), 'Heartbeat(): Arg "now" missing')
local data   = ARGV[4]

-- We should find the heartbeat interval for this queue
-- heartbeat. First, though, we need to find the queue
-- this particular job is in
local queue     = redis.call('hget', 'ql:j:' .. jid, 'queue') or ''
local _hb, _qhb = unpack(redis.call('hmget', 'ql:config', 'heartbeat', queue .. '-heartbeat'))
local expires   = now + tonumber(_qhb or _hb or 60)

if data then
	data = cjson.decode(data)
end

-- First, let's see if the worker still owns this job, and there is a worker
if redis.call('hget', 'ql:j:' .. jid, 'worker') ~= worker or #worker == 0 then
    return false
else
    -- Otherwise, optionally update the user data, and the heartbeat
    if data then
        -- I don't know if this is wise, but I'm decoding and encoding
        -- the user data to hopefully ensure its sanity
        redis.call('hmset', 'ql:j:' .. jid, 'expires', expires, 'worker', worker, 'data', cjson.encode(data))
    else
        redis.call('hmset', 'ql:j:' .. jid, 'expires', expires, 'worker', worker)
    end
	
	-- Update hwen this job was last updated on that worker
	-- Add this job to the list of jobs handled by this worker
	redis.call('zadd', 'ql:w:' .. worker .. ':jobs', expires, jid)
	
    -- And now we should just update the locks
    local queue = redis.call('hget', 'ql:j:' .. jid, 'queue')
    redis.call('zadd', 'ql:q:'.. queue .. '-locks', expires, jid)
    return expires
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
qless-0.9.2	lib/qless/qless-core/heartbeat.lua
qless-0.9.1	lib/qless/qless-core/heartbeat.lua