github
/
mosquitto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Tests can now use valgrind.

Browse Source
pull/211/merge
Roger A. Light 11 years ago
parent 7f18ced0b4
commit 6427105bf6
66 changed files with 137 additions and 175 deletions
Show Stats Download Patch File Download Diff File

1
.gitignore vendored
Unescape Escape View File

@ -4,6 +4,7 @@
c/*.test
cpp/*.test
*.pyc
*.vglog
client/mosquitto_pub
client/mosquitto_sub

4
test/broker/01-connect-anon-denied.py
Unescape Escape View File

@ -19,11 +19,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-anon-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=5)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '01-connect-anon-denied.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

5
test/broker/01-connect-invalid-id-0-311.py
Unescape Escape View File

@ -19,11 +19,10 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("", keepalive=keepalive, proto_ver=4)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

5
test/broker/01-connect-invalid-id-0.py
Unescape Escape View File

@ -19,11 +19,10 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=2)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

5
test/broker/01-connect-invalid-id-missing.py
Unescape Escape View File

@ -18,11 +18,10 @@ rc = 1
keepalive = 10
connect_packet = mosq_test.gen_connect(None, keepalive=keepalive)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, "")
sock.close()
rc = 0

5
test/broker/01-connect-invalid-protonum.py
Unescape Escape View File

@ -19,11 +19,10 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-invalid-test", keepalive=keepalive, proto_ver=0)
connack_packet = mosq_test.gen_connack(rc=1)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

5
test/broker/01-connect-success.py
Unescape Escape View File

@ -21,11 +21,10 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-success-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

4
test/broker/01-connect-uname-no-password-denied.py
Unescape Escape View File

@ -20,11 +20,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-uname-test", keepalive=keepalive, username="user")
connack_packet = mosq_test.gen_connack(rc=4)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '01-connect-uname-no-password-denied.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

4
test/broker/01-connect-uname-password-denied.py
Unescape Escape View File

@ -20,11 +20,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-uname-pwd-test", keepalive=keepalive, username="user", password="password9")
connack_packet = mosq_test.gen_connack(rc=4)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '01-connect-uname-password-denied.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

4
test/broker/01-connect-uname-password-success.py
Unescape Escape View File

@ -20,11 +20,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-uname-pwd-test", keepalive=keepalive, username="user", password="password")
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '01-connect-uname-password-success.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.close()
rc = 0

5
test/broker/02-subpub-qos0.py
Unescape Escape View File

@ -25,11 +25,10 @@ suback_packet = mosq_test.gen_suback(mid, 0)
publish_packet = mosq_test.gen_publish("subpub/qos0", qos=0, payload="message")
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20)
sock.send(subscribe_packet)

5
test/broker/02-subpub-qos1.py
Unescape Escape View File

@ -30,11 +30,10 @@ puback_packet = mosq_test.gen_puback(mid)
mid = 1
publish_packet2 = mosq_test.gen_publish("subpub/qos1", qos=1, mid=mid, payload="message")
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20)
sock.send(subscribe_packet)

5
test/broker/02-subpub-qos2.py
Unescape Escape View File

@ -35,11 +35,10 @@ pubrec_packet2 = mosq_test.gen_pubrec(mid)
pubrel_packet2 = mosq_test.gen_pubrel(mid)
pubcomp_packet2 = mosq_test.gen_pubcomp(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20)
sock.send(subscribe_packet)

3
test/broker/02-subscribe-qos0.py
Unescape Escape View File

@ -23,7 +23,8 @@ connack_packet = mosq_test.gen_connack(rc=0)
subscribe_packet = mosq_test.gen_subscribe(mid, "qos0/test", 0)
suback_packet = mosq_test.gen_suback(mid, 0)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)

5
test/broker/02-subscribe-qos1.py
Unescape Escape View File

@ -23,11 +23,10 @@ connack_packet = mosq_test.gen_connack(rc=0)
subscribe_packet = mosq_test.gen_subscribe(mid, "qos1/test", 1)
suback_packet = mosq_test.gen_suback(mid, 1)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

5
test/broker/02-subscribe-qos2.py
Unescape Escape View File

@ -23,11 +23,10 @@ connack_packet = mosq_test.gen_connack(rc=0)
subscribe_packet = mosq_test.gen_subscribe(mid, "qos2/test", 2)
suback_packet = mosq_test.gen_suback(mid, 2)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

5
test/broker/02-unsubscribe-qos0.py
Unescape Escape View File

@ -24,11 +24,10 @@ connack_packet = mosq_test.gen_connack(rc=0)
unsubscribe_packet = mosq_test.gen_unsubscribe(mid, "qos0/test")
unsuback_packet = mosq_test.gen_unsuback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(unsubscribe_packet)

5
test/broker/02-unsubscribe-qos1.py
Unescape Escape View File

@ -23,11 +23,10 @@ connack_packet = mosq_test.gen_connack(rc=0)
unsubscribe_packet = mosq_test.gen_unsubscribe(mid, "qos1/test")
unsuback_packet = mosq_test.gen_unsuback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(unsubscribe_packet)

5
test/broker/02-unsubscribe-qos2.py
Unescape Escape View File

@ -23,11 +23,10 @@ connack_packet = mosq_test.gen_connack(rc=0)
unsubscribe_packet = mosq_test.gen_unsubscribe(mid, "qos2/test")
unsuback_packet = mosq_test.gen_unsuback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(unsubscribe_packet)

4
test/broker/03-publish-b2c-disconnect-qos1.py
Unescape Escape View File

@ -31,11 +31,9 @@ mid = 3266
publish2_packet = mosq_test.gen_publish("qos1/outgoing", qos=1, mid=mid, payload="outgoing-message")
puback2_packet = mosq_test.gen_puback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '03-publish-b2c-disconnect-qos1.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

4
test/broker/03-publish-b2c-disconnect-qos2.py
Unescape Escape View File

@ -34,11 +34,9 @@ mid = 3266
publish2_packet = mosq_test.gen_publish("qos1/outgoing", qos=1, mid=mid, payload="outgoing-message")
puback2_packet = mosq_test.gen_puback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '03-publish-b2c-disconnect-qos2.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

4
test/broker/03-publish-b2c-timeout-qos1.py
Unescape Escape View File

@ -29,11 +29,9 @@ publish_packet = mosq_test.gen_publish("qos1/timeout/test", qos=1, mid=mid, payl
publish_dup_packet = mosq_test.gen_publish("qos1/timeout/test", qos=1, mid=mid, payload="timeout-message", dup=True)
puback_packet = mosq_test.gen_puback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '03-publish-b2c-timeout-qos1.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

4
test/broker/03-publish-b2c-timeout-qos2.py
Unescape Escape View File

@ -32,11 +32,9 @@ pubrel_packet = mosq_test.gen_pubrel(mid)
pubrel_dup_packet = mosq_test.gen_pubrel(mid, dup=True)
pubcomp_packet = mosq_test.gen_pubcomp(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '03-publish-b2c-timeout-qos2.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

7
test/broker/03-publish-c2b-disconnect-qos2.py
Unescape Escape View File

@ -34,15 +34,10 @@ mid = 3266
publish2_packet = mosq_test.gen_publish("qos1/outgoing", qos=1, mid=mid, payload="outgoing-message")
puback2_packet = mosq_test.gen_puback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '03-publish-c2b-disconnect-qos2.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
#sock.send(subscribe_packet)
#if mosq_test.expect_packet(sock, "suback", suback_packet):
sock.send(publish_packet)
if mosq_test.expect_packet(sock, "pubrec", pubrec_packet):

4
test/broker/03-publish-c2b-timeout-qos2.py
Unescape Escape View File

@ -27,11 +27,9 @@ pubrec_packet = mosq_test.gen_pubrec(mid)
pubrel_packet = mosq_test.gen_pubrel(mid)
pubcomp_packet = mosq_test.gen_pubcomp(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '03-publish-c2b-timeout-qos2.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(publish_packet)

5
test/broker/03-publish-qos1.py
Unescape Escape View File

@ -23,11 +23,10 @@ connack_packet = mosq_test.gen_connack(rc=0)
publish_packet = mosq_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message")
puback_packet = mosq_test.gen_puback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(publish_packet)

5
test/broker/03-publish-qos2.py
Unescape Escape View File

@ -25,11 +25,10 @@ pubrec_packet = mosq_test.gen_pubrec(mid)
pubrel_packet = mosq_test.gen_pubrel(mid)
pubcomp_packet = mosq_test.gen_pubcomp(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(publish_packet)

5
test/broker/04-retain-qos0-clear.py
Unescape Escape View File

@ -30,11 +30,10 @@ mid_unsub = 593
unsubscribe_packet = mosq_test.gen_unsubscribe(mid_unsub, "retain/clear/test")
unsuback_packet = mosq_test.gen_unsuback(mid_unsub)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=4)
# Send retained message
sock.send(publish_packet)

5
test/broker/04-retain-qos0-fresh.py
Unescape Escape View File

@ -26,11 +26,10 @@ publish_fresh_packet = mosq_test.gen_publish("retain/qos0/test", qos=0, payload=
subscribe_packet = mosq_test.gen_subscribe(mid, "retain/qos0/test", 0)
suback_packet = mosq_test.gen_suback(mid, 0)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

5
test/broker/04-retain-qos0-repeated.py
Unescape Escape View File

@ -29,11 +29,10 @@ unsub_mid = 13
unsubscribe_packet = mosq_test.gen_unsubscribe(unsub_mid, "retain/qos0/test/")
unsuback_packet = mosq_test.gen_unsuback(unsub_mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20)
sock.send(publish_packet)
sock.send(subscribe_packet)

5
test/broker/04-retain-qos0.py
Unescape Escape View File

@ -24,11 +24,10 @@ publish_packet = mosq_test.gen_publish("retain/qos0/test", qos=0, payload="retai
subscribe_packet = mosq_test.gen_subscribe(mid, "retain/qos0/test", 0)
suback_packet = mosq_test.gen_suback(mid, 0)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(publish_packet)
sock.send(subscribe_packet)

5
test/broker/04-retain-qos1-qos0.py
Unescape Escape View File

@ -29,11 +29,10 @@ subscribe_packet = mosq_test.gen_subscribe(mid, "retain/qos1/test", 0)
suback_packet = mosq_test.gen_suback(mid, 0)
publish0_packet = mosq_test.gen_publish("retain/qos1/test", qos=0, payload="retained message", retain=True)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(publish_packet)

5
test/broker/05-clean-session-qos1.py
Unescape Escape View File

@ -29,11 +29,10 @@ mid = 1
publish_packet = mosq_test.gen_publish("qos1/clean_session/test", qos=1, mid=mid, payload="clean-session-message")
puback_packet = mosq_test.gen_puback(mid)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

4
test/broker/06-bridge-b2br-disconnect-qos1.py
Unescape Escape View File

@ -44,11 +44,9 @@ ssock.settimeout(40)
ssock.bind(('', 1888))
ssock.listen(5)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '06-bridge-b2br-disconnect-qos1.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
(bridge, address) = ssock.accept()
bridge.settimeout(20)

4
test/broker/06-bridge-b2br-disconnect-qos2.py
Unescape Escape View File

@ -46,11 +46,9 @@ ssock.settimeout(40)
ssock.bind(('', 1888))
ssock.listen(5)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '06-bridge-b2br-disconnect-qos2.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
(bridge, address) = ssock.accept()
bridge.settimeout(20)

4
test/broker/06-bridge-br2b-disconnect-qos1.py
Unescape Escape View File

@ -40,11 +40,9 @@ ssock.settimeout(40)
ssock.bind(('', 1888))
ssock.listen(5)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '06-bridge-br2b-disconnect-qos1.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
(bridge, address) = ssock.accept()
bridge.settimeout(20)

4
test/broker/06-bridge-br2b-disconnect-qos2.py
Unescape Escape View File

@ -47,11 +47,9 @@ ssock.settimeout(40)
ssock.bind(('', 1888))
ssock.listen(5)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '06-bridge-br2b-disconnect-qos2.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
(bridge, address) = ssock.accept()
bridge.settimeout(20)

13
test/broker/06-bridge-reconnect-local-out.py
Unescape Escape View File

@ -31,18 +31,17 @@ try:
except OSError:
pass
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
time.sleep(0.5)
local_broker = subprocess.Popen(['../../src/mosquitto', '-c', '06-bridge-reconnect-local-out.conf'], stderr=subprocess.PIPE)
time.sleep(0.5)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
local_cmd = ['../../src/mosquitto', '-c', '06-bridge-reconnect-local-out.conf']
local_broker = mosq_test.start_broker(cmd=local_cmd, filename=os.path.basename(__file__)+'_local1')
local_broker.terminate()
local_broker.wait()
local_broker = subprocess.Popen(['../../src/mosquitto', '-c', '06-bridge-reconnect-local-out.conf'], stderr=subprocess.PIPE)
local_broker = mosq_test.start_broker(cmd=local_cmd, filename=os.path.basename(__file__)+'_local2')
pub = None
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet)
sock.send(subscribe_packet)

5
test/broker/07-will-null-topic.py
Unescape Escape View File

@ -18,11 +18,10 @@ keepalive = 60
connect_packet = mosq_test.gen_connect("will-null-topic", keepalive=keepalive, will_topic="", will_payload=struct.pack("!4sB7s", "will", 0, "message"))
connack_packet = mosq_test.gen_connack(rc=2)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, "", timeout=30)
rc = 0
sock.close()

5
test/broker/07-will-null.py
Unescape Escape View File

@ -26,11 +26,10 @@ suback_packet = mosq_test.gen_suback(mid, 0)
publish_packet = mosq_test.gen_publish("will/null/test", qos=0)
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=30)
sock.send(subscribe_packet)

5
test/broker/07-will-qos0.py
Unescape Escape View File

@ -25,11 +25,10 @@ suback_packet = mosq_test.gen_suback(mid, 0)
publish_packet = mosq_test.gen_publish("will/qos0/test", qos=0, payload="will-message")
broker = subprocess.Popen(['../../src/mosquitto', '-p', '1888'], stderr=subprocess.PIPE)
cmd = ['../../src/mosquitto', '-p', '1888']
broker = mosq_test.start_broker(filename=os.path.basename(__file__), cmd=cmd)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=30)
sock.send(subscribe_packet)

4
test/broker/08-ssl-bridge.py
Unescape Escape View File

@ -33,11 +33,9 @@ ssock.settimeout(20)
ssock.bind(('', 1888))
ssock.listen(5)
broker = subprocess.Popen(['../../src/mosquitto', '-v', '-c', '08-ssl-bridge.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
(bridge, address) = ssock.accept()
bridge.settimeout(20)

2
test/broker/08-ssl-connect-cert-auth-crl.conf
Unescape Escape View File

@ -5,3 +5,5 @@ certfile ../ssl/server.crt
keyfile ../ssl/server.key
require_certificate true
crlfile ../ssl/crl.pem
listener 1889

4
test/broker/08-ssl-connect-cert-auth-crl.py
Unescape Escape View File

@ -23,11 +23,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-success-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-cert-auth-crl.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", certfile="../ssl/client.crt", keyfile="../ssl/client.key", cert_reqs=ssl.CERT_REQUIRED)
ssock.settimeout(20)

2
test/broker/08-ssl-connect-cert-auth-expired.conf
Unescape Escape View File

@ -4,3 +4,5 @@ cafile ../ssl/all-ca.crt
certfile ../ssl/server.crt
keyfile ../ssl/server.key
require_certificate true
listener 1889

4
test/broker/08-ssl-connect-cert-auth-expired.py
Unescape Escape View File

@ -26,11 +26,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-success-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-v', '-c', '08-ssl-connect-cert-auth.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", certfile="../ssl/client-expired.crt", keyfile="../ssl/client.key", cert_reqs=ssl.CERT_REQUIRED)
ssock.settimeout(20)

4
test/broker/08-ssl-connect-cert-auth-revoked.conf
Unescape Escape View File

@ -1,7 +1,9 @@
port 1888
port 1889
listener 1888
cafile ../ssl/all-ca.crt
certfile ../ssl/server.crt
keyfile ../ssl/server.key
require_certificate true
crlfile ../ssl/crl.pem

4
test/broker/08-ssl-connect-cert-auth-revoked.py
Unescape Escape View File

@ -23,11 +23,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-revoked-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-cert-auth-revoked.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", certfile="../ssl/client-revoked.crt", keyfile="../ssl/client-revoked.key", cert_reqs=ssl.CERT_REQUIRED)
ssock.settimeout(20)

4
test/broker/08-ssl-connect-cert-auth-without.conf
Unescape Escape View File

@ -1,6 +1,8 @@
port 1888
port 1889
listener 1888
cafile ../ssl/all-ca.crt
certfile ../ssl/server.crt
keyfile ../ssl/server.key
require_certificate true

4
test/broker/08-ssl-connect-cert-auth-without.py
Unescape Escape View File

@ -27,9 +27,7 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-cert-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-cert-auth-without.conf'], stderr=subprocess.PIPE)
time.sleep(0.5)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", cert_reqs=ssl.CERT_REQUIRED)

5
test/broker/08-ssl-connect-cert-auth.conf
Unescape Escape View File

@ -1,6 +1,9 @@
port 1888
port 1889
listener 1888
cafile ../ssl/all-ca.crt
certfile ../ssl/server.crt
keyfile ../ssl/server.key
require_certificate true

4
test/broker/08-ssl-connect-cert-auth.py
Unescape Escape View File

@ -25,11 +25,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-success-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-cert-auth.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", certfile="../ssl/client.crt", keyfile="../ssl/client.key", cert_reqs=ssl.CERT_REQUIRED)
ssock.settimeout(20)

2
test/broker/08-ssl-connect-identity.conf
Unescape Escape View File

@ -5,3 +5,5 @@ certfile ../ssl/server.crt
keyfile ../ssl/server.key
use_identity_as_username true
listener 1889

4
test/broker/08-ssl-connect-identity.py
Unescape Escape View File

@ -24,11 +24,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-identity-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-identity.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", certfile="../ssl/client.crt", keyfile="../ssl/client.key", cert_reqs=ssl.CERT_REQUIRED)
ssock.settimeout(20)

2
test/broker/08-ssl-connect-no-auth-wrong-ca.conf
Unescape Escape View File

@ -3,3 +3,5 @@ port 1888
cafile ../ssl/all-ca.crt
certfile ../ssl/server.crt
keyfile ../ssl/server.key
listener 1889

4
test/broker/08-ssl-connect-no-auth-wrong-ca.py
Unescape Escape View File

@ -25,9 +25,7 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-success-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-no-auth-wrong-ca.conf'], stderr=subprocess.PIPE)
time.sleep(0.5)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-alt-ca.crt", cert_reqs=ssl.CERT_REQUIRED)

3
test/broker/08-ssl-connect-no-auth.conf
Unescape Escape View File

@ -1,5 +1,6 @@
port 1888
port 1889
listener 1888
cafile ../ssl/all-ca.crt
certfile ../ssl/server.crt
keyfile ../ssl/server.key

4
test/broker/08-ssl-connect-no-auth.py
Unescape Escape View File

@ -25,11 +25,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-success-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-no-auth.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", cert_reqs=ssl.CERT_REQUIRED, ssl_version=ssl.PROTOCOL_TLSv1)
ssock.settimeout(20)

2
test/broker/08-ssl-connect-no-identity.conf
Unescape Escape View File

@ -5,3 +5,5 @@ certfile ../ssl/server.crt
keyfile ../ssl/server.key
use_identity_as_username true
listener 1889

4
test/broker/08-ssl-connect-no-identity.py
Unescape Escape View File

@ -24,11 +24,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-no-identity-test", keepalive=keepalive)
connack_packet = mosq_test.gen_connack(rc=4)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-ssl-connect-no-identity.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssock = ssl.wrap_socket(sock, ca_certs="../ssl/test-root-ca.crt", cert_reqs=ssl.CERT_REQUIRED)
ssock.settimeout(20)

7
test/broker/08-tls-psk-bridge.py
Unescape Escape View File

@ -43,13 +43,12 @@ suback_packet = mosq_test.gen_suback(mid, 0)
publish_packet = mosq_test.gen_publish(topic="psk/test", payload="message", qos=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-tls-psk-bridge.conf'], stderr=subprocess.PIPE)
bridge = subprocess.Popen(['../../src/mosquitto', '-c', '08-tls-psk-bridge.conf2'], stderr=subprocess.PIPE)
bridge_cmd = ['../../src/mosquitto', '-c', '08-tls-psk-bridge.conf2']
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
bridge = mosq_test.start_broker(filename=os.path.basename(__file__)+'_bridge', cmd=bridge_cmd, port=1890)
pub = None
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=30)
sock.send(subscribe_packet)

4
test/broker/08-tls-psk-pub.py
Unescape Escape View File

@ -43,11 +43,9 @@ suback_packet = mosq_test.gen_suback(mid, 0)
publish_packet = mosq_test.gen_publish(topic="psk/test", payload="message", qos=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '08-tls-psk-pub.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__), port=1889)
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, port=1889, timeout=20)
sock.send(subscribe_packet)

4
test/broker/09-plugin-auth-unpwd-fail.py
Unescape Escape View File

@ -20,11 +20,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-uname-pwd-test", keepalive=keepalive, username="test-username", password="wrong")
connack_packet = mosq_test.gen_connack(rc=4)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '09-plugin-auth-unpwd-fail.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20)
rc = 0

4
test/broker/09-plugin-auth-unpwd-success.py
Unescape Escape View File

@ -20,11 +20,9 @@ keepalive = 10
connect_packet = mosq_test.gen_connect("connect-uname-pwd-test", keepalive=keepalive, username="test-username", password="cnwTICONIURW")
connack_packet = mosq_test.gen_connack(rc=0)
broker = subprocess.Popen(['../../src/mosquitto', '-c', '09-plugin-auth-unpwd-success.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20)
rc = 0
sock.close()

4
test/broker/10-listener-mount-point.py
Unescape Escape View File

@ -24,11 +24,9 @@ suback_packet = mosq_test.gen_suback(mid, 0)
publish_packet = mosq_test.gen_publish("mount/test", qos=0, payload="mount point")
broker = subprocess.Popen(['../../src/mosquitto', '-c', '10-listener-mount-point.conf'], stderr=subprocess.PIPE)
broker = mosq_test.start_broker(filename=os.path.basename(__file__))
try:
time.sleep(0.5)
sock = mosq_test.do_client_connect(connect_packet, connack_packet, timeout=20)
sock.send(subscribe_packet)

27
test/mosq_test.py
Unescape Escape View File

@ -1,5 +1,32 @@
import errno
import os
import socket
import subprocess
import struct
import time
def start_broker(filename, cmd=None, port=1888):
delay = 0.1
if cmd is None:
cmd = ['../../src/mosquitto', '-v', '-c', filename.replace('.py', '.conf')]
if os.environ.get('MOSQ_USE_VALGRIND') is not None:
cmd = ['valgrind', '-q', '--log-file='+filename+'.vglog'] + cmd
delay = 0.5
broker = subprocess.Popen(cmd, stderr=subprocess.PIPE)
for i in range(0, 20):
time.sleep(delay)
c = None
try:
c = socket.create_connection(("localhost", port))
except socket.error as err:
if err.errno != errno.ECONNREFUSED:
raise
if c is not None:
c.close()
return broker
raise IOError
def expect_packet(sock, name, expected):
if len(expected) > 0:

Write Preview
Loading…
Cancel
Save