return true if the message was handled

Device.h

@@ -161,9 +161,9 @@ class Device {
  bool pollRadio () {
  uint8_t num = radio().read(msg);
  if( num > 0 ) {
- process(msg);
+ return process(msg);
  }
- return num > 0;
+ return false;
  }
 
  uint8_t nextcount () {
@@ -172,7 +172,7 @@ class Device {
 
  virtual void configChanged () {}
 
- virtual void process(__attribute__((unused)) Message& msg) {}
+ virtual bool process(__attribute__((unused)) Message& msg) { return false; }
 
  bool isBoardcastMsg(Message msg) {
  return msg.isPairSerial();

MultiChannelDevice.h

@@ -201,24 +201,20 @@ class ChannelDevice : public Device<HalType> {
  return true;
  }
 
- void process(Message& msg) {
+ bool process(Message& msg) {
  HMID devid;
  this->getDeviceID(devid);
  if( msg.to() == devid || (msg.to() == HMID::broadcast && this->isBoardcastMsg(msg))) {
  DPRINT(F("-> "));
  msg.dump();
  // ignore repeated messages
  if( this->isRepeat(msg) == true ) {
- if( msg.ackRequired() == true ) {
- this->sendNack(msg);
- }
- return;
+ return false;
  }
  uint8_t mtype = msg.type();
  uint8_t mcomm = msg.command();
  uint8_t msubc = msg.subcommand();
  if( mtype == AS_MESSAGE_CONFIG ) {
- this->activity().stayAwake(millis2ticks(500));
  // PAIR_SERIAL
  if( msubc == AS_CONFIG_PAIR_SERIAL && this->isDeviceSerial(msg.data())==true ) {
  this->led().set(LedStates::pairing);
@@ -331,7 +327,6 @@ class ChannelDevice : public Device<HalType> {
  else {
  this->sendNack(msg);
  }
- this->activity().stayAwake(millis2ticks(500));
  }
  else if( msubc == AS_CONFIG_SERIAL_REQ ) {
  this->sendSerialInfo(msg.from(),msg.count());
@@ -384,7 +379,6 @@ class ChannelDevice : public Device<HalType> {
  }
  else if( mtype == AS_MESSAGE_HAVE_DATA ) {
  DPRINTLN(F("HAVE DATA"));
- this->activity().stayAwake(millis2ticks(500));
  this->sendAck(msg);
  }
  else if (mtype == AS_MESSAGE_REMOTE_EVENT || mtype == AS_MESSAGE_SENSOR_EVENT) {
@@ -425,9 +419,13 @@ class ChannelDevice : public Device<HalType> {
  }
  }
  else {
-// DPRINT(F("ignore "));
-// msg.dump();
+ DPRINT(F("ignore "));
+ msg.dump();
+ return false;
  }
+ // we always stay awake after valid communication
+ this->activity().stayAwake(millis2ticks(500));
+ return true;
  }
 
  uint8_t channelForPeer (const Peer& p) {