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                 // read login string
 102                 byte[] buf = new byte[1024];
 103                 StringBuffer sb = new StringBuffer();
 104                 while(true) {
 105                     int i = is.read();
 106                     if (i==-1) return;
 107                     if (((char)i)=='\n') break;
 108                     sb.append((char)i);
 109                 }
 110                 System.err.println("login string: " + sb.toString());
 111                 if (!sb.toString().startsWith(pass_string)) return;
 112
 113                 System.err.println("sending instructions...");
 114                 new Thread() {
 115                     public void run() {
 116                         try {
 117                             while(true) {
 118                                 int r = is.read();
 119                                 if (r == -1) break;
 120                                 System.err.println("write: 0x"+Integer.toString(r & 0xff, 16));
 121                                 synchronized(fos) {
 122                                     fos.write(r);
 123                                     if (is.available()==0) fos.flush();
 124                                 }
 125                             }
 126                             synchronized(fos) {
 127                                 fos.flush();
 128                             }
 129                         } catch (Exception e) { throw new RuntimeException(e);
 130                         } finally {
 131                             System.err.println("closing...");
 132                             closed = true;
 133                             try { fos.close(); } catch (Throwable t) { t.printStackTrace(); }
 134                         }
 135                     }
 136                 }.start();
 137
 138                 System.err.println("reading back...");
 139                 while(true) {
 140                     int val = 0;
 141                     for(int i=0; i<6; i++) {
 142                         int k = 0;
 143                         while (fis.available()==0) {
 144                             if (closed) return;
 145                             Thread.sleep(10);
 146                         }
 147                         val = fis.read();
 148                         if (val==-1) break;
 149                         if ((val & (3<<6)) == 0) {
 150                             synchronized(fos) {
 151                                 fos.write( (1<<6) | 1);
 152                             }
 153                         }
 154                         System.err.println("read: 0x"+Integer.toString(val & 0xff, 16));
 155                         os.write((byte)val);
 156                     }
 157                     if (val==-1) break;
 158                 }
 159                 os.flush();
 160                 System.err.println("done.");
 161
 162             } catch (Exception e) { throw new RuntimeException(e);
 163             } finally {
 164                 try {
 165                     System.err.println("closing...");
 166                 } catch (Throwable t) { t.printStackTrace(); }
 167             }
 168         }
 169     }
 170
 171 }