* OF THE POSSIBILITY OF SUCH DAMAGE
*/
+#include "TestPeriodic.h"
+
/**
+ * This app sends a message from Transmitter node to the recevier node
+ * 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.
+ *
* @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 {
-
-#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
-
- 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;
-
+
+ uint8_t count;
+ message_t fullMsg;
+ bool transmitter;
+
+ /**************** Prototypes ****************/
+ task void send();
+
+ /**************** Boot Events ****************/
+ event void Boot.booted() {
+ transmitter = (call AMPacket.address() != 0);
+ 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) {
+ if(!transmitter) {
+ call Leds.led1Toggle();
+ }
+ 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(0, &fullMsg, sizeof(TestPeriodicMsg)) != SUCCESS) {
+ post send();
+ } else {
+ call Leds.led0On();
+ }
+ }
}