class TestCarbon(DNSDistTest):
- _serverCount = 3
- _serverUpCount = 2
- _toResponderQueue1 = Queue()
- _fromResponderQueue1 = Queue()
_carbonServer1Port = 8000
_carbonServer1Name = "carbonname1"
_carbonServer2Port = 8001
self.assertTrue(value >= 1)
def testCarbonServerUp(self):
+ """
+ Carbon: set up 2 carbon servers
+ """
# wait for the carbon data to be sent
time.sleep(self._carbonInterval + 1)
for line in data1.splitlines():
if expectedStart in line:
parts = line.split(b' ')
- if 'servers-up' in line:
+ if b'servers-up' in line:
self.assertEquals(len(parts), 3)
self.assertTrue(parts[1].isdigit())
- self.assertEquals(int(parts[1]), self._serverUpCount)
+ self.assertEquals(int(parts[1]), 2)
self.assertTrue(parts[2].isdigit())
self.assertTrue(int(parts[2]) <= int(after))
else:
self.assertEquals(len(parts), 3)
self.assertTrue(parts[1].isdigit())
- self.assertEquals(int(parts[1]), self._serverCount)
+ self.assertEquals(int(parts[1]), 3)
self.assertTrue(parts[2].isdigit())
self.assertTrue(int(parts[2]) <= int(after))
for line in data2.splitlines():
if expectedStart in line:
parts = line.split(b' ')
- if 'servers-up' in line:
+ if b'servers-up' in line:
self.assertEquals(len(parts), 3)
self.assertTrue(parts[1].isdigit())
- self.assertEquals(int(parts[1]), self._serverUpCount)
+ self.assertEquals(int(parts[1]), 2)
self.assertTrue(parts[2].isdigit())
self.assertTrue(int(parts[2]) <= int(after))
else:
self.assertEquals(len(parts), 3)
self.assertTrue(parts[1].isdigit())
- self.assertEquals(int(parts[1]), self._serverCount)
+ self.assertEquals(int(parts[1]), 3)
self.assertTrue(parts[2].isdigit())
self.assertTrue(int(parts[2]) <= int(after))