summaryrefslogtreecommitdiffhomepage
path: root/test/scenario_test/monitor_test.py
diff options
context:
space:
mode:
authorISHIDA Wataru <ishida.wataru@lab.ntt.co.jp>2016-08-14 06:18:31 +0000
committerFUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>2016-08-15 18:53:03 +0900
commit061d894c1478b30b06c86bd5f26a6fbd4bd292d3 (patch)
tree71f51041a593bc5c4494b8ba4c932393ac238b5a /test/scenario_test/monitor_test.py
parent2c12fa2b92c3372d8639e84be6ee89a9ab581158 (diff)
test: execute gobgp monitor on docker host
docker-py's exec_start stream fails often. execute gobgp monitor on docker host instead. Signed-off-by: ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp>
Diffstat (limited to 'test/scenario_test/monitor_test.py')
-rw-r--r--test/scenario_test/monitor_test.py26
1 files changed, 9 insertions, 17 deletions
diff --git a/test/scenario_test/monitor_test.py b/test/scenario_test/monitor_test.py
index 8b4fabe5..147391d1 100644
--- a/test/scenario_test/monitor_test.py
+++ b/test/scenario_test/monitor_test.py
@@ -73,15 +73,11 @@ class GoBGPTestBase(unittest.TestCase):
cnt = 0
while True:
- try:
- info = qu.get(timeout=1)
- if info == 'timeout':
- raise Exception('timeout')
- cnt += 1
- if cnt == len(self.quaggas):
- break
- except Queue.Empty:
- pass
+ info = qu.get(timeout=120)
+ cnt += 1
+ print 'monitor got {0}, cnt = {1}'.format(info, cnt)
+ if cnt == len(self.quaggas):
+ break
def test_02_stop_q1(self):
qu = Queue.Queue()
@@ -89,14 +85,10 @@ class GoBGPTestBase(unittest.TestCase):
self.quaggas['q1'].stop()
while True:
- try:
- info = qu.get(timeout=1)
- if info == 'timeout':
- raise Exception('timeout')
- self.assertTrue(info['isWithdraw'])
- break
- except Queue.Empty:
- pass
+ info = qu.get(timeout=120)
+ print 'monitor got {0}'.format(info)
+ self.assertTrue(info['isWithdraw'])
+ break
if __name__ == '__main__':