David Fletcher / mqtt_V1

TI's mqtt.

Dependencies:   client server

sl/sl_mqtt_client.cpp@1:673880ad39ad, 2015-06-06 (annotated)

Committer:
dflet
Date:
Sat Jun 06 13:37:53 2015 +0000
Revision:
1:673880ad39ad
Parent:
0:698866e331b2 
TI's mqtt

Who changed what in which revision?

UserRevisionLine numberNew contents of line
dflet 0:698866e331b2 1 /******************************************************************************
dflet 0:698866e331b2 2 *
dflet 0:698866e331b2 3 * Copyright (C) 2014 Texas Instruments Incorporated
dflet 0:698866e331b2 4 *
dflet 0:698866e331b2 5 * All rights reserved. Property of Texas Instruments Incorporated.
dflet 0:698866e331b2 6 * Restricted rights to use, duplicate or disclose this code are
dflet 0:698866e331b2 7 * granted through contract.
dflet 0:698866e331b2 8 *
dflet 0:698866e331b2 9 * The program may not be used without the written permission of
dflet 0:698866e331b2 10 * Texas Instruments Incorporated or against the terms and conditions
dflet 0:698866e331b2 11 * stipulated in the agreement under which this program has been supplied,
dflet 0:698866e331b2 12 * and under no circumstances can it be used with non-TI connectivity device.
dflet 0:698866e331b2 13 *
dflet 0:698866e331b2 14 ******************************************************************************/
dflet 0:698866e331b2 15
dflet 0:698866e331b2 16 #include "sl_mqtt_client.h"
dflet 0:698866e331b2 17 #include "cc31xx_sl_net.h"
dflet 0:698866e331b2 18 //#include "cc3100_nonos.h"
dflet 0:698866e331b2 19 #include "myBoardInit.h"
dflet 0:698866e331b2 20 #include "cli_uart.h"
dflet 0:698866e331b2 21 #include "osi.h"
dflet 0:698866e331b2 22
dflet 0:698866e331b2 23 using namespace mbed_cc3100;
dflet 0:698866e331b2 24
dflet 0:698866e331b2 25 #if (THIS_BOARD == MBED_BOARD_LPC1768)
dflet 0:698866e331b2 26 //cc3100 _cc3100module(p9, p10, p8, SPI(p11, p12, p13));//LPC1768 irq, nHib, cs, mosi, miso, sck
dflet 0:698866e331b2 27 cc3100 _cc3100module(p16, p17, p9, p10, p8, SPI(p5, p6, p7));//LPC1768 irq, nHib, cs, mosi, miso, sck
dflet 0:698866e331b2 28 #elif (THIS_BOARD == Seeed_Arch_Max)
dflet 0:698866e331b2 29 class cc3100 _cc3100module(PE_5, PE_4, PE_6, SPI(PB_5, PB_4, PB_3));
dflet 0:698866e331b2 30 #elif (THIS_BOARD == ST_MBED_NUCLEOF103)
dflet 0:698866e331b2 31 class cc3100 _cc3100module(PA_9, PC_7, PB_6, SPI(PA_7, PA_6, PA_5));//nucleoF103 irq, nHib, cs, mosi, miso, sck
dflet 0:698866e331b2 32 #elif (THIS_BOARD == ST_MBED_NUCLEOF411)
dflet 0:698866e331b2 33 class cc3100 _cc3100module(PA_9, PC_7, PB_6, SPI(PA_7, PA_6, PA_5));//nucleoF411 irq, nHib, cs, mosi, miso, sck
dflet 0:698866e331b2 34 #elif (THIS_BOARD == ST_MBED_NUCLEOF401)
dflet 0:698866e331b2 35 class cc3100 _cc3100module(PA_8, PA_9, PC_7, PB_6, SPI(PA_7, PA_6, PA_5));//nucleoF401 irq, nHib, cs, mosi, miso, sck
dflet 0:698866e331b2 36 #elif (THIS_BOARD == EA_MBED_LPC4088)
dflet 0:698866e331b2 37 class cc3100 _cc3100module(p14, p15, p9, p10, p8, SPI(p5, p6, p7));//LPC4088 irq, nHib, cs, mosi, miso, sck
dflet 0:698866e331b2 38 #elif (THIS_BOARD == LPCXpresso4337)
dflet 0:698866e331b2 39 class cc3100 _cc3100module(P2_2, P3_5, P1_2, SPI(P1_4, P1_3, PF_4));//LPCXpresso4337 irq, nHib, cs, mosi, miso, sck
dflet 0:698866e331b2 40 #endif
dflet 0:698866e331b2 41
dflet 0:698866e331b2 42 namespace mbed_mqtt {
dflet 0:698866e331b2 43
dflet 0:698866e331b2 44 #ifndef CFG_SL_CL_BUF_LEN
dflet 0:698866e331b2 45 #define BUF_LEN 1024 /*Buffer length*/
dflet 0:698866e331b2 46 #else
dflet 0:698866e331b2 47 #define BUF_LEN CFG_SL_CL_BUF_LEN
dflet 0:698866e331b2 48 #endif
dflet 0:698866e331b2 49
dflet 0:698866e331b2 50 #ifndef CFG_SL_CL_MAX_MQP
dflet 0:698866e331b2 51 #define MAX_MQP 2 /* # of buffers */
dflet 0:698866e331b2 52 #else
dflet 0:698866e331b2 53 #define MAX_MQP CFG_SL_CL_MAX_MQP
dflet 0:698866e331b2 54 #endif
dflet 0:698866e331b2 55
dflet 0:698866e331b2 56 #ifndef CFG_SL_CL_STACK
dflet 0:698866e331b2 57 #define OSI_STACK_SIZE 2048
dflet 0:698866e331b2 58 #else
dflet 0:698866e331b2 59 #define OSI_STACK_SIZE CFG_SL_CL_STACK
dflet 0:698866e331b2 60 #endif
dflet 0:698866e331b2 61 //*****************************************************************************
dflet 0:698866e331b2 62 // global variables used
dflet 0:698866e331b2 63 //*****************************************************************************
dflet 0:698866e331b2 64
dflet 0:698866e331b2 65
dflet 0:698866e331b2 66 struct sl_client_ctx {
dflet 0:698866e331b2 67 /* Client information details */
dflet 0:698866e331b2 68 char *client_id;
dflet 0:698866e331b2 69 char *usr_name;
dflet 0:698866e331b2 70 char *usr_pwd;
dflet 0:698866e331b2 71 SlMqttWill_t mqtt_will;
dflet 0:698866e331b2 72
dflet 0:698866e331b2 73 /* Client management variables */
dflet 0:698866e331b2 74 bool in_use;
dflet 0:698866e331b2 75 char awaited_ack;
dflet 0:698866e331b2 76 uint16_t conn_ack;
dflet 0:698866e331b2 77
dflet 0:698866e331b2 78 /*Sync Object used to ensure single inflight message -
dflet 0:698866e331b2 79 used in blocking mode to wait on ack*/
dflet 0:698866e331b2 80 _SlSyncObj_t ack_sync_obj;
dflet 0:698866e331b2 81 /* Suback QoS pointer to store passed by application */
dflet 0:698866e331b2 82 char *suback_qos;
dflet 0:698866e331b2 83
dflet 0:698866e331b2 84 /* Application information */
dflet 0:698866e331b2 85 void* app_hndl;
dflet 0:698866e331b2 86 SlMqttClientCbs_t app_cbs;
dflet 0:698866e331b2 87
dflet 0:698866e331b2 88 /* Library information */
dflet 0:698866e331b2 89 void *cli_hndl;
dflet 0:698866e331b2 90 bool blocking_send;
dflet 0:698866e331b2 91 };
dflet 0:698866e331b2 92
dflet 0:698866e331b2 93 #ifndef CFG_CL_MQTT_CTXS
dflet 0:698866e331b2 94 #define MAX_SIMULTANEOUS_SERVER_CONN 4
dflet 0:698866e331b2 95 #else
dflet 0:698866e331b2 96 #define MAX_SIMULTANEOUS_SERVER_CONN CFG_MQTT_CL_CTXS
dflet 0:698866e331b2 97 #endif
dflet 0:698866e331b2 98
dflet 0:698866e331b2 99
dflet 0:698866e331b2 100 static struct sl_client_ctx sl_cli_ctx[MAX_SIMULTANEOUS_SERVER_CONN];
dflet 0:698866e331b2 101
dflet 0:698866e331b2 102 /* Lock Object to be passed to the MQTT lib */
dflet 0:698866e331b2 103 _SlLockObj_t mqtt_lib_lockobj;
dflet 0:698866e331b2 104
dflet 0:698866e331b2 105 /* Creating a pool of MQTT coonstructs that can be used by the MQTT Lib
dflet 0:698866e331b2 106 mqp_vec =>pointer to a pool of the mqtt packet constructs
dflet 0:698866e331b2 107 buf_vec => the buffer area which is attached with each of mqp_vec*/
dflet 0:698866e331b2 108 DEFINE_MQP_BUF_VEC(MAX_MQP, mqp_vec, BUF_LEN, buf_vec);
dflet 0:698866e331b2 109
dflet 0:698866e331b2 110 /*Task Priority and Response Time*/
dflet 0:698866e331b2 111 uint32_t g_wait_secs;
dflet 0:698866e331b2 112
dflet 0:698866e331b2 113 bool g_multi_srvr_conn = false;
dflet 0:698866e331b2 114
dflet 0:698866e331b2 115 /* Receive task handle */
dflet 0:698866e331b2 116 OsiTaskHandle g_rx_task_hndl;
dflet 0:698866e331b2 117
dflet 0:698866e331b2 118 /* Synchronization object used between the Rx and App task */
dflet 0:698866e331b2 119 _SlSyncObj_t g_rx_tx_sync_obj;
dflet 0:698866e331b2 120
dflet 0:698866e331b2 121 #define RX_TX_SIGNAL_WAIT() _cc3100module._nonos.sl_SyncObjWait(&g_rx_tx_sync_obj, NON_OS_SYNC_OBJ_SIGNAL_VALUE, NON_OS_SYNC_OBJ_CLEAR_VALUE, SL_OS_WAIT_FOREVER)
dflet 0:698866e331b2 122 #define RX_TX_SIGNAL_POST() _cc3100module._nonos.sl_SyncObjSignal(&g_rx_tx_sync_obj, NON_OS_SYNC_OBJ_SIGNAL_VALUE)
dflet 0:698866e331b2 123
dflet 0:698866e331b2 124 /* MQTT Quality of Service */
dflet 0:698866e331b2 125 static const enum mqtt_qos qos[] ={
dflet 0:698866e331b2 126 MQTT_QOS0,
dflet 0:698866e331b2 127 MQTT_QOS1,
dflet 0:698866e331b2 128 MQTT_QOS2
dflet 0:698866e331b2 129 };
dflet 0:698866e331b2 130
dflet 0:698866e331b2 131 /* Network Services specific to cc3200*/
dflet 0:698866e331b2 132 struct device_net_services net={&comm_open,&tcp_send,&tcp_recv,&send_dest,&recv_from,&comm_close,
dflet 0:698866e331b2 133 &tcp_listen,&tcp_accept,&tcp_select,&rtc_secs};
dflet 0:698866e331b2 134
dflet 0:698866e331b2 135 /* Defining Retain Flag. Getting retain flag bit from fixed header*/
dflet 0:698866e331b2 136 #define MQP_PUB_RETAIN(mqp) ( ((mqp->fh_byte1 ) & 0x01)?true:false )
dflet 0:698866e331b2 137
dflet 0:698866e331b2 138 /*Defining Duplicate flag. Getting Duplicate flag bit from fixed header*/
dflet 0:698866e331b2 139 #define MQP_PUB_DUP(mqp) (((mqp->fh_byte1>>3) & 0x01)?true:false )
dflet 0:698866e331b2 140
dflet 0:698866e331b2 141 /*Defining QOS value. Getting QOS value from fixed header*/
dflet 0:698866e331b2 142 #define MQP_PUB_QOS(mqp) ((mqp->fh_byte1 >>1) & 0x03)
dflet 0:698866e331b2 143
dflet 0:698866e331b2 144 #define ACK_RX_SIGNAL_WAIT(ack_sync_obj) _cc3100module._nonos.sl_SyncObjWait(ack_sync_obj, NON_OS_SYNC_OBJ_SIGNAL_VALUE, NON_OS_SYNC_OBJ_CLEAR_VALUE, SL_OS_WAIT_FOREVER)
dflet 0:698866e331b2 145 #define ACK_RX_SIGNAL_POST(ack_sync_obj) _cc3100module._nonos.sl_SyncObjSignal(ack_sync_obj, NON_OS_SYNC_OBJ_SIGNAL_VALUE)
dflet 0:698866e331b2 146
dflet 0:698866e331b2 147 #define STR2UTF_CONV(utf_s, str) {utf_s.buffer = (char *)str; utf_s.length = strlen(str);}
dflet 0:698866e331b2 148
dflet 0:698866e331b2 149 /*Defining Event Messages*/
dflet 0:698866e331b2 150 #define MQTT_ACK "Ack Received from server"
dflet 0:698866e331b2 151 #define MQTT_ERROR "Connection Lost with broker"
dflet 0:698866e331b2 152
dflet 0:698866e331b2 153 //*****************************************************************************
dflet 0:698866e331b2 154 // process_notify_ack_cb
dflet 0:698866e331b2 155 //*****************************************************************************
dflet 0:698866e331b2 156 static void
dflet 0:698866e331b2 157 process_notify_ack_cb(void *app, uint8_t msg_type, uint16_t msg_id, uint8_t *buf, uint32_t len)
dflet 0:698866e331b2 158 {
dflet 0:698866e331b2 159
dflet 0:698866e331b2 160 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)app;
dflet 0:698866e331b2 161 int32_t loopcnt;
dflet 0:698866e331b2 162
dflet 0:698866e331b2 163 switch(msg_type) {
dflet 0:698866e331b2 164
dflet 0:698866e331b2 165 case MQTT_CONNACK:
dflet 0:698866e331b2 166 client_ctx->conn_ack = ((buf[0] << 8) | buf[1]);
dflet 0:698866e331b2 167 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 168 ACK_RX_SIGNAL_POST(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 169 break;
dflet 0:698866e331b2 170 case MQTT_SUBACK:
dflet 0:698866e331b2 171 if(true == client_ctx->blocking_send) {
dflet 0:698866e331b2 172 for(loopcnt = 0; loopcnt < len; loopcnt++) {
dflet 0:698866e331b2 173 client_ctx->suback_qos[loopcnt] = buf[loopcnt];
dflet 0:698866e331b2 174 }
dflet 0:698866e331b2 175
dflet 0:698866e331b2 176 if(client_ctx->awaited_ack == msg_type) {
dflet 0:698866e331b2 177 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 178 ACK_RX_SIGNAL_POST(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 179 }
dflet 0:698866e331b2 180 } else {
dflet 0:698866e331b2 181 client_ctx->app_cbs.sl_ExtLib_MqttEvent(
dflet 0:698866e331b2 182 client_ctx->app_hndl,
dflet 0:698866e331b2 183 SL_MQTT_CL_EVT_SUBACK, buf, len);
dflet 0:698866e331b2 184 }
dflet 0:698866e331b2 185 break;
dflet 0:698866e331b2 186 /* Error returns --- TBD */
dflet 0:698866e331b2 187 default:
dflet 0:698866e331b2 188 if(true == client_ctx->blocking_send) {
dflet 0:698866e331b2 189 if(client_ctx->awaited_ack == msg_type) {
dflet 0:698866e331b2 190 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 191 ACK_RX_SIGNAL_POST(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 192 }
dflet 0:698866e331b2 193 } else {
dflet 0:698866e331b2 194 client_ctx->app_cbs.sl_ExtLib_MqttEvent(
dflet 0:698866e331b2 195 client_ctx->app_hndl,
dflet 0:698866e331b2 196 msg_type, MQTT_ACK, strlen(MQTT_ACK));
dflet 0:698866e331b2 197 }
dflet 0:698866e331b2 198 break;
dflet 0:698866e331b2 199
dflet 0:698866e331b2 200 }
dflet 0:698866e331b2 201
dflet 0:698866e331b2 202 return ;
dflet 0:698866e331b2 203 }
dflet 0:698866e331b2 204
dflet 0:698866e331b2 205 //*****************************************************************************
dflet 0:698866e331b2 206 // process_publish_rx_cb
dflet 0:698866e331b2 207 //*****************************************************************************
dflet 0:698866e331b2 208 static bool
dflet 0:698866e331b2 209 process_publish_rx_cb(void *app, bool dup, enum mqtt_qos qos, bool retain,
dflet 0:698866e331b2 210 struct mqtt_packet *mqp)
dflet 0:698866e331b2 211 {
dflet 0:698866e331b2 212 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)app;
dflet 0:698866e331b2 213 /*If incoming message is a publish message from broker */
dflet 0:698866e331b2 214 /* Invokes the event handler with topic,topic length,payload and
dflet 0:698866e331b2 215 payload length values*/
dflet 0:698866e331b2 216 client_ctx->app_cbs.sl_ExtLib_MqttRecv(client_ctx->app_hndl,
dflet 0:698866e331b2 217 (char const*)MQP_PUB_TOP_BUF(mqp),
dflet 0:698866e331b2 218 MQP_PUB_TOP_LEN(mqp),MQP_PUB_PAY_BUF(mqp),
dflet 0:698866e331b2 219 MQP_PUB_PAY_LEN(mqp), dup,
dflet 0:698866e331b2 220 MQP_PUB_QOS(mqp), retain);
dflet 0:698866e331b2 221 return true;
dflet 0:698866e331b2 222 }
dflet 0:698866e331b2 223
dflet 0:698866e331b2 224 //*****************************************************************************
dflet 0:698866e331b2 225 // process_disconn_cb
dflet 0:698866e331b2 226 //*****************************************************************************
dflet 0:698866e331b2 227 static void process_disconn_cb(void *app, int32_t cause)
dflet 0:698866e331b2 228 {
dflet 0:698866e331b2 229 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)app;
dflet 0:698866e331b2 230
dflet 0:698866e331b2 231 if(client_ctx->awaited_ack != 0) {
dflet 0:698866e331b2 232 client_ctx->awaited_ack = MQTT_DISCONNECT;
dflet 0:698866e331b2 233 ACK_RX_SIGNAL_POST(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 234 } else {
dflet 0:698866e331b2 235 if(false == client_ctx->blocking_send) {
dflet 0:698866e331b2 236 /* Invoke the disconnect callback */
dflet 0:698866e331b2 237 client_ctx->app_cbs.sl_ExtLib_MqttDisconn(
dflet 0:698866e331b2 238 client_ctx->app_hndl);
dflet 0:698866e331b2 239 }
dflet 0:698866e331b2 240 }
dflet 0:698866e331b2 241 return;
dflet 0:698866e331b2 242 }
dflet 0:698866e331b2 243
dflet 0:698866e331b2 244
dflet 0:698866e331b2 245 //*****************************************************************************
dflet 0:698866e331b2 246 // Receive Task. Invokes in the context of a task
dflet 0:698866e331b2 247 //*****************************************************************************
dflet 0:698866e331b2 248 void
dflet 0:698866e331b2 249 VMqttRecvTask(void *pArgs)
dflet 0:698866e331b2 250 {
dflet 0:698866e331b2 251
dflet 0:698866e331b2 252 int32_t retval;
dflet 0:698866e331b2 253 do {
dflet 0:698866e331b2 254 if(false == g_multi_srvr_conn) {
dflet 0:698866e331b2 255 /* wait on broker connection */
dflet 0:698866e331b2 256 RX_TX_SIGNAL_WAIT();
dflet 0:698866e331b2 257 while(1) {
dflet 0:698866e331b2 258 /* Forcing to use the index 0 always - caution */
dflet 0:698866e331b2 259 retval = mqtt_client_ctx_run(
dflet 0:698866e331b2 260 sl_cli_ctx[0].cli_hndl,
dflet 0:698866e331b2 261 g_wait_secs);
dflet 0:698866e331b2 262 if((retval < 0) &&
dflet 0:698866e331b2 263 (retval != MQP_ERR_TIMEOUT)) {
dflet 0:698866e331b2 264 break;
dflet 0:698866e331b2 265 }
dflet 0:698866e331b2 266 }
dflet 0:698866e331b2 267 } else {
dflet 0:698866e331b2 268 mqtt_client_run(g_wait_secs);
dflet 0:698866e331b2 269 }
dflet 0:698866e331b2 270 }while(1);
dflet 0:698866e331b2 271 }
dflet 0:698866e331b2 272
dflet 0:698866e331b2 273 static struct sl_client_ctx *get_available_clictx_mem()
dflet 0:698866e331b2 274 {
dflet 0:698866e331b2 275 int32_t loopcnt, max_store;
dflet 0:698866e331b2 276
dflet 0:698866e331b2 277 if(false == g_multi_srvr_conn) {
dflet 0:698866e331b2 278 max_store = 1;
dflet 0:698866e331b2 279 } else {
dflet 0:698866e331b2 280 max_store = MAX_SIMULTANEOUS_SERVER_CONN;
dflet 0:698866e331b2 281 }
dflet 0:698866e331b2 282
dflet 0:698866e331b2 283 for(loopcnt = 0; loopcnt < max_store; loopcnt++) {
dflet 0:698866e331b2 284 if(false == sl_cli_ctx[loopcnt].in_use) {
dflet 0:698866e331b2 285 sl_cli_ctx[loopcnt].in_use = true;
dflet 0:698866e331b2 286 return(&(sl_cli_ctx[loopcnt]));
dflet 0:698866e331b2 287 }
dflet 0:698866e331b2 288 }
dflet 0:698866e331b2 289
dflet 0:698866e331b2 290 return NULL;
dflet 0:698866e331b2 291 }
dflet 0:698866e331b2 292
dflet 0:698866e331b2 293 //*****************************************************************************
dflet 0:698866e331b2 294 // sl_ExtLib_MqttClientCtxCreate
dflet 0:698866e331b2 295 //*****************************************************************************
dflet 0:698866e331b2 296 void *sl_ExtLib_MqttClientCtxCreate(const SlMqttClientCtxCfg_t *ctx_cfg,
dflet 0:698866e331b2 297 const SlMqttClientCbs_t *msg_cbs,
dflet 0:698866e331b2 298 void *app_hndl)
dflet 0:698866e331b2 299 {
dflet 0:698866e331b2 300
dflet 0:698866e331b2 301 struct sl_client_ctx *client_ctx_ptr;
dflet 0:698866e331b2 302 struct mqtt_client_ctx_cfg lib_ctx_cfg;
dflet 0:698866e331b2 303 struct mqtt_client_ctx_cbs lib_cli_cbs;
dflet 0:698866e331b2 304 struct secure_conn lib_nw_security;
dflet 0:698866e331b2 305 int32_t retval;
dflet 0:698866e331b2 306
dflet 0:698866e331b2 307 /* Get a client context storage area */
dflet 0:698866e331b2 308 client_ctx_ptr = get_available_clictx_mem();
dflet 0:698866e331b2 309 if(client_ctx_ptr == NULL) {
dflet 0:698866e331b2 310 return NULL;
dflet 0:698866e331b2 311 }
dflet 0:698866e331b2 312
dflet 0:698866e331b2 313 /* Create the sync object to signal on arrival of ACK packet */
dflet 0:698866e331b2 314 _cc3100module._nonos.sl_SyncObjCreate(&client_ctx_ptr->ack_sync_obj, "AckSyncObject");
dflet 0:698866e331b2 315 _cc3100module._nonos.sl_SyncObjWait(&client_ctx_ptr->ack_sync_obj, NON_OS_SYNC_OBJ_SIGNAL_VALUE, NON_OS_SYNC_OBJ_CLEAR_VALUE, SL_OS_NO_WAIT);
dflet 0:698866e331b2 316
dflet 0:698866e331b2 317 /* Store the application handle */
dflet 0:698866e331b2 318 client_ctx_ptr->app_hndl = app_hndl;
dflet 0:698866e331b2 319 /* Initialize the ACK awaited */
dflet 0:698866e331b2 320 client_ctx_ptr->awaited_ack = 0;
dflet 0:698866e331b2 321
dflet 0:698866e331b2 322 /* Store the application callbacks, to be invoked later */
dflet 0:698866e331b2 323 client_ctx_ptr->app_cbs.sl_ExtLib_MqttRecv = \
dflet 0:698866e331b2 324 msg_cbs->sl_ExtLib_MqttRecv;
dflet 0:698866e331b2 325 client_ctx_ptr->app_cbs.sl_ExtLib_MqttEvent = \
dflet 0:698866e331b2 326 msg_cbs->sl_ExtLib_MqttEvent;
dflet 0:698866e331b2 327 client_ctx_ptr->app_cbs.sl_ExtLib_MqttDisconn = \
dflet 0:698866e331b2 328 msg_cbs->sl_ExtLib_MqttDisconn;
dflet 0:698866e331b2 329
dflet 0:698866e331b2 330 /* Initialize the client lib */
dflet 0:698866e331b2 331 lib_ctx_cfg.config_opts = ctx_cfg->mqtt_mode31;
dflet 0:698866e331b2 332
dflet 0:698866e331b2 333 if(true == g_multi_srvr_conn) {
dflet 0:698866e331b2 334 lib_ctx_cfg.config_opts |=
dflet 0:698866e331b2 335 (MQTT_CFG_APP_HAS_RTSK | MQTT_CFG_MK_GROUP_CTX);
dflet 0:698866e331b2 336 } else {
dflet 0:698866e331b2 337 lib_ctx_cfg.config_opts |= MQTT_CFG_APP_HAS_RTSK;
dflet 0:698866e331b2 338 }
dflet 0:698866e331b2 339
dflet 0:698866e331b2 340 /* get the network connection options */
dflet 0:698866e331b2 341 client_ctx_ptr->blocking_send = ctx_cfg->blocking_send;
dflet 0:698866e331b2 342 lib_ctx_cfg.nwconn_opts = ctx_cfg->server_info.netconn_flags;
dflet 0:698866e331b2 343 lib_ctx_cfg.nwconn_opts |= DEV_NETCONN_OPT_TCP;
dflet 0:698866e331b2 344 lib_ctx_cfg.server_addr = (char*)ctx_cfg->server_info.server_addr;
dflet 0:698866e331b2 345 lib_ctx_cfg.port_number = ctx_cfg->server_info.port_number;
dflet 0:698866e331b2 346 /*initialize secure socket parameters */
dflet 0:698866e331b2 347 if(ctx_cfg->server_info.netconn_flags & SL_MQTT_NETCONN_SEC) {
dflet 0:698866e331b2 348 lib_ctx_cfg.nw_security = &lib_nw_security;
dflet 0:698866e331b2 349 /* initialize secure socket parameters */
dflet 0:698866e331b2 350 lib_ctx_cfg.nw_security->cipher =
dflet 0:698866e331b2 351 (void*)&(ctx_cfg->server_info.cipher);
dflet 0:698866e331b2 352 lib_ctx_cfg.nw_security->method =
dflet 0:698866e331b2 353 (void*)&(ctx_cfg->server_info.method);
dflet 0:698866e331b2 354 lib_ctx_cfg.nw_security->n_file =
dflet 0:698866e331b2 355 ctx_cfg->server_info.n_files;
dflet 0:698866e331b2 356 lib_ctx_cfg.nw_security->files =
dflet 0:698866e331b2 357 (char**)ctx_cfg->server_info.secure_files;
dflet 0:698866e331b2 358 }
dflet 0:698866e331b2 359 else {
dflet 0:698866e331b2 360 lib_ctx_cfg.nw_security=NULL;
dflet 0:698866e331b2 361 }
dflet 0:698866e331b2 362
dflet 0:698866e331b2 363 lib_cli_cbs.publish_rx = process_publish_rx_cb;
dflet 0:698866e331b2 364 lib_cli_cbs.ack_notify = process_notify_ack_cb;
dflet 0:698866e331b2 365 lib_cli_cbs.disconn_cb = process_disconn_cb;
dflet 0:698866e331b2 366
dflet 0:698866e331b2 367 retval = mqtt_client_ctx_create(&lib_ctx_cfg,
dflet 0:698866e331b2 368 &lib_cli_cbs, client_ctx_ptr,
dflet 0:698866e331b2 369 &client_ctx_ptr->cli_hndl);
dflet 0:698866e331b2 370
dflet 0:698866e331b2 371 if(retval < 0) {
dflet 0:698866e331b2 372 Uart_Write((uint8_t*)"mqtt_client_ctx_create failed\r\n");
dflet 0:698866e331b2 373 client_ctx_ptr->in_use = false;
dflet 0:698866e331b2 374 return NULL;
dflet 0:698866e331b2 375 }
dflet 0:698866e331b2 376
dflet 0:698866e331b2 377 return (void*)client_ctx_ptr;
dflet 0:698866e331b2 378 }
dflet 0:698866e331b2 379
dflet 0:698866e331b2 380 //*****************************************************************************
dflet 0:698866e331b2 381 // sl_ExtLib_MqttClientCtxDelete
dflet 0:698866e331b2 382 //*****************************************************************************
dflet 0:698866e331b2 383 int32_t sl_ExtLib_MqttClientCtxDelete(void *cli_ctx)
dflet 0:698866e331b2 384 {
dflet 0:698866e331b2 385 struct sl_client_ctx *client_ctx=(struct sl_client_ctx *)cli_ctx;
dflet 0:698866e331b2 386 int32_t retval;
dflet 0:698866e331b2 387
dflet 0:698866e331b2 388 retval = mqtt_client_ctx_delete(client_ctx->cli_hndl);
dflet 0:698866e331b2 389 if(retval >= 0) {
dflet 0:698866e331b2 390 /* Check for more paramaters --- TBD */
dflet 0:698866e331b2 391 _cc3100module._nonos.sl_SyncObjDelete(&client_ctx->ack_sync_obj, 0);
dflet 0:698866e331b2 392 /* Free up the context */
dflet 0:698866e331b2 393 memset(client_ctx, 0, sizeof(struct sl_client_ctx));
dflet 0:698866e331b2 394 }
dflet 0:698866e331b2 395
dflet 0:698866e331b2 396 return (retval < 0)? -1: 0;
dflet 0:698866e331b2 397 }
dflet 0:698866e331b2 398
dflet 0:698866e331b2 399 void
dflet 0:698866e331b2 400 mutex_lockup(void *mqtt_lib_lock)
dflet 0:698866e331b2 401 {
dflet 0:698866e331b2 402 _cc3100module._nonos.sl_LockObjLock((_SlLockObj_t*)mqtt_lib_lock, SL_OS_WAIT_FOREVER, NON_OS_LOCK_OBJ_LOCK_VALUE, SL_OS_WAIT_FOREVER);
dflet 0:698866e331b2 403 }
dflet 0:698866e331b2 404
dflet 0:698866e331b2 405 void
dflet 0:698866e331b2 406 mutex_unlock(void *mqtt_lib_lock)
dflet 0:698866e331b2 407 {
dflet 0:698866e331b2 408 _cc3100module._nonos.sl_LockObjUnlock((_SlLockObj_t*)mqtt_lib_lock, NON_OS_LOCK_OBJ_UNLOCK_VALUE);
dflet 0:698866e331b2 409 }
dflet 0:698866e331b2 410
dflet 0:698866e331b2 411 //*****************************************************************************
dflet 0:698866e331b2 412 // sl_ExtLib_MqttClientInit
dflet 0:698866e331b2 413 //*****************************************************************************
dflet 0:698866e331b2 414 int32_t sl_ExtLib_MqttClientInit(const SlMqttClientLibCfg_t *cfg)
dflet 0:698866e331b2 415 {
dflet 0:698866e331b2 416
dflet 0:698866e331b2 417 struct mqtt_client_lib_cfg lib_cfg;
dflet 0:698866e331b2 418 /* Initialize the control variables */
dflet 0:698866e331b2 419 memset(sl_cli_ctx, 0, sizeof(sl_cli_ctx));
dflet 0:698866e331b2 420
dflet 0:698866e331b2 421 /* Setup the MQTT client lib configurations */
dflet 0:698866e331b2 422 lib_cfg.loopback_port = cfg->loopback_port;
dflet 0:698866e331b2 423 /* Initializing the sync object */
dflet 0:698866e331b2 424 g_rx_tx_sync_obj = 0;
dflet 0:698866e331b2 425
dflet 0:698866e331b2 426 if(cfg->loopback_port) {
dflet 0:698866e331b2 427 g_multi_srvr_conn = true;
dflet 0:698866e331b2 428 lib_cfg.grp_uses_cbfn = true; /* Does use the group callback func */
dflet 0:698866e331b2 429 } else {
dflet 0:698866e331b2 430 g_multi_srvr_conn = false;
dflet 0:698866e331b2 431 lib_cfg.grp_uses_cbfn = false; /* Doesnt use the group callback func */
dflet 0:698866e331b2 432 /* Create the sync object between Rx and App tasks */
dflet 0:698866e331b2 433 _cc3100module._nonos.sl_SyncObjCreate(&g_rx_tx_sync_obj, "RxTxSyncObject");
dflet 0:698866e331b2 434 _cc3100module._nonos.sl_SyncObjWait(&g_rx_tx_sync_obj, NON_OS_SYNC_OBJ_SIGNAL_VALUE, NON_OS_SYNC_OBJ_CLEAR_VALUE, SL_OS_NO_WAIT);
dflet 0:698866e331b2 435 }
dflet 0:698866e331b2 436
dflet 0:698866e331b2 437 g_wait_secs = cfg->resp_time;
dflet 0:698866e331b2 438 /* Setup the mutex operations */
dflet 0:698866e331b2 439 _cc3100module._nonos.sl_LockObjCreate(&mqtt_lib_lockobj,"MQTT Lock");
dflet 0:698866e331b2 440 lib_cfg.mutex = (void *)&mqtt_lib_lockobj;
dflet 0:698866e331b2 441 lib_cfg.mutex_lockin = mutex_lockup;
dflet 0:698866e331b2 442 lib_cfg.mutex_unlock = mutex_unlock;
dflet 0:698866e331b2 443 /* hooking DBG print function */
dflet 0:698866e331b2 444 lib_cfg.debug_printf = cfg->dbg_print;
dflet 0:698866e331b2 445 /* Initialize client library */
dflet 0:698866e331b2 446 if(mqtt_client_lib_init(&lib_cfg) < 0) {
dflet 0:698866e331b2 447 Uart_Write((uint8_t*)"mqtt_client_lib_init failed\r\n");
dflet 0:698866e331b2 448 return -1;
dflet 0:698866e331b2 449 }
dflet 0:698866e331b2 450
dflet 0:698866e331b2 451 /* provide MQTT Lib information to create a pool of MQTT constructs. */
dflet 0:698866e331b2 452 mqtt_client_buffers_register(MAX_MQP,mqp_vec,BUF_LEN,&buf_vec[0][0]);
dflet 0:698866e331b2 453 /* Register network services speicific to CC3200 */
dflet 0:698866e331b2 454 mqtt_client_net_svc_register(&net);
dflet 0:698866e331b2 455 /* start the receive task */
dflet 0:698866e331b2 456 osi_TaskCreate( VMqttRecvTask,
dflet 0:698866e331b2 457 (const signed char *) "MQTTRecv",
dflet 0:698866e331b2 458 OSI_STACK_SIZE,
dflet 0:698866e331b2 459 NULL,
dflet 0:698866e331b2 460 cfg->rx_tsk_priority, &g_rx_task_hndl );
dflet 0:698866e331b2 461
dflet 0:698866e331b2 462 return 0;
dflet 0:698866e331b2 463 }
dflet 0:698866e331b2 464
dflet 0:698866e331b2 465 //*****************************************************************************
dflet 0:698866e331b2 466 // sl_ExtLib_MqttClientExit
dflet 0:698866e331b2 467 //*****************************************************************************
dflet 0:698866e331b2 468 int32_t
dflet 0:698866e331b2 469 sl_ExtLib_MqttClientExit()
dflet 0:698866e331b2 470 {
dflet 0:698866e331b2 471 int32_t retval;
dflet 0:698866e331b2 472
dflet 0:698866e331b2 473 /* Deinitialize the MQTT client lib */
dflet 0:698866e331b2 474 retval = mqtt_client_lib_exit();
dflet 0:698866e331b2 475 if(retval >= 0) {
dflet 0:698866e331b2 476 if(mqtt_lib_lockobj != NULL)
dflet 0:698866e331b2 477 {
dflet 0:698866e331b2 478 /* Delete the MQTT lib lock object */
dflet 0:698866e331b2 479 _cc3100module._nonos.sl_LockObjDelete(&mqtt_lib_lockobj, 0);
dflet 0:698866e331b2 480 }
dflet 0:698866e331b2 481 if(g_rx_task_hndl != NULL)
dflet 0:698866e331b2 482 {
dflet 0:698866e331b2 483 /* Delete the Rx Task */
dflet 0:698866e331b2 484 osi_TaskDelete(&g_rx_task_hndl);
dflet 0:698866e331b2 485 }
dflet 0:698866e331b2 486
dflet 0:698866e331b2 487 if(g_rx_tx_sync_obj != NULL)
dflet 0:698866e331b2 488 {
dflet 0:698866e331b2 489 /* Delete the Rx-Tx task sync object */
dflet 0:698866e331b2 490 _cc3100module._nonos.sl_SyncObjDelete(&g_rx_tx_sync_obj, 0);
dflet 0:698866e331b2 491 }
dflet 0:698866e331b2 492
dflet 0:698866e331b2 493 g_rx_task_hndl = NULL;
dflet 0:698866e331b2 494 g_rx_tx_sync_obj = NULL;
dflet 0:698866e331b2 495 mqtt_lib_lockobj = NULL;
dflet 0:698866e331b2 496 }
dflet 0:698866e331b2 497
dflet 0:698866e331b2 498 return (retval < 0)? -1: 0;
dflet 0:698866e331b2 499 }
dflet 0:698866e331b2 500
dflet 0:698866e331b2 501 //*****************************************************************************
dflet 0:698866e331b2 502 // sl_ExtLib_MqttClientSet
dflet 0:698866e331b2 503 //*****************************************************************************
dflet 0:698866e331b2 504 int32_t
dflet 0:698866e331b2 505 sl_ExtLib_MqttClientSet(void *app, int32_t param, const void *value, uint32_t len)
dflet 0:698866e331b2 506 {
dflet 0:698866e331b2 507
dflet 0:698866e331b2 508 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)app;
dflet 0:698866e331b2 509 switch(param)
dflet 0:698866e331b2 510 {
dflet 0:698866e331b2 511 case SL_MQTT_PARAM_CLIENT_ID:
dflet 0:698866e331b2 512 /* Save the reference to the Client ID */
dflet 0:698866e331b2 513 client_ctx->client_id =(char*)value;
dflet 0:698866e331b2 514 break;
dflet 0:698866e331b2 515
dflet 0:698866e331b2 516 case SL_MQTT_PARAM_USER_NAME:
dflet 0:698866e331b2 517 /* Save the reference to the Username */
dflet 0:698866e331b2 518 client_ctx->usr_name =(char*)value;
dflet 0:698866e331b2 519 break;
dflet 0:698866e331b2 520
dflet 0:698866e331b2 521 case SL_MQTT_PARAM_PASS_WORD:
dflet 0:698866e331b2 522 /* Save the reference to the password */
dflet 0:698866e331b2 523 client_ctx->usr_pwd =(char*)value;
dflet 0:698866e331b2 524 break;
dflet 0:698866e331b2 525
dflet 0:698866e331b2 526 case SL_MQTT_PARAM_WILL_PARAM:
dflet 0:698866e331b2 527 /* Save the reference to will parameters*/
dflet 0:698866e331b2 528 client_ctx->mqtt_will = *((SlMqttWill_t*)value);
dflet 0:698866e331b2 529 break;
dflet 0:698866e331b2 530 default:
dflet 0:698866e331b2 531 break;
dflet 0:698866e331b2 532 }
dflet 0:698866e331b2 533
dflet 0:698866e331b2 534 return 0;
dflet 0:698866e331b2 535
dflet 0:698866e331b2 536 }
dflet 0:698866e331b2 537
dflet 0:698866e331b2 538 //*****************************************************************************
dflet 0:698866e331b2 539 // sl_ExtLib_MqttClientConnect
dflet 0:698866e331b2 540 //*****************************************************************************
dflet 0:698866e331b2 541 int32_t
dflet 0:698866e331b2 542 sl_ExtLib_MqttClientConnect(void *cli_ctx, bool clean, uint16_t keep_alive_time)
dflet 0:698866e331b2 543 {
dflet 0:698866e331b2 544
dflet 0:698866e331b2 545
dflet 0:698866e331b2 546 int32_t ret = -1;
dflet 0:698866e331b2 547 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)cli_ctx;
dflet 0:698866e331b2 548
dflet 0:698866e331b2 549 /*utf8 strings into which client info will be stored*/
dflet 0:698866e331b2 550 struct utf8_string client_id, username, usr_pwd, will_topic, will_msg;
dflet 0:698866e331b2 551 struct utf8_string *usrname = NULL, *usrpasswd = NULL, *clientid=NULL;
dflet 0:698866e331b2 552
dflet 0:698866e331b2 553 /* Provide Client ID,user name and password into MQTT Library */
dflet 0:698866e331b2 554 if(client_ctx->client_id != NULL) {
dflet 0:698866e331b2 555 STR2UTF_CONV(client_id, client_ctx->client_id);
dflet 0:698866e331b2 556 clientid = &client_id;
dflet 0:698866e331b2 557 }
dflet 0:698866e331b2 558
dflet 0:698866e331b2 559 if(client_ctx->usr_name != NULL) {
dflet 0:698866e331b2 560 STR2UTF_CONV(username, client_ctx->usr_name);
dflet 0:698866e331b2 561 usrname = &username;
dflet 0:698866e331b2 562 }
dflet 0:698866e331b2 563 if(client_ctx->usr_pwd != NULL) {
dflet 0:698866e331b2 564 STR2UTF_CONV(usr_pwd, client_ctx->usr_pwd);
dflet 0:698866e331b2 565 usrpasswd = &usr_pwd;
dflet 0:698866e331b2 566 }
dflet 0:698866e331b2 567 ret = mqtt_client_ctx_info_register(client_ctx->cli_hndl,
dflet 0:698866e331b2 568 clientid, usrname, usrpasswd);
dflet 0:698866e331b2 569 if(ret < 0) {
dflet 0:698866e331b2 570 goto mqtt_connect_exit1;
dflet 0:698866e331b2 571 }
dflet 0:698866e331b2 572
dflet 0:698866e331b2 573 /* Register a will message, if specified, into MQTT Library */
dflet 0:698866e331b2 574 if(NULL != client_ctx->mqtt_will.will_topic ) {
dflet 0:698866e331b2 575 STR2UTF_CONV(will_topic, client_ctx->mqtt_will.will_topic);
dflet 0:698866e331b2 576 STR2UTF_CONV(will_msg, client_ctx->mqtt_will.will_msg);
dflet 0:698866e331b2 577 ret = mqtt_client_ctx_will_register(client_ctx->cli_hndl,
dflet 0:698866e331b2 578 &will_topic, &will_msg,
dflet 0:698866e331b2 579 qos[client_ctx->mqtt_will.will_qos],
dflet 0:698866e331b2 580 client_ctx->mqtt_will.retain);
dflet 0:698866e331b2 581 if(ret < 0) {
dflet 0:698866e331b2 582 Uart_Write((uint8_t*)"mqtt_client_ctx_will_register fail\r\n");
dflet 0:698866e331b2 583 goto mqtt_connect_exit1;
dflet 0:698866e331b2 584 }
dflet 0:698866e331b2 585 }
dflet 0:698866e331b2 586
dflet 0:698866e331b2 587 client_ctx->awaited_ack = MQTT_CONNACK;
dflet 0:698866e331b2 588 client_ctx->conn_ack = 0;
dflet 0:698866e331b2 589
dflet 0:698866e331b2 590 /* Connect to the server */
dflet 0:698866e331b2 591 ret = mqtt_connect_msg_send(client_ctx->cli_hndl, clean, keep_alive_time);
dflet 0:698866e331b2 592 /*Network or Socket Error happens*/
dflet 0:698866e331b2 593 if(ret < 0) {
dflet 0:698866e331b2 594 Uart_Write((uint8_t*)"mqtt_connect_msg_send failed \r\n");
dflet 0:698866e331b2 595 goto mqtt_connect_exit1;
dflet 0:698866e331b2 596 }
dflet 0:698866e331b2 597
dflet 0:698866e331b2 598 if(false == g_multi_srvr_conn) {
dflet 0:698866e331b2 599 /* Unblock the receive task here */
dflet 0:698866e331b2 600 RX_TX_SIGNAL_POST();
dflet 0:698866e331b2 601 }
dflet 0:698866e331b2 602
dflet 0:698866e331b2 603 /* Wait for a CONNACK here */
dflet 0:698866e331b2 604 ACK_RX_SIGNAL_WAIT(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 605
dflet 0:698866e331b2 606 if(MQTT_DISCONNECT == client_ctx->awaited_ack) {
dflet 0:698866e331b2 607 Uart_Write((uint8_t*)"sl_ExtLib_MqttClientConnect fail\r\n");
dflet 0:698866e331b2 608 ret = -1;
dflet 0:698866e331b2 609 } else {
dflet 0:698866e331b2 610 ret = (int32_t)client_ctx->conn_ack;
dflet 0:698866e331b2 611 }
dflet 0:698866e331b2 612
dflet 0:698866e331b2 613 mqtt_connect_exit1:
dflet 0:698866e331b2 614
dflet 0:698866e331b2 615 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 616 client_ctx->conn_ack = 0;
dflet 0:698866e331b2 617 return (ret < 0)? -1: ret;
dflet 0:698866e331b2 618 }
dflet 0:698866e331b2 619
dflet 0:698866e331b2 620 //*****************************************************************************
dflet 0:698866e331b2 621 // sl_ExtLib_MqttClientDisconnect
dflet 0:698866e331b2 622 //*****************************************************************************
dflet 0:698866e331b2 623 int32_t
dflet 0:698866e331b2 624 sl_ExtLib_MqttClientDisconnect(void *cli_ctx)
dflet 0:698866e331b2 625 {
dflet 0:698866e331b2 626 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)cli_ctx;
dflet 0:698866e331b2 627 int32_t retval;
dflet 0:698866e331b2 628
dflet 0:698866e331b2 629 if(!(mqtt_client_is_connected(client_ctx->cli_hndl)))
dflet 0:698866e331b2 630 return -1;
dflet 0:698866e331b2 631
dflet 0:698866e331b2 632 client_ctx->awaited_ack = MQTT_DISCONNECT;
dflet 0:698866e331b2 633
dflet 0:698866e331b2 634 /* send the disconnect command. */
dflet 0:698866e331b2 635 retval = mqtt_disconn_send(client_ctx->cli_hndl);
dflet 0:698866e331b2 636
dflet 0:698866e331b2 637 if(retval >= 0) {
dflet 0:698866e331b2 638 /* wait on Rx task to acknowledge */
dflet 0:698866e331b2 639 ACK_RX_SIGNAL_WAIT(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 640 }
dflet 0:698866e331b2 641 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 642
dflet 0:698866e331b2 643 return (retval < 0)? -1: 0;
dflet 0:698866e331b2 644 }
dflet 0:698866e331b2 645
dflet 0:698866e331b2 646
dflet 0:698866e331b2 647 //*****************************************************************************
dflet 0:698866e331b2 648 // sl_ExtLib_MqttClientSub
dflet 0:698866e331b2 649 //*****************************************************************************
dflet 0:698866e331b2 650 int32_t
dflet 0:698866e331b2 651 sl_ExtLib_MqttClientSub(void *cli_ctx, char* const *topics,
dflet 0:698866e331b2 652 uint8_t *qos_level, int32_t count)
dflet 0:698866e331b2 653 {
dflet 0:698866e331b2 654 #define MAX_SIMULTANEOUS_SUB_TOPICS 4
dflet 0:698866e331b2 655
dflet 0:698866e331b2 656 int32_t ret = -1, i;
dflet 0:698866e331b2 657
dflet 0:698866e331b2 658 struct utf8_strqos qos_topics[MAX_SIMULTANEOUS_SUB_TOPICS];
dflet 0:698866e331b2 659 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)cli_ctx;
dflet 0:698866e331b2 660
dflet 0:698866e331b2 661 if(!(mqtt_client_is_connected(client_ctx->cli_hndl)) || (count > MAX_SIMULTANEOUS_SUB_TOPICS)) {
dflet 0:698866e331b2 662 goto mqtt_sub_exit1; /* client not connected*/
dflet 0:698866e331b2 663 }
dflet 0:698866e331b2 664
dflet 0:698866e331b2 665 for(i = 0; i < count; i++) {
dflet 0:698866e331b2 666 qos_topics[i].buffer = topics[i];
dflet 0:698866e331b2 667 qos_topics[i].qosreq = qos[qos_level[i]];
dflet 0:698866e331b2 668 qos_topics[i].length = strlen(topics[i]);
dflet 0:698866e331b2 669 }
dflet 0:698866e331b2 670
dflet 0:698866e331b2 671 /* Set up all variables to receive an ACK for the message to be sent*/
dflet 0:698866e331b2 672 if(true == client_ctx->blocking_send) {
dflet 0:698866e331b2 673 /* Update the qos_level to be in-out parameter */
dflet 0:698866e331b2 674 client_ctx->suback_qos = (char*)qos_level;
dflet 0:698866e331b2 675 client_ctx->awaited_ack = MQTT_SUBACK;
dflet 0:698866e331b2 676 }
dflet 0:698866e331b2 677
dflet 0:698866e331b2 678 /* Send the subscription MQTT message */
dflet 0:698866e331b2 679 ret = mqtt_sub_msg_send(client_ctx->cli_hndl, qos_topics, count);
dflet 0:698866e331b2 680 if(ret < 0) {
dflet 0:698866e331b2 681 goto mqtt_sub_exit1;
dflet 0:698866e331b2 682 }
dflet 0:698866e331b2 683
dflet 0:698866e331b2 684 if(true == client_ctx->blocking_send) {
dflet 0:698866e331b2 685 ACK_RX_SIGNAL_WAIT(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 686 if(MQTT_DISCONNECT == client_ctx->awaited_ack) {
dflet 0:698866e331b2 687 ret = -1;
dflet 0:698866e331b2 688 }
dflet 0:698866e331b2 689 }
dflet 0:698866e331b2 690
dflet 0:698866e331b2 691 mqtt_sub_exit1:
dflet 0:698866e331b2 692 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 693 return (ret < 0)? -1: 0;
dflet 0:698866e331b2 694 }
dflet 0:698866e331b2 695
dflet 0:698866e331b2 696
dflet 0:698866e331b2 697 //*****************************************************************************
dflet 0:698866e331b2 698 // sl_ExtLib_MqttClientUnsub
dflet 0:698866e331b2 699 //*****************************************************************************
dflet 0:698866e331b2 700 int32_t
dflet 0:698866e331b2 701 sl_ExtLib_MqttClientUnsub(void *cli_ctx, char* const *topics, int32_t count)
dflet 0:698866e331b2 702 {
dflet 0:698866e331b2 703 #define MAX_SIMULTANEOUS_UNSUB_TOPICS 4
dflet 0:698866e331b2 704
dflet 0:698866e331b2 705 int32_t ret = -1, i;
dflet 0:698866e331b2 706 struct utf8_string unsub_topics[MAX_SIMULTANEOUS_UNSUB_TOPICS];
dflet 0:698866e331b2 707 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)cli_ctx;
dflet 0:698866e331b2 708
dflet 0:698866e331b2 709 if(!(mqtt_client_is_connected(client_ctx->cli_hndl)) || (count > MAX_SIMULTANEOUS_UNSUB_TOPICS)) {
dflet 0:698866e331b2 710 goto mqtt_unsub_exit1; /* Check client status */
dflet 0:698866e331b2 711 }
dflet 0:698866e331b2 712
dflet 0:698866e331b2 713 for(i = 0; i < count; i++) {
dflet 0:698866e331b2 714 STR2UTF_CONV(unsub_topics[i], topics[i]);
dflet 0:698866e331b2 715 }
dflet 0:698866e331b2 716
dflet 0:698866e331b2 717 /* Set up all variables to receive an ACK for the message to be sent*/
dflet 0:698866e331b2 718 if(true == client_ctx->blocking_send) {
dflet 0:698866e331b2 719 client_ctx->awaited_ack = MQTT_UNSUBACK;
dflet 0:698866e331b2 720 }
dflet 0:698866e331b2 721
dflet 0:698866e331b2 722 /* Send the unsubscription MQTT message */
dflet 0:698866e331b2 723 ret = mqtt_unsub_msg_send(client_ctx->cli_hndl, unsub_topics, count);
dflet 0:698866e331b2 724 if(ret < 0) {
dflet 0:698866e331b2 725 goto mqtt_unsub_exit1;
dflet 0:698866e331b2 726 }
dflet 0:698866e331b2 727
dflet 0:698866e331b2 728 if(true == client_ctx->blocking_send) {
dflet 0:698866e331b2 729 ACK_RX_SIGNAL_WAIT(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 730 if(MQTT_DISCONNECT == client_ctx->awaited_ack) {
dflet 0:698866e331b2 731 ret = -1;
dflet 0:698866e331b2 732 }
dflet 0:698866e331b2 733 }
dflet 0:698866e331b2 734
dflet 0:698866e331b2 735 mqtt_unsub_exit1:
dflet 0:698866e331b2 736 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 737 return (ret < 0)? -1: 0;
dflet 0:698866e331b2 738 }
dflet 0:698866e331b2 739 //*****************************************************************************
dflet 0:698866e331b2 740 // sl_ExtLib_MqttClientSend
dflet 0:698866e331b2 741 //*****************************************************************************
dflet 0:698866e331b2 742 int32_t
dflet 0:698866e331b2 743 sl_ExtLib_MqttClientSend(void *cli_ctx, const char *topic,
dflet 0:698866e331b2 744 const void *data, int32_t len,
dflet 0:698866e331b2 745 char qos_level, bool retain)
dflet 0:698866e331b2 746 {
dflet 0:698866e331b2 747
dflet 0:698866e331b2 748 int32_t ret = -1;
dflet 0:698866e331b2 749 struct utf8_string topic_utf8;
dflet 0:698866e331b2 750 struct sl_client_ctx *client_ctx = (struct sl_client_ctx *)cli_ctx;
dflet 0:698866e331b2 751
dflet 0:698866e331b2 752 /* Check whether Client is connected or not? */
dflet 0:698866e331b2 753 if(!(mqtt_client_is_connected(client_ctx->cli_hndl))) {
dflet 0:698866e331b2 754 Uart_Write((uint8_t*)"mqtt client is not connected\n\r");
dflet 0:698866e331b2 755 return ret;
dflet 0:698866e331b2 756 }
dflet 0:698866e331b2 757
dflet 0:698866e331b2 758 STR2UTF_CONV(topic_utf8, topic);
dflet 0:698866e331b2 759
dflet 0:698866e331b2 760 /*Set up all variables to receive an ACK for the message to be sent*/
dflet 0:698866e331b2 761 if(MQTT_QOS1 == qos[qos_level]) {
dflet 0:698866e331b2 762 client_ctx->awaited_ack = MQTT_PUBACK;
dflet 0:698866e331b2 763 } else if(MQTT_QOS2 == qos[qos_level]) {
dflet 0:698866e331b2 764 client_ctx->awaited_ack = MQTT_PUBCOMP;
dflet 0:698866e331b2 765 }
dflet 0:698866e331b2 766 /*publish the message*/
dflet 0:698866e331b2 767 ret = mqtt_client_pub_msg_send(client_ctx->cli_hndl, &topic_utf8,
dflet 0:698866e331b2 768 (const uint8_t*)data, len,
dflet 0:698866e331b2 769 qos[qos_level], retain);
dflet 0:698866e331b2 770 if(ret < 0) {
dflet 0:698866e331b2 771 Uart_Write((uint8_t*)"mqtt_client_pub_msg_send failed\n\r");
dflet 0:698866e331b2 772 goto mqtt_pub_exit1;
dflet 0:698866e331b2 773 }
dflet 0:698866e331b2 774
dflet 0:698866e331b2 775 if(MQTT_QOS0 != qos[qos_level]) {
dflet 0:698866e331b2 776 if(true == client_ctx->blocking_send) {
dflet 0:698866e331b2 777 ACK_RX_SIGNAL_WAIT(&client_ctx->ack_sync_obj);
dflet 0:698866e331b2 778 if(MQTT_DISCONNECT == client_ctx->awaited_ack) {
dflet 0:698866e331b2 779 Uart_Write((uint8_t*)"MQTT_DISCONNECT\n\r");
dflet 0:698866e331b2 780 ret = -1;
dflet 0:698866e331b2 781 }
dflet 0:698866e331b2 782 }
dflet 0:698866e331b2 783 }
dflet 0:698866e331b2 784
dflet 0:698866e331b2 785 mqtt_pub_exit1:
dflet 0:698866e331b2 786 client_ctx->awaited_ack = 0;
dflet 0:698866e331b2 787 return (ret < 0)? -1: 0;
dflet 0:698866e331b2 788 }
dflet 0:698866e331b2 789
dflet 0:698866e331b2 790 }//namespace mbed_mqtt
dflet 0:698866e331b2 791