test: make sure that underlying connection is closed

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,25 @@ local function test_connection_reset(test, pool)
     assert(pool.queue:is_full(), 'test case postcondition fails')
 end
 
+local function test_underlying_conn_closed(test)
+    test:plan(1)
+    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, ...); ]])
+    test:ok(ffi.C.fcntl(handle, 1) == -1, 'descriptor is closed')
+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 +511,7 @@ 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', test_underlying_conn_closed, p)
 p:close()
 
 os.exit(test:check() and 0 or 1)