web page publish and main loop share the MQTT send queue
@Yukti007 已经在做这个了。
开始于 2026年10月13日。
评估
这个 Issue 还没有评估数据。
描述
Describe the bug
Messages going to the MQTT broker first go into a small queue of 8 slots. The main program adds messages to it (alarm Acknowledge/Dismiss/Shelve replies and the "online" message). The Broker Console web page also adds messages when someone presses Publish. The web page runs in a separate task that can interrupt the main program at any moment, and there is no lock. Both can pick the same empty slot. Then one message is lost, or a message goes out with one sender's topic and the other sender's text.
Short Summary of the expected behavior:
Every message added to the MQTT queue is sent once, on the right topic, with the right text, no matter which part of the program added it.
Short Summary of the buggy behavior:
If the web page and the main program add a message at the same moment, one message can be lost, or the topic and the text can come from different messages. The web page can still say "published".
To Reproduce
Found by reading the code. Not yet tested on a real Krake board. The two writes must overlap within microseconds, so this is hard to make happen on purpose. Suggested steps to try:
- Connect the Krake to Wi-Fi and an MQTT broker. Subscribe to its ACK topic and to a Broker Console publish topic with an MQTT client.
- Open the Broker Console web page on the Krake.
- Use a script to send many POST requests to
/broker-console/publishvery quickly. - At the same time, send alarms to the Krake and acknowledge them on the knob, or just let the "online" message go out every 10 seconds.
- See error: some messages are missing on the broker, or an ACK-topic message arrives on the Broker Console topic (or the other way round).
Expected behavior
All messages arrive at the broker, each on its own topic with its own text. An operator's Acknowledge is never lost.
Screenshots
None. Not yet tested on hardware.
Hardware description
Model: Krake (GPAD_API firmware), checked against main at commit b6ea4b3 (2026-09-20)
Serial Number: N/A (found by reading the code)
Other: Affects any Krake with Wi-Fi/MQTT and the web page in use.
Test Equipment
Model: N/A (not yet tested)
Serial Number: N/A
Additional context
Where in the code:
- The queue and the function that adds to it:
Firmware/GPAD_API/GPAD_API/mqtt_handler.cpplines 30–55
https://github.com/PubInv/krake/blob/b6ea4b3eaf0e93a580cad7cdc9f8c1541860ff06/Firmware/GPAD_API/GPAD_API/mqtt_handler.cpp#L30-L55 - Sending from the queue (in
loop()):mqtt_handler.cpplines 57–77
https://github.com/PubInv/krake/blob/b6ea4b3eaf0e93a580cad7cdc9f8c1541860ff06/Firmware/GPAD_API/GPAD_API/mqtt_handler.cpp#L57-L77 - The web page handler that adds to the queue (runs in the async web server's task):
GPAD_API.inolines 2175–2225 (thequeueMqttcall is at line 2203)
https://github.com/PubInv/krake/blob/b6ea4b3eaf0e93a580cad7cdc9f8c1541860ff06/Firmware/GPAD_API/GPAD_API/GPAD_API.ino#L2175-L2225 - Main-loop code that adds to the queue:
GPAD_API.inoline 397 ("online" message every 10 seconds) and line 575 ("online" message on broker connect);GPAD_menu.cpplines 63, 78, 92 and 118 (Acknowledge/Dismiss/Shelve/Complete)
https://github.com/PubInv/krake/blob/b6ea4b3eaf0e93a580cad7cdc9f8c1541860ff06/Firmware/GPAD_API/GPAD_API/GPAD_menu.cpp#L63 - The same pattern in the SPI mirror queue, which
queueMqtt()also fills:spi_broker_mirror.cpplines 50–70
https://github.com/PubInv/krake/blob/b6ea4b3eaf0e93a580cad7cdc9f8c1541860ff06/Firmware/GPAD_API/GPAD_API/spi_broker_mirror.cpp#L50-L70
Why it happens: queueMqtt() finds an empty slot, copies in the topic, then the text, and only then marks the slot as used. The web task can interrupt in the middle of that, see the same slot as empty, and write into it too. There is no mutex, critical section or FreeRTOS queue: a search of the firmware for mutex, Semaphore, portENTER_CRITICAL and xQueue finds nothing.
How likely: low. The two writes must overlap within microseconds. But it happens at random, cannot be reproduced on demand, and a lost Acknowledge matters on an alarm device.
Possible fix: protect queueMqtt() and serviceMqttQueue() (and the matching SPI mirror functions) with a FreeRTOS mutex or a short critical section. Or have the web handler pass the message to the main loop through a FreeRTOS queue, so only loop() touches the MQTT queue. The same handler also changes saved publish topics and settings from the web task (lines 2204–2221), so the fix should cover those too.
Not checked: the async web server library is not listed in platformio.ini, so its exact task priority and core setting could not be confirmed from this repo.
Related: #370 (MQTT messages published), #283 (shared global variables).
- 主要语言
- C++
- 星标
- 9
- 派生
- 6
- PR 合并指标
- 30 天内没有已合并 PR
环境准备
这个项目没有提供开发容器、Dockerfile 或贡献指南,环境需要你自己搭建:先看它的 README,通用步骤见我们的新手贡献指南。
从这里开始
- 先读完整个 Issue,再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库,在一个分支上完成修改。
- 提交 Pull Request,并在描述里引用这个 Issue 编号。
PubInv/krake 的其他 Issue
-
USB and COM port share one command buffer可能已有人在做 @Yukti007 于 4 天前认领。 未关闭High Priority
-
Firmware, Krake Loosing Broker Settings back to a Default可能已有人在做 @nk25719 于 16 天前认领。 未关闭
-
Hardware, LB0007 Not Playing Alarm File可能已有人在做 @nk25719 于 23 天前认领。 未关闭
-
Mini MP3 File Names and File Order For Reliable Play Back, Both GPAD_API and Factory Test可能已有人在做 @Yukti007 于 25 天前认领。 未关闭
-
难度 5/5 一周以上 新手友好度 15/100
相似的 Issue
-
Mac mini M6 (16 GB): Q2_0 streaming works - measured 11.7->27.2 tok/s + arena fix for sub-32 GB Macs未关闭
难度 2/5 1-3 小时 新手友好度 68/100
维护者通常 1 天内回复
-
champion good first issue remake source/qq
难度 2/5 1-3 小时 新手友好度 65/100
metasequoiaime/msime-windows#1025 ·
维护者通常 1 天内回复
-
backlog bug
难度 2/5 1-3 小时 新手友好度 75/100
EchoTools/nevr-runtime#653 ·
维护者通常 1 天内回复
-
`--fail-require-skip` never fires: run_tests.py searches stdout, but the unittest binary writes the skip summary to stderr可能已有人在做 关联的 PR 仍在进行中或已合并。 未关闭
难度 2/5 1-3 小时 新手友好度 72/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 75/100
InfiniTimeOrg/InfiniTime#2492 ·