mqttasync_module.c File Reference

#include <Python.h>
#include "MQTTAsync.h"
#include "LinkedList.h"

Include dependency graph for mqttasync_module.c:

Go to the source code of this file.

Classes
struct	CallbackEntry
struct	ConnectedEntry
struct	ResponseEntry

Enumerations
enum	msgTypes {   CONNECT = 1, CONNACK, PUBLISH, PUBACK,   PUBREC, PUBREL, PUBCOMP, SUBSCRIBE,   SUBACK, UNSUBSCRIBE, UNSUBACK, PINGREQ,   PINGRESP, DISCONNECT, AUTH, CONNECT,   PUBLISH, SUBSCRIBE, SUBSCRIBE_MANY, UNSUBSCRIBE,   CONNECT = 1, CONNACK, PUBLISH, PUBACK,   PUBREC, PUBREL, PUBCOMP, SUBSCRIBE,   SUBACK, UNSUBSCRIBE, UNSUBACK, PINGREQ,   PINGRESP, DISCONNECT, AUTH }

Functions
int	clientCompare (void *a, void *b)
void	connected (void *context, char *cause)
int	connectedCompare (void *a, void *b)
void	connectionLost (void *context, char *cause)
void	deliveryComplete (void *context, MQTTAsync_token dt)
int	getResponseOptions (MQTTAsync c, PyObject *pyoptions, MQTTAsync_responseOptions *responseOptions, enum msgTypes msgType)
PyMODINIT_FUNC	initpaho_mqtt3a (void)
int	messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
static PyObject *	mqttv3_connect (PyObject *self, PyObject *args)
static PyObject *	mqttv3_create (PyObject *self, PyObject *args)
static PyObject *	mqttv3_destroy (PyObject *self, PyObject *args)
static PyObject *	mqttv3_disconnect (PyObject *self, PyObject *args)
static PyObject *	mqttv3_getPendingTokens (PyObject *self, PyObject *args)
static PyObject *	mqttv3_isConnected (PyObject *self, PyObject *args)
static PyObject *	mqttv3_send (PyObject *self, PyObject *args)
static PyObject *	mqttv3_sendMessage (PyObject *self, PyObject *args)
static PyObject *	mqttv3_setcallbacks (PyObject *self, PyObject *args)
static PyObject *	mqttv3_setconnected (PyObject *self, PyObject *args)
static PyObject *	mqttv3_subscribe (PyObject *self, PyObject *args)
static PyObject *	mqttv3_subscribeMany (PyObject *self, PyObject *args)
static PyObject *	mqttv3_unsubscribe (PyObject *self, PyObject *args)
static PyObject *	mqttv3_unsubscribeMany (PyObject *self, PyObject *args)
static PyObject *	mqttv3_waitForCompletion (PyObject *self, PyObject *args)
void	onFailure (void *context, MQTTAsync_failureData *response)
void	onSuccess (void *context, MQTTAsync_successData *response)

Variables
static List *	callbacks = NULL
static List *	connected_callbacks = NULL
static PyObject *	MqttV3Error
static PyMethodDef	MqttV3Methods []

Enumeration Type Documentation

enum msgTypes

Enumerator
CONNECT
CONNACK
PUBLISH
PUBACK
PUBREC
PUBREL
PUBCOMP
SUBSCRIBE
SUBACK
UNSUBSCRIBE
UNSUBACK
PINGREQ
PINGRESP
DISCONNECT
AUTH
CONNECT
PUBLISH
SUBSCRIBE
SUBSCRIBE_MANY
UNSUBSCRIBE
CONNECT
CONNACK
PUBLISH
PUBACK
PUBREC
PUBREL
PUBCOMP
SUBSCRIBE
SUBACK
UNSUBSCRIBE
UNSUBACK
PINGREQ
PINGRESP
DISCONNECT
AUTH

Definition at line 76 of file mqttasync_module.c.

Function Documentation

int clientCompare	(	void *	a,
		void *	b
	)

Definition at line 97 of file mqttasync_module.c.

void connected	(	void *	context,
		char *	cause
	)

Definition at line 111 of file mqttasync_module.c.

int connectedCompare	(	void *	a,
		void *	b
	)

Definition at line 104 of file mqttasync_module.c.

void connectionLost	(	void *	context,
		char *	cause
	)

Definition at line 127 of file mqttasync_module.c.

void deliveryComplete	(	void *	context,
		MQTTAsync_token	dt
	)

Definition at line 176 of file mqttasync_module.c.

int getResponseOptions	(	MQTTAsync	c,
		PyObject *	pyoptions,
		MQTTAsync_responseOptions *	responseOptions,
		enum msgTypes	msgType
	)

Definition at line 362 of file mqttasync_module.c.

PyMODINIT_FUNC initpaho_mqtt3a

(

void

)

Definition at line 997 of file mqttasync_module.c.

int messageArrived	(	void *	context,
		char *	topicName,
		int	topicLen,
		MQTTAsync_message *	message
	)

Definition at line 143 of file mqttasync_module.c.

static PyObject* mqttv3_connect ( PyObject *  self, PyObject *  args  )

static

Definition at line 419 of file mqttasync_module.c.

static PyObject* mqttv3_create ( PyObject *  self, PyObject *  args  )

static

Definition at line 9 of file mqttasync_module.c.

static PyObject* mqttv3_destroy ( PyObject *  self, PyObject *  args  )

static

Definition at line 935 of file mqttasync_module.c.

static PyObject* mqttv3_disconnect ( PyObject *  self, PyObject *  args  )

static

Definition at line 634 of file mqttasync_module.c.

static PyObject* mqttv3_getPendingTokens ( PyObject *  self, PyObject *  args  )

static

Definition at line 907 of file mqttasync_module.c.

static PyObject* mqttv3_isConnected ( PyObject *  self, PyObject *  args  )

static

Definition at line 650 of file mqttasync_module.c.

static PyObject* mqttv3_send ( PyObject *  self, PyObject *  args  )

static

Definition at line 805 of file mqttasync_module.c.

static PyObject* mqttv3_sendMessage ( PyObject *  self, PyObject *  args  )

static

Definition at line 835 of file mqttasync_module.c.

static PyObject* mqttv3_setcallbacks ( PyObject *  self, PyObject *  args  )

static

Definition at line 191 of file mqttasync_module.c.

static PyObject* mqttv3_setconnected ( PyObject *  self, PyObject *  args  )

static

Definition at line 236 of file mqttasync_module.c.

static PyObject* mqttv3_subscribe ( PyObject *  self, PyObject *  args  )

static

Definition at line 664 of file mqttasync_module.c.

static PyObject* mqttv3_subscribeMany ( PyObject *  self, PyObject *  args  )

static

Definition at line 686 of file mqttasync_module.c.

static PyObject* mqttv3_unsubscribe ( PyObject *  self, PyObject *  args  )

static

Definition at line 745 of file mqttasync_module.c.

static PyObject* mqttv3_unsubscribeMany ( PyObject *  self, PyObject *  args  )

static

Definition at line 766 of file mqttasync_module.c.

static PyObject* mqttv3_waitForCompletion ( PyObject *  self, PyObject *  args  )

static

Definition at line 889 of file mqttasync_module.c.

void onFailure	(	void *	context,
		MQTTAsync_failureData *	response
	)

Definition at line 339 of file mqttasync_module.c.

void onSuccess	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 285 of file mqttasync_module.c.

Variable Documentation

List* callbacks = NULL

static

Definition at line 73 of file mqttasync_module.c.

List* connected_callbacks = NULL

static

Definition at line 74 of file mqttasync_module.c.

PyObject* MqttV3Error

static

Definition at line 6 of file mqttasync_module.c.

PyMethodDef MqttV3Methods[]

static

Definition at line 962 of file mqttasync_module.c.