test: add test for check that underlying connection is closed

Closes #31

Author: romanhabibov

test/mysql.test.lua

@@ -7,6 +7,8 @@ local mysql = require('mysql')
 local json = require('json')
 local tap = require('tap')
 local fiber = require('fiber')
+local fio = require('fio')
+local ffi = require('ffi')
 
 local host, port, user, password, db = string.match(os.getenv('MYSQL') or '',
     "([^:]*):([^:]*):([^:]*):([^:]*):([^:]*)")
@@ -481,8 +483,42 @@ local function test_connection_reset(test, pool)
     assert(pool.queue:is_full(), 'test case postcondition fails')
 end
 
+local function is_linux()
+    local os_name
+    if jit and jit.os then
+        os_name = jit.os
+    end
+    os_name = (os_name):lower()
+    if os_name:match('linux') then
+        return true
+    end
+    return false
+end
+
+local function test_underlying_conn_closed_during_gc(test)
+    test:plan(1)
+    if jit.os == 'Linux' then
+        local fh = fio.open('/dev/zero', {'O_RDONLY'})
+        if fh == nil then error(err) end
+        local handle = fh.fh
+        fh:close()
+        local conn, err = mysql.connect({ host = host, port = port, user = user,
+            password = password, db = db })
+        if conn == nil then error(err) end
+
+        -- Somehow we lost the connection handle.
+        conn = nil
+        collectgarbage()
+        ffi.cdef([[ int fcntl(int fd, int cmd, ...); ]])
+        local F_GETFD = 1
+        test:ok(ffi.C.fcntl(handle, F_GETFD) == -1, 'descriptor is closed')
+    else
+        test:skip(1, 'wrong OS')
+    end
+end
+
 local test = tap.test('mysql connector')
-test:plan(7)
+test:plan(8)
 
 test:test('connection old api', test_old_api, conn)
 local pool_conn = p:get()
@@ -492,6 +528,8 @@ test:test('concurrent connections', test_conn_concurrent, p)
 test:test('int64', test_mysql_int64, p)
 test:test('connection pool', test_connection_pool, p)
 test:test('connection reset', test_connection_reset, p)
+test:test('test_underlying_conn_closed_during_gc',
+          test_underlying_conn_closed_during_gc, p)
 p:close()
 
 os.exit(test:check() and 0 or 1)