Node broadcast loop



  • Hi all,

    I have a node with 2 sensor that have been working well for weeks and suddenly starts to loop on some kind of broadcasting message. It comes back if I restart the RPI+Gateway (but not if I just restart the Mysensor service at RPI).

    I would like to solve it the right way, instead of having to reboot the server every time it happens.

    This is the log at the server:

    Oct 13 20:44:27 DEBUG TSF:MSG:READ,2-2-255,s=255,c=3,t=7,pt=0,l=0,sg=0:
    Oct 13 20:44:27 DEBUG TSF:MSG:BC
    Oct 13 20:44:27 DEBUG TSF:MSG:FPAR REQ,ID=2
    Oct 13 20:44:27 DEBUG TSF:CKU:OK,FCTRL
    Oct 13 20:44:27 DEBUG TSF:MSG:GWL OK
    Oct 13 20:44:28 DEBUG !TSF:MSG:SEND,0-0-2-2,s=255,c=3,t=8,pt=1,l=1,sg=0,ft=0,st=NACK:0
    Oct 13 20:44:30 DEBUG TSF:MSG:READ,2-2-255,s=255,c=3,t=7,pt=0,l=0,sg=0:
    Oct 13 20:44:30 DEBUG TSF:MSG:BC
    Oct 13 20:44:30 DEBUG TSF:MSG:FPAR REQ,ID=2
    Oct 13 20:44:30 DEBUG TSF:CKU:OK,FCTRL
    Oct 13 20:44:30 DEBUG TSF:MSG:GWL OK
    Oct 13 20:44:31 DEBUG !TSF:MSG:SEND,0-0-2-2,s=255,c=3,t=8,pt=1,l=1,sg=0,ft=0,st=NACK:0
    Oct 13 20:44:32 DEBUG TSF:MSG:READ,2-2-255,s=255,c=3,t=7,pt=0,l=0,sg=0:
    Oct 13 20:44:32 DEBUG TSF:MSG:BC
    Oct 13 20:44:32 DEBUG TSF:MSG:FPAR REQ,ID=2
    Oct 13 20:44:32 DEBUG TSF:CKU:OK,FCTRL
    Oct 13 20:44:32 DEBUG TSF:MSG:GWL OK
    Oct 13 20:44:34 DEBUG !TSF:MSG:SEND,0-0-2-2,s=255,c=3,t=8,pt=1,l=1,sg=0,ft=0,st=NACK:0
    Oct 13 20:45:35 DEBUG TSF:MSG:READ,2-2-255,s=255,c=3,t=7,pt=0,l=0,sg=0:
    Oct 13 20:45:35 DEBUG TSF:MSG:BC
    Oct 13 20:45:35 DEBUG TSF:MSG:FPAR REQ,ID=2
    Oct 13 20:45:35 DEBUG TSF:PNG:SEND,TO=0
    Oct 13 20:45:35 DEBUG TSF:CKU:OK
    Oct 13 20:45:35 DEBUG TSF:MSG:GWL OK
    Oct 13 20:45:37 DEBUG !TSF:MSG:SEND,0-0-2-2,s=255,c=3,t=8,pt=1,l=1,sg=0,ft=0,st=NACK:0
    
    

    This is the node's code:

    
    /**
     * The MySensors Arduino library handles the wireless radio link and protocol
     * between your home built sensors/actuators and HA controller of choice.
     * The sensors forms a self healing radio network with optional repeaters. Each
     * repeater and gateway builds a routing tables in EEPROM which keeps track of the
     * network topology allowing messages to be routed to nodes.
     *
     * Created by Henrik Ekblad <henrik.ekblad@mysensors.org>
     * Copyright (C) 2013-2015 Sensnology AB
     * Full contributor list: https://github.com/mysensors/Arduino/graphs/contributors
     *
     * Documentation: http://www.mysensors.org
     * Support Forum: http://forum.mysensors.org
     *
     * This program is free software; you can redistribute it and/or
     * modify it under the terms of the GNU General Public License
     * version 2 as published by the Free Software Foundation.
     *
     *******************************
     *
     * REVISION HISTORY
     * Version 1.0: Henrik EKblad
     * Version 1.1 - 2016-07-20: Converted to MySensors v2.0 and added various improvements - Torben Woltjen (mozzbozz)
     * 
     * DESCRIPTION
     * This sketch provides an example of how to implement a humidity/temperature
     * sensor using a DHT11/DHT-22.
     *  
     * For more information, please visit:
     * http://www.mysensors.org/build/humidity
     * 
     */
    
    // Enable debug prints
    #define MY_DEBUG
    
    // Atualizar para nó esperado
    #define MY_NODE_ID 2
    
    // Novo driver para gateway RPI
    #define MY_RFM69_NEW_DRIVER
    
    // Enable and select radio type attached 
    #define MY_RADIO_RFM69
    
    #define MY_RFM69_FREQUENCY RFM69_433MHZ  // Define for frequency setting. Needed if you're radio module isn't 868Mhz (868Mhz is default in lib)
    #define MY_IS_RFM69HW  // Mandatory if you radio module is the high power version (RFM69HW and RFM69HCW), Comment it if it's not the case
    
    #include <SPI.h>
    #include <MySensors.h>  
    #include <DHT.h>
    #include <NewPing.h>
    
    // Set this to the pin you connected the DHT's data pin to
    #define DHT_DATA_PIN 3
    // Sonar parameters
    #define TRIGGER_PIN  8  // Arduino pin tied to trigger pin on the ultrasonic sensor.
    #define ECHO_PIN     9  // Arduino pin tied to echo pin on the ultrasonic sensor.
    #define MAX_DISTANCE 200 // Maximum distance we want to ping for (in centimeters). Maximum sensor distance is rated at 400-500cm.
    #define ITERATIONS     5 // Number of iterations.
    
    // Set this offset if the sensor has a permanent small offset to the real temperatures.
    // In Celsius degrees (as measured by the device)
    #define SENSOR_TEMP_OFFSET 0
    
    NewPing sonar(TRIGGER_PIN, ECHO_PIN, MAX_DISTANCE); // NewPing setup of pins and maximum distance.
    
    
    
    // Sleep time between sensor updates (in milliseconds)
    // Must be >1000ms for DHT22 and >2000ms for DHT11
    static const uint64_t UPDATE_INTERVAL = 600000; // 600000 = 10 min
    
    // Force sending an update of the temperature after n sensor reads, so a controller showing the
    // timestamp of the last update doesn't show something like 3 hours in the unlikely case, that
    // the value didn't change since;
    // i.e. the sensor would force sending an update every UPDATE_INTERVAL*FORCE_UPDATE_N_READS [ms]
    static const uint8_t FORCE_UPDATE_N_READS = 5;
    
    #define CHILD_ID_HUM 0
    #define CHILD_ID_TEMP 1
    #define CHILD_ID_RSSI 2               //RSSI
    #define CHILD_ID_VOLT 3               //Voltage
    #define CHILD_ID_DIST 4                //Distance
    
    
    //float lastTemp;
    //float lastHum;
    //uint8_t nNoUpdatesTemp;
    //uint8_t nNoUpdatesHum;
    bool metric = true;
    int8_t rssiVal;               //RSSI
    uint8_t dist;
    //static const uint8_t update_count = 6; // 6 = every 1 hour
    //uint8_t count = 100;  // > than update_count
    
    
    MyMessage msgHum(CHILD_ID_HUM, V_HUM);
    MyMessage msgTemp(CHILD_ID_TEMP, V_TEMP);
    MyMessage msgRSSI(CHILD_ID_RSSI,V_VAR5);
    MyMessage msgDist(CHILD_ID_DIST, V_DISTANCE);
    MyMessage msgVOLT(CHILD_ID_VOLT,V_VOLTAGE);
    DHT dht;
    
    
    
    void presentation()  
    { 
      // Send the sketch version information to the gateway
      sendSketchInfo("Temperature+Humidity+Sonar", "2.0");
    //  sendSketchInfo("Battery Meter", "1.0");
    //  sendSketchInfo("No02_DHT11+Sonar_v06");
    
      // Register all sensors to gw (they will be created as child devices)
      present(CHILD_ID_HUM, S_HUM);
      present(CHILD_ID_TEMP, S_TEMP);
      present(CHILD_ID_RSSI, S_CUSTOM);
      present(CHILD_ID_DIST, S_DISTANCE);
      present(CHILD_ID_VOLT, S_MULTIMETER);
    
    
      metric = getControllerConfig().isMetric;
    }
    
    
    void setup()
    {
      // Battery
      // use the 1.1 V internal reference
      #if defined(__AVR_ATmega2560__)
        analogReference(INTERNAL1V1);
      #else
        analogReference(INTERNAL);
      #endif
      
      dht.setup(DHT_DATA_PIN); // set data pin of DHT sensor
      if (UPDATE_INTERVAL <= dht.getMinimumSamplingPeriod()) {
        Serial.println("Warning: UPDATE_INTERVAL is smaller than supported by the sensor!");
      }
      // Sleep for the time of the minimum sampling period to give the sensor time to power up
      // (otherwise, timeout errors might occure for the first reading)
      sleep(dht.getMinimumSamplingPeriod());
    }
    
    
    void loop()      
    {  
      // Force reading sensor, so it works also after sleep()
      dht.readSensor(true);
    
      // Get temperature from DHT library
      float temperature = dht.getTemperature();
      if (isnan(temperature)) {
        Serial.println("Failed reading temperature from DHT!");
      } else {
    //  } else if (temperature != lastTemp || nNoUpdatesTemp == FORCE_UPDATE_N_READS) {
        // Only send temperature if it changed since the last measurement or if we didn't send an update for n times
    //    lastTemp = temperature;
    
        // apply the offset before converting to something different than Celsius degrees
          temperature += SENSOR_TEMP_OFFSET;
      
          if (!metric) {
            temperature = dht.toFahrenheit(temperature);
          }
        // Reset no updates counter
    //    nNoUpdatesTemp = 0;
        send(msgTemp.set(temperature, 2));
        #ifdef MY_DEBUG
          Serial.print("T: ");
          Serial.println(temperature);
        #endif
    //  } else {
        // Increase no update counter if the temperature stayed the same
    //    nNoUpdatesTemp++;
      }
    
      // Get humidity from DHT library
      float humidity = dht.getHumidity();
      if (isnan(humidity)) {
        Serial.println("Failed reading humidity from DHT");
      } else {
    //  } else if (humidity != lastHum || nNoUpdatesHum == FORCE_UPDATE_N_READS) {
        // Only send humidity if it changed since the last measurement or if we didn't send an update for n times
    //    lastHum = humidity;
        // Reset no updates counter
    //    nNoUpdatesHum = 0;
        send(msgHum.set(humidity, 2));
    
        #ifdef MY_DEBUG
          Serial.print("H: ");
          Serial.println(humidity);
        #endif
    //  } else {
        // Increase no update counter if the humidity stayed the same
    //    nNoUpdatesHum++;
      }
    
    //  rssiVal = _radio.readRSSI();  // Old Driver
    
      rssiVal = RFM69_getSendingRSSI();  // New Driver
      send(msgRSSI.set(rssiVal));
      #ifdef MY_DEBUG
        Serial.print("RSSI Sending: ");
        Serial.println(rssiVal);
    //    Serial.print("RSSI Receiving: ");
    //    Serial.println(RFM69_getReceivingRSSI());
      #endif
    
      dist = sonar.convert_cm(sonar.ping_median(ITERATIONS, MAX_DISTANCE));
      #ifdef MY_DEBUG
        Serial.print("Dist: ");
        Serial.print(dist);
        Serial.println("cm");      
      #endif
    
      if (dist > 0) {
        dist = 90 - dist;
        send(msgDist.set(dist, 2));
      }
    
      long batteryMillivolts = hwCPUVoltage();
      send(msgVOLT.set(batteryMillivolts / 1000.0, 2));
      #ifdef MY_DEBUG
        Serial.print(batteryMillivolts / 1000.0);
        Serial.println(" V");
      #endif  
    
    
      // Sleep for a while to save energy
      sleep(UPDATE_INTERVAL); 
    }
    

    This is the configuration of the RPI gateway

    ./configure --my-gateway=mqtt --my-controller-ip-address=127.0.0.1 --my-mqtt-user=user --my-mqtt-password=password --my-mqtt-publish-topic-prefix=mygateway1-out --my-mqtt-subscribe-topic-prefix=mygateway1-in --my-mqtt-client-id=gw_02 --my-transport=rfm69 --my-rfm69-frequency=433 --my-is-rfm69hw --extra-cxxflags="-DMY_DEBUG_VERBOSE_GATEWAY"
    

    Thanks!



  • Solved. Issue with power supply. Added a capacidade to power source.


Log in to reply
 

Suggested Topics

  • 3
  • 4
  • 15
  • 3
  • 2
  • 2

0
Online

11.2k
Users

11.1k
Topics

112.5k
Posts