version 1.1, 2000/09/08 07:29:45 |
version 1.3, 2001/03/02 11:13:57 |
|
|
/** |
/** |
* $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(); |
|
} |
} |
|
|
/** |
/** |