Changeset 231 for rtos_arduino/trunk/arduino_lib
- Timestamp:
- May 4, 2016, 9:45:02 PM (8 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
rtos_arduino/trunk/arduino_lib/libraries/Milkcocoa_Arduino_SDK/Milkcocoa.cpp
r184 r231 24 24 */ 25 25 #include "Milkcocoa.h" 26 #include "rca.h" 26 27 27 28 DataElement::DataElement() { … … 124 125 125 126 MILKCOCOA_DEBUG_PRINTLN("Connecting to MQTT... "); 126 127 128 wai_sem(MILKCOCOA_SEM); 127 129 while ((ret = mqtt->connect()) != 0) { // connect will return 0 for connected 128 130 mqtt->disconnect(); 129 131 // Timeout 130 132 if ((tmout != 0) && (++retry == tmout)) { 133 sig_sem(MILKCOCOA_SEM); 131 134 return ret; 132 135 } … … 134 137 } 135 138 MILKCOCOA_DEBUG_PRINTLN("MQTT Connected!"); 136 139 sig_sem(MILKCOCOA_SEM); 140 137 141 return 0; 138 142 } … … 144 148 145 149 if((ret = connect(timeout)) != 0){return ret;} 146 150 151 wai_sem(MILKCOCOA_SEM); 147 152 sprintf(topic, "%s/%s/push", app_id, path); 148 153 Adafruit_MQTT_Publish pushPublisher = Adafruit_MQTT_Publish(mqtt, topic); … … 150 155 ret = (pushPublisher.publish(send_array))? 0 : MILKCOCOA_PUSH_ERRORNO; 151 156 free(send_array); 157 sig_sem(MILKCOCOA_SEM); 158 152 159 return ret; 153 160 } … … 159 166 160 167 if((ret = connect(timeout)) != 0){return ret;} 161 168 169 wai_sem(MILKCOCOA_SEM); 162 170 sprintf(topic, "%s/%s/send", app_id, path); 163 171 Adafruit_MQTT_Publish pushPublisher = Adafruit_MQTT_Publish(mqtt, topic); 164 172 send_array = pdataelement->toCharArray(); 165 173 ret = (pushPublisher.publish(send_array))? 0 : MILKCOCOA_PUSH_ERRORNO; 166 free(send_array); 174 free(send_array); 175 sig_sem(MILKCOCOA_SEM); 176 167 177 return ret; 168 178 } … … 178 188 179 189 if((ret = connect(timeout)) != 0){return ret;} 180 190 191 wai_sem(MILKCOCOA_SEM); 181 192 Adafruit_MQTT_Subscribe *subscription; 182 193 while ((subscription = mqtt->readSubscription(1000))) { … … 189 200 } 190 201 } 191 202 sig_sem(MILKCOCOA_SEM); 203 192 204 return 0; 193 205 }
Note:
See TracChangeset
for help on using the changeset viewer.