universal MQTT / Timer / Localbus event loop

[spyder]

Hi,

I am running this code to react to incoming MQTT messages.

During execution, I access storage using a semaphore, but after a while I get 'failed to create semaphore'.

Code:

require('sem')
-- wait for 5 seconds max before executing callback
res1, res2 = sem.runlocked('eventlock', 5, function(lockres)
  -- lock acquired
  if lockres then
    storage.set('my_storage', '')
    return true, 'ok'
  -- failed to acquire lock
  elseif lockres == nil then
    return nil, 'failed to create semaphore'
  else
    return nil, 'failed to lock semaphore'
  end
end)
log(res1, res2)

In the documentation for semaphore:close(), it is stated:

Code:

semaphore:close()

Closes the semaphore. Not required, semaphore handles are closed automatically when script execution ends

Do I explicitely need to do it in the case of an eventloop? What can I do to prevent failure to create a semaphore?

Thanks