Fix the apps affected by the changes in the LowPowerListening interface.

[tinyos-2.x.git] / apps / tests / cc2420 / LplBroadcastPeriodicDelivery / TestPeriodicC.nc

diff --git a/apps/tests/cc2420/LplBroadcastPeriodicDelivery/TestPeriodicC.nc b/apps/tests/cc2420/LplBroadcastPeriodicDelivery/TestPeriodicC.nc
index 553bf8445ddbfc152f4e10cce24e74143ab6cd10..9e7dfff9afb128e7336329632a18bb09bf41bb58 100644 (file)
--- a/apps/tests/cc2420/LplBroadcastPeriodicDelivery/TestPeriodicC.nc
+++ b/apps/tests/cc2420/LplBroadcastPeriodicDelivery/TestPeriodicC.nc
@@ -29,48 +29,107 @@
  * OF THE POSSIBILITY OF SUCH DAMAGE
  */
 
+#include "TestPeriodic.h"
+
 /**
  * This app sends a message from Transmitter node to AM_BROADCAST_ADDR
  * and waits 1000 ms between each delivery so the Rx mote's radio
  * shuts back off and has to redetect to receive the next message. 
- * Receiver: TOS_NODE_ID != 1
- * Transmitter: TOS_NODE_ID == 1
+ * Receiver: TOS_NODE_ID != 1.
+ * Transmitter: TOS_NODE_ID == 1.
  *
  * @author David Moss
  */
- 
-#include "TestPeriodic.h"
 
-configuration TestPeriodicC {
+module TestPeriodicC {
+  uses {
+    interface Boot;
+    interface SplitControl;
+    interface LowPowerListening;
+    interface AMSend;
+    interface Receive;
+    interface AMPacket;
+    interface Packet;
+    interface Leds;
+    interface Timer<TMilli>;
+  }
 }
 
 implementation {
+ 
+  uint8_t count;
+  message_t fullMsg;
+  bool transmitter;
+
+  uint8_t lastCount;
+  
+  /**************** Prototypes ****************/
+  task void send();
+  
+  /**************** Boot Events ****************/
+  event void Boot.booted() {
+    transmitter = (call AMPacket.address() == 1);
+    count = 0;
+    
+    call LowPowerListening.setLocalWakeupInterval(1000);
+    call SplitControl.start();
+  }
+  
+  event void SplitControl.startDone(error_t error) {
+    if(transmitter) {
+      post send();
+    }
+  }
+  
+  event void SplitControl.stopDone(error_t error) {
+  }
+  
+  
+  /**************** Send Receive Events *****************/
+  event void AMSend.sendDone(message_t *msg, error_t error) {
+    if(transmitter) {
+      count++; 
+      call Timer.startOneShot(1000);
+      call Leds.led0Off();
+    }
+  }
+  
+  event message_t *Receive.receive(message_t *msg, void *payload, uint8_t len) {
+    TestPeriodicMsg *periodicMsg = (TestPeriodicMsg *) payload;
 
-#if defined(PLATFORM_MICA2) || defined(PLATFORM_MICA2DOT)
-  components CC1000ActiveMessageC as Lpl;
-#elif defined(PLATFORM_MICAZ) || defined(PLATFORM_TELOSB)
-  components CC2420ActiveMessageC as Lpl;
-#else
-#error "LPL testing not supported on this platform"
-#endif
+    if(!transmitter) {
+      if(lastCount == periodicMsg->count) {
+        call Leds.led0On();
+        call Leds.led1Off();
+      } else {
+        call Leds.led1On();
+        call Leds.led0Off();
+      }
 
-  components TestPeriodicP,
-      MainC,
-      ActiveMessageC,
-      new TimerMilliC(),
-      new AMSenderC(AM_TESTPERIODICMSG),
-      new AMReceiverC(AM_TESTPERIODICMSG),
-      LedsC;
-      
-  TestPeriodicP.Boot -> MainC;
-  TestPeriodicP.SplitControl -> ActiveMessageC;
-  TestPeriodicP.LowPowerListening -> Lpl;
-  TestPeriodicP.AMPacket -> ActiveMessageC;
-  TestPeriodicP.AMSend -> AMSenderC;
-  TestPeriodicP.Receive -> AMReceiverC;
-  TestPeriodicP.Packet -> ActiveMessageC;
-  TestPeriodicP.Timer -> TimerMilliC;
-  TestPeriodicP.Leds -> LedsC;
+      lastCount = periodicMsg->count;
 
+      call Leds.led2Toggle();
+    }
+    return msg;
+  }
+  
+  /**************** Timer Events ****************/
+  event void Timer.fired() {
+    if(transmitter) {
+      post send();
+    }
+  }
+  
+  /**************** Tasks ****************/
+  task void send() {
+    TestPeriodicMsg *periodicMsg = (TestPeriodicMsg *) call Packet.getPayload(&fullMsg, sizeof(TestPeriodicMsg));
+    periodicMsg->count = count;
+    call LowPowerListening.setRemoteWakeupInterval(&fullMsg, 1000);
+    if(call AMSend.send(AM_BROADCAST_ADDR, &fullMsg, sizeof(TestPeriodicMsg)) != SUCCESS) {
+      post send();
+    } else {
+      call Leds.led0On();
+    }
+  }
 }