Fix unlimited message quota not being properly checked.
This is for incoming messages. Closes #2593. Thanks to dongguoqing2015.
This commit is contained in:
parent
71a90177d7
commit
a146c218ad
@ -53,6 +53,8 @@ Broker:
|
|||||||
- Fix broker sending duplicate CONNACK on failed MQTT v5 reauthentication.
|
- Fix broker sending duplicate CONNACK on failed MQTT v5 reauthentication.
|
||||||
Closes #2339.
|
Closes #2339.
|
||||||
- Fix mosquitto_plugin.h not including mosquitto_broker.h. Closes #2350.
|
- Fix mosquitto_plugin.h not including mosquitto_broker.h. Closes #2350.
|
||||||
|
- Fix unlimited message quota not being properly checked for incoming
|
||||||
|
messages. Closes #2593.
|
||||||
|
|
||||||
Client library:
|
Client library:
|
||||||
- Initialise sockpairR/W to invalid in `mosquitto_reinitialise()` to avoid
|
- Initialise sockpairR/W to invalid in `mosquitto_reinitialise()` to avoid
|
||||||
|
@ -1188,7 +1188,7 @@ int db__message_write_queued_in(struct mosquitto *context)
|
|||||||
}
|
}
|
||||||
|
|
||||||
DL_FOREACH_SAFE(context->msgs_in.queued, tail, tmp){
|
DL_FOREACH_SAFE(context->msgs_in.queued, tail, tmp){
|
||||||
if(context->msgs_out.inflight_maximum != 0 && context->msgs_in.inflight_quota == 0){
|
if(context->msgs_in.inflight_maximum != 0 && context->msgs_in.inflight_quota == 0){
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user