[BACK]Return to OpenXMstream.java CVS log [TXT][DIR] Up to [local] / OpenXM / src / OpenMath / ORG / openxm / tam

Diff for /OpenXM/src/OpenMath/ORG/openxm/tam/OpenXMstream.java between version 1.1 and 1.3

version 1.1, 2000/09/08 07:29:45 version 1.3, 2001/03/02 11:13:57
Line 1 
Line 1 
 /**  /**
  * $OpenXM$   * $OpenXM: OpenXM/src/OpenMath/ORG/openxm/tam/OpenXMstream.java,v 1.2 2000/10/11 08:32:15 ohara Exp $
  */   */
 package ORG.openxm.tam;  package ORG.openxm.tam;
   
Line 15  import java.net.*;
Line 15  import java.net.*;
  */   */
 public class OpenXMstream{  public class OpenXMstream{
   private int serial = 0;    private int serial = 0;
   private Socket socket = null;    //private Socket socket = null;
   private InputStream  is = null;    private InputStream  is = null;
   private OutputStream os = null;    private OutputStream os = null;
   private int order = OX_BYTE_NETWORK_BYTE_ORDER;    private int order = OX_BYTE_NETWORK_BYTE_ORDER;
Line 41  public class OpenXMstream{
Line 41  public class OpenXMstream{
   final public static int OX_BYTE_BIG_INDIAN         = 0xff;    final public static int OX_BYTE_BIG_INDIAN         = 0xff;
   
   /**    /**
      * InputStream is $B$H(B OutputStream os $B$rMQ$$$F(B OpenXM $BDL?.$r9T$J$&(B.
      */
     public OpenXMstream(InputStream is,OutputStream os) throws IOException{
       this.is = is;
       this.os = os;
     }
   
     /**
    * $B%^%7%sL>(B host $B$N%]!<%HHV9f(B Port $B$X(B TCP $B@\B3$r9T$J$$(B,     * $B%^%7%sL>(B host $B$N%]!<%HHV9f(B Port $B$X(B TCP $B@\B3$r9T$J$$(B,
    * $B@\B3$r9T$J$&(B.     * $B@\B3$r9T$J$&(B. $B8=:_$O8_49@-$N$?$a$K;D$7$F$"$k(B.
    */     */
   public OpenXMstream(String host,int Port) throws IOException{    public OpenXMstream(String host,int Port) throws IOException{
     this(host,Port,false);      this(host,Port,false);
Line 51  public class OpenXMstream{
Line 59  public class OpenXMstream{
   /**    /**
    * $B%^%7%sL>(B host $B$N%]!<%HHV9f(B Port $B$X(B TCP $B@\B3$r9T$J$$(B,     * $B%^%7%sL>(B host $B$N%]!<%HHV9f(B Port $B$X(B TCP $B@\B3$r9T$J$$(B,
    * $B@\B3$r9T$J$&(B. reverse $B$,(B true $B$N$H$-!"(B TCP $B%=%1%C%H$r(B     * $B@\B3$r9T$J$&(B. reverse $B$,(B true $B$N$H$-!"(B TCP $B%=%1%C%H$r(B
    * $B:n@.$7(B, $B@\B3$rBT$D(B.     * $B:n@.$7(B, $B@\B3$rBT$D(B. $B8=:_$O8_49@-$N$?$a$K;D$7$F$"$k(B.
    */     */
   public OpenXMstream(String host,int Port,boolean reverse) throws IOException{    public OpenXMstream(String host,int Port,boolean reverse) throws IOException{
       Socket socket;
   
     // create socket      // create socket
     if(!reverse){      if(!reverse){
       socket = new Socket(host,Port);        socket = new Socket(host,Port);
Line 62  public class OpenXMstream{
Line 72  public class OpenXMstream{
     }      }
   
     //is =new DebugInputStream(new BufferedInputStream(socket.getInputStream()));      //is =new DebugInputStream(new BufferedInputStream(socket.getInputStream()));
     is = new BufferedInputStream(socket.getInputStream());      is= new BufferedInputStream(socket.getInputStream());
     os = socket.getOutputStream();      os = socket.getOutputStream();
   }    }
   
   /**    /**
    * $B%P%$%H%*!<%@$N7hDj$r9T$J$&(B. $B8=:_$O%M%C%H%o!<%/%P%$%H%*!<%@!<$N$_(B.     * $B%P%$%H%*!<%@$N7hDj$r9T$J$&(B. $B8=:_$O%M%C%H%o!<%/%P%$%H%*!<%@!<$N$_(B.
    */     */
   public int sendByteOrder() throws IOException{    public int exchangeByteOrder(int order) throws IOException{
     // send byte order      // send byte order
     os.write(OX_BYTE_NETWORK_BYTE_ORDER);      os.write(OX_BYTE_NETWORK_BYTE_ORDER);
     os.flush();      os.flush();
   
     // receive byte order      // receive byte order
     //System.out.println("get: "+is.read());      //System.err.println("get: "+is.read());
     is.read();      is.read();
   
     order = OX_BYTE_NETWORK_BYTE_ORDER;      this.order = OX_BYTE_NETWORK_BYTE_ORDER;
   
     return order;      return this.order;
   }    }
   
   /**    /**
      * $B%P%$%H%*!<%@$N7hDj$r9T$J$&(B. $B8=:_$O%M%C%H%o!<%/%P%$%H%*!<%@!<$N$_(B.
      * $B?d>)$5$l$J$$(B.
      */
     public int sendByteOrder() throws IOException{
       return exchangeByteOrder(OX_BYTE_NETWORK_BYTE_ORDER);
     }
   
     /**
    * $B@\B3$rJD$8$k(B.     * $B@\B3$rJD$8$k(B.
    */     */
   public void close() throws IOException{    public void close() throws IOException{
     is.close();      is.close();
     os.close();      os.close();
     socket.close();  
   }    }
   
   /**    /**
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.3
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>