src/edu/berkeley/fleet/fpga/Server.java

   1 package edu.berkeley.fleet.fpga;
   2
   3 import gnu.io.*;
   4 import java.io.*;
   5 import java.net.*;
   6 import java.util.*;
   7 import java.util.concurrent.Semaphore;
   8
   9 // FIXME: accept connections, but stall, during programming
  10 public class Server {
  11     static boolean sign = false;
  12
  13     static long jarFileTime = 0;
  14     static long bitFileTime = 0;
  15     static {
  16         try {
  17             jarFileTime = new File("fleet.jar").lastModified();
  18             bitFileTime = new File("build/fpga/main.bit").lastModified();
  19         } catch (Exception e) { throw new RuntimeException(e); }
  20     }
  21
  22     public static ServerSocket ss;
  23     public static void main(String[] args) throws Exception {
  24         System.err.println("programming...");
  25         Process proc = Runtime.getRuntime().exec(new String[] {
  26                 "misc/program.sh",
  27                 "build/fpga/main.bit"
  28             });
  29         BufferedReader br = new BufferedReader(new InputStreamReader(proc.getInputStream()));
  30         String str = null;
  31         while((str = br.readLine()) != null) {
  32             System.err.println("  " + str);
  33         }
  34         int ret = proc.waitFor();
  35         if (ret != 0) {
  36             System.err.println("programming error: " + ret);
  37             return;
  38         }
  39         System.err.println("done programming.");
  40         new Thread() {
  41             public void run() {
  42                 try {
  43                     while(true) {
  44                         Thread.sleep(500);
  45                         if (jarFileTime != new File("fleet.jar").lastModified()) {
  46                             System.err.println("jarfile modified; exiting...");
  47                             System.exit(0);
  48                         }
  49                         if (bitFileTime != new File("build/fpga/main.bit").lastModified()) {
  50                             System.err.println("bitfile modified; exiting...");
  51                             System.exit(0);
  52                         }
  53                     }
  54                 } catch (Exception e) { throw new RuntimeException(e); }
  55             }
  56         }.start();
  57         ss = new ServerSocket(3133);
  58         while(true) {
  59             try {
  60                 Socket s = ss.accept();
  61                 System.out.println("accept!");
  62                 new Handler(s).start();
  63             } catch (Exception e) {
  64                 e.printStackTrace();
  65             }
  66         }
  67     }
  68
  69     public static String pass_string = "password=security_is_for_wimps ";
  70     static class Handler extends Thread {
  71         private Socket socket;
  72         boolean closed = false;
  73         private SerialPort sp;
  74         public Handler(Socket s) { this.socket = s; this.sp = sp; }
  75         public void run() {
  76             System.err.println("waiting for Server.class lock...");
  77             synchronized(Server.class) {
  78                 System.err.println("   (got it)");
  79                 try {
  80                     this.sp = new RXTXPort("/dev/ttyS0");
  81                     sp.setInputBufferSize(0);
  82                     sp.setOutputBufferSize(0);
  83                     sp.setSerialPortParams(38400, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
  84                     //sp.setFlowControlMode(sp.FLOWCONTROL_RTSCTS_IN | sp.FLOWCONTROL_RTSCTS_OUT);
  85                     sp.setFlowControlMode(0);
  86                     try {
  87                         _run();
  88                     } finally {
  89                         sp.close();
  90                     }
  91                 } catch (Exception e) { throw new RuntimeException(e); }
  92             }
  93         }
  94         public void _run() {
  95             try {
  96                 final InputStream is = new BufferedInputStream(socket.getInputStream());
  97                 final OutputStream os = socket.getOutputStream();
  98                 final OutputStream fos = sp.getOutputStream();
  99                 final InputStream fis = new BufferedInputStream(sp.getInputStream());
 100
 101                 sp.sendBreak(100);
 102
 103                 // read login string
 104                 byte[] buf = new byte[1024];
 105                 StringBuffer sb = new StringBuffer();
 106                 while(true) {
 107                     int i = is.read();
 108                     if (i==-1) return;
 109                     if (((char)i)=='\n') break;
 110                     sb.append((char)i);
 111                 }
 112                 System.err.println("login string: " + sb.toString());
 113                 if (!sb.toString().startsWith(pass_string)) return;
 114
 115                 System.err.println("sending instructions...");
 116                 new Thread() {
 117                     public void run() {
 118                         try {
 119                             while(true) {
 120                                 int r = is.read();
 121                                 if (r == -1) break;
 122                                 System.err.println("write: 0x"+Integer.toString(r & 0xff, 16));
 123                                 synchronized(fos) {
 124                                     fos.write(r);
 125                                     if (is.available()==0) fos.flush();
 126                                 }
 127                             }
 128                             synchronized(fos) {
 129                                 fos.flush();
 130                             }
 131                         } catch (Exception e) { throw new RuntimeException(e);
 132                         } finally {
 133                             System.err.println("closing...");
 134                             closed = true;
 135                             try { fos.close(); } catch (Throwable t) { t.printStackTrace(); }
 136                         }
 137                     }
 138                 }.start();
 139
 140                 System.err.println("reading back...");
 141                 while(true) {
 142                     int val = 0;
 143                     for(int i=0; i<6; i++) {
 144                         int k = 0;
 145                         while (fis.available()==0) {
 146                             if (closed) return;
 147                             Thread.sleep(10);
 148                         }
 149                         val = fis.read();
 150                         if (val==-1) break;
 151                         if ((val & (3<<6)) == 0) {
 152                             synchronized(fos) {
 153                                 fos.write( (1<<6) | 1);
 154                             }
 155                         }
 156                         System.err.println("read: 0x"+Integer.toString(val & 0xff, 16));
 157                         os.write((byte)val);
 158                     }
 159                     if (val==-1) break;
 160                 }
 161                 os.flush();
 162                 System.err.println("done.");
 163
 164             } catch (Exception e) { throw new RuntimeException(e);
 165             } finally {
 166                 try {
 167                     System.err.println("closing...");
 168                 } catch (Throwable t) { t.printStackTrace(); }
 169             }
 170         }
 171     }
 172
 173 }