test-timer.lua

local uvVersionGEQ = require('lib/utils').uvVersionGEQ

return require('lib/tap')(function (test)

  -- This tests using timers for a simple timeout.
  -- It also tests the handle close callback and
  test("simple timeout", function (print, p, expect, uv)
    local timer = uv.new_timer()
    local function onclose()
      p("closed", timer)
    end
    local function ontimeout()
      p("timeout", timer)
      uv.close(timer, expect(onclose))
    end
    uv.timer_start(timer, 10, 0, expect(ontimeout))
  end)

  -- This is like the previous test, but using repeat.
  test("simple interval", function (print, p, expect, uv)
    local timer = uv.new_timer()
    local count = 3
    local onclose = expect(function ()
      p("closed", timer)
    end)
    local function oninterval()
      p("interval", timer)
      count = count - 1
      if count == 0 then
        uv.close(timer, onclose)
      end
    end
    uv.timer_start(timer, 10, 10, oninterval)
  end)

  -- Test two concurrent timers
  test("timeout with interval", function (print, p, expect, uv)
    local a = uv.new_timer()
    local b = uv.new_timer()
    uv.timer_start(a, 200, 0, expect(function ()
      p("timeout", a)
      uv.close(a)
    end))
    local count = 2
    uv.timer_start(b, 100, 200, expect(function ()
      p("interval", b)
      count = count - 1
      if count == 0 then
        uv.close(b)
      end
    end, 2))
  end)

  -- This advanced test uses the rest of the uv_timer_t functions
  -- to create an interval that shrinks over time.
  test("shrinking interval", function (print, p, expect, uv)
    local timer = uv.new_timer()
    uv.timer_start(timer, 10, 0, expect(function ()
      local r = uv.timer_get_repeat(timer)
      p("interval", timer, r)
      if r == 0 then
        uv.timer_set_repeat(timer, 8)
        uv.timer_again(timer)
      elseif r == 2 then
        uv.timer_stop(timer)
        uv.close(timer)
      else
        uv.timer_set_repeat(timer, r / 2)
      end
    end, 4))
  end)

  test("shrinking interval using methods", function (print, p, expect, uv)
    local timer = uv.new_timer()
    timer:start(10, 0, expect(function ()
      local r = timer:get_repeat()
      p("interval", timer, r)
      if r == 0 then
        timer:set_repeat(8)
        timer:again()
      elseif r == 2 then
        timer:stop()
        timer:close()
      else
        timer:set_repeat(r / 2)
      end
    end, 4))
  end)

  test("timer init", function(print, p, expect, uv)
    local timer = uv.new_timer()
    assert(timer:get_repeat()==0)
    if uvVersionGEQ("1.40.0") then
      assert(uv.timer_get_due_in)
      -- avoid https://github.com/libuv/libuv/issues/3020
      --assert(timer:get_due_in()==0)
    end
    assert(timer:is_active()==false)
    uv.close(timer)
  end)

  test("timer huge timeout", function(print, p, expect, uv)
    local tiny_timer = uv.new_timer()
    local huge_timer = uv.new_timer()

    local function timer_cb()
      uv.close(tiny_timer)
      uv.close(huge_timer)
    end

    uv.timer_start(tiny_timer, 1, 0, expect(timer_cb))
    uv.timer_start(huge_timer, 0xffff, 0, timer_cb)
    --(Lua_Integer)0xffffffff is not 0xffffffff on x86
    assert(tiny_timer:get_due_in()==1)
    assert(huge_timer:get_due_in()==0xffff)
  end, "1.40.0")

end)