Add test for Pool.__del__

aiopg/pool.py

@@ -250,7 +250,7 @@ def __iter__(self):
         conn = yield from self.acquire()
         return _ConnectionContextManager(self, conn)
 
-    if PY_34:
+    if PY_34:  # pragma: no branch
         def __del__(self):
             try:
                 self._free

tests/test_cursor.py

@@ -485,3 +485,17 @@ def go():
                 self.assertEqual(item, tst)
 
         self.loop.run_until_complete(go())
+
+    def test_echo_callproc(self):
+        @asyncio.coroutine
+        def go():
+            conn = yield from self.connect(echo=True)
+            cur = yield from conn.cursor()
+
+            # TODO: check log records
+            yield from cur.callproc('inc', [1])
+            ret = yield from cur.fetchone()
+            self.assertEqual((2,), ret)
+            cur.close()
+
+        self.loop.run_until_complete(go())

tests/test_pool.py

@@ -1,6 +1,7 @@
 import asyncio
 import unittest
 from unittest import mock
+import sys
 
 from psycopg2.extensions import TRANSACTION_STATUS_INTRANS
 
@@ -526,3 +527,15 @@ def go():
                                             0.1, loop=self.loop)
 
         self.loop.run_until_complete(go())
+
+    @unittest.skipIf(sys.version_info < (3, 4),
+                     "Python 3.3 doesnt support __del__ calls from GC")
+    def test___del__(self):
+        @asyncio.coroutine
+        def go():
+            pool = yield from self.create_pool()
+            self.pool = None  # drop reference
+            with self.assertWarns(ResourceWarning):
+                del pool
+
+        self.loop.run_until_complete(go())