Jump to content
43oh

M2X Library Disconnect after ~5 uploads

Kazz

By Kazz,
in Energia - MSP

 Share Followers 0

Recommended Posts

Kazz

Kazz 0

Posted
Posted

Hello, 

I am working on project that involves uploading data to an M2X server approximately 8 times per second (different streams) but I am having an issue. I constantly lose connection after 5 data uploads. I have used the M2X-Button_Press demo to test the issue on an MSP430FR5969 but NOT on an MSP430F5529 with.

 

The response code I get is first -2 then followed by -1. I can reset the MSP430FR5969 and the system works again for ~5 iterations only to stop working again. My full code is posted below and after fully testing it works on an MSP430F5529 with seemingly no issue other than the time delay between sending posts out (~1 second per post). 

Thankfully 
Kas

/*
  Multple serial test
 
  Receives from the MCP39F511 on Serial1 port, sends to the others. 
  Receives from serial port 1, sends to the main serial (Serial 0).
 
  The circuit: 
  * MCP39F511 RX and TX connected to Serial1 
  * Serial monitor open on Serial port 0:
 
  created 7 September 2016
  by Kasriel Lewis
  adapted from code created by:
  Tom Igoe - MultiSerial (Energia Demo)
  Mark Easley - M2X-Button_Press (M2X Demo)
 
  This example code is in the public domain.
 
*/
#include <aJSON.h>
#include "SPI.h"
#include "WiFi.h"
#include "M2XStreamClient.h"
#include "WiFi_Credentials.h"

#define ACK 0x06
#define NACK 0x15
#define CSFAIL 0x51

//DEBUG DEFINES 
#define debug 0
#define debugState 1
#define debugVerbose 0
#define debugStateThree 1
#define debugHEX 0
#define debugDEC 0
#define debugDOUBLE 0

byte requestData[] = {0xA5, 0x08, 0x41, 0x00, 0x02, 0x4E, 0x1C, 0x5A};
int timeSlot = 300; //Lowest 200
unsigned long time0 = 0;
unsigned long time1 = 0;
int receiveCounter = 0;
int bytesToReceive = -1;
unsigned char reveivedData[50]; //Input array 
int i = 0;
int state = 0;
unsigned char inChar;
unsigned char checksum;
double tempOutput;
int diconnectCounter;
int response;
int deviceReadFrequency = 10000;
double valuesToPush[7];
int availableBytes = 0;

//DEBUG VARIABLES
int outputCounter = 0;
unsigned int tempUInt_16;
unsigned long tempUInt_32;


WiFiClient client;
M2XStreamClient m2xClient(&client, m2xKey);

void setup() {
  // initialize both serial ports:
  Serial.begin(115200);
  Serial1.begin(115200);
  
  // attempt to connect to Wifi network:
  Serial.print("Attempting to connect to Network named: ");
  // print the network name (SSID);
  Serial.println(ssid); 
  // Connect to WPA/WPA2 network. Change this line if using open or WEP network:
  WiFi.begin(ssid, pass);
  while ( WiFi.status() != WL_CONNECTED) {
    // print dots while we wait to connect
    Serial.print(".");
    delay(300);
  }

  Serial.println("\nYou're connected to the network");
  Serial.println("Waiting for an ip address");

  while (WiFi.localIP() == INADDR_NONE) {
    // print dots while we wait for an ip addresss
    Serial.print(".");
    delay(300);
  }

  Serial.println("\nIP Address obtained");

  // you're connected now, so print out the status  
  printWifiStatus();
  
  // prints title with ending line break 
  Serial.println("\n\n\rRead Data from MCP39F511"); 
   
}

