Add asynchronous connection method for MQTT v5 #2345
+186
−14
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Description
It is currently only possible to make a blocking MQTT v5 connection to a broker by using
mosquitto_connect_bind_v5
. The non-blocking alternativemosquitto_connect_bind_async
can only be used for MQTT v3, because it does not allow passing MQTT v5 properties.This pull request adds 2 new API functions to the mosquitto library:
mosquitto_connect_bind_async_v5
: This function will create a non-blocking socket connection to the MQTT broker. It will return withMOSQ_ERR_CONN_INPROGRESS
when the socket connection was created, but the connection is still in progress. The socket can be added to an event loop to check when it becomes ready for writing.mosquitto_send_connect
: This function must be called once the connection is ready for writing to send the actual MQTT CONNECT message.Started from this issue: #1835
Checklist
Signed-off-by: Johan Jacobs [email protected]
Thank you for contributing your time to the Mosquitto project!
Before you go any further, please note that we cannot accept contributions if
you haven't signed the Eclipse Contributor Agreement.
If you aren't able to do that, or just don't want to, please describe your bug
fix/feature change in an issue. For simple bug fixes it is can be just as easy
for us to be told about the problem and then go fix it directly.
Then please check the following list of things we ask for in your pull request:
make test
with your changes locally?