+check_timeout = 180
+
+
+def cleanup ():
+ shutil.rmtree (os.path.join (tmp, "c_bootstrap_server"), True)
+ shutil.rmtree (os.path.join (tmp, "c_no_nat_client"), True)
+ shutil.rmtree (os.path.join (tmp, "c_no_nat_client_2"), True)
+
+
+def success_cont (check):
+ global success
+ success = True;
+
+def fail_cont (check):
+ global success
+ success= False;
+ check.evaluate(True)
+
+
+def check_disconnect_client ():
+ test.p ('Shutting down bootstrap client')
+ client.stop ()
+ check = Check (test)
+
+ check.add (StatisticsCondition (client2, 'transport', '# peers connected',0))
+ check.add (StatisticsCondition (client2, 'core', '# neighbour entries allocated',0))
+ check.add (StatisticsCondition (client2, 'core', '# peers connected',0))
+ check.add (StatisticsCondition (client2, 'topology', '# peers connected',0))
+ check.add (StatisticsCondition (client2, 'fs', '# peers connected',0))
+
+ check.run_blocking (check_timeout, success_cont, fail_cont)
+
+
+def success_disconnect_server_cont (check):
+ check_disconnect_client ()
+
+
+def fail_disconnect_server_cont (check):
+ global success
+ success= False;
+ check.evaluate(True)
+
+
+def check_disconnect_server ():
+ test.p ('Shutting down bootstrap server')
+ server.stop ()
+ check = Check (test)
+ check.add (StatisticsCondition (client, 'transport', '# peers connected',1))
+ check.add (StatisticsCondition (client, 'core', '# neighbour entries allocated',1))
+ check.add (StatisticsCondition (client, 'core', '# peers connected',1))
+ check.add (StatisticsCondition (client, 'topology', '# peers connected',1))
+ check.add (StatisticsCondition (client, 'fs', '# peers connected',1))
+
+ check.add (StatisticsCondition (client2, 'transport', '# peers connected',1))
+ check.add (StatisticsCondition (client2, 'core', '# neighbour entries allocated',1))
+ check.add (StatisticsCondition (client2, 'core', '# peers connected',1))
+ check.add (StatisticsCondition (client2, 'topology', '# peers connected',1))
+ check.add (StatisticsCondition (client2, 'fs', '# peers connected',1))
+
+ check.run_blocking (check_timeout, success_disconnect_server_cont, fail_disconnect_server_cont)
+
+
+def success_connect_cont (check):
+ check_disconnect_server ()
+
+
+def fail_connect_cont (check):
+ global success
+ success= False;
+ check.evaluate(True)
+
+
+def check_connect ():
+ check = Check (test)
+ check.add (StatisticsCondition (client, 'transport', '# peers connected',2))
+ check.add (StatisticsCondition (client, 'core', '# neighbour entries allocated',2))
+ check.add (StatisticsCondition (client, 'core', '# peers connected',2))
+ check.add (StatisticsCondition (client, 'topology', '# peers connected',2))
+ check.add (StatisticsCondition (client, 'fs', '# peers connected',2))
+
+ check.add (StatisticsCondition (client2, 'transport', '# peers connected',2))
+ check.add (StatisticsCondition (client2, 'core', '# neighbour entries allocated',2))
+ check.add (StatisticsCondition (client2, 'core', '# peers connected',2))
+ check.add (StatisticsCondition (client2, 'topology', '# peers connected',2))
+ check.add (StatisticsCondition (client2, 'fs', '# peers connected',2))
+
+ check.add (StatisticsCondition (server, 'transport', '# peers connected',2))
+ check.add (StatisticsCondition (server, 'core', '# neighbour entries allocated',2))
+ check.add (StatisticsCondition (server, 'core', '# peers connected',2))
+ check.add (StatisticsCondition (server, 'topology', '# peers connected',2))
+ check.add (StatisticsCondition (server, 'fs', '# peers connected',2))
+
+ check.run_blocking (check_timeout, success_connect_cont, fail_connect_cont)