+ public synchronized void scanFPGA(boolean on) throws DeviceException {
+ try {
+ if (on) {
+ out.writeByte(3);
+ out.flush();
+ } else {
+ // FIXME
+ }
+ } catch (IOException e) { throw new DeviceException(e); }
+ }
+ // fixme!
+ public static int retval = 0;
+ public synchronized int readCount() throws DeviceException {
+ try {
+ if (reader != null) {
+ reader.start();
+ reader = null;
+ }
+ ByteCallback bc = new ByteCallback() {
+ public synchronized void call(byte b) throws Exception {
+ retval =
+ ((b & 0xff) << 24) |
+ ((in.read() & 0xff) << 16) |
+ ((in.read() & 0xff) << 8) |
+ ((in.read() & 0xff) << 0);
+ this.notify();
+ }
+ };
+ synchronized(bc) {
+ callbacks.add(bc);
+ out.writeByte(6);
+ out.flush();
+ bc.wait();
+ }
+ return retval;
+ } catch (Exception e) { throw new DeviceException(e); }
+ }
+
+ public static interface ByteCallback {
+ public void call(byte b) throws Exception;
+ }
+
+ private Vector callbacks = new Vector();
+
+ private Thread reader = new Thread() {
+ public void run() {
+ while(true) {
+ try {
+ byte b = in.readByte();
+ ByteCallback bc = (ByteCallback)callbacks.remove(0);
+ bc.call(b);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ };
+
+ public synchronized void readBus(ByteCallback bc) throws DeviceException {
+ try {
+ callbacks.add(bc);
+ out.writeByte(2);
+ out.flush();
+ if (reader != null) {
+ reader.start();
+ reader = null;
+ }
+ } catch (IOException e) { throw new DeviceException(e); }
+ }
+
+ public synchronized void readInterrupts(ByteCallback bc) throws DeviceException {
+ try {
+ callbacks.add(bc);
+ out.writeByte(6);
+ out.flush();
+ if (reader != null) {
+ reader.start();
+ reader = null;
+ }
+ } catch (IOException e) { throw new DeviceException(e); }
+ }
+
+ public synchronized void reset() throws DeviceException {