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
   8 public class Server {
   9
  10     public static ServerSocket ss;
  11     public static void main(String[] args) throws Exception {
  12         System.err.println("programming...");
  13         Process proc = Runtime.getRuntime().exec(new String[] {
  14                 "/afs/megacz.com/work/ml410/program.sh",
  15                 "/afs/megacz.com/work/ml410/main.bit"
  16             });
  17         BufferedReader br = new BufferedReader(new InputStreamReader(proc.getInputStream()));
  18         String str = null;
  19         while((str = br.readLine()) != null) {
  20             System.err.println("  " + str);
  21         }
  22         int ret = proc.waitFor();
  23         if (ret != 0) {
  24             System.err.println("programming error: " + ret);
  25             return;
  26         }
  27         System.err.println("done programming.");
  28         ss = new ServerSocket(3133);
  29         while(true) {
  30             try {
  31                 Socket s = ss.accept();
  32                 new Handler(s).start();
  33             } catch (Exception e) {
  34                 e.printStackTrace();
  35             }
  36         }
  37     }
  38
  39     public static String pass_string = "password=security_is_for_wimps ";
  40
  41     static class Handler extends Thread {
  42         private Socket socket;
  43         boolean closed = false;
  44         private SerialPort sp;
  45         public Handler(Socket s) { this.socket = s; this.sp = sp; }
  46         public void run() {
  47             synchronized(Server.class) {
  48                 try {
  49                     this.sp = new RXTXPort("/dev/ttyS0");
  50                     //sp.sendBreak(500);
  51                     try {
  52                         _run();
  53                     } finally {
  54                         sp.close();
  55                     }
  56                 } catch (Exception e) { throw new RuntimeException(e); }
  57             }
  58         }
  59         public void _run() {
  60             try {
  61                 final InputStream is = socket.getInputStream();
  62                 byte[] buf = new byte[1024];
  63                 StringBuffer sb = new StringBuffer();
  64                 while(true) {
  65                     int i = is.read();
  66                     if (i==-1) return;
  67                     if (((char)i)=='\n') break;
  68                     sb.append((char)i);
  69                 }
  70                 System.err.println("login string: " + sb.toString());
  71                 if (!sb.toString().startsWith(pass_string)) return;
  72
  73                 //try { Thread.sleep(2000); } catch(Exception e) { }
  74                 final OutputStream os = socket.getOutputStream();
  75                 System.err.println("sending instructions...");
  76
  77                 sp.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
  78                 final OutputStream fos = sp.getOutputStream();
  79                 final InputStream fis = sp.getInputStream();
  80
  81                 new Thread() {
  82                     public void run() {
  83                         try {
  84                             byte[] buf = new byte[1024];
  85                             while(true) {
  86                                 int numread = is.read(buf, 0, buf.length);
  87                                 if (numread == -1) break;
  88                                 fos.write(buf, 0, numread);
  89                                 fos.flush();
  90                             }
  91                         } catch (Exception e) { throw new RuntimeException(e);
  92                         } finally {
  93                             System.err.println("closing...");
  94                             closed = true;
  95                             try { fos.close(); } catch (Throwable t) { t.printStackTrace(); }
  96                         }
  97                     }
  98                 }.start();
  99
 100                 System.err.println("reading back...");
 101                 while(true) {
 102                     long result = 0;
 103                     int val = 0;
 104                     for(int i=0; i<6; i++) {
 105                         int k = 0;
 106                         while(!closed && fis.available()==0) {
 107                             if (closed) return;
 108                             k++;
 109                             if (k >= 100) {
 110                                 System.err.println("sleep");
 111                                 k = 0;
 112                             }
 113                             Thread.sleep(10);
 114                         }
 115                         if (closed) return;
 116                         val = fis.read();
 117                         if (val==-1) break;
 118                         os.write((byte)val);
 119                         os.flush();
 120                         result |= ((long)val) << (i * 8);
 121                     }
 122                     if (val==-1) break;
 123                     System.err.print(result);
 124                     System.err.print(" 0x");
 125                     System.err.print(Long.toString(result, 16));
 126                     System.err.println();
 127                 }
 128                 System.err.println("done.");
 129
 130             } catch (Exception e) { throw new RuntimeException(e);
 131             } finally {
 132                 try {
 133                     System.err.println("closing...");
 134                     /*
 135                     fis.close();
 136                     if (fis != null) fis.close();
 137                     */
 138                 } catch (Throwable t) { t.printStackTrace(); }
 139             }
 140         }
 141     }
 142
 143 }