Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
镜像
Eclipse Foundation
paho.mqtt.python
提交
18a32136
P
paho.mqtt.python
项目概览
镜像
/
Eclipse Foundation
/
paho.mqtt.python
9 个月 前同步成功
通知
2
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
P
paho.mqtt.python
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
18a32136
编写于
7月 22, 2021
作者:
R
Roger A. Light
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Fix tests.
上级
cc94fc8b
变更
28
隐藏空白更改
内联
并排
Showing
28 changed file
with
77 addition
and
77 deletion
+77
-77
test/lib/01-asyncio.py
test/lib/01-asyncio.py
+5
-5
test/lib/01-decorators.py
test/lib/01-decorators.py
+5
-5
test/lib/01-keepalive-pingreq.py
test/lib/01-keepalive-pingreq.py
+3
-3
test/lib/01-no-clean-session.py
test/lib/01-no-clean-session.py
+1
-1
test/lib/01-reconnect-on-failure.py
test/lib/01-reconnect-on-failure.py
+3
-3
test/lib/01-unpwd-empty-password-set.py
test/lib/01-unpwd-empty-password-set.py
+1
-1
test/lib/01-unpwd-empty-set.py
test/lib/01-unpwd-empty-set.py
+1
-1
test/lib/01-unpwd-set.py
test/lib/01-unpwd-set.py
+1
-1
test/lib/01-unpwd-unicode-set.py
test/lib/01-unpwd-unicode-set.py
+1
-1
test/lib/01-will-set.py
test/lib/01-will-set.py
+1
-1
test/lib/01-will-unpwd-set.py
test/lib/01-will-unpwd-set.py
+1
-1
test/lib/01-zero-length-clientid.py
test/lib/01-zero-length-clientid.py
+2
-2
test/lib/02-subscribe-qos0.py
test/lib/02-subscribe-qos0.py
+3
-3
test/lib/02-subscribe-qos1.py
test/lib/02-subscribe-qos1.py
+3
-3
test/lib/02-subscribe-qos2.py
test/lib/02-subscribe-qos2.py
+3
-3
test/lib/02-unsubscribe.py
test/lib/02-unsubscribe.py
+3
-3
test/lib/03-publish-b2c-qos1.py
test/lib/03-publish-b2c-qos1.py
+2
-2
test/lib/03-publish-c2b-qos1-disconnect.py
test/lib/03-publish-c2b-qos1-disconnect.py
+5
-5
test/lib/03-publish-c2b-qos2-disconnect.py
test/lib/03-publish-c2b-qos2-disconnect.py
+8
-8
test/lib/03-publish-helper-qos0-v5.py
test/lib/03-publish-helper-qos0-v5.py
+3
-3
test/lib/03-publish-helper-qos0.py
test/lib/03-publish-helper-qos0.py
+3
-3
test/lib/03-publish-helper-qos1-disconnect.py
test/lib/03-publish-helper-qos1-disconnect.py
+5
-5
test/lib/03-publish-qos0-no-payload.py
test/lib/03-publish-qos0-no-payload.py
+3
-3
test/lib/03-publish-qos0.py
test/lib/03-publish-qos0.py
+3
-3
test/lib/04-retain-qos0.py
test/lib/04-retain-qos0.py
+2
-2
test/lib/08-ssl-connect-cert-auth-pw.py
test/lib/08-ssl-connect-cert-auth-pw.py
+2
-2
test/lib/08-ssl-connect-cert-auth.py
test/lib/08-ssl-connect-cert-auth.py
+2
-2
test/lib/08-ssl-connect-no-auth.py
test/lib/08-ssl-connect-no-auth.py
+2
-2
未找到文件。
test/lib/01-asyncio.py
浏览文件 @
18a32136
...
...
@@ -31,20 +31,20 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
conn
.
send
(
suback_packet
)
paho_test
.
expect_packet
(
conn
,
"unsubscribe"
,
unsubscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"unsubscribe"
,
unsubscribe_packet
)
conn
.
send
(
unsuback_packet
)
conn
.
send
(
publish_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet_in
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet_in
)
conn
.
send
(
puback_packet_in
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-decorators.py
浏览文件 @
18a32136
...
...
@@ -31,20 +31,20 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
conn
.
send
(
suback_packet
)
paho_test
.
expect_packet
(
conn
,
"unsubscribe"
,
unsubscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"unsubscribe"
,
unsubscribe_packet
)
conn
.
send
(
unsuback_packet
)
conn
.
send
(
publish_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet_in
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet_in
)
conn
.
send
(
puback_packet_in
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-keepalive-pingreq.py
浏览文件 @
18a32136
...
...
@@ -28,14 +28,14 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
keepalive
+
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"pingreq"
,
pingreq_packet
)
:
paho_test
.
expect_packet
(
conn
,
"pingreq"
,
pingreq_packet
)
time
.
sleep
(
1.0
)
conn
.
send
(
pingresp_packet
)
paho_test
.
expect_packet
(
conn
,
"pingreq"
,
pingreq_packet
)
:
paho_test
.
expect_packet
(
conn
,
"pingreq"
,
pingreq_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-no-clean-session.py
浏览文件 @
18a32136
...
...
@@ -20,7 +20,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-reconnect-on-failure.py
浏览文件 @
18a32136
...
...
@@ -22,11 +22,11 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet_ok
)
# Connection is a success, so we expect a publish
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
conn
.
close
()
# Expect the client to quit here due to socket being closed
client
.
wait
(
1
)
...
...
@@ -36,7 +36,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet_failure
)
# Expect the client to quit here due to socket being closed
client
.
wait
(
1
)
...
...
test/lib/01-unpwd-empty-password-set.py
浏览文件 @
18a32136
...
...
@@ -23,7 +23,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-unpwd-empty-set.py
浏览文件 @
18a32136
...
...
@@ -23,7 +23,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-unpwd-set.py
浏览文件 @
18a32136
...
...
@@ -23,7 +23,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-unpwd-unicode-set.py
浏览文件 @
18a32136
...
...
@@ -25,7 +25,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-will-set.py
浏览文件 @
18a32136
...
...
@@ -24,7 +24,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-will-unpwd-set.py
浏览文件 @
18a32136
...
...
@@ -24,7 +24,7 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/01-zero-length-clientid.py
浏览文件 @
18a32136
...
...
@@ -20,10 +20,10 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/02-subscribe-qos0.py
浏览文件 @
18a32136
...
...
@@ -34,13 +34,13 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
conn
.
send
(
suback_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/02-subscribe-qos1.py
浏览文件 @
18a32136
...
...
@@ -34,13 +34,13 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
conn
.
send
(
suback_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/02-subscribe-qos2.py
浏览文件 @
18a32136
...
...
@@ -34,13 +34,13 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"subscribe"
,
subscribe_packet
)
conn
.
send
(
suback_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/02-unsubscribe.py
浏览文件 @
18a32136
...
...
@@ -24,13 +24,13 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"unsubscribe"
,
unsubscribe_packet
)
:
paho_test
.
expect_packet
(
conn
,
"unsubscribe"
,
unsubscribe_packet
)
conn
.
send
(
unsuback_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-b2c-qos1.py
浏览文件 @
18a32136
...
...
@@ -36,11 +36,11 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
conn
.
send
(
publish_packet
)
paho_test
.
expect_packet
(
conn
,
"puback"
,
puback_packet
)
:
paho_test
.
expect_packet
(
conn
,
"puback"
,
puback_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-c2b-qos1-disconnect.py
浏览文件 @
18a32136
...
...
@@ -29,23 +29,23 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
15
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
# Disconnect client. It should reconnect.
conn
.
close
()
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
15
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"retried publish"
,
publish_packet_dup
)
:
paho_test
.
expect_packet
(
conn
,
"retried publish"
,
publish_packet_dup
)
conn
.
send
(
puback_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-c2b-qos2-disconnect.py
浏览文件 @
18a32136
...
...
@@ -31,23 +31,23 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
5
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
# Disconnect client. It should reconnect.
conn
.
close
()
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
15
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"retried publish"
,
publish_dup_packet
)
:
paho_test
.
expect_packet
(
conn
,
"retried publish"
,
publish_dup_packet
)
conn
.
send
(
pubrec_packet
)
paho_test
.
expect_packet
(
conn
,
"pubrel"
,
pubrel_packet
)
:
paho_test
.
expect_packet
(
conn
,
"pubrel"
,
pubrel_packet
)
# Disconnect client. It should reconnect.
conn
.
close
()
...
...
@@ -55,13 +55,13 @@ try:
conn
.
settimeout
(
15
)
# Complete connection and message flow.
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"retried pubrel"
,
pubrel_packet
)
:
paho_test
.
expect_packet
(
conn
,
"retried pubrel"
,
pubrel_packet
)
conn
.
send
(
pubcomp_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-helper-qos0-v5.py
浏览文件 @
18a32136
...
...
@@ -36,11 +36,11 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-helper-qos0.py
浏览文件 @
18a32136
...
...
@@ -36,11 +36,11 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-helper-qos1-disconnect.py
浏览文件 @
18a32136
...
...
@@ -34,23 +34,23 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
# Disconnect client. It should reconnect.
conn
.
close
()
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
15
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"retried publish"
,
publish_packet_dup
)
:
paho_test
.
expect_packet
(
conn
,
"retried publish"
,
publish_packet_dup
)
conn
.
send
(
puback_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-qos0-no-payload.py
浏览文件 @
18a32136
...
...
@@ -30,11 +30,11 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/03-publish-qos0.py
浏览文件 @
18a32136
...
...
@@ -30,11 +30,11 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/04-retain-qos0.py
浏览文件 @
18a32136
...
...
@@ -22,10 +22,10 @@ try:
(
conn
,
address
)
=
sock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
:
paho_test
.
expect_packet
(
conn
,
"publish"
,
publish_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/08-ssl-connect-cert-auth-pw.py
浏览文件 @
18a32136
...
...
@@ -30,10 +30,10 @@ try:
(
conn
,
address
)
=
ssock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/08-ssl-connect-cert-auth.py
浏览文件 @
18a32136
...
...
@@ -30,10 +30,10 @@ try:
(
conn
,
address
)
=
ssock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
test/lib/08-ssl-connect-no-auth.py
浏览文件 @
18a32136
...
...
@@ -28,10 +28,10 @@ try:
(
conn
,
address
)
=
ssock
.
accept
()
conn
.
settimeout
(
10
)
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"connect"
,
connect_packet
)
conn
.
send
(
connack_packet
)
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
:
paho_test
.
expect_packet
(
conn
,
"disconnect"
,
disconnect_packet
)
rc
=
0
conn
.
close
()
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录