Dongho Kim
HW4
Diff: main.cpp
- Revision:
- 23:e2ab0669caeb
- Parent:
- 21:a68bd76740f9
--- a/main.cpp Mon Sep 11 16:43:49 2017 +0200
+++ b/main.cpp Fri Jan 05 06:36:32 2018 +0000
@@ -1,139 +1,183 @@
-/*******************************************************************************
- * Copyright (c) 2014, 2015 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * and Eclipse Distribution License v1.0 which accompany this distribution.
- *
- * The Eclipse Public License is available at
- * http://www.eclipse.org/legal/epl-v10.html
- * and the Eclipse Distribution License is available at
- * http://www.eclipse.org/org/documents/edl-v10.php.
- *
- * Contributors:
- * Ian Craggs - initial API and implementation and/or initial documentation
- * Ian Craggs - make sure QoS2 processing works, and add device headers
- *******************************************************************************/
-
- /**
- This is a sample program to illustrate the use of the MQTT Client library
- on the mbed platform. The Client class requires two classes which mediate
- access to system interfaces for networking and timing. As long as these two
- classes provide the required public programming interfaces, it does not matter
- what facilities they use underneath. In this program, they use the mbed
- system libraries.
-
- */
-
- // change this to 1 to output messages to LCD instead of serial
-#define USE_LCD 0
-
-#if USE_LCD
-#include "C12832.h"
-
-// the actual pins are defined in mbed_app.json and can be overridden per target
-C12832 lcd(LCD_MOSI, LCD_SCK, LCD_MISO, LCD_A0, LCD_NCS);
-
-#define logMessage lcd.cls();lcd.printf
-
-#else
-
#define logMessage printf
-
-#endif
-
#define MQTTCLIENT_QOS2 1
+#include "mbed.h"
#include "easy-connect.h"
#include "MQTTNetwork.h"
#include "MQTTmbed.h"
#include "MQTTClient.h"
-int arrivedcount = 0;
+#define ADT7420_TEMP_REG (0x00) // Temperature Register
+#define ADT7420_CONF_REG (0x03) // Configuration Register
+#define EVAL_ADT7420_ADDR (0x48) // EVAL_ADT7420 i2c address
+
+
+/* connect this pin to both the CH_PD (aka EN) & RST pins on the ESP8266 just in case */
+#define WIFI_HW_RESET_PIN D4
+/* See if you can try using a hostname here */
+#define MQTT_BROKER_ADDR "192.168.0.14"
+#define MQTT_BROKER_PORT 1883
+
+DigitalOut wifiHwResetPin(WIFI_HW_RESET_PIN);
+DigitalOut led2(LED2);
+Serial pc(USBTX, USBRX); // computer to mbed boardSerial esp(D1, D0);
+I2C i2c(I2C_SDA, I2C_SCL);
+
+volatile bool flag = false;
+Mutex mqttMtx;
+
+char* topic1 = "LED";
+char* topic2 = "TEMP";
void messageArrived(MQTT::MessageData& md)
{
MQTT::Message &message = md.message;
- logMessage("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id);
+
+ /* our messaging standard says the first byte denotes which thread to fwd to */
+ logMessage("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n",
+ message.qos, message.retained, message.dup, message.id);
logMessage("Payload %.*s\r\n", message.payloadlen, (char*)message.payload);
- ++arrivedcount;
+
+ char fwdTarget = ((char *)message.payload)[0];
+ switch(fwdTarget)
+ {
+ case '0': // turn off
+ led2 = 0;
+ break;
+
+ case '1': //turn on
+ led2 = 1;
+ break;
+
+ default:
+ pc.printf("Unknown MQTT message\n");
+ break;
+ }
}
-
int main(int argc, char* argv[])
{
- float version = 0.6;
- char* topic = "mbed-sample";
+ float version = 0.5;
+ pc.baud(115200);
+ logMessage("MQTT example: version is %.2f\r\n", version);
+
+ wait(0.2); //delay startup
+ pc.printf("Resetting ESP8266 Hardware...\r\n");
- logMessage("HelloMQTT: version is %.2f\r\n", version);
+ wifiHwResetPin = 0;
+ wait_ms(500);
+ wifiHwResetPin = 1;
+ pc.printf("Starting MQTT example with an ESP8266 wifi device using Mbed OS.\r\n");
+ pc.printf("Attempting to connect to access point...\r\n");
NetworkInterface* network = easy_connect(true);
if (!network) {
+ pc.printf("Error in east connection\r\n");
return -1;
}
-
+
MQTTNetwork mqttNetwork(network);
-
MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork);
+ logMessage("Connecting to %s:%d\r\n", MQTT_BROKER_ADDR, MQTT_BROKER_PORT);
+ int rc = mqttNetwork.connect(MQTT_BROKER_ADDR, MQTT_BROKER_PORT);
- const char* hostname = "m2m.eclipse.org";
- int port = 1883;
- logMessage("Connecting to %s:%d\r\n", hostname, port);
- int rc = mqttNetwork.connect(hostname, port);
if (rc != 0)
logMessage("rc from TCP connect is %d\r\n", rc);
MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
data.MQTTVersion = 3;
- data.clientID.cstring = "mbed-sample";
- data.username.cstring = "testuser";
- data.password.cstring = "testpassword";
+ data.clientID.cstring = "mbed-kdh";
+ data.username.cstring = "kdh";
+ data.password.cstring = "2ehd2gh4";
+
if ((rc = client.connect(data)) != 0)
logMessage("rc from MQTT connect is %d\r\n", rc);
- if ((rc = client.subscribe(topic, MQTT::QOS2, messageArrived)) != 0)
+ if ((rc = client.subscribe(topic1, MQTT::QOS0, messageArrived)) != 0)
logMessage("rc from MQTT subscribe is %d\r\n", rc);
- MQTT::Message message;
+ int count = 0;
+
+ int status;
+ float temp;
+ char data_write[2];
+ char data_read[2];
+
+ i2c.frequency(100000); // 100 k
+
+ // 13-bit resolution and 1 SPS mode
+ data_write[0] = ADT7420_CONF_REG;
+ data_write[1] = 0x40;
+ status = i2c.write((EVAL_ADT7420_ADDR << 1), data_write, 2);
- // QoS 0
- char buf[100];
- sprintf(buf, "Hello World! QoS 0 message from app version %f\r\n", version);
- message.qos = MQTT::QOS0;
- message.retained = false;
- message.dup = false;
- message.payload = (void*)buf;
- message.payloadlen = strlen(buf)+1;
- rc = client.publish(topic, message);
- while (arrivedcount < 1)
- client.yield(100);
+ if (status != 0) { // error
+ char buf[100];
+ MQTT::Message message;
+
+ pc.printf("I2C configuration error!!\r\n");
+ sprintf(buf, "{ \"actions\": [ { \"name\": 'error' , \"parameter\": \"NaN\" } ] }");
+ pc.printf("%s\r\n", buf);
+
+ message.qos = MQTT::QOS2;
+ message.retained = false;
+ message.dup = false;
+ message.payload = (void*)buf;
+ message.payloadlen = strlen(buf)+1;
+ mqttMtx.lock();
+
+ rc = client.publish(topic2, message);
+ mqttMtx.unlock();
+
+ while(1) {
+ }
+ }
+
+ while(1) {
+ Thread::wait(1000);
+ char buf[100];
+ MQTT::Message message;
- // QoS 1
- sprintf(buf, "Hello World! QoS 1 message from app version %f\r\n", version);
- message.qos = MQTT::QOS1;
- message.payloadlen = strlen(buf)+1;
- rc = client.publish(topic, message);
- while (arrivedcount < 2)
- client.yield(100);
+ if (count == 5) {
+
+ // Read temperature register
+ data_write[0] = ADT7420_TEMP_REG;
+ i2c.write((EVAL_ADT7420_ADDR << 1), data_write, 1, 0);
+ i2c.read(((EVAL_ADT7420_ADDR << 1) | 0x01), data_read, 2, 0);
+
+ // Calculate temperature value in Celcius
+ int tempval = ((int)data_read[0] << 8) | data_read[1];
+ tempval >>= 3;
- // QoS 2
- sprintf(buf, "Hello World! QoS 2 message from app version %f\r\n", version);
- message.qos = MQTT::QOS2;
- message.payloadlen = strlen(buf)+1;
- rc = client.publish(topic, message);
- while (arrivedcount < 3)
- client.yield(100);
+ // tempval = 0x1e70; //test value for a negative temperature (-25.0)
+ if ((tempval & 0x1000) > 0) { //negative value
+ temp = (tempval - 8192)/16.0;
+ } else {
+ temp = tempval/16.0;
+ }
+
+ pc.printf("Publish: TEMP\r\n");
+ sprintf(buf, "%4.2f", temp);
+ pc.printf("%s\r\n", buf);
+
+ message.qos = MQTT::QOS2;
+ message.retained = false;
+ message.dup = false;
+ message.payload = (void*)buf;
+ message.payloadlen = strlen(buf)+1;
+ mqttMtx.lock();
+
+ rc = client.publish(topic2, message);
+ mqttMtx.unlock();
+ count = 0;
+ }
- if ((rc = client.unsubscribe(topic)) != 0)
- logMessage("rc from unsubscribe was %d\r\n", rc);
-
- if ((rc = client.disconnect()) != 0)
- logMessage("rc from disconnect was %d\r\n", rc);
+ if(!client.isConnected())
+ NVIC_SystemReset(); // soft reset
- mqttNetwork.disconnect();
-
- logMessage("Version %.2f: finish %d msgs\r\n", version, arrivedcount);
-
+ /* yield() needs to be called at least once per keepAliveInterval */
+ client.yield(10);
+ count++;
+ }
return 0;
-}
+}
\ No newline at end of file