![]() |
MQTT C Client Libraries Internals
|
Functions dealing with the MQTT protocol exchanges. More...
#include <stdlib.h>
#include "MQTTProtocolOut.h"
#include "StackTrace.h"
#include "Heap.h"
Functions | |
char * | MQTTProtocol_addressPort (const char *uri, int *port) |
Separates an address:port into two separate values. More... | |
int | MQTTProtocol_connect (const char *ip_address, Clients *aClient, int MQTTVersion) |
MQTT outgoing connect processing for a client. More... | |
int | MQTTProtocol_handlePingresps (void *pack, int sock) |
Process an incoming pingresp packet for a socket. More... | |
int | MQTTProtocol_subscribe (Clients *client, List *topics, List *qoss, int msgID) |
MQTT outgoing subscribe processing for a client. More... | |
int | MQTTProtocol_handleSubacks (void *pack, int sock) |
Process an incoming suback packet for a socket. More... | |
int | MQTTProtocol_unsubscribe (Clients *client, List *topics, int msgID) |
MQTT outgoing unsubscribe processing for a client. More... | |
int | MQTTProtocol_handleUnsubacks (void *pack, int sock) |
Process an incoming unsuback packet for a socket. More... | |
Variables | |
ClientStates * | bstate |
Functions dealing with the MQTT protocol exchanges.
Some other related functions are in the MQTTProtocolClient module
char* MQTTProtocol_addressPort | ( | const char * | uri, |
int * | port | ||
) |
Separates an address:port into two separate values.
uri | the input string - hostname:port |
port | the returned port integer |
int MQTTProtocol_connect | ( | const char * | ip_address, |
Clients * | aClient, | ||
int | MQTTVersion | ||
) |
MQTT outgoing connect processing for a client.
ip_address | the TCP address:port to connect to |
aClient | a structure with all MQTT data needed |
int | ssl |
int | MQTTVersion the MQTT version to connect with (3 or 4) |
int MQTTProtocol_handlePingresps | ( | void * | pack, |
int | sock | ||
) |
Process an incoming pingresp packet for a socket.
pack | pointer to the publish packet |
sock | the socket on which the packet was received |
int MQTTProtocol_handleSubacks | ( | void * | pack, |
int | sock | ||
) |
Process an incoming suback packet for a socket.
pack | pointer to the publish packet |
sock | the socket on which the packet was received |
int MQTTProtocol_handleUnsubacks | ( | void * | pack, |
int | sock | ||
) |
Process an incoming unsuback packet for a socket.
pack | pointer to the publish packet |
sock | the socket on which the packet was received |
MQTT outgoing subscribe processing for a client.
client | the client structure |
topics | list of topics |
qoss | corresponding list of QoSs |