Re: [mosquitto-dev] Help needed, odd behaviour: What are the reasons the

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]

Re: [mosquitto-dev] Help needed, odd behaviour: What are the reasons the Broker will stop sending PUBLISH to a client?

From: Roger Light <roger@xxxxxxxxxx>
Date: Tue, 7 Jul 2015 16:31:21 +0100
Delivered-to: mosquitto-dev@xxxxxxxxxxx
List-archive: <https://dev.eclipse.org/mailman/private/mosquitto-dev>
List-help: <mailto:mosquitto-dev-request@eclipse.org?subject=help>
List-subscribe: <https://dev.eclipse.org/mailman/listinfo/mosquitto-dev>, <mailto:mosquitto-dev-request@eclipse.org?subject=subscribe>
List-unsubscribe: <https://dev.eclipse.org/mailman/options/mosquitto-dev>, <mailto:mosquitto-dev-request@eclipse.org?subject=unsubscribe>

Hi Felipe,

I think this is down to the same problem as your previous email. Try
the patch I sent, or else increase the value of max_inflight_messages.

I forgot to say thanks for bring this up in my previous email - thanks!

Cheers,

Roger



On Tue, Jul 7, 2015 at 4:04 PM, Felipe de Andrade Neves Lavratti
<felipelav@xxxxxxxxx> wrote:
> Hi!
>
> I am running a stress test in my network, sending a publish in qos2
> each 5 seconds in the topic "test" where clients are subscribed with
> qo2, and then the clients answer in the topic "testout" with a qos2 as
> well.
>
> I have observed this odd behaviour and would like to understand it
> better, can you help me?
>
> The odd behaviour is this: The Mosqutto stopped send PUBLISH to the
> client, after a while.
>
> I am using the following configuration file:
>
> persistence true
> persistence_location /var/lib/mosquitto/
> max_inflight_messages 1
>
>
> This is the log:
>
> *** client subscribe to topic ***
>
> 1436277833: New client connected from aaaa::215:8d00:76:8140 as
> fe80::215:8d00:76:8140 (c1, k60).
> 1436277833: Sending CONNACK to fe80::215:8d00:76:8140 (0)
> 1436277839: Received SUBSCRIBE from fe80::215:8d00:76:8140
> 1436277839: fe80::215:8d00:76:8140 2 test
> 1436277839: Sending SUBACK to fe80::215:8d00:76:8140
>
>
> 1436277859: Received PINGREQ from fe80::215:8d00:76:8140
> 1436277859: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436277880: Received PINGREQ from fe80::215:8d00:76:8140
> 1436277880: Sending PINGRESP to fe80::215:8d00:76:8140
>
> *** data starts to be exchanged ***
>
> 1436277886: Sending PUBLISH to fe80::215:8d00:76:8140 (d0, q2, r0, m1,
> 'test', ... (9 bytes))
> 1436277886: Received PUBREC from fe80::215:8d00:76:8140 (Mid: 1)
> 1436277886: Sending PUBREL to fe80::215:8d00:76:8140 (Mid: 1)
> 1436277886: Received PUBCOMP from fe80::215:8d00:76:8140 (Mid: 1)
>
> 1436277887: Received PUBLISH from fe80::215:8d00:76:8140 (d0, q2, r0,
> m29, 'testout', ... (3 bytes))
> 1436277887: Sending PUBREC to fe80::215:8d00:76:8140 (Mid: 29)
> 1436277887: Received PUBREL from fe80::215:8d00:76:8140 (Mid: 29)
> 1436277887: Sending PUBCOMP to fe80::215:8d00:76:8140 (Mid: 29)
>
> 1436277891: Sending PUBLISH to fe80::215:8d00:76:8140 (d0, q2, r0, m2,
> 'test', ... (9 bytes))
> 1436277891: Received PUBREC from fe80::215:8d00:76:8140 (Mid: 2)
> 1436277891: Sending PUBREL to fe80::215:8d00:76:8140 (Mid: 2)
> 1436277891: Received PUBCOMP from fe80::215:8d00:76:8140 (Mid: 2)
>
> 1436277892: Received PUBLISH from fe80::215:8d00:76:8140 (d0, q2, r0,
> m30, 'testout', ... (3 bytes))
> 1436277892: Sending PUBREC to fe80::215:8d00:76:8140 (Mid: 30)
> 1436277892: Received PUBREL from fe80::215:8d00:76:8140 (Mid: 30)
> 1436277892: Sending PUBCOMP to fe80::215:8d00:76:8140 (Mid: 30)
>
> 1436277896: Sending PUBLISH to fe80::215:8d00:76:8140 (d0, q2, r0, m3,
> 'test', ... (9 bytes))
> 1436277896: Received PUBREC from fe80::215:8d00:76:8140 (Mid: 3)
> 1436277896: Sending PUBREL to fe80::215:8d00:76:8140 (Mid: 3)
> 1436277896: Received PUBCOMP from fe80::215:8d00:76:8140 (Mid: 3)
>
> 1436277897: Received PUBLISH from fe80::215:8d00:76:8140 (d0, q2, r0,
> m31, 'testout', ... (3 bytes))
> 1436277897: Sending PUBREC to fe80::215:8d00:76:8140 (Mid: 31)
> 1436277899: Received PUBREL from fe80::215:8d00:76:8140 (Mid: 31)
> 1436277899: Sending PUBCOMP to fe80::215:8d00:76:8140 (Mid: 31)
>
> 1436277901: Sending PUBLISH to fe80::215:8d00:76:8140 (d0, q2, r0, m4,
> 'test', ... (9 bytes))
> 1436277901: Received PUBREC from fe80::215:8d00:76:8140 (Mid: 4)
> 1436277901: Sending PUBREL to fe80::215:8d00:76:8140 (Mid: 4)
> 1436277901: Received PUBCOMP from fe80::215:8d00:76:8140 (Mid: 4)
>
> 1436277902: Received PUBLISH from fe80::215:8d00:76:8140 (d0, q2, r0,
> m32, 'testout', ... (3 bytes))
> 1436277902: Sending PUBREC to fe80::215:8d00:76:8140 (Mid: 32)
> 1436277902: Received PUBREL from fe80::215:8d00:76:8140 (Mid: 32)
> 1436277902: Sending PUBCOMP to fe80::215:8d00:76:8140 (Mid: 32)
>
> 1436277906: Sending PUBLISH to fe80::215:8d00:76:8140 (d0, q2, r0, m5,
> 'test', ... (9 bytes))
> 1436277906: Received PUBREC from fe80::215:8d00:76:8140 (Mid: 5)
> 1436277906: Sending PUBREL to fe80::215:8d00:76:8140 (Mid: 5)
> 1436277906: Received PUBCOMP from fe80::215:8d00:76:8140 (Mid: 5)
>
> 1436277907: Received PUBLISH from fe80::215:8d00:76:8140 (d0, q2, r0,
> m33, 'testout', ... (3 bytes))
> 1436277907: Sending PUBREC to fe80::215:8d00:76:8140 (Mid: 33)
> 1436277909: Received PUBREL from fe80::215:8d00:76:8140 (Mid: 33)
> 1436277909: Sending PUBCOMP to fe80::215:8d00:76:8140 (Mid: 33)
>
> 1436277911: Sending PUBLISH to fe80::215:8d00:76:8140 (d0, q2, r0, m6,
> 'test', ... (9 bytes))
> 1436277911: Received PUBREC from fe80::215:8d00:76:8140 (Mid: 6)
> 1436277911: Sending PUBREL to fe80::215:8d00:76:8140 (Mid: 6)
> 1436277911: Received PUBCOMP from fe80::215:8d00:76:8140 (Mid: 6)
>
> 1436277916: Received PUBLISH from fe80::215:8d00:76:8140 (d0, q2, r0,
> m34, 'testout', ... (3 bytes))
> 1436277916: Sending PUBREC to fe80::215:8d00:76:8140 (Mid: 34)
> 1436277918: Received PUBREL from fe80::215:8d00:76:8140 (Mid: 34)
> 1436277918: Sending PUBCOMP to fe80::215:8d00:76:8140 (Mid: 34)
>
>
> *** data exchange stops, why ? There is still publishes being made to
> the `test` topic. ***
>
>
> 1436277938: Received PINGREQ from fe80::215:8d00:76:8140
> 1436277938: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436277959: Received PINGREQ from fe80::215:8d00:76:8140
> 1436277959: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436277981: Received PINGREQ from fe80::215:8d00:76:8140
> 1436277981: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278002: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278002: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278022: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278022: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278043: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278043: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278063: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278063: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278084: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278084: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278104: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278104: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278125: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278125: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278145: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278145: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278166: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278166: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278186: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278186: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278207: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278207: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278227: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278227: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278248: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278248: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278268: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278268: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278289: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278289: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278309: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278309: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278330: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278330: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278350: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278350: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278371: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278371: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278391: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278391: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278412: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278412: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278432: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278432: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278453: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278453: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278473: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278473: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278494: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278494: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278514: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278514: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278535: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278535: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278555: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278555: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278576: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278576: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278596: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278596: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278617: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278617: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278637: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278637: Sending PINGRESP to fe80::215:8d00:76:8140
> 1436278658: Received PINGREQ from fe80::215:8d00:76:8140
> 1436278658: Sending PINGRESP to fe80::215:8d00:76:8140
>
> *** buffer overflow **
>
> 1436278661: Outgoing messages are being dropped for client
> fe80::215:8d00:76:8140.
>
>
>
> --
> Skype: felipeanl
> _______________________________________________
> mosquitto-dev mailing list
> mosquitto-dev@xxxxxxxxxxx
> To change your delivery options, retrieve your password, or unsubscribe from this list, visit
> https://dev.eclipse.org/mailman/listinfo/mosquitto-dev

References:
- [mosquitto-dev] Help needed, odd behaviour: What are the reasons the Broker will stop sending PUBLISH to a client?
  - From: Felipe de Andrade Neves Lavratti

Prev by Date: Re: [mosquitto-dev] Maybe found a bug: Received publish not being ack'd with QOS=2 and `max_inflight_messages 1`
Next by Date: Re: [mosquitto-dev] Help needed, odd behaviour: What are the reasons the Broker will stop sending PUBLISH to a client?
Previous by thread: [mosquitto-dev] Help needed, odd behaviour: What are the reasons the Broker will stop sending PUBLISH to a client?
Next by thread: Re: [mosquitto-dev] Help needed, odd behaviour: What are the reasons the Broker will stop sending PUBLISH to a client?
Index(es):
- Date
- Thread

Breadcrumbs