mqtt_msg.c File Reference

#include <string.h>
#include "mqtt_msg.h"
#include "user_config.h"

Include dependency graph for mqtt_msg.c:

Go to the source code of this file.

Macros
#define	MQTT_MAX_FIXED_HEADER_SIZE   3

Enumerations
enum	mqtt_connect_flag {   MQTT_CONNECT_FLAG_USERNAME = 1 << 7, MQTT_CONNECT_FLAG_PASSWORD = 1 << 6, MQTT_CONNECT_FLAG_WILL_RETAIN = 1 << 5, MQTT_CONNECT_FLAG_WILL = 1 << 2,   MQTT_CONNECT_FLAG_CLEAN_SESSION = 1 << 1 }

Functions
struct	__attribute ((__packed__))
static int ICACHE_FLASH_ATTR	append_string (mqtt_connection_t *connection, const char *string, int len)
static uint16_t ICACHE_FLASH_ATTR	append_message_id (mqtt_connection_t *connection, uint16_t message_id)
static int ICACHE_FLASH_ATTR	init_message (mqtt_connection_t *connection)
static mqtt_message_t *ICACHE_FLASH_ATTR	fail_message (mqtt_connection_t *connection)
static mqtt_message_t *ICACHE_FLASH_ATTR	fini_message (mqtt_connection_t *connection, int type, int dup, int qos, int retain)
void ICACHE_FLASH_ATTR	mqtt_msg_init (mqtt_connection_t *connection, uint8_t *buffer, uint16_t buffer_length)
int ICACHE_FLASH_ATTR	mqtt_get_total_length (uint8_t *buffer, uint16_t length)
const char *ICACHE_FLASH_ATTR	mqtt_get_publish_topic (uint8_t *buffer, uint16_t *length)
const char *ICACHE_FLASH_ATTR	mqtt_get_publish_data (uint8_t *buffer, uint16_t *length)
uint16_t ICACHE_FLASH_ATTR	mqtt_get_id (uint8_t *buffer, uint16_t length)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_connect (mqtt_connection_t *connection, mqtt_connect_info_t *info)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_publish (mqtt_connection_t *connection, const char *topic, const char *data, int data_length, int qos, int retain, uint16_t *message_id)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_puback (mqtt_connection_t *connection, uint16_t message_id)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_pubrec (mqtt_connection_t *connection, uint16_t message_id)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_pubrel (mqtt_connection_t *connection, uint16_t message_id)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_pubcomp (mqtt_connection_t *connection, uint16_t message_id)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_subscribe (mqtt_connection_t *connection, const char *topic, int qos, uint16_t *message_id)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_unsubscribe (mqtt_connection_t *connection, const char *topic, uint16_t *message_id)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_pingreq (mqtt_connection_t *connection)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_pingresp (mqtt_connection_t *connection)
mqtt_message_t *ICACHE_FLASH_ATTR	mqtt_msg_disconnect (mqtt_connection_t *connection)

Macro Definition Documentation

MQTT_MAX_FIXED_HEADER_SIZE

#define MQTT_MAX_FIXED_HEADER_SIZE   3

Definition at line 35 of file mqtt_msg.c.

Referenced by fini_message(), and init_message().

Enumeration Type Documentation

mqtt_connect_flag

enum mqtt_connect_flag

Enumerator
MQTT_CONNECT_FLAG_USERNAME
MQTT_CONNECT_FLAG_PASSWORD
MQTT_CONNECT_FLAG_WILL_RETAIN
MQTT_CONNECT_FLAG_WILL
MQTT_CONNECT_FLAG_CLEAN_SESSION

Definition at line 37 of file mqtt_msg.c.

{
  MQTT_CONNECT_FLAG_USERNAME = 1 << 7,
  MQTT_CONNECT_FLAG_PASSWORD = 1 << 6,
  MQTT_CONNECT_FLAG_WILL_RETAIN = 1 << 5,
  MQTT_CONNECT_FLAG_WILL = 1 << 2,
  MQTT_CONNECT_FLAG_CLEAN_SESSION = 1 << 1
};

Function Documentation

__attribute()

struct __attribute

(

(__packed__)

)

Definition at line 46 of file mqtt_msg.c.

