Robust/src/ClassLibrary/Socket.java

   1 public class Socket {
   2     /* Data pending flag */
   3     external flag IOPending;
   4     /* File Descriptor */
   5     int fd;
   6     private SocketInputStream sin;
   7     private SocketOutputStream sout;
   8
   9     public Socket() {
  10         sin=new SocketInputStream(this);
  11         sout=new SocketOutputStream(this);
  12     }
  13
  14     public InputStream getInputStream() {
  15         return sin;
  16     }
  17
  18     public OutputStream getOutputStream() {
  19         return sout;
  20     }
  21
  22     public Socket(String host, int port) {
  23         InetAddress address=InetAddress.getByName(host);
  24         fd=nativeBind(address.getAddress(), port);
  25         nativeConnect(fd, address.getAddress(), port);
  26     }
  27
  28     public Socket(InetAddress address, int port) {
  29         fd=nativeBind(address.getAddress(), port);
  30         nativeConnect(fd, address.getAddress(), port);
  31     }
  32
  33     public void connect(String host, int port) {
  34         InetAddress address=InetAddress.getByName(host);
  35         fd=nativeBind(address.getAddress(), port);
  36         nativeConnect(fd, address.getAddress(), port);
  37     }
  38
  39     public void connect(InetAddress address, int port) {
  40         fd=nativeBind(address.getAddress(), port);
  41         nativeConnect(fd, address.getAddress(), port);
  42     }
  43
  44     public static native int nativeBind(byte[] address, int port);
  45
  46     public native int nativeConnect(int fd, byte[] address, int port);
  47
  48     int setFD(int filed) {
  49         fd=filed;
  50     }
  51
  52     public int read(byte[] b) {
  53         return nativeRead(b);
  54     }
  55     public void write(byte[] b) {
  56         nativeWrite(b, 0, b.length);
  57     }
  58
  59     public void write(byte[] b, int offset, int len) {
  60         nativeWrite(b, offset, len);
  61     }
  62
  63     private native void nativeBindFD(int fd);
  64     private native int nativeRead(byte[] b);
  65     private native void nativeWrite(byte[] b, int offset, int len);
  66     private native void nativeClose();
  67
  68     public void close() {
  69         nativeClose();
  70     }
  71 }