Speed up pattern matching test.
This commit is contained in:
parent
016ce7dca5
commit
950ad8d16f
@ -20,11 +20,9 @@ def pattern_test(sub_topic, pub_topic):
|
|||||||
unsuback_packet = mosq_test.gen_unsuback(mid)
|
unsuback_packet = mosq_test.gen_unsuback(mid)
|
||||||
|
|
||||||
port = mosq_test.get_port()
|
port = mosq_test.get_port()
|
||||||
broker = subprocess.Popen(['../../src/mosquitto', '-p', str(port)], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
|
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=port)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
time.sleep(0.5)
|
|
||||||
|
|
||||||
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20, port=port)
|
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20, port=port)
|
||||||
mosq_test.do_send_receive(sock, subscribe_packet, suback_packet, "suback")
|
mosq_test.do_send_receive(sock, subscribe_packet, suback_packet, "suback")
|
||||||
|
|
||||||
@ -48,7 +46,7 @@ def pattern_test(sub_topic, pub_topic):
|
|||||||
if rc:
|
if rc:
|
||||||
print(stde)
|
print(stde)
|
||||||
print(stdo)
|
print(stdo)
|
||||||
raise
|
sys.exit(rc)
|
||||||
|
|
||||||
return rc
|
return rc
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user