Sun SPOT offline sensing client

To monitor an activity, sometimes base station is not in communication range. SPOT should be able to store data in its internal memory. When the base station is avaliable, it could send data back to PC.
this is how it works:
1. start SPOT
2. before your activity, click left button on SPOT,and it is recording
3. click left button again to pause recording
4. take it back, click right button on SPOT to send recoreded back to base station

SPOT Side:

/*
 * StartApplication.java
 *
 * Created on Sep 15, 2009 4:32:39 PM;
 */
package org.sunspotworld;

import com.sun.spot.sensorboard.EDemoBoard;
import com.sun.spot.sensorboard.peripheral.ISwitch;
import com.sun.spot.sensorboard.peripheral.ITriColorLED;
import com.sun.spot.peripheral.radio.RadioFactory;
import com.sun.spot.io.j2me.radiostream.*;
import com.sun.spot.peripheral.NoRouteException;
import com.sun.spot.sensorboard.peripheral.IAccelerometer3D;
import com.sun.spot.sensorboard.peripheral.ILightSensor;
import com.sun.spot.sensorboard.peripheral.ISwitchListener;
import com.sun.spot.sensorboard.peripheral.ITemperatureInput;
import com.sun.spot.util.*;

import java.io.*;
import java.util.Date;
import javax.microedition.io.*;
import javax.microedition.midlet.MIDlet;
import javax.microedition.midlet.MIDletStateChangeException;
import javax.microedition.rms.RecordStore;
import javax.microedition.rms.RecordStoreException;
import javax.microedition.rms.RecordStoreNotOpenException;

/**
 * The startApp method of this class is called by the VM to start the
 * application.
 * 
 * The manifest specifies this class as MIDlet-1, which means it will
 * be selected for execution.
 */
public class StartApplication extends MIDlet implements ISwitchListener {

    private ITriColorLED[] leds = EDemoBoard.getInstance().getLEDs();
    ISwitch switch0 = EDemoBoard.getInstance().getSwitches()[0];
    ISwitch switch1 = EDemoBoard.getInstance().getSwitches()[1];
    boolean switch0Status = false;
    boolean switch1Status = false;
    RecordStore rms;
    int recordStoreIndex = 0;
    private IAccelerometer3D accel = EDemoBoard.getInstance().getAccelerometer();
    private ITemperatureInput tempSensor = EDemoBoard.getInstance().getADCTemperature();
    private ILightSensor lightSensor = EDemoBoard.getInstance().getLightSensor();

    protected void startApp() throws MIDletStateChangeException {
        new BootloaderListener().start();   // monitor the USB (if connected) and recognize commands from host

        long ourAddr = RadioFactory.getRadioPolicyManager().getIEEEAddress();
        System.out.println("Our radio address = " + IEEEAddress.toDottedHex(ourAddr));

        //add listeners to two switchs
        switch0.addISwitchListener(this);
        switch1.addISwitchListener(this);

        //set the default LED indicator
        leds[0].setRGB(100, 100, 0);
        leds[0].setOn();

        //uncomment this line below would delete all RecordStore
        //deleteRecordStore();

        while (true) {
            //click the left button to start/stop recording
            if (switch0Status) {
                try {
                    //create or open RecordStore
                    rms = RecordStore.openRecordStore("Record", true);
                } catch (RecordStoreException ex) {
                    ex.printStackTrace();
                }
                //get values from sensors and store
                while (switch0Status) {
                    try {
                        String msg = String.valueOf(accel.getAccelX()) + "," +
                                String.valueOf(accel.getAccelY()) + "," +
                                String.valueOf(accel.getAccelZ()) + "," +
                                String.valueOf(accel.getTiltX()) + "," +
                                String.valueOf(accel.getTiltY()) + "," +
                                String.valueOf(accel.getTiltZ()) + "," +
                                String.valueOf(tempSensor.getCelsius()) + "," +
                                String.valueOf(lightSensor.getValue() + "," +
                                new Date().getTime());
                        System.out.println(msg);
                        Utils.sleep(10);
                        //add value to RecordStore
                        rms.addRecord(msg.getBytes(), 0, msg.getBytes().length);
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }
                }
                try {
                    //add a spliter for each of activities
                    rms.addRecord("finish".getBytes(), 0, "finish".getBytes().length);
                } catch (RecordStoreNotOpenException ex) {
                    ex.printStackTrace();
                } catch (RecordStoreException ex) {
                    ex.printStackTrace();
                }
            }

            //click the right button to send data to server
            if (switch1Status) {
                leds[0].setOff();
                //send data
                try {
                    sendout();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
                switch1Status = false;
                leds[7].setOff();
                leds[0].setRGB(100, 100, 0);
                leds[0].setOn();
            }
        }
    }

    protected void pauseApp() {
        // This is not currently called by the Squawk VM
    }

    /**
     * Called if the MIDlet is terminated by the system.
     * I.e. if startApp throws any exception other than MIDletStateChangeException,
     * if the isolate running the MIDlet is killed with Isolate.exit(), or
     * if VM.stopVM() is called.
     * 
     * It is not called if MIDlet.notifyDestroyed() was called.
     *
     * @param unconditional If true when this method is called, the MIDlet must
     *    cleanup and release all resources. If false the MIDlet may throw
     *    MIDletStateChangeException  to indicate it does not want to be destroyed
     *    at this time.
     */
    protected void destroyApp(boolean unconditional) throws MIDletStateChangeException {
        for (int i = 0; i < 8; i++) {
            leds[i].setOff();
        }
    }

    public void switchPressed(ISwitch sw) {
    }

    public void switchReleased(ISwitch sw) {
        if (sw == switch0) {
            System.out.println("switch 0 released");
            if (switch0Status == false) {
                switch0Status = true;
                leds[0].setRGB(100, 0, 0);
                leds[0].setOn();
            } else {
                switch0Status = false;
                leds[0].setRGB(100, 100, 0);
                leds[0].setOn();
            }
        } else if (sw == switch1) {
            System.out.println("switch 1 released");
            if (switch1Status == false) {
                switch1Status = true;
                leds[7].setRGB(100, 0, 0);
                leds[7].setOn();
            } else {
                switch1Status = false;
                leds[7].setRGB(100, 100, 0);
                leds[7].setOn();
            }
        }
    }

    private void sendout() throws Exception {
        RadiostreamConnection conn =
                (RadiostreamConnection) Connector.open("radiostream://0014.4F01.0000.4bfd:100");
        DataInputStream dis = conn.openDataInputStream();
        DataOutputStream dos = conn.openDataOutputStream();
        try {

            for (int j = 1; j < rms.getNumRecords(); j++) {
                dos.writeUTF(new String(rms.getRecord(j)));
            }
            dos.flush();
        } catch (NoRouteException e) {
            System.out.println("No route to 0014.4F01.0000.0006");
        } finally {
            dis.close();
            dos.close();
            conn.close();
        }
    }

    private void deleteRecordStore() {
        if (RecordStore.listRecordStores().length > 0) {
            for (int k = 0; k < RecordStore.listRecordStores().length; k++) {
                try {
                    RecordStore.deleteRecordStore(RecordStore.listRecordStores()[k]);
                } catch (RecordStoreException ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
}

Host Side:

/*
 * SunSpotHostApplication.java
 *
 * Created on Sep 15, 2009 4:03:06 PM;
 */
package org.sunspotworld;

import com.sun.spot.peripheral.radio.RadioFactory;
import com.sun.spot.io.j2me.radiostream.*;
import com.sun.spot.peripheral.NoRouteException;
import com.sun.spot.util.IEEEAddress;

import java.io.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.microedition.io.*;

/**
 * Sample Sun SPOT host application
 */
public class SunSpotHostApplication {

    FileWriter fc = null;
    PrintWriter pc = null;

    /**
     * Print out our radio address.
     */
    public void run() {
        try {
            fc = new java.io.FileWriter("C:\\value.dat", true);
        } catch (IOException ex) {
            ex.printStackTrace();
        }
        pc = new java.io.PrintWriter(fc);
        long ourAddr = RadioFactory.getRadioPolicyManager().getIEEEAddress();
        System.out.println("Our radio address = " + IEEEAddress.toDottedHex(ourAddr));
        try {
            receive();
        } catch (IOException ex) {
            Logger.getLogger(SunSpotHostApplication.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    /**
     * Start up the host application.
     *
     * @param args any command line arguments
     */
    public static void main(String[] args) {
        SunSpotHostApplication app = new SunSpotHostApplication();
        app.run();
    }

    private void receive() throws IOException {
        RadiostreamConnection conn =
                (RadiostreamConnection) Connector.open("radiostream://0014.4F01.0000.46e0:100");
        DataInputStream dis = conn.openDataInputStream();
        DataOutputStream dos = conn.openDataOutputStream();
        try {
            while (true) {
                String question = dis.readUTF();
                write2File(question);
            }
        } catch (NoRouteException e) {
            System.out.println("No route to 0014.4F01.0000.0007");
        } finally {
            dis.close();
            dos.close();
            conn.close();
            pc.close();
        try {
            fc.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
        }
    }

    private void write2File(String question) {
        pc.println(question);
    }
}