Skip to content

Commit

Permalink
Fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Marco Paolini committed Aug 22, 2015
1 parent 2b1cefe commit 1e8714f
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions tests/test_connector.py
Original file line number Diff line number Diff line change
Expand Up @@ -253,7 +253,7 @@ def test_release(self):

tr, proto = unittest.mock.Mock(), unittest.mock.Mock()
key = 1
conn._acquired[key].append(tr)
conn._acquired[key].add(tr)
conn._release(key, req, tr, proto)
self.assertEqual(conn._conns[1][0], (tr, proto, 10))
self.assertTrue(conn._start_cleanup_task.called)
Expand All @@ -273,7 +273,7 @@ def test_release_close(self):

tr, proto = unittest.mock.Mock(), unittest.mock.Mock()
key = 1
conn._acquired[key].append(tr)
conn._acquired[key].add(tr)
conn._release(key, req, tr, proto)
self.assertFalse(conn._conns)
self.assertTrue(tr.close.called)
Expand All @@ -291,7 +291,7 @@ def test_release_pop_empty_conns(self):
conn._conns[key] = []

tr, proto = unittest.mock.Mock(), unittest.mock.Mock()
conn._acquired[key].append(tr)
conn._acquired[key].add(tr)
conn._release(key, req, tr, proto)
self.assertEqual({}, conn._conns)
self.assertTrue(tr.close.called)
Expand All @@ -309,7 +309,7 @@ def test_release_close_do_not_delete_existing_connections(self):
req.response = resp

tr, proto = unittest.mock.Mock(), unittest.mock.Mock()
conn._acquired[key].append(tr1)
conn._acquired[key].add(tr1)
conn._release(key, req, tr, proto)
self.assertEqual(conn._conns[key], [(tr1, proto1, 1)])
self.assertTrue(tr.close.called)
Expand All @@ -324,7 +324,7 @@ def test_release_not_started(self):

tr, proto = unittest.mock.Mock(), unittest.mock.Mock()
key = 1
conn._acquired[key].append(tr)
conn._acquired[key].add(tr)
conn._release(key, req, tr, proto)
self.assertEqual(conn._conns, {1: [(tr, proto, 10)]})
self.assertFalse(tr.close.called)
Expand All @@ -338,7 +338,7 @@ def test_release_not_opened(self):

tr, proto = unittest.mock.Mock(), unittest.mock.Mock()
key = 1
conn._acquired[key].append(tr)
conn._acquired[key].add(tr)
conn._release(key, req, tr, proto)
self.assertTrue(tr.close.called)

Expand Down

0 comments on commit 1e8714f

Please sign in to comment.