MQTT C Client Libraries Internals
 All Data Structures Files Functions Variables Typedefs Macros Pages
Functions | Variables
MQTTProtocolOut.c File Reference

Functions dealing with the MQTT protocol exchanges. More...

#include <stdlib.h>
#include <string.h>
#include "MQTTProtocolOut.h"
#include "StackTrace.h"
#include "Heap.h"
Include dependency graph for MQTTProtocolOut.c:

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

ClientStatesbstate
 

Detailed Description

Functions dealing with the MQTT protocol exchanges.

Some other related functions are in the MQTTProtocolClient module

Function Documentation

char* MQTTProtocol_addressPort ( const char *  uri,
int *  port 
)

Separates an address:port into two separate values.

Parameters
urithe input string - hostname:port
portthe returned port integer
Returns
the address string

Here is the call graph for this function:

int MQTTProtocol_connect ( const char *  ip_address,
Clients aClient,
int  MQTTVersion 
)

MQTT outgoing connect processing for a client.

Parameters
ip_addressthe TCP address:port to connect to
aClienta structure with all MQTT data needed
intssl
intMQTTVersion the MQTT version to connect with (3 or 4)
Returns
return code

Here is the call graph for this function:

int MQTTProtocol_handlePingresps ( void *  pack,
int  sock 
)

Process an incoming pingresp packet for a socket.

Parameters
packpointer to the publish packet
sockthe socket on which the packet was received
Returns
completion code

Here is the call graph for this function:

int MQTTProtocol_handleSubacks ( void *  pack,
int  sock 
)

Process an incoming suback packet for a socket.

Parameters
packpointer to the publish packet
sockthe socket on which the packet was received
Returns
completion code

Here is the call graph for this function:

int MQTTProtocol_handleUnsubacks ( void *  pack,
int  sock 
)

Process an incoming unsuback packet for a socket.

Parameters
packpointer to the publish packet
sockthe socket on which the packet was received
Returns
completion code

Here is the call graph for this function:

int MQTTProtocol_subscribe ( Clients client,
List topics,
List qoss,
int  msgID 
)

MQTT outgoing subscribe processing for a client.

Parameters
clientthe client structure
topicslist of topics
qosscorresponding list of QoSs
Returns
completion code

Here is the call graph for this function:

int MQTTProtocol_unsubscribe ( Clients client,
List topics,
int  msgID 
)

MQTT outgoing unsubscribe processing for a client.

Parameters
clientthe client structure
topicslist of topics
Returns
completion code

Here is the call graph for this function: