[Tinyos-2-commits] CVS: tinyos-2.x/apps/tests/TestSerialBandwidth
Makefile, NONE, 1.1.4.2 TestSerial.h, NONE,
1.1.4.2 TestSerial.java, NONE, 1.1.4.2 TestSerialAppC.nc, NONE,
1.1.4.2 TestSerialC.nc, NONE, 1.1.4.2 TestSerialMsg.java, NONE,
1.1.4.2
Kevin Klues
klueska at users.sourceforge.net
Mon May 15 11:35:27 PDT 2006
- Previous message: [Tinyos-2-commits]
CVS: tinyos-2.x/apps/tests/TestSerial .cvsignore, NONE,
1.1.4.2 Makefile, NONE, 1.1.4.2 TestSerial.h, NONE,
1.1.4.2 TestSerial.java, NONE, 1.1.4.2 TestSerialAppC.nc, NONE,
1.1.4.2 TestSerialC.nc, NONE, 1.1.4.2
- Next message: [Tinyos-2-commits] CVS: tinyos-2.x/apps/tests/TestSleep Makefile,
NONE, 1.2.2.2 TestSleepC.nc, NONE, 1.2.2.2 TestSleepM.nc, NONE,
1.2.2.2
- Messages sorted by:
[ date ]
[ thread ]
[ subject ]
[ author ]
Update of /cvsroot/tinyos/tinyos-2.x/apps/tests/TestSerialBandwidth
In directory sc8-pr-cvs10.sourceforge.net:/tmp/cvs-serv18756/apps/tests/TestSerialBandwidth
Added Files:
Tag: tos-2-resource-pm-eval-cand
Makefile TestSerial.h TestSerial.java TestSerialAppC.nc
TestSerialC.nc TestSerialMsg.java
Log Message:
Merging the development branch with the resource/power management evaluation branch. After this merge all files except those already commited should be identical.
--- NEW FILE: Makefile ---
COMPONENT=TestSerialAppC
CFLAGS += -I%T/lib/oski
BUILD_EXTRA_DEPS += TestSerialMsg.class TestSerial.class
CFLAGS += -DTOSH_DATA_LENGTH=100
%.class: %.java
javac $<
TestSerialMsg.java:
mig java -target=$(PLATFORM) $(CFLAGS) -java-classname=TestSerialMsg TestSerial.h TestSerialMsg -o $@
include $(MAKERULES)
--- NEW FILE: TestSerial.h ---
typedef nx_struct TestSerialMsg {
nx_uint16_t counter;
nx_uint8_t x[TOSH_DATA_LENGTH-sizeof(nx_uint16_t)];
} TestSerialMsg;
enum {
AM_TESTSERIALMSG = 9,
};
--- NEW FILE: TestSerial.java ---
/* tab:4
* "Copyright (c) 2005 The Regents of the University of California.
* All rights reserved.
*
* Permission to use, copy, modify, and distribute this software and
* its documentation for any purpose, without fee, and without written
* agreement is hereby granted, provided that the above copyright
* notice, the following two paragraphs and the author appear in all
* copies of this software.
*
* IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY
* PARTY FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL
* DAMAGES ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS
* DOCUMENTATION, EVEN IF THE UNIVERSITY OF CALIFORNIA HAS BEEN
* ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
* THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
* INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
* AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE PROVIDED HEREUNDER IS
* ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
* PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS."
*
*/
/**
* Java-side application for testing serial port communication.
*
*
* @author Phil Levis <pal at cs.berkeley.edu>
* @date August 12 2005
*/
import java.io.IOException;
import net.tinyos.message.*;
import net.tinyos.packet.*;
import net.tinyos.util.*;
public class TestSerial implements MessageListener {
private MoteIF moteIF;
public TestSerial(MoteIF moteIF) {
this.moteIF = moteIF;
this.moteIF.registerListener(new TestSerialMsg(), this);
}
public void sendPackets() {
int counter = 0;
TestSerialMsg payload = new TestSerialMsg();
try {
while (true) {
System.out.println("Sending packet " + counter);
payload.set_counter(counter);
moteIF.send(0, payload);
counter++;
try {Thread.sleep(1000);}
catch (InterruptedException exception) {}
}
}
catch (IOException exception) {
System.err.println("Exception thrown when sending packets. Exiting.");
System.err.println(exception);
}
}
public void messageReceived(int to, Message message) {
TestSerialMsg msg = (TestSerialMsg)message;
System.out.println("Received packet sequence number " + msg.get_counter());
}
private static void usage() {
System.err.println("usage: TestSerial [-comm <source>]");
}
public static void main(String[] args) throws Exception {
String source = "";
System.out.println("hello");
if (args.length == 2) {
if (!args[0].equals("-comm")) {
usage();
System.exit(1);
}
source = args[1];
}
else if (args.length != 0) {
usage();
System.exit(1);
}
PhoenixSource phoenix;
if (source == null) {
phoenix = BuildSource.makePhoenix(PrintStreamMessenger.err);
}
else {
phoenix = BuildSource.makePhoenix(source, PrintStreamMessenger.err);
}
System.out.println("goodbye");
MoteIF mif = new MoteIF(phoenix);
TestSerial serial = new TestSerial(mif);
serial.sendPackets();
}
}
--- NEW FILE: TestSerialAppC.nc ---
// $Id: TestSerialAppC.nc,v 1.1.4.2 2006/05/15 18:35:25 klueska Exp $
/* tab:4
* "Copyright (c) 2000-2005 The Regents of the University of California.
* All rights reserved.
*
* Permission to use, copy, modify, and distribute this software and its
* documentation for any purpose, without fee, and without written agreement is
* hereby granted, provided that the above copyright notice, the following
* two paragraphs and the author appear in all copies of this software.
*
* IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY FOR
* DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING OUT
* OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF THE UNIVERSITY OF
* CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
* THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
* INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
* AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE PROVIDED HEREUNDER IS
* ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
* PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS."
*
* Copyright (c) 2002-2005 Intel Corporation
* All rights reserved.
*
* This file is distributed under the terms in the attached INTEL-LICENSE
* file. If you do not find these files, copies can be found by writing to
* Intel Research Berkeley, 2150 Shattuck Avenue, Suite 1300, Berkeley, CA,
* 94704. Attention: Intel License Inquiry.
*/
/**
* Application to test that the TinyOS java toolchain can communicate
* with motes over the serial port. The application sends packets to
* the serial port at 1Hz: the packet contains an incrementing
* counter. When the application receives a counter packet, it
* displays the bottom three bits on its LEDs. This application is
* very similar to RadioCountToLeds, except that it operates over the
* serial port. There is Java application for testing the mote
* application: run TestSerial to print out the received packets and
* send packets to the mote.
*
* @author Gilman Tolle
* @author Philip Levis
*
* @date Aug 12 2005
*
**/
#include "TestSerial.h"
configuration TestSerialAppC {}
implementation {
components TestSerialC as App, LedsC, MainC;
components SerialActiveMessageC as AM;
components new TimerMilliC();
MainC.SoftwareInit -> AM;
App.Boot -> MainC.Boot;
App.Control -> AM;
App.Receive -> AM.Receive[AM_TESTSERIALMSG];
App.AMSend -> AM.AMSend[AM_TESTSERIALMSG];
App.Leds -> LedsC;
App.MilliTimer -> TimerMilliC;
App.Packet -> AM;
}
--- NEW FILE: TestSerialC.nc ---
// $Id: TestSerialC.nc,v 1.1.4.2 2006/05/15 18:35:25 klueska Exp $
/* tab:4
* "Copyright (c) 2000-2005 The Regents of the University of California.
* All rights reserved.
*
* Permission to use, copy, modify, and distribute this software and its
* documentation for any purpose, without fee, and without written agreement is
* hereby granted, provided that the above copyright notice, the following
* two paragraphs and the author appear in all copies of this software.
*
* IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY FOR
* DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING OUT
* OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF THE UNIVERSITY OF
* CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
* THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
* INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
* AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE PROVIDED HEREUNDER IS
* ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
* PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS."
*
* Copyright (c) 2002-2003 Intel Corporation
* All rights reserved.
*
* This file is distributed under the terms in the attached INTEL-LICENSE
* file. If you do not find these files, copies can be found by writing to
* Intel Research Berkeley, 2150 Shattuck Avenue, Suite 1300, Berkeley, CA,
* 94704. Attention: Intel License Inquiry.
*/
/**
* Application to test that the TinyOS java toolchain can communicate
* with motes over the serial port. The application sends packets to
* the serial port at 1Hz: the packet contains an incrementing
* counter. When the application receives a counter packet, it
* displays the bottom three bits on its LEDs. This application is
* very similar to RadioCountToLeds, except that it operates over the
* serial port. There is Java application for testing the mote
* application: run TestSerial to print out the received packets and
* send packets to the mote.
*
* @author Gilman Tolle
* @author Philip Levis
*
* @date Aug 12 2005
*
**/
#include "Timer.h"
#include "TestSerial.h"
module TestSerialC {
uses {
interface SplitControl as Control;
interface Leds;
interface Boot;
interface Receive;
interface AMSend;
interface Timer<TMilli> as MilliTimer;
interface Packet;
}
}
implementation {
message_t packet;
bool locked;
bool afap = TRUE;
uint32_t interval = 10;
uint16_t counter = 0;
event void Boot.booted() {
call Control.start();
}
event void MilliTimer.fired() {
counter++;
if (locked) {
if (afap) call MilliTimer.startPeriodic(interval);
return;
}
else {
TestSerialMsg* rcm = (TestSerialMsg*)call Packet.getPayload(&packet, NULL);
if (call Packet.maxPayloadLength() < sizeof(TestSerialMsg)) {
return;
}
rcm->counter = counter;
if (call AMSend.send(AM_BROADCAST_ADDR, &packet, sizeof(TestSerialMsg)) == SUCCESS) {
locked = TRUE;
}
}
}
event message_t* Receive.receive(message_t* bufPtr,
void* payload, uint8_t len) {
if (len != sizeof(TestSerialMsg)) {return bufPtr;}
else {
TestSerialMsg* rcm = (TestSerialMsg*)payload;
if (rcm->counter & 0x1) {
call Leds.led0On();
}
else {
call Leds.led0Off();
}
if (rcm->counter & 0x2) {
call Leds.led1On();
}
else {
call Leds.led1Off();
}
if (rcm->counter & 0x4) {
call Leds.led2On();
}
else {
call Leds.led2Off();
}
return bufPtr;
}
}
event void AMSend.sendDone(message_t* bufPtr, error_t error) {
if (&packet == bufPtr) {
locked = FALSE;
// as fast as possible
if (afap){
TestSerialMsg* rcm = (TestSerialMsg*)call Packet.getPayload(&packet,NULL);
counter++;
rcm->counter = counter;
call Leds.led0Toggle();
if (call AMSend.send(AM_BROADCAST_ADDR, &packet, sizeof(TestSerialMsg)) == SUCCESS) {
locked = TRUE;
}
else {
call MilliTimer.startOneShot(interval);
}
}
}
}
event void Control.startDone(error_t err) {
if (err == SUCCESS) {
if (afap){
call MilliTimer.startOneShot(interval);
}
else {
call MilliTimer.startPeriodic(interval);
}
}
}
event void Control.stopDone(error_t err) {}
}
--- NEW FILE: TestSerialMsg.java ---
/**
* This class is automatically generated by mig. DO NOT EDIT THIS FILE.
* This class implements a Java interface to the 'TestSerialMsg'
* message type.
*/
public class TestSerialMsg extends net.tinyos.message.Message {
/** The default size of this message type in bytes. */
public static final int DEFAULT_MESSAGE_SIZE = 100;
/** The Active Message type associated with this message. */
public static final int AM_TYPE = 9;
/** Create a new TestSerialMsg of size 100. */
public TestSerialMsg() {
super(DEFAULT_MESSAGE_SIZE);
amTypeSet(AM_TYPE);
}
/** Create a new TestSerialMsg of the given data_length. */
public TestSerialMsg(int data_length) {
super(data_length);
amTypeSet(AM_TYPE);
}
/**
* Create a new TestSerialMsg with the given data_length
* and base offset.
*/
public TestSerialMsg(int data_length, int base_offset) {
super(data_length, base_offset);
amTypeSet(AM_TYPE);
}
/**
* Create a new TestSerialMsg using the given byte array
* as backing store.
*/
public TestSerialMsg(byte[] data) {
super(data);
amTypeSet(AM_TYPE);
}
/**
* Create a new TestSerialMsg using the given byte array
* as backing store, with the given base offset.
*/
public TestSerialMsg(byte[] data, int base_offset) {
super(data, base_offset);
amTypeSet(AM_TYPE);
}
/**
* Create a new TestSerialMsg using the given byte array
* as backing store, with the given base offset and data length.
*/
public TestSerialMsg(byte[] data, int base_offset, int data_length) {
super(data, base_offset, data_length);
amTypeSet(AM_TYPE);
}
/**
* Create a new TestSerialMsg embedded in the given message
* at the given base offset.
*/
public TestSerialMsg(net.tinyos.message.Message msg, int base_offset) {
super(msg, base_offset, DEFAULT_MESSAGE_SIZE);
amTypeSet(AM_TYPE);
}
/**
* Create a new TestSerialMsg embedded in the given message
* at the given base offset and length.
*/
public TestSerialMsg(net.tinyos.message.Message msg, int base_offset, int data_length) {
super(msg, base_offset, data_length);
amTypeSet(AM_TYPE);
}
/**
/* Return a String representation of this message. Includes the
* message type name and the non-indexed field values.
*/
public String toString() {
String s = "Message <TestSerialMsg> \n";
try {
s += " [counter=0x"+Long.toHexString(get_counter())+"]\n";
} catch (ArrayIndexOutOfBoundsException aioobe) { /* Skip field */ }
try {
s += " [x=";
for (int i = 0; i < 98; i++) {
s += "0x"+Long.toHexString(getElement_x(i) & 0xff)+" ";
}
s += "]\n";
} catch (ArrayIndexOutOfBoundsException aioobe) { /* Skip field */ }
return s;
}
// Message-type-specific access methods appear below.
/////////////////////////////////////////////////////////
// Accessor methods for field: counter
// Field type: int, unsigned
// Offset (bits): 0
// Size (bits): 16
/////////////////////////////////////////////////////////
/**
* Return whether the field 'counter' is signed (false).
*/
public static boolean isSigned_counter() {
return false;
}
/**
* Return whether the field 'counter' is an array (false).
*/
public static boolean isArray_counter() {
return false;
}
/**
* Return the offset (in bytes) of the field 'counter'
*/
public static int offset_counter() {
return (0 / 8);
}
/**
* Return the offset (in bits) of the field 'counter'
*/
public static int offsetBits_counter() {
return 0;
}
/**
* Return the value (as a int) of the field 'counter'
*/
public int get_counter() {
return (int)getUIntBEElement(offsetBits_counter(), 16);
}
/**
* Set the value of the field 'counter'
*/
public void set_counter(int value) {
setUIntBEElement(offsetBits_counter(), 16, value);
}
/**
* Return the size, in bytes, of the field 'counter'
*/
public static int size_counter() {
return (16 / 8);
}
/**
* Return the size, in bits, of the field 'counter'
*/
public static int sizeBits_counter() {
return 16;
}
/////////////////////////////////////////////////////////
// Accessor methods for field: x
// Field type: short[], unsigned
// Offset (bits): 16
// Size of each element (bits): 8
/////////////////////////////////////////////////////////
/**
* Return whether the field 'x' is signed (false).
*/
public static boolean isSigned_x() {
return false;
}
/**
* Return whether the field 'x' is an array (true).
*/
public static boolean isArray_x() {
return true;
}
/**
* Return the offset (in bytes) of the field 'x'
*/
public static int offset_x(int index1) {
int offset = 16;
if (index1 < 0 || index1 >= 98) throw new ArrayIndexOutOfBoundsException();
offset += 0 + index1 * 8;
return (offset / 8);
}
/**
* Return the offset (in bits) of the field 'x'
*/
public static int offsetBits_x(int index1) {
int offset = 16;
if (index1 < 0 || index1 >= 98) throw new ArrayIndexOutOfBoundsException();
offset += 0 + index1 * 8;
return offset;
}
/**
* Return the entire array 'x' as a short[]
*/
public short[] get_x() {
short[] tmp = new short[98];
for (int index0 = 0; index0 < numElements_x(0); index0++) {
tmp[index0] = getElement_x(index0);
}
return tmp;
}
/**
* Set the contents of the array 'x' from the given short[]
*/
public void set_x(short[] value) {
for (int index0 = 0; index0 < value.length; index0++) {
setElement_x(index0, value[index0]);
}
}
/**
* Return an element (as a short) of the array 'x'
*/
public short getElement_x(int index1) {
return (short)getUIntBEElement(offsetBits_x(index1), 8);
}
/**
* Set an element of the array 'x'
*/
public void setElement_x(int index1, short value) {
setUIntBEElement(offsetBits_x(index1), 8, value);
}
/**
* Return the total size, in bytes, of the array 'x'
*/
public static int totalSize_x() {
return (784 / 8);
}
/**
* Return the total size, in bits, of the array 'x'
*/
public static int totalSizeBits_x() {
return 784;
}
/**
* Return the size, in bytes, of each element of the array 'x'
*/
public static int elementSize_x() {
return (8 / 8);
}
/**
* Return the size, in bits, of each element of the array 'x'
*/
public static int elementSizeBits_x() {
return 8;
}
/**
* Return the number of dimensions in the array 'x'
*/
public static int numDimensions_x() {
return 1;
}
/**
* Return the number of elements in the array 'x'
*/
public static int numElements_x() {
return 98;
}
/**
* Return the number of elements in the array 'x'
* for the given dimension.
*/
public static int numElements_x(int dimension) {
int array_dims[] = { 98, };
if (dimension < 0 || dimension >= 1) throw new ArrayIndexOutOfBoundsException();
if (array_dims[dimension] == 0) throw new IllegalArgumentException("Array dimension "+dimension+" has unknown size");
return array_dims[dimension];
}
/**
* Fill in the array 'x' with a String
*/
public void setString_x(String s) {
int len = s.length();
int i;
for (i = 0; i < len; i++) {
setElement_x(i, (short)s.charAt(i));
}
setElement_x(i, (short)0); //null terminate
}
/**
* Read the array 'x' as a String
*/
public String getString_x() {
char carr[] = new char[Math.min(net.tinyos.message.Message.MAX_CONVERTED_STRING_LENGTH,98)];
int i;
for (i = 0; i < carr.length; i++) {
if ((char)getElement_x(i) == (char)0) break;
carr[i] = (char)getElement_x(i);
}
return new String(carr,0,i);
}
}
- Previous message: [Tinyos-2-commits]
CVS: tinyos-2.x/apps/tests/TestSerial .cvsignore, NONE,
1.1.4.2 Makefile, NONE, 1.1.4.2 TestSerial.h, NONE,
1.1.4.2 TestSerial.java, NONE, 1.1.4.2 TestSerialAppC.nc, NONE,
1.1.4.2 TestSerialC.nc, NONE, 1.1.4.2
- Next message: [Tinyos-2-commits] CVS: tinyos-2.x/apps/tests/TestSleep Makefile,
NONE, 1.2.2.2 TestSleepC.nc, NONE, 1.2.2.2 TestSleepM.nc, NONE,
1.2.2.2
- Messages sorted by:
[ date ]
[ thread ]
[ subject ]
[ author ]
More information about the Tinyos-2-commits
mailing list