Commit a88f1e2f authored by Sean Bleier's avatar Sean Bleier

Up the delay a bit.

parent a507852a
...@@ -11,11 +11,11 @@ from redis_cache.connection import pool ...@@ -11,11 +11,11 @@ from redis_cache.connection import pool
from tests.testapp.tests.base_tests import SetupMixin from tests.testapp.tests.base_tests import SetupMixin
MASTER_LOCATION = "127.0.0.1:6387" MASTER_LOCATION = "127.0.0.2:6387"
LOCATIONS = [ LOCATIONS = [
'127.0.0.1:6387', '127.0.0.2:6387',
'127.0.0.1:6388', '127.0.0.2:6388',
'127.0.0.1:6389', '127.0.0.2:6389',
] ]
...@@ -43,14 +43,14 @@ class MasterSlaveTestCase(SetupMixin, TestCase): ...@@ -43,14 +43,14 @@ class MasterSlaveTestCase(SetupMixin, TestCase):
client = cache.master_client client = cache.master_client
self.assertEqual( self.assertEqual(
client.connection_pool.connection_identifier, client.connection_pool.connection_identifier,
('127.0.0.1', 6387, 1, None) ('127.0.0.2', 6387, 1, None)
) )
self.assertEqual(len(pool._connection_pools), 3) self.assertEqual(len(pool._connection_pools), 3)
def test_set(self): def test_set(self):
cache = self.get_cache() cache = self.get_cache()
cache.set('a', 'a') cache.set('a', 'a')
time.sleep(.1) time.sleep(.2)
for client in self.cache.clients.values(): for client in self.cache.clients.values():
key = cache.make_key('a') key = cache.make_key('a')
self.assertIsNotNone(client.get(key)) self.assertIsNotNone(client.get(key))
...@@ -68,7 +68,7 @@ class MasterSlaveTestCase(SetupMixin, TestCase): ...@@ -68,7 +68,7 @@ class MasterSlaveTestCase(SetupMixin, TestCase):
cache = self.get_cache() cache = self.get_cache()
cache.set('a', 0) cache.set('a', 0)
cache.incr('a') cache.incr('a')
time.sleep(.1) time.sleep(.2)
key = cache.make_key('a') key = cache.make_key('a')
for client in self.cache.clients.values(): for client in self.cache.clients.values():
self.assertEqual(int(client.get(key)), 1) self.assertEqual(int(client.get(key)), 1)
...@@ -76,10 +76,10 @@ class MasterSlaveTestCase(SetupMixin, TestCase): ...@@ -76,10 +76,10 @@ class MasterSlaveTestCase(SetupMixin, TestCase):
def test_delete(self): def test_delete(self):
cache = self.get_cache() cache = self.get_cache()
cache.set('a', 'a') cache.set('a', 'a')
time.sleep(.1) time.sleep(.2)
self.assertEqual(cache.get('a'), 'a') self.assertEqual(cache.get('a'), 'a')
cache.delete('a') cache.delete('a')
time.sleep(.1) time.sleep(.2)
key = cache.make_key('a') key = cache.make_key('a')
for client in self.cache.clients.values(): for client in self.cache.clients.values():
self.assertIsNone(client.get(key)) self.assertIsNone(client.get(key))
...@@ -87,9 +87,9 @@ class MasterSlaveTestCase(SetupMixin, TestCase): ...@@ -87,9 +87,9 @@ class MasterSlaveTestCase(SetupMixin, TestCase):
def test_clear(self): def test_clear(self):
cache = self.get_cache() cache = self.get_cache()
cache.set('a', 'a') cache.set('a', 'a')
time.sleep(.1) time.sleep(.2)
self.assertEqual(cache.get('a'), 'a') self.assertEqual(cache.get('a'), 'a')
cache.clear() cache.clear()
time.sleep(.1) time.sleep(.2)
for client in self.cache.clients.values(): for client in self.cache.clients.values():
self.assertEqual(len(client.keys('*')), 0) self.assertEqual(len(client.keys('*')), 0)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment