X-Git-Url: https://oss.titaniummirror.com/gitweb?a=blobdiff_plain;f=support%2Fsdk%2Fjava%2Fnet%2Ftinyos%2Fpacket%2FSerialByteSource.java;fp=support%2Fsdk%2Fjava%2Fnet%2Ftinyos%2Fpacket%2FSerialByteSource.java;h=2baa2536b7780c1bdc1c25dbbd814353f613704e;hb=b35f4d0cf0d8659f1acfb3c53f879768309895f0;hp=73357f41ce15a8f3c345f8f31a444001aebe9ad0;hpb=0112e2acfb1a732f45537bb8ecbe73a8b9dbbb60;p=tinyos-2.x.git

diff --git a/support/sdk/java/net/tinyos/packet/SerialByteSource.java b/support/sdk/java/net/tinyos/packet/SerialByteSource.java
index 73357f41..2baa2536 100644
--- a/support/sdk/java/net/tinyos/packet/SerialByteSource.java
+++ b/support/sdk/java/net/tinyos/packet/SerialByteSource.java
@@ -51,27 +51,27 @@ public class SerialByteSource extends StreamByteSource implements
   }
 
   public void openStreams() throws IOException {
-    //if (serialPort == null) {
-      try {
-        serialPort = new TOSSerial(portName);
-      } catch (Exception e) {
-        throw new IOException("Could not open " + portName + ": "
-            + e.getMessage());
-      }
-      /*
-    } else {
-      if (!serialPort.open()) {
-        throw new IOException("Could not re-open " + portName);
-      }
+    // if (serialPort == null) {
+    try {
+      serialPort = new TOSSerial(portName);
+    } catch (Exception e) {
+      throw new IOException("Could not open " + portName + ": "
+          + e.getMessage());
     }
-    */
+    /*
+     * } else { if (!serialPort.open()) { throw new IOException("Could not
+     * re-open " + portName); } }
+     */
 
     try {
       // serialPort.setFlowControlMode(SerialPort.FLOWCONTROL_NONE);
       serialPort.setSerialPortParams(baudRate, 8, SerialPort.STOPBITS_1, false);
-
       serialPort.addListener(this);
+      
       serialPort.notifyOn(SerialPortEvent.DATA_AVAILABLE, true);
+      serialPort.notifyOn(SerialPortEvent.OUTPUT_EMPTY, true);
+
+      
     } catch (Exception e) {
       serialPort.close();
       throw new IOException("Could not configure " + portName + ": "
@@ -122,8 +122,10 @@ public class SerialByteSource extends StreamByteSource implements
   }
 
   public void serialEvent(SerialPortEvent ev) {
-    synchronized (sync) {
-      sync.notify();
+    if (ev.getEventType() == SerialPortEvent.DATA_AVAILABLE) {
+      synchronized (sync) {
+        sync.notify();
+      }
     }
   }