Diff: Communication.cpp

Revision:

12:ade22f4681af

Parent:

11:2ab3397b6e30

Child:

13:2c12f60bd10a

--- a/Communication.cpp	Fri Dec 13 03:23:31 2019 +0000
+++ b/Communication.cpp	Fri Dec 13 07:47:33 2019 +0000
@@ -81,6 +81,7 @@
 //callback for update/control messages
 void Communication::update_message_arrived(MQTT::MessageData& md)
 {
+    printf("UPDATE MESSAGE ARRIVED"); 
     MQTT::Message &message = md.message;
     char* payload = (char*)message.payload;
     printf("%s\r\n", payload);
@@ -98,10 +99,10 @@
 {
     MQTT::Message &message = md.message;
     char* payload = (char*)message.payload;
-    printf("%s\r\n", payload);
+    //printf("%s\r\n", payload);
     if (strcmp (Communication::mac_address(NULL), payload) != 0) {
-        printf("not matching address\r\n");
-        Road::ready(1);//oad_in_use(NULL)->done_flags.set(0xF0);
+        //printf("not matching address\r\n");
+        Road::ready(1);
     }
 }
 
@@ -133,11 +134,13 @@
     char* update_topic = (char*) buf;
     int rc = Communication::client(NULL)->subscribe(update_topic, MQTT::QOS1, update_message_arrived);
     if (rc != 0) {
+        printf("Failed subscribe updates\r\n"); 
         return -1;
     }
     char* sync_topic = "Chen_Goldsmith_Sync";
     rc = Communication::client(NULL)->subscribe(sync_topic, MQTT::QOS1, sync_message_arrived);
     if (rc != 0) {
+        printf("Failed subscribe sync\r\n"); 
         return -1;
     }
     
@@ -152,9 +155,7 @@
     char buf[50];
     const char* mac = Communication::mac_address(NULL); 
     sprintf(buf, "%d, %d, %d, %s", id, pos, speed, mac);
-    printf("publishing... "); 
     int rc = Communication::client(NULL)->publish(topic, (char*) buf, strlen(buf), MQTT::QOS1);
-    printf(" success!\r\n"); 
     
     if (rc != 0) {
         return -1;   
@@ -170,10 +171,10 @@
     char buf[100];
     sprintf(buf, "%s", Communication::mac_address(NULL));
     int rc = Communication::client(NULL)->publish(topic, (char*) buf, strlen(buf)+1, MQTT::QOS1);
-    printf("successfull publish: ready\r\n");
     if (rc != 0) {
         return -1;   
     } else {
+        printf("successful publish: ready\r\n");
         return 0;
     }
 }