unittests: Run tests in a separate process

1 files changed, 50 insertions, 0 deletions

diff --git a/test/unit/helpers.lua b/test/unit/helpers.lua
index 4af078b486..482bedd6c0 100644
--- a/test/unit/helpers.lua
+++ b/test/unit/helpers.lua
@@ -4,6 +4,9 @@ local Set = require('test.unit.set')
 local Preprocess = require('test.unit.preprocess')
 local Paths = require('test.config.paths')
 local global_helpers = require('test.helpers')
+local posix = require('posix')
+local assert = require('luassert')
+local say = require('say')
 
 local neq = global_helpers.neq
 local eq = global_helpers.eq
@@ -216,6 +219,52 @@ do
   main.event_init()
 end
 
+local function gen_itp(it)
+  local function just_fail(_)
+    return false
+  end
+  say:set('assertion.just_fail.positive', '%s')
+  say:set('assertion.just_fail.negative', '%s')
+  assert:register('assertion', 'just_fail', just_fail,
+                  'assertion.just_fail.positive',
+                  'assertion.just_fail.negative')
+  local function itp(name, func)
+    it(name, function()
+      local rd, wr = posix.pipe()
+      local pid = posix.fork()
+      if pid == 0 then
+        posix.close(rd)
+        local err, emsg = pcall(func)
+        emsg = tostring(emsg)
+        if not err then
+          posix.write(wr, ('-\n%05u\n%s'):format(#emsg, emsg))
+          posix.close(wr)
+          posix._exit(1)
+        else
+          posix.write(wr, '+\n')
+          posix.close(wr)
+          posix._exit(0)
+        end
+      else
+        posix.close(wr)
+        posix.wait(pid)
+        local res = posix.read(rd, 2)
+        eq(2, #res)
+        if res == '+\n' then
+          return
+        end
+        eq('-\n', res)
+        local len_s = posix.read(rd, 5)
+        local len = tonumber(len_s)
+        neq(0, len)
+        local err = posix.read(rd, len + 1)
+        assert.just_fail(err)
+      end
+    end)
+  end
+  return itp
+end
+
 return {
   cimport = cimport,
   cppimport = cppimport,
@@ -231,4 +280,5 @@ return {
   OK = OK,
   FAIL = FAIL,
   alloc_log_new = alloc_log_new,
+  gen_itp = gen_itp,
 }