From 116da0f19b484cbd566f0ad8cccede5cadae1d85 Mon Sep 17 00:00:00 2001
From: mmaroti <mmaroti>
Date: Tue, 13 May 2008 09:12:04 +0000
Subject: [PATCH] make the default rxSleepinterval(msg) to be the
 localSleepInterval and Send.cancel improvements

---
 tos/chips/rf230/LowPowerListeningLayerP.nc | 24 +++++++++++++---------
 1 file changed, 14 insertions(+), 10 deletions(-)

diff --git a/tos/chips/rf230/LowPowerListeningLayerP.nc b/tos/chips/rf230/LowPowerListeningLayerP.nc
index d4b2ff79..ef4bac56 100644
--- a/tos/chips/rf230/LowPowerListeningLayerP.nc
+++ b/tos/chips/rf230/LowPowerListeningLayerP.nc
@@ -253,7 +253,7 @@ implementation
 
 	event void Timer.fired()
 	{
-		ASSERT( state == LISTEN || state == SLEEP || state == SEND_SUBSEND|| state == SEND_SUBSEND_DONE );
+		ASSERT( state == LISTEN || state == SLEEP || state == SEND_SUBSEND || state == SEND_SUBSEND_DONE );
 
 		if( state == LISTEN )
 			state = SLEEP_SUBSTOP;
@@ -290,7 +290,7 @@ implementation
 			state = SEND_SUBSTART;
 		else if( state == LISTEN_SUBSTART_DONE )
 			state = SEND_SUBSTART_DONE;
-		else if( state == LISTEN_TIMER || state == SLEEP_SUBSTOP|| state == LISTEN )
+		else if( state == LISTEN_TIMER || state == SLEEP_SUBSTOP || state == LISTEN )
 			state = SEND_TIMER;
 		else
 			return EBUSY;
@@ -307,12 +307,19 @@ implementation
 		if( state == SEND_SUBSEND )
 		{
 			call Timer.stop();
-			state = LISTEN_TIMER;
+			state = SEND_DONE;
+			txError = ECANCEL;
 			post transition();
 
-			// TODO: ask if sendDone should be called after a succesfull cancel
 			return SUCCESS;
 		}
+		else if( state == SEND_SUBSEND_DONE )
+		{
+			// we stop sending the message even if SubSend.cancel was not succesfull
+			state = SEND_SUBSEND_DONE_LAST;
+
+			return call SubSend.cancel(txMsg);
+		}
 		else
 			return FAIL;
 	}
@@ -417,23 +424,20 @@ implementation
 	command uint16_t LowPowerListening.getRxSleepInterval(message_t *msg)
     {
 		if( ! call PacketSleepInterval.isSet(msg) )
-			return 0;
+			return sleepInterval;
 
 		return call PacketSleepInterval.get(msg);
 	}
 
 	command void LowPowerListening.setRxDutyCycle(message_t *msg, uint16_t dutyCycle)
     {
-		call PacketSleepInterval.set(msg, 
+		call LowPowerListening.setRxSleepInterval(msg, 
 			call LowPowerListening.dutyCycleToSleepInterval(dutyCycle));
 	}
 
 	command uint16_t LowPowerListening.getRxDutyCycle(message_t *msg)
     {
-		if( ! call PacketSleepInterval.isSet(msg) )
-			return 10000;
-
 		return call LowPowerListening.sleepIntervalToDutyCycle(
-			call PacketSleepInterval.get(msg));
+			call LowPowerListening.getRxSleepInterval(msg));
 	}
 }
-- 
2.39.2