[Tinyos-help] TOSSIM doesn't seem to raise events if node behavior depends on variable

[Victor Cionca]

Hello!

I am trying to run some tests on tmotes using tinyos 2. As it's uneasy
to re-program a whole set of motes by plugging/unplugging from usb, i
started learning TOSSIM.

Now, I am a beginner at this, I've only read the tutorial (parts) and
ran some basic tests on the motes.

I'm using 4 motes: 1 is an initiator that makes the others start an
activity. The program assigns initiator title to mote with id 0, right
at boot (boot event).
The initiator just sends a special packet to everyone else. 

To achieve this I start the radio, and when that is done (startDone),
the node will only send an initiator packet if it is the initiator. So
the startDone event looks like this:

event void SplitControl.startDone(error_t err){
	dbg("Boot", "Radio started\n");
	if (err == SUCCESS){
		if (iAmInitiator){
			MSPacket *initPacket = (MSPacket *)
				(call Packet.getPayload(&radio_packet, NULL));
		buildInitPacket(initPacket);
		if (SEND == SUCCESS){
			dbg("MS", "Packet sent to radio\n");
			radioBusy = TRUE;
		}
		call Leds.led1On();
	}
	}else{
		dbg("Boot", "Unable to start radio\n");
		call SplitControl.start();
	}
}

The only problem is that the sendDone event is never called.

I have tried changing the if (iAmInitiator) to if (TRUE) and it works.
So this means that it doesn't work when the node can have different
behavior depending on a state variable. 

Is this true, or is there something in my code? Here's all of it. (the
module part).

Best regards,
Victor Cionca

#include "MSH.h"

#define SEND (call AMSend.send(AM_BROADCAST_ADDR, &radio_packet,
sizeof(MSPacket)))
#define SEND_TO(X) (call AMSend.send((X), &radio_packet,
sizeof(MSPacket)))

module MSModC{
	uses interface Boot;

	uses interface Packet;
	uses interface AMPacket;
	uses interface AMSend;
	uses interface Receive;
	uses interface SplitControl;

	uses interface Leds;

	//uses interface RadioBackoff;
}

implementation{
	bool numberSet;
	uint8_t number;
	bool iAmInitiator;
	message_t radio_packet;
	bool radioBusy = FALSE;

	void buildInitPacket(MSPacket*);
	void buildBeaconPacket(MSPacket *packet, bool isMaster);
	void buildCorrectionPacket(MSPacket *packet, uint8_t number_t);
	
	event void Boot.booted(){
		if (TOS_NODE_ID == 0) iAmInitiator = TRUE;
		else iAmInitiator = FALSE;
		numberSet = FALSE;
		number = 1;

		call Leds.led0Off();
		call Leds.led1Off();
		call Leds.led2Off();

		//start radio
		call SplitControl.start();

		dbg("Boot", "Booted as node %d role = %s\n", TOS_NODE_ID,
((iAmInitiator)?"initiator":"regular"));
	}

	void send_init_packet(){
		if (iAmInitiator){
			MSPacket *initPacket = (MSPacket *)
				(call Packet.getPayload(&radio_packet, NULL));
			buildInitPacket(initPacket);
			if (SEND == SUCCESS){
				dbg("MS", "Packet sent to radio\n");
				radioBusy = TRUE;
			}

			call Leds.led1On();
		}
	}

	event void SplitControl.startDone(error_t err){
		dbg("Boot", "Radio started\n");
		if (err == SUCCESS){
			send_init_packet();
		}else{
			dbg("Boot", "Unable to start radio\n");
			call SplitControl.start();
		}
	}

	event void SplitControl.stopDone(error_t err){
	}

	event void AMSend.sendDone(message_t *msg, error_t err){
		dbg("MS", "Packet sent\n");
		if (msg == &radio_packet){
			MSPacket *packet;
			radioBusy = FALSE;

			packet = (MSPacket*)(call Packet.getPayload(&radio_packet, NULL));
			if (packet->type == BEACON){
			       numberSet = TRUE;
			       call Leds.set(number);
			       dbg("MS", "Beacon packet sent. Number set\n");
			}
		}
	}

	void receivedInitPacket(MSPacket *packet){
		//if receive init packet, activate (turn leds on)
		//call Leds.set(TOS_NODE_ID);		

		//if receive init packet switch to beacon mode
		MSPacket *beacon;

		//send beacon packet
		beacon = (MSPacket*)(call Packet.getPayload(&radio_packet, NULL));
		buildBeaconPacket(beacon, number);
		if (SEND == SUCCESS){
			radioBusy = TRUE;
		}

		dbg("MS", "Received init packet\n");

	}

	void receivedBeaconPacket(message_t *msg, MSPacket *packet){
		dbg("MS", "Received beacon packet. Number is %s\n",
((numberSet)?"set":"not set"));
		if (numberSet == FALSE){
			MSPacket *crtNumber;

			//increment number
			number++;

			//build beacon packet
			crtNumber = (MSPacket*)(call Packet.getPayload(&radio_packet, NULL));

			buildBeaconPacket(crtNumber, number);

			//send it
			if (SEND == SUCCESS){
				radioBusy = TRUE;
			}
		}else{//on the else side treat corrections in node discovery
			if (packet->number <= number){
				am_addr_t source_add;
				MSPacket *crtNumber;
				crtNumber = (MSPacket*)(call Packet.getPayload(&radio_packet,
NULL));
				buildCorrectionPacket(crtNumber, number);

				source_add = call AMPacket.source(msg);
				if (SEND_TO(source_add) == SUCCESS){
					radioBusy = TRUE;
				}
			}
		}
	}

	void receivedCorrectionPacket(MSPacket *packet){
		dbg("MS", "Received correction packet number %d\n", packet->number);
		if (packet->number >= number) number = packet->number + 1;
		call Leds.set(number);
	}

	void buildInitPacket(MSPacket *packet){
		packet->mote_id = TOS_NODE_ID;
		packet->type = INIT;
	}

	void buildBeaconPacket(MSPacket *packet, uint8_t nr){
		packet->mote_id = TOS_NODE_ID;
		packet->type = BEACON;
		packet->number = nr;
	}

	void buildCorrectionPacket(MSPacket *packet, uint8_t nr){
		packet->mote_id = TOS_NODE_ID;
		packet->type = CORRECTION;
		packet->number = nr;
	}

	event message_t *Receive.receive(message_t *msg, void *payload, uint8_t
len){
		MSPacket *packet;
		dbg("MS", "Received packet\n");
		if (len != sizeof(MSPacket)) return msg; //just ignore

		//get payload
		packet = (MSPacket*)payload;

		switch (packet->type){
			/**
			 * Hack for node discovery:
			 * if node settled on number will not reinit
			 */
			case INIT:{
					  if (numberSet == FALSE){
						  receivedInitPacket(packet);
					  }
					  break;
				  }
			case BEACON:{ 
					    //initiator ignores beacon messages
					    if (iAmInitiator) break;
					    receivedBeaconPacket(msg, packet); break;
				    }
			case CORRECTION:{
						if (call AMPacket.isForMe(msg)){
							receivedCorrectionPacket(packet);
						}
						break; //upon new node
					}
			default: break;
		}
		return msg;
	}

}