diff options
| author |   Romain Forlot <romain.forlot@iot.bzh> | 2018-09-16 14:21:26 +0200 |
|---|---|---|
| committer | Romain Forlot <romain.forlot@iot.bzh> | 2018-09-25 16:35:16 +0200 |
| commit | ca9049abfcf30e4e7f817441b9b1eff3936d5bf7 (patch) | |
| tree | 2a928363991f890c7e0576bb9a395494bba4490d /conf.d | |
| parent | 3db71f8774af1e1553e1b5a85ab62e210889dbe1 (diff) | |
Assert that an event hasn't been received
Change-Id: Icc1bef7f87f55a377cacfb590e1d371d9f6a1511
Signed-off-by: Romain Forlot <romain.forlot@iot.bzh>
Diffstat (limited to 'conf.d')
| -rw-r--r-- | conf.d/controller/lua.d/aft.lua | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/conf.d/controller/lua.d/aft.lua b/conf.d/controller/lua.d/aft.lua index aabeb93..a76bf45 100644 --- a/conf.d/controller/lua.d/aft.lua +++ b/conf.d/controller/lua.d/aft.lua @@ -226,6 +226,30 @@ end Assert and test functions about the event part. ]] +function _AFT.assertEvtGrpNotReceived(eventGroup, timeout) + local count = 0 + local expected = 0 + local eventName = "" + + if timeout then + count = _AFT.lockWaitGroup(eventGroup, timeout) + else + for event in pairs(eventGroup) do + count = count + _AFT.monitored_events[event].receivedCount + end + end + + for event,expectedCount in pairs(eventGroup) do + eventName = eventName .. " " .. event + expected = expected + expectedCount + end + _AFT.assertIsTrue(count <= expected, "One of the following events has been received: '".. eventName .."' but it shouldn't") + + for event in pairs(eventGroup) do + _AFT.triggerEvtCallback(event) + end + end + function _AFT.assertEvtGrpReceived(eventGroup, timeout) local count = 0 local expected = 0 @@ -251,6 +275,17 @@ function _AFT.assertEvtGrpReceived(eventGroup, timeout) end end +function _AFT.assertEvtNotReceived(eventName, timeout) + local count = _AFT.monitored_events[eventName].receivedCount + if timeout then + count = _AFT.lockWait(eventName, timeout) + end + + _AFT.assertIsTrue(count == 0, "Event '".. eventName .."' received but it shouldn't") + + _AFT.triggerEvtCallback(eventName) + end + function _AFT.assertEvtReceived(eventName, timeout) local count = _AFT.monitored_events[eventName].receivedCount if timeout then |