Home
last modified time | relevance | path

Searched refs:publish1_packet (Results 1 – 25 of 32) sorted by relevance

12

/dports/net/mosquitto/mosquitto-2.0.13/test/broker/
H A D02-subpub-recover-subscriptions.py10 publish1_packet = mosq_test.gen_publish("not-shared/sub", qos=0, payload="message1")
13 sock.send(publish1_packet)
36 …publish1_packet = mosq_test.gen_publish("not-shared/sub", qos=0, payload="message1", proto_ver=pro…
49 mosq_test.expect_packet(sock, "publish1", publish1_packet)
58 mosq_test.expect_packet(sock, "publish1", publish1_packet)
H A D02-shared-qos0-v5.py55 publish1_packet = mosq_test.gen_publish("share-test", qos=0, payload="message1", proto_ver=5) variable
96 sock1.send(publish1_packet)
97 mosq_test.expect_packet(sock1, "publish1 1", publish1_packet)
98 mosq_test.expect_packet(sock2, "publish1 2", publish1_packet)
99 mosq_test.expect_packet(sock3, "publish1 3", publish1_packet)
H A D02-subpub-qos1-message-expiry-retain.py35 …publish1_packet = mosq_test.gen_publish("subpub/expired", mid=mid, qos=1, retain=True, payload="me…
52 mosq_test.do_send_receive(helper, publish1_packet, puback1_packet, "puback 1")
59 mosq_test.expect_packet(sock, "publish 1", publish1_packet)
H A D02-subpub-qos0-topic-alias-unknown.py15 …publish1_packet = mosq_test.gen_publish("", qos=0, payload="message", proto_ver=5, properties=prop…
24 sock.send(publish1_packet)
H A D11-persistent-subscription-no-local.py36 publish1_packet = mosq_test.gen_publish("subpub/nolocal", qos=1, mid=mid, payload="message", proto_… variable
62 mosq_test.do_send_receive(sock, publish1_packet, puback1_packet, "puback1a")
77 mosq_test.do_send_receive(sock, publish1_packet, puback1_packet, "puback1b")
H A D02-subpub-qos0-subscription-id.py46 publish1_packet = mosq_test.gen_publish("subpub/id1", qos=0, payload="message1", proto_ver=5)
82 mosq_test.do_send_receive(sock, publish1_packet, publish1r_packet, "publish1")
91 mosq_test.do_send_receive(sock, publish1_packet, publish1ru_packet, "publish1u")
H A D12-prop-maximum-packet-size-publish-qos1.py20 publish1_packet = mosq_test.gen_publish(topic="test/topic", mid=mid, qos=1, payload="12345678901234… variable
34 mosq_test.do_send_receive(sock, publish1_packet, puback1_packet, "puback 1")
H A D02-subpub-qos0-topic-alias.py22 …publish1_packet = mosq_test.gen_publish("subpub/alias", qos=0, payload="message", proto_ver=5, pro…
36 sock1.send(publish1_packet)
H A D02-subpub-qos0-retain-as-publish.py22 …publish1_packet = mosq_test.gen_publish("subpub/normal", qos=0, retain=True, payload="message", pr…
41 mosq_test.do_send_receive(sock, publish1_packet, publish1r_packet, "publish1")
H A D12-prop-maximum-packet-size-publish-qos2.py20 publish1_packet = mosq_test.gen_publish(topic="test/topic", mid=mid, qos=2, payload="12345678901234… variable
38 mosq_test.do_send_receive(sock, publish1_packet, pubrec1_packet, "pubrec 1")
H A D09-plugin-acl-change.py33 publish1_packet = mosq_test.gen_publish("publish/topic", qos=2, mid=mid, payload="message")
44 mosq_test.do_send_receive(sock, publish1_packet, pubrec1_packet, "pubrec")
H A D09-plugin-auth-acl-pub.py32 publish1_packet = mosq_test.gen_publish("readonly", qos=2, mid=mid, payload="message")
46 mosq_test.do_send_receive(sock, publish1_packet, pubrec1_packet, "pubrec1")
/dports/www/domoticz/domoticz-2020.2/extern/mosquitto/test/broker/
H A D02-shared-qos0-v5.py55 publish1_packet = mosq_test.gen_publish("share-test", qos=0, payload="message1", proto_ver=5) variable
96 sock1.send(publish1_packet)
97 if mosq_test.expect_packet(sock1, "publish1 1", publish1_packet):
98 if mosq_test.expect_packet(sock2, "publish1 2", publish1_packet):
99 if mosq_test.expect_packet(sock3, "publish1 3", publish1_packet):
H A D02-subpub-qos1-message-expiry-retain.py34 publish1_packet = mosq_test.gen_publish("subpub/expired", mid=mid, qos=1, retain=True, payload="mes… variable
51 mosq_test.do_send_receive(helper, publish1_packet, puback1_packet, "puback 1")
58 if mosq_test.expect_packet(sock, "publish 1", publish1_packet):
H A D02-subpub-qos0-topic-alias-unknown.py14 publish1_packet = mosq_test.gen_publish("", qos=0, payload="message", proto_ver=5, properties=props) variable
23 sock.send(publish1_packet)
H A D11-persistent-subscription-no-local.py36 publish1_packet = mosq_test.gen_publish("subpub/nolocal", qos=1, mid=mid, payload="message", proto_… variable
62 mosq_test.do_send_receive(sock, publish1_packet, puback1_packet, "puback1a")
77 mosq_test.do_send_receive(sock, publish1_packet, puback1_packet, "puback1b")
H A D12-prop-maximum-packet-size-publish.py19 publish1_packet = mosq_test.gen_publish(topic="test/topic", qos=0, payload="12345678901234567890", … variable
28 sock.send(publish1_packet)
H A D02-subpub-qos0-subscription-id.py45 publish1_packet = mosq_test.gen_publish("subpub/id1", qos=0, payload="message1", proto_ver=5) variable
81 mosq_test.do_send_receive(sock, publish1_packet, publish1r_packet, "publish1")
90 mosq_test.do_send_receive(sock, publish1_packet, publish1ru_packet, "publish1u")
H A D12-prop-maximum-packet-size-publish-qos1.py20 publish1_packet = mosq_test.gen_publish(topic="test/topic", mid=mid, qos=1, payload="12345678901234… variable
34 mosq_test.do_send_receive(sock, publish1_packet, puback1_packet, "puback 1")
H A D02-subpub-qos0-topic-alias.py21 publish1_packet = mosq_test.gen_publish("subpub/alias", qos=0, payload="message", proto_ver=5, prop… variable
35 sock1.send(publish1_packet)
H A D02-subpub-qos0-retain-as-publish.py21 publish1_packet = mosq_test.gen_publish("subpub/normal", qos=0, retain=True, payload="message", pro… variable
40 mosq_test.do_send_receive(sock, publish1_packet, publish1r_packet, "publish1")
H A D12-prop-maximum-packet-size-publish-qos2.py20 publish1_packet = mosq_test.gen_publish(topic="test/topic", mid=mid, qos=2, payload="12345678901234… variable
38 mosq_test.do_send_receive(sock, publish1_packet, pubrec1_packet, "pubrec 1")
H A D09-plugin-auth-acl-pub.py31 publish1_packet = mosq_test.gen_publish("readonly", qos=2, mid=mid, payload="message") variable
45 mosq_test.do_send_receive(sock, publish1_packet, pubrec1_packet, "pubrec1")
/dports/net/mosquitto/mosquitto-2.0.13/test/lib/
H A D03-request-response.py24 publish1_packet = mosq_test.gen_publish(pub_topic, qos=0, payload="action", proto_ver=5, properties… variable
58 mosq_test.expect_packet(conn1, "publish1", publish1_packet)
59 conn2.send(publish1_packet)
/dports/www/domoticz/domoticz-2020.2/extern/mosquitto/test/lib/
H A D03-request-response.py24 publish1_packet = mosq_test.gen_publish(pub_topic, qos=0, payload="action", proto_ver=5, properties… variable
64 if mosq_test.expect_packet(conn1, "publish1", publish1_packet):
65 conn2.send(publish1_packet)

12