{
  uint8_t lengthMsb;
  uint8_t lengthLsb;
#if defined(PROTOCOL_NAMEv31)
  uint8_t magic[6];
#elif defined(PROTOCOL_NAMEv311)
  uint8_t magic[4];
#else
#error "Please define protocol name"
#endif
  uint8_t version;
  uint8_t flags;
  uint8_t keepaliveMsb;
  uint8_t keepaliveLsb;
};

append_message_id()

static uint16_t ICACHE_FLASH_ATTR append_message_id ( mqtt_connection_t *  connection, uint16_t  message_id  )

static

Definition at line 76 of file mqtt_msg.c.

References mqtt_connection::buffer, mqtt_connection::buffer_length, mqtt_message::length, mqtt_connection::message, and mqtt_connection::message_id.

Referenced by mqtt_msg_puback(), mqtt_msg_pubcomp(), mqtt_msg_publish(), mqtt_msg_pubrec(), mqtt_msg_pubrel(), mqtt_msg_subscribe(), and mqtt_msg_unsubscribe().

{
  // If message_id is zero then we should assign one, otherwise
  // we'll use the one supplied by the caller
  while (message_id == 0)
    message_id = ++connection->message_id;

  if (connection->message.length + 2 > connection->buffer_length)
    return 0;

  connection->buffer[connection->message.length++] = message_id >> 8;
  connection->buffer[connection->message.length++] = message_id & 0xff;

  return message_id;
}

Here is the caller graph for this function:

append_string()

static int ICACHE_FLASH_ATTR append_string ( mqtt_connection_t *  connection, const char *  string, int  len  )

static

Definition at line 63 of file mqtt_msg.c.

References mqtt_connection::buffer, mqtt_connection::buffer_length, mqtt_message::length, memcpy, and mqtt_connection::message.

Referenced by mqtt_msg_connect(), mqtt_msg_publish(), mqtt_msg_subscribe(), and mqtt_msg_unsubscribe().

{
  if (connection->message.length + len + 2 > connection->buffer_length)
    return -1;

  connection->buffer[connection->message.length++] = len >> 8;
  connection->buffer[connection->message.length++] = len & 0xff;
  memcpy(connection->buffer + connection->message.length, string, len);
  connection->message.length += len;

  return len + 2;
}

Here is the caller graph for this function:

fail_message()

static mqtt_message_t* ICACHE_FLASH_ATTR fail_message ( mqtt_connection_t *  connection )

static

Definition at line 98 of file mqtt_msg.c.

References mqtt_connection::buffer, mqtt_message::data, mqtt_message::length, and mqtt_connection::message.

Referenced by mqtt_msg_connect(), mqtt_msg_puback(), mqtt_msg_pubcomp(), mqtt_msg_publish(), mqtt_msg_pubrec(), mqtt_msg_pubrel(), mqtt_msg_subscribe(), and mqtt_msg_unsubscribe().

{
  connection->message.data = connection->buffer;
  connection->message.length = 0;
  return &connection->message;
}

Here is the caller graph for this function:

fini_message()

static mqtt_message_t* ICACHE_FLASH_ATTR fini_message ( mqtt_connection_t *  connection, int  type, int  dup, int  qos, int  retain  )

static

Definition at line 105 of file mqtt_msg.c.

References mqtt_connection::buffer, mqtt_message::data, mqtt_message::length, mqtt_connection::message, and MQTT_MAX_FIXED_HEADER_SIZE.

Referenced by mqtt_msg_connect(), mqtt_msg_disconnect(), mqtt_msg_pingreq(), mqtt_msg_pingresp(), mqtt_msg_puback(), mqtt_msg_pubcomp(), mqtt_msg_publish(), mqtt_msg_pubrec(), mqtt_msg_pubrel(), mqtt_msg_subscribe(), and mqtt_msg_unsubscribe().

{
  int remaining_length = connection->message.length - MQTT_MAX_FIXED_HEADER_SIZE;

  if (remaining_length > 127)
  {
    connection->buffer[0] = ((type & 0x0f) << 4) | ((dup & 1) << 3) | ((qos & 3) << 1) | (retain & 1);
    connection->buffer[1] = 0x80 | (remaining_length % 128);
    connection->buffer[2] = remaining_length / 128;
    connection->message.length = remaining_length + 3;
    connection->message.data = connection->buffer;
  }
  else
  {
    connection->buffer[1] = ((type & 0x0f) << 4) | ((dup & 1) << 3) | ((qos & 3) << 1) | (retain & 1);
    connection->buffer[2] = remaining_length;
    connection->message.length = remaining_length + 2;
    connection->message.data = connection->buffer + 1;
  }

  return &connection->message;
}

Here is the caller graph for this function:

init_message()

static int ICACHE_FLASH_ATTR init_message ( mqtt_connection_t *  connection )

static

Definition at line 92 of file mqtt_msg.c.

References mqtt_message::length, mqtt_connection::message, and MQTT_MAX_FIXED_HEADER_SIZE.

Referenced by mqtt_msg_connect(), mqtt_msg_disconnect(), mqtt_msg_pingreq(), mqtt_msg_pingresp(), mqtt_msg_puback(), mqtt_msg_pubcomp(), mqtt_msg_publish(), mqtt_msg_pubrec(), mqtt_msg_pubrel(), mqtt_msg_subscribe(), and mqtt_msg_unsubscribe().

{
  connection->message.length = MQTT_MAX_FIXED_HEADER_SIZE;
  return MQTT_MAX_FIXED_HEADER_SIZE;
}

Here is the caller graph for this function:

mqtt_get_id()

uint16_t ICACHE_FLASH_ATTR mqtt_get_id	(	uint8_t *	buffer,
		uint16_t	length
	)

Definition at line 229 of file mqtt_msg.c.

References mqtt_get_qos(), mqtt_get_type(), MQTT_MSG_TYPE_PUBACK, MQTT_MSG_TYPE_PUBCOMP, MQTT_MSG_TYPE_PUBLISH, MQTT_MSG_TYPE_PUBREC, MQTT_MSG_TYPE_PUBREL, MQTT_MSG_TYPE_SUBACK, MQTT_MSG_TYPE_SUBSCRIBE, and MQTT_MSG_TYPE_UNSUBACK.

Referenced by mqtt_get_retain(), mqtt_send_keepalive(), MQTT_Task(), mqtt_tcpclient_connect_cb(), and mqtt_tcpclient_recv().

{
  if (length < 1)
    return 0;

  switch (mqtt_get_type(buffer))
  {
    case MQTT_MSG_TYPE_PUBLISH:
      {
        int i;
        int topiclen;

        for (i = 1; i < length; ++i)
        {
          if ((buffer[i] & 0x80) == 0)
          {
            ++i;
            break;
          }
        }

        if (i + 2 >= length)
          return 0;
        topiclen = buffer[i++] << 8;
        topiclen |= buffer[i++];

        if (i + topiclen >= length)
          return 0;
        i += topiclen;

        if (mqtt_get_qos(buffer) > 0)
        {
          if (i + 2 >= length)
            return 0;
          //i += 2;
        } else {
          return 0;
        }

        return (buffer[i] << 8) | buffer[i + 1];
      }
    case MQTT_MSG_TYPE_PUBACK:
    case MQTT_MSG_TYPE_PUBREC:
    case MQTT_MSG_TYPE_PUBREL:
    case MQTT_MSG_TYPE_PUBCOMP:
    case MQTT_MSG_TYPE_SUBACK:
    case MQTT_MSG_TYPE_UNSUBACK:
    case MQTT_MSG_TYPE_SUBSCRIBE:
      {
        // This requires the remaining length to be encoded in 1 byte,
        // which it should be.
        if (length >= 4 && (buffer[1] & 0x80) == 0)
          return (buffer[2] << 8) | buffer[3];
        else
          return 0;
      }

    default:
      return 0;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_get_publish_data()

const char* ICACHE_FLASH_ATTR mqtt_get_publish_data	(	uint8_t *	buffer,
		uint16_t *	length
	)

Definition at line 183 of file mqtt_msg.c.

References mqtt_get_qos(), and NULL.

Referenced by deliver_publish(), and mqtt_get_retain().

{
  int i;
  int totlen = 0;
  int topiclen;
  int blength = *length;
  *length = 0;

  for (i = 1; i < blength; ++i)
  {
    totlen += (buffer[i] & 0x7f) << (7 * (i - 1));
    if ((buffer[i] & 0x80) == 0)
    {
      ++i;
      break;
    }
  }
  totlen += i;

  if (i + 2 >= blength)
    return NULL;
  topiclen = buffer[i++] << 8;
  topiclen |= buffer[i++];

  if (i + topiclen >= blength)
    return NULL;

  i += topiclen;

  if (mqtt_get_qos(buffer) > 0)
  {
    if (i + 2 >= blength)
      return NULL;
    i += 2;
  }

  if (totlen < i)
    return NULL;

  if (totlen <= blength)
    *length = totlen - i;
  else
    *length = blength - i;
  return (const char*)(buffer + i);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_get_publish_topic()

const char* ICACHE_FLASH_ATTR mqtt_get_publish_topic	(	uint8_t *	buffer,
		uint16_t *	length
	)

Definition at line 154 of file mqtt_msg.c.

References NULL.

Referenced by deliver_publish(), and mqtt_get_retain().

{
  int i;
  int totlen = 0;
  int topiclen;

  for (i = 1; i < *length; ++i)
  {
    totlen += (buffer[i] & 0x7f) << (7 * (i - 1));
    if ((buffer[i] & 0x80) == 0)
    {
      ++i;
      break;
    }
  }
  totlen += i;

  if (i + 2 >= *length)
    return NULL;
  topiclen = buffer[i++] << 8;
  topiclen |= buffer[i++];

  if (i + topiclen > *length)
    return NULL;

  *length = topiclen;
  return (const char*)(buffer + i);
}

Here is the caller graph for this function:

mqtt_get_total_length()

int ICACHE_FLASH_ATTR mqtt_get_total_length	(	uint8_t *	buffer,
		uint16_t	length
	)

Definition at line 135 of file mqtt_msg.c.

Referenced by mqtt_get_retain(), and mqtt_tcpclient_recv().

{
  int i;
  int totlen = 0;

  for (i = 1; i < length; ++i)
  {
    totlen += (buffer[i] & 0x7f) << (7 * (i - 1));
    if ((buffer[i] & 0x80) == 0)
    {
      ++i;
      break;
    }
  }
  totlen += i;

  return totlen;
}

Here is the caller graph for this function:

mqtt_msg_connect()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_connect	(	mqtt_connection_t *	connection,
		mqtt_connect_info_t *	info
	)

Definition at line 291 of file mqtt_msg.c.

References append_string(), mqtt_connection::buffer, mqtt_connection::buffer_length, mqtt_connect_info::clean_session, mqtt_connect_info::client_id, fail_message(), fini_message(), init_message(), mqtt_connect_info::keepalive, mqtt_message::length, memcpy, mqtt_connection::message, MQTT_CONNECT_FLAG_CLEAN_SESSION, MQTT_CONNECT_FLAG_PASSWORD, MQTT_CONNECT_FLAG_USERNAME, MQTT_CONNECT_FLAG_WILL, MQTT_CONNECT_FLAG_WILL_RETAIN, MQTT_MSG_TYPE_CONNECT, NULL, mqtt_connect_info::password, strlen, mqtt_connect_info::username, mqtt_connect_info::will_message, mqtt_connect_info::will_qos, mqtt_connect_info::will_retain, and mqtt_connect_info::will_topic.

Referenced by mqtt_get_retain(), and mqtt_tcpclient_connect_cb().

{
  struct mqtt_connect_variable_header* variable_header;

  init_message(connection);

  if (connection->message.length + sizeof(*variable_header) > connection->buffer_length)
    return fail_message(connection);
  variable_header = (void*)(connection->buffer + connection->message.length);
  connection->message.length += sizeof(*variable_header);

  variable_header->lengthMsb = 0;
#if defined(PROTOCOL_NAMEv31)
  variable_header->lengthLsb = 6;
  memcpy(variable_header->magic, "MQIsdp", 6);
  variable_header->version = 3;
#elif defined(PROTOCOL_NAMEv311)
  variable_header->lengthLsb = 4;
  memcpy(variable_header->magic, "MQTT", 4);
  variable_header->version = 4;
#else
#error "Please define protocol name"
#endif

  variable_header->flags = 0;
  variable_header->keepaliveMsb = info->keepalive >> 8;
  variable_header->keepaliveLsb = info->keepalive & 0xff;

  if (info->clean_session)
    variable_header->flags |= MQTT_CONNECT_FLAG_CLEAN_SESSION;

  if (info->client_id == NULL)
  {
    /* Never allowed */
    return fail_message(connection);
  }
  else if (info->client_id[0] == '\0')
  {
#ifdef PROTOCOL_NAMEv311
    /* Allowed. Format 0 Length ID */
    append_string(connection, info->client_id, 2) ;
#else
    /* 0 Length not allowed */
    return fail_message(connection);
#endif
  }
  else
  {
    /* No 0 data and at least 1 long. Good to go. */
    if(append_string(connection, info->client_id, strlen(info->client_id)) < 0)
      return fail_message(connection);
  }

  if (info->will_topic != NULL && info->will_topic[0] != '\0')
  {
    if (append_string(connection, info->will_topic, strlen(info->will_topic)) < 0)
      return fail_message(connection);

    if (append_string(connection, info->will_message, strlen(info->will_message)) < 0)
      return fail_message(connection);

    variable_header->flags |= MQTT_CONNECT_FLAG_WILL;
    if (info->will_retain)
      variable_header->flags |= MQTT_CONNECT_FLAG_WILL_RETAIN;
    variable_header->flags |= (info->will_qos & 3) << 3;
  }

  if (info->username != NULL && info->username[0] != '\0')
  {
    if (append_string(connection, info->username, strlen(info->username)) < 0)
      return fail_message(connection);

    variable_header->flags |= MQTT_CONNECT_FLAG_USERNAME;
  }

  if (info->password != NULL && info->password[0] != '\0')
  {
    if (append_string(connection, info->password, strlen(info->password)) < 0)
      return fail_message(connection);

    variable_header->flags |= MQTT_CONNECT_FLAG_PASSWORD;
  }

  return fini_message(connection, MQTT_MSG_TYPE_CONNECT, 0, 0, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_disconnect()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_disconnect

(

mqtt_connection_t *

connection

)

Definition at line 483 of file mqtt_msg.c.

References fini_message(), init_message(), and MQTT_MSG_TYPE_DISCONNECT.

Referenced by mqtt_get_retain().

{
  init_message(connection);
  return fini_message(connection, MQTT_MSG_TYPE_DISCONNECT, 0, 0, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_init()

void ICACHE_FLASH_ATTR mqtt_msg_init	(	mqtt_connection_t *	connection,
		uint8_t *	buffer,
		uint16_t	buffer_length
	)

Definition at line 128 of file mqtt_msg.c.

References mqtt_connection::buffer, mqtt_connection::buffer_length, and memset.

Referenced by mqtt_get_retain(), MQTT_InitClient(), and mqtt_tcpclient_connect_cb().

{
  memset(connection, 0, sizeof(mqtt_connection_t));
  connection->buffer = buffer;
  connection->buffer_length = buffer_length;
}

Here is the caller graph for this function:

mqtt_msg_pingreq()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_pingreq

(

mqtt_connection_t *

connection

)

Definition at line 471 of file mqtt_msg.c.

References fini_message(), init_message(), and MQTT_MSG_TYPE_PINGREQ.

Referenced by mqtt_get_retain(), MQTT_Ping(), and mqtt_send_keepalive().

{
  init_message(connection);
  return fini_message(connection, MQTT_MSG_TYPE_PINGREQ, 0, 0, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_pingresp()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_pingresp

(

mqtt_connection_t *

connection

)

Definition at line 477 of file mqtt_msg.c.

References fini_message(), init_message(), and MQTT_MSG_TYPE_PINGRESP.

Referenced by mqtt_get_retain(), and mqtt_tcpclient_recv().

{
  init_message(connection);
  return fini_message(connection, MQTT_MSG_TYPE_PINGRESP, 0, 0, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_puback()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_puback	(	mqtt_connection_t *	connection,
		uint16_t	message_id
	)

Definition at line 403 of file mqtt_msg.c.

References append_message_id(), fail_message(), fini_message(), init_message(), and MQTT_MSG_TYPE_PUBACK.

Referenced by mqtt_get_retain(), and mqtt_tcpclient_recv().

{
  init_message(connection);
  if (append_message_id(connection, message_id) == 0)
    return fail_message(connection);
  return fini_message(connection, MQTT_MSG_TYPE_PUBACK, 0, 0, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_pubcomp()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_pubcomp	(	mqtt_connection_t *	connection,
		uint16_t	message_id
	)

Definition at line 427 of file mqtt_msg.c.

References append_message_id(), fail_message(), fini_message(), init_message(), and MQTT_MSG_TYPE_PUBCOMP.

Referenced by mqtt_get_retain(), and mqtt_tcpclient_recv().

{
  init_message(connection);
  if (append_message_id(connection, message_id) == 0)
    return fail_message(connection);
  return fini_message(connection, MQTT_MSG_TYPE_PUBCOMP, 0, 0, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_publish()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_publish	(	mqtt_connection_t *	connection,
		const char *	topic,
		const char *	data,
		int	data_length,
		int	qos,
		int	retain,
		uint16_t *	message_id
	)

Definition at line 377 of file mqtt_msg.c.

References append_message_id(), append_string(), mqtt_connection::buffer, mqtt_connection::buffer_length, fail_message(), fini_message(), init_message(), mqtt_message::length, memcpy, mqtt_connection::message, MQTT_MSG_TYPE_PUBLISH, NULL, and strlen.

Referenced by mqtt_get_retain(), and MQTT_Publish().

{
  init_message(connection);

  if (topic == NULL || topic[0] == '\0')
    return fail_message(connection);

  if (append_string(connection, topic, strlen(topic)) < 0)
    return fail_message(connection);

  if (qos > 0)
  {
    if ((*message_id = append_message_id(connection, 0)) == 0)
      return fail_message(connection);
  }
  else
    *message_id = 0;

  if (connection->message.length + data_length > connection->buffer_length)
    return fail_message(connection);
  memcpy(connection->buffer + connection->message.length, data, data_length);
  connection->message.length += data_length;

  return fini_message(connection, MQTT_MSG_TYPE_PUBLISH, 0, qos, retain);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_pubrec()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_pubrec	(	mqtt_connection_t *	connection,
		uint16_t	message_id
	)

Definition at line 411 of file mqtt_msg.c.

References append_message_id(), fail_message(), fini_message(), init_message(), and MQTT_MSG_TYPE_PUBREC.

Referenced by mqtt_get_retain(), and mqtt_tcpclient_recv().

{
  init_message(connection);
  if (append_message_id(connection, message_id) == 0)
    return fail_message(connection);
  return fini_message(connection, MQTT_MSG_TYPE_PUBREC, 0, 0, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_pubrel()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_pubrel	(	mqtt_connection_t *	connection,
		uint16_t	message_id
	)

Definition at line 419 of file mqtt_msg.c.

References append_message_id(), fail_message(), fini_message(), init_message(), and MQTT_MSG_TYPE_PUBREL.

Referenced by mqtt_get_retain(), and mqtt_tcpclient_recv().

{
  init_message(connection);
  if (append_message_id(connection, message_id) == 0)
    return fail_message(connection);
  return fini_message(connection, MQTT_MSG_TYPE_PUBREL, 0, 1, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_subscribe()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_subscribe	(	mqtt_connection_t *	connection,
		const char *	topic,
		int	qos,
		uint16_t *	message_id
	)

Definition at line 435 of file mqtt_msg.c.

References append_message_id(), append_string(), mqtt_connection::buffer, mqtt_connection::buffer_length, fail_message(), fini_message(), init_message(), mqtt_message::length, mqtt_connection::message, MQTT_MSG_TYPE_SUBSCRIBE, NULL, and strlen.

Referenced by mqtt_get_retain(), and MQTT_Subscribe().

{
  init_message(connection);

  if (topic == NULL || topic[0] == '\0')
    return fail_message(connection);

  if ((*message_id = append_message_id(connection, 0)) == 0)
    return fail_message(connection);

  if (append_string(connection, topic, strlen(topic)) < 0)
    return fail_message(connection);

  if (connection->message.length + 1 > connection->buffer_length)
    return fail_message(connection);
  connection->buffer[connection->message.length++] = qos;

  return fini_message(connection, MQTT_MSG_TYPE_SUBSCRIBE, 0, 1, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mqtt_msg_unsubscribe()

mqtt_message_t* ICACHE_FLASH_ATTR mqtt_msg_unsubscribe	(	mqtt_connection_t *	connection,
		const char *	topic,
		uint16_t *	message_id
	)

Definition at line 455 of file mqtt_msg.c.

References append_message_id(), append_string(), fail_message(), fini_message(), init_message(), MQTT_MSG_TYPE_UNSUBSCRIBE, NULL, and strlen.

Referenced by mqtt_get_retain(), and MQTT_UnSubscribe().

{
  init_message(connection);

  if (topic == NULL || topic[0] == '\0')
    return fail_message(connection);

  if ((*message_id = append_message_id(connection, 0)) == 0)
    return fail_message(connection);

  if (append_string(connection, topic, strlen(topic)) < 0)
    return fail_message(connection);

  return fini_message(connection, MQTT_MSG_TYPE_UNSUBSCRIBE, 0, 1, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function: