| [mosquitto-dev] mosquitto library stops working |
Hi all,
I am using the mosquitto c sourcecode (1.4.10) in my raspberry project (Raspbian Jessy). In my current test setup, I have a condition, where mosquitto stops working.
In my test setup I’m calling the mosquitto_publish() function 5 times as fast as possible and then wait for 2 seconds (75 Bytes, qos 2, retain false, topic: "testtarget/status"). The broker is receiving the messages correctly. Normally this setup runs forever. Then I subscribe a topic (e.g. "testtarget/command"). I manually publish a message on this topic from another device. When the subscribed message reaches the testtarget while it is still publishing messages, mosquitto just stops working in the out direction. The target is not able to publish messages any more.
I attached the debug output from my code and the mosquitto library to this email.
Any suggestions? Anything that I can imlement to make it safer?
Thanks and Regards,
Chris
mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1823, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1823 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1824, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1824 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1825, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1825 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1826, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1826 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREC (Mid: 1822) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREL (Mid: 1822) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREC (Mid: 1823) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREL (Mid: 1823) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREC (Mid: 1824) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREL (Mid: 1824) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREC (Mid: 1825) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREL (Mid: 1825) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREC (Mid: 1826) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREL (Mid: 1826) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBCOMP (Mid: 1822) callback: Published mid: 1822 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBCOMP (Mid: 1823) callback: Published mid: 1823 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBLISH (d0, q2, r0, m5, 'testtarget/command', ... (469 bytes)) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREC (Mid: 5) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBCOMP (Mid: 1824) callback: Published mid: 1824 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBCOMP (Mid: 1825) callback: Published mid: 1825 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBCOMP (Mid: 1826) callback: Published mid: 1826 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBLISH (d0, q2, r0, m6, 'testtarget/command', ... (469 bytes)) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREC (Mid: 6) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREL (Mid: 5) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBCOMP (Mid: 5) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBLISH (d0, q2, r0, m7, 'testtarget/command', ... (469 bytes)) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBREC (Mid: 7) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREL (Mid: 6) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBCOMP (Mid: 6) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: received PUBREL (Mid: 7) mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1827, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1827 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1828, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1828 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1829, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1829 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1830, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1830 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1831, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1831 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1832, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1832 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1833, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1833 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1834, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1834 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1835, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1835 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1836, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1836 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1837, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1837 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1838, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1838 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1839, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1839 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1840, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1840 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1841, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1841 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1842, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1842 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1843, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1843 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1844, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1844 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1845, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1845 mqtt_log(16): Client mosq/V5\x[^@Ho@wEn:kU]: sending PUBLISH (d0, q2, r0, m1846, 'testtarget/status', ... (75 bytes)) mosquitto_publish() returned mid 1846 mosquitto_publish() returned mid 1847 mosquitto_publish() returned mid 1848 mosquitto_publish() returned mid 1849 mosquitto_publish() returned mid 1850 mosquitto_publish() returned mid 1851 mosquitto_publish() returned mid 1852 mosquitto_publish() returned mid 1853 mosquitto_publish() returned mid 1854 mosquitto_publish() returned mid 1855 mosquitto_publish() returned mid 1856 mosquitto_publish() returned mid 1857 mosquitto_publish() returned mid 1858 mosquitto_publish() returned mid 1859 mosquitto_publish() returned mid 1860 mosquitto_publish() returned mid 1861 mosquitto_publish() returned mid 1862 mosquitto_publish() returned mid 1863 mosquitto_publish() returned mid 1864 mosquitto_publish() returned mid 1865 mosquitto_publish() returned mid 1866