Programming Languages Research Group: Git - IRC.git/blob

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