void loop() {
  //send read data command to MCP39F511
  time1 = millis();
  switch(state){
    case 0:
      Serial.flush();
      if((time1 - time0) >= deviceReadFrequency){
        for(i = 0; i < sizeof(requestData); i++){
          Serial1.write(requestData[i]);
          delayMicroseconds(timeSlot);
        }
      time0 = millis();
      #if debugState
      Serial.println("0 Send Command");
      #endif
      state++;
      }
      break;
      
    case 1:
      availableBytes = Serial1.available();
      if(availableBytes > 0){
        inChar = (char)Serial1.read();
        if(inChar == ACK){
          reveivedData[receiveCounter] = inChar;
          checksum = inChar;
          receiveCounter++;
          state++;
          #if debug
          Serial.print("1 Receive first byte");
          Serial.print(" - inChar ");
          Serial.print(inChar, HEX);
          Serial.print(" - receiveCounter ");
          Serial.print(receiveCounter, HEX);
          Serial.print(" - state ");
          Serial.print(state, DEC);
          Serial.print(" - availableBytes ");
          Serial.println(availableBytes, DEC);
          #endif
        }
        else if(inChar == NACK){
          //Output error message
          Serial.println("Frame received with success command not understood or another error in command bytes");
          state--;
        }
        else if(inChar == CSFAIL){
          //Output error message
          Serial.println("Frame received with success, however, checksum did not match bytes in frame");
          state--;
        }
        else{
          state--;
        }
      }
      else{
        if(diconnectCounter >= 10){
          state = 0;
          diconnectCounter = 0;
          
        }
      }
      diconnectCounter++;
      #if debugState
      Serial.println("State #1");
      #endif
      break;
      
    case 2:
      diconnectCounter = 0;
      availableBytes = Serial1.available();
      if(availableBytes > 0){
        inChar = (char)Serial1.read();
        reveivedData[receiveCounter] = inChar;
        bytesToReceive = inChar;
        checksum += inChar;
        receiveCounter++;
        state++;
        #if debug
        Serial.print("2 Receive number of bytes to receive");
        Serial.print(" - inChar ");
        Serial.print(inChar, HEX);
        Serial.print(" - receiveCounter ");
        Serial.print(receiveCounter, HEX);
        Serial.print(" - bytesToReceive ");
        Serial.print(bytesToReceive, DEC);
        Serial.print(" - state ");
        Serial.print(state, DEC);
        Serial.print(" - availableBytes ");
        Serial.println(availableBytes, DEC);
        #endif
      }
      #if debugState
      Serial.println("State #2");
      #endif
      break;
      
    case 3:
      availableBytes = Serial1.available();
      if(availableBytes > 0){
        inChar = (char)Serial1.read();
        reveivedData[receiveCounter] = inChar;
        receiveCounter++;
        if(receiveCounter < bytesToReceive){
          checksum += inChar;
        }
        if(receiveCounter == bytesToReceive){
          state++;
          #if debugState
          Serial.println("State #3 -> #4");
          #endif
        }
        #if debug
        Serial.print("3 Receive remaining bytes");
        Serial.print(" - inChar ");
        Serial.print(inChar, HEX);
        Serial.print(" - receiveCounter ");
        Serial.print(receiveCounter, HEX);
        Serial.print(" - bytesToReceive ");
        Serial.print(bytesToReceive, DEC);
        Serial.print(" - state ");
        Serial.print(state, DEC);
        Serial.print(" - availableBytes ");
        Serial.println(availableBytes, DEC);
        #endif
      }
      #if debugStateThree
      Serial.println("State #3");
      #endif
      break;
      
    case 4:
      // timeService.getTimestamp32(timeStamp);
      if(checksum == reveivedData[30]){
        tempOutput = (reveivedData[7] << 8) | reveivedData[6];
        valuesToPush[1] = tempOutput;
        response = m2xClient.updateStreamValue(deviceId, streamName1, (tempOutput / 10));
        Serial.print("\n\rVoltage RMS = ");
        Serial.println(response);
        
        tempOutput = 0x0000FFFF & (reveivedData[9] << 8) | reveivedData[8];
        valuesToPush[3] = tempOutput;
        response = m2xClient.updateStreamValue(deviceId, streamName3, (tempOutput / 1000));
        Serial.print("\n\rLine Frequency = ");
        Serial.println(response);
        
        tempOutput = 0x0000FFFF & ((reveivedData[13] << 8) | reveivedData[12]);
        valuesToPush[7] = tempOutput;
        response = m2xClient.updateStreamValue(deviceId, streamName7, (tempOutput * 3051757813) / 100000000000000);
        Serial.print("\n\rPower Factor = ");//TODO: This is a signed number, this needs to betaken into account
        Serial.println(response);
        
        tempOutput = (reveivedData[17] << 24) | (reveivedData[16] << 16) | (reveivedData[15] << 8) | reveivedData[14];
        valuesToPush[2] = tempOutput;
        response = m2xClient.updateStreamValue(deviceId, streamName2, (tempOutput / 10000));
        Serial.print("\n\rCurent RMS = ");
        Serial.println(response);
              
        tempOutput = (reveivedData[21] << 24) | (reveivedData[20] << 16) | (reveivedData[19] << 8) | reveivedData[18];
        valuesToPush[4] = tempOutput;
        response = m2xClient.updateStreamValue(deviceId, streamName4, (tempOutput / 100));
        Serial.print("\n\rActive Power = ");
        Serial.println(response);
                    
        
        tempOutput = (reveivedData[25] << 24) | (reveivedData[24] << 16) | (reveivedData[23] << 8) | reveivedData[22];
        valuesToPush[5] = tempOutput;
        response = m2xClient.updateStreamValue(deviceId, streamName5, (tempOutput / 100));
        Serial.print("\n\rReactive Power = ");
        Serial.println(response);
                    
        
        tempOutput = (reveivedData[29] << 24) | (reveivedData[28] << 16) | (reveivedData[27] << 8) | reveivedData[26];
        valuesToPush[6] = tempOutput;
        response = m2xClient.updateStreamValue(deviceId, streamName6, (tempOutput / 100));
        Serial.print("\n\rApparent Power = ");
        Serial.println(response);
        
      }
      #if debugDEC
      Serial.print("\n\rNumber of Bytes - ");
      Serial.print(reveivedData[1], DEC);
      
      Serial.print("\n\rSystem Status - 0x");
      Serial.print(reveivedData[3], HEX);
      Serial.print(reveivedData[2], HEX);
      
      Serial.print("\n\rSystem Version - Year-20");
      Serial.print(((reveivedData[5] & 0xF0) >> 4), DEC);
      Serial.print(" Month-");
      Serial.print((reveivedData[5] & 0x0F), DEC);
      Serial.print(" Day-");
      Serial.print(reveivedData[4], DEC);
      
      Serial.print("\n\rVoltage RMS = ");
      tempUInt_16 = (reveivedData[7] << 8) | reveivedData[6];
      Serial.print((tempUInt_16 / 10), DEC);
      Serial.print(".");
      Serial.print((tempUInt_16 % 10), DEC);
            
      Serial.print("\n\rLine Frequency = ");
      tempUInt_16 = (reveivedData[9] << 8) | reveivedData[8];
      Serial.print((tempUInt_16 / 1000), DEC);
      Serial.print(".");
      Serial.print((tempUInt_16 % 1000), DEC);
            
      Serial.print("\n\rAnalog Input Voltage = ");
      tempUInt_16 = (reveivedData[11] << 8) | reveivedData[10];
      Serial.print(tempUInt_16, DEC);
            
      Serial.print("\n\rPower Factor = ");
      tempUInt_32 = 0x0000FFFF & ((reveivedData[13] << 8) | reveivedData[12]);
      Serial.print("0.");
      Serial.print(tempUInt_32 * 3051, DEC);
      
      Serial.print("\n\rCurent RMS = ");
      tempUInt_32 = (reveivedData[17] << 24) | (reveivedData[16] << 16) | (reveivedData[15] << 8) | reveivedData[14];
      Serial.print((tempUInt_32 / 1000), DEC);
      Serial.print(".");
      Serial.print((tempUInt_32 % 1000), DEC);

            
      Serial.print("\n\rActive Power = ");
      tempUInt_32 = (reveivedData[21] << 24) | (reveivedData[20] << 16) | (reveivedData[19] << 8) | reveivedData[18];
      Serial.print((tempUInt_32 / 100), DEC);
      Serial.print(".");
      Serial.print((tempUInt_32 % 100), DEC);
                  
      Serial.print("\n\rReactive Power = ");
      tempUInt_32 = (reveivedData[25] << 24) | (reveivedData[24] << 16) | (reveivedData[23] << 8) | reveivedData[22];
      Serial.print((tempUInt_32 / 100), DEC);
      Serial.print(".");
      Serial.print((tempUInt_32 % 100), DEC);
                  
      Serial.print("\n\rApparent Power = ");
      tempUInt_32 = (reveivedData[29] << 24) | (reveivedData[28] << 16) | (reveivedData[27] << 8) | reveivedData[26];
      Serial.print((tempUInt_32 / 100), DEC);
      Serial.print(".");
      Serial.print((tempUInt_32 % 100), DEC);
      
      Serial.print("\n\rChecksum Value Reveived = 0x");
      Serial.print(reveivedData[30], HEX);
      Serial.print("\n\rChecksum Value Calculated = 0x");
      Serial.println(checksum, HEX);
      #endif
    
    
      #if debugHEX
      Serial.print("ACK - 0x");
      Serial.print(reveivedData[0], HEX);
      Serial.print("\n\rNumber of Bytes - 0x");
      Serial.print(reveivedData[1], HEX);
      
      Serial.print("\n\rSystem Status - 0x");
      Serial.print(reveivedData[3], HEX);
      Serial.print(reveivedData[2], HEX);
      
      Serial.print("\n\rSystem Version - 0x");
      Serial.print(reveivedData[5], HEX);
      Serial.print(reveivedData[4], HEX);
      
      Serial.print("\n\rVoltage RMS x 10 = 0x");
      Serial.print(reveivedData[7], HEX);
      Serial.print(reveivedData[6], HEX);
            
      Serial.print("\n\rLine Frequency x 1000 = 0x");
      Serial.print(reveivedData[9], HEX);
      Serial.print(reveivedData[8], HEX);
            
      Serial.print("\n\rAnalog Input Voltage = 0x");
      Serial.print(reveivedData[11], HEX);
      Serial.print(reveivedData[10], HEX);
            
      Serial.print("\n\rPower Factor / 2^(-15) = 0x");
      Serial.print(reveivedData[13], HEX);
      Serial.print(reveivedData[12], HEX);
      
      Serial.print("\n\rCurent RMS x 1000 = 0x");
      Serial.print(reveivedData[17], HEX);
      Serial.print(reveivedData[16], HEX);
      Serial.print(reveivedData[15], HEX);
      Serial.print(reveivedData[14], HEX);
            
      Serial.print("\n\rActive Power x 100 = 0x");
      Serial.print(reveivedData[21], HEX);
      Serial.print(reveivedData[20], HEX);
      Serial.print(reveivedData[19], HEX);
      Serial.print(reveivedData[18], HEX);
                  
      Serial.print("\n\rReactive Power x 100 = 0x");
      Serial.print(reveivedData[25], HEX);
      Serial.print(reveivedData[24], HEX);
      Serial.print(reveivedData[23], HEX);
      Serial.print(reveivedData[22], HEX);
                  
      Serial.print("\n\rApparent Power x 100 = 0x");
      Serial.print(reveivedData[29], HEX);
      Serial.print(reveivedData[28], HEX);
      Serial.print(reveivedData[27], HEX);
      Serial.print(reveivedData[26], HEX);
      
      Serial.print("\n\rChecksum Value Reveived  =  0x");
      Serial.print(reveivedData[30], HEX);
      Serial.print("\n\rChecksum Value Calculated = 0x");
      Serial.println(checksum, HEX);
      #endif
      
      
      #if  debugDOUBLE      
      Serial.print("\n\rNumber of Bytes - ");
      Serial.print(reveivedData[1], DEC);
      
      Serial.print("\n\rSystem Status - 0x");
      Serial.print(reveivedData[3], HEX);
      Serial.print(reveivedData[2], HEX);
      
      Serial.print("\n\rSystem Version - Year-20");
      Serial.print(((reveivedData[5] & 0xF0) >> 4), DEC);
      Serial.print(" Month-");
      Serial.print((reveivedData[5] & 0x0F), DEC);
      Serial.print(" Day-");
      Serial.print(reveivedData[4], DEC);
      
      Serial.print("\n\rVoltage RMS = ");
      tempOutput = (reveivedData[7] << 8) | reveivedData[6];
      Serial.print((tempOutput / 10), 4);
            
      Serial.print("\n\rLine Frequency = ");
      tempOutput = 0x0000FFFF & (reveivedData[9] << 8) | reveivedData[8];
      Serial.print((tempOutput/ 1000), DEC);
            
      Serial.print("\n\rAnalog Input Voltage = ");
      tempUInt_16 = (reveivedData[11] << 8) | reveivedData[10];
      Serial.print(tempUInt_16, 4);
            
      Serial.print("\n\rPower Factor = ");//TODO: This is a signed number, this needs to betaken into account
      tempOutput = 0x0000FFFF & ((reveivedData[13] << 8) | reveivedData[12]);
      Serial.print((tempOutput * 3051757813) / 100000000000000, 4);
      
      Serial.print("\n\rCurent RMS = ");
      tempOutput = (reveivedData[17] << 24) | (reveivedData[16] << 16) | (reveivedData[15] << 8) | reveivedData[14];
      Serial.print((tempOutput / 10000), 4);
            
      Serial.print("\n\rActive Power = ");
      tempOutput = (reveivedData[21] << 24) | (reveivedData[20] << 16) | (reveivedData[19] << 8) | reveivedData[18];
      Serial.print((tempOutput / 100), 4);
                  
      Serial.print("\n\rReactive Power = ");
      tempOutput = (reveivedData[25] << 24) | (reveivedData[24] << 16) | (reveivedData[23] << 8) | reveivedData[22];
      Serial.print((tempOutput / 100), DEC);
                  
      Serial.print("\n\rApparent Power = ");
      tempOutput = (reveivedData[29] << 24) | (reveivedData[28] << 16) | (reveivedData[27] << 8) | reveivedData[26];
      Serial.print((tempOutput / 100), DEC);
      
      Serial.print("\n\rChecksum Value Reveived = 0x");
      Serial.print(reveivedData[30], HEX);
      Serial.print("\n\rChecksum Value Calculated = 0x");
      Serial.println(checksum, HEX);
      #endif
      
      #if debugVerbose
      for(outputCounter = 0; outputCounter < receiveCounter; outputCounter++){
        Serial.print(reveivedData[outputCounter], HEX);
        Serial.print(" - outputCounter ");
        Serial.print(outputCounter, DEC);
        Serial.print(" - receiveCounter ");
        Serial.println(receiveCounter, HEX);
      }
      #endif
      receiveCounter = 0;
      state = 0;
      #if debugState
      Serial.println("State #4");
      #endif
      break;

    // default :
      // break;
  }
 
}

void printWifiStatus() {
  // print the SSID of the network you're attached to:
  Serial.print("SSID: ");
  Serial.println(WiFi.SSID());

  // print your WiFi shield's IP address:
  IPAddress ip = WiFi.localIP();
  Serial.print("IP Address: ");
  Serial.println(ip);
}
Link to post
Share on other sites
NurseBob

NurseBob 111

Posted
Posted

I assume you're referring to the ATT M2X server? If so, after a brief look at the documentation, you need to supply a lot more information.  At the minimum, are you getting any error codes back from the server? You've provided no information to help diagnose your issue...

 

I do see in your previous post in CC3200 that you reported: "I have also tried a similar demo (LaunchPadWiFiPost) using the MSP430F5969 with no issues."

You may want to review the suggestion on what to include with your request for help... HTH

 

FWIW - when it comes to streams, and talking via wifi to an http server, I'm not a useful resource :(

Link to post
Share on other sites
Kazz

Kazz 0

Posted
  • Author
Posted

I have updated the original post to better explain the issue (not to much added realy) and to include my full code. The conclusions I have reached without further testing is either the MSP430FR5969 or the CC3100BP used in that setup are faulty, hardware issue. Or that the the code generated for the MSP430FR5969 WiFi has some form of issue with it, software issue. Since I have not anything regarding a WiFi issue for the MSP430FR5969 I will start with my hardware setup when I get a chance.

 

Currently I am behind in my projects that need to be completed so if there is no update feel free to poke me for one.

 

Thanks

Kas

Link to post
Share on other sites
Fmilburn

Fmilburn 446

Posted
Posted

Whoa, I thought I put a lot of debug print in my code :) .  Seriously, very few people are going to feel like wading through that so try and reduce it down to the minimum that demonstrates the issue.

 

Here is a shot in the dark.  Serial output in Energia uses a ring buffer with only 16 bytes because it was originally written for the MSP430G series.  Try increasing  the serial ring buffer size in Energia (HardwareSerial.cpp) to say. #define SERIAL_BUFFER_SIZE 512 and see what happens.  The F5529 runs faster and maybe it can clear the buffer while the others can't. Remove extraneous serial print.

 

Edit:  Slowing down the frequency of postings to the library may also help

Link to post
Share on other sites

Join the conversation

You can post now and register later. If you have an account, sign in now to post with your account.

Guest
Reply to this topic...

×   Pasted as rich text.   Paste as plain text instead

  Only 75 emoji are allowed.

×   Your link has been automatically embedded.   Display as a link instead

×   Your previous content has been restored.   Clear editor

×   You cannot paste images directly. Upload or insert images from URL.

×
 Share
Followers 0
Go to topic listing
×
×
  • Create New...