resty/concurrent/timer_task: fix params in call to schedule_next()

3scale · Jun 29, 2018 · bc4c74a · bc4c74a
1 parent b3e60d7
commit bc4c74a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/gateway/src/resty/concurrent/timer_task.lua b/gateway/src/resty/concurrent/timer_task.lua
@@ -64,7 +64,7 @@ run_periodic = function(run_now, id, func, args, interval)
     func(unpack(args))
   end
 
-  schedule_next(interval, id, func, args, interval)
+  schedule_next(id, func, args, interval)
 end
 
 -- Note: ngx.timer.at always sends "premature" as the first param.

diff --git a/spec/resty/concurrent/timer_task_spec.lua b/spec/resty/concurrent/timer_task_spec.lua
@@ -114,6 +114,10 @@ describe('TimerTask', function()
         timer_task:execute(true)
 
         assert.stub(ngx_timer_stub).was_called()
+
+        -- Can't check all the arguments of ngx.timer.at because it calls an
+        -- private function but at least we can check the interval (first arg)
+        assert.equals(interval, ngx_timer_stub.calls[1].vals[1])
       end)
     end)