version 1.17, 2000/01/18 07:59:19 |
version 1.23, 2000/01/20 16:40:13 |
|
|
/** |
/** |
* $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.16 2000/01/13 12:35:56 tam Exp $ |
* $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.22 2000/01/19 15:32:50 tam Exp $ |
*/ |
*/ |
|
|
import JP.ac.kobe_u.math.tam.OpenXM.*; |
import JP.ac.kobe_u.math.tam.OpenXM.*; |
|
|
class OMproxy implements Runnable{ |
class OMproxy implements Runnable{ |
private OpenXM ox; |
private OpenXM ox; |
private Stack stack = new Stack(); |
private Stack stack = new Stack(); |
private boolean debug = true; |
protected boolean debug = false; |
final int version = 199911110; |
final int version = 200001190; |
|
|
public OMproxy(String host,int ControlPort,int DataPort) throws IOException{ |
public OMproxy(String host,int ControlPort,int DataPort) throws IOException{ |
ox = new OpenXM(this,host,ControlPort,DataPort); |
ox = new OpenXM(this,host,ControlPort,DataPort); |
Line 20 class OMproxy implements Runnable{ |
|
Line 20 class OMproxy implements Runnable{ |
|
OM2OXM P = new OM2OXM(); |
OM2OXM P = new OM2OXM(); |
|
|
debug("OMproxy started."); |
debug("OMproxy started."); |
try{ |
while(true){ |
while(true){ |
try{ |
int ox_tag = ox.receiveOXtag(); |
int ox_tag = ox.receiveOXtag(); |
|
|
switch(ox_tag){ |
switch(ox_tag){ |
Line 34 class OMproxy implements Runnable{ |
|
Line 34 class OMproxy implements Runnable{ |
|
debug("push: "+ stack.peek()); |
debug("push: "+ stack.peek()); |
break; |
break; |
} |
} |
|
}catch(Throwable e){ |
|
System.err.println(e.getMessage()); |
|
e.printStackTrace(); |
|
debug("error occured. stack was cleared."); |
} |
} |
}catch(java.io.IOException e){ |
|
System.err.println(e.getMessage()); |
|
e.printStackTrace(); |
|
} |
} |
|
//System.out.println("breaking..."); |
System.out.println("breaking..."); |
|
} |
} |
|
|
/* |
/* |
Line 113 class OMproxy implements Runnable{ |
|
Line 113 class OMproxy implements Runnable{ |
|
CMO[] list = {new CMO_INT32(SM.SM_popCMO), |
CMO[] list = {new CMO_INT32(SM.SM_popCMO), |
new CMO_INT32(SM.SM_executeFunction), |
new CMO_INT32(SM.SM_executeFunction), |
new CMO_INT32(SM.SM_mathcap), |
new CMO_INT32(SM.SM_mathcap), |
|
new CMO_INT32(SM.SM_setMathCap), |
new CMO_INT32(SM.SM_control_kill), |
new CMO_INT32(SM.SM_control_kill), |
new CMO_INT32(SM.SM_control_reset_connection)}; |
new CMO_INT32(SM.SM_control_reset_connection)}; |
mathcap[1] = new CMO_LIST(list); |
mathcap[1] = new CMO_LIST(list); |
Line 221 class OMproxy implements Runnable{ |
|
Line 222 class OMproxy implements Runnable{ |
|
ret += "\t -data port \t (default 1300)\n"; |
ret += "\t -data port \t (default 1300)\n"; |
ret += "\t -control port \t (default 1200)\n"; |
ret += "\t -control port \t (default 1200)\n"; |
ret += "\t -insecure \t this version ignore this option\n"; |
ret += "\t -insecure \t this version ignore this option\n"; |
ret += "\t -nohup \t ignore signals (required libnative.so)\n"; |
ret += "\t -debug \t display debug messages\n"; |
|
|
return ret; |
return ret; |
} |
} |
|
|
private static native void setNoInterrupt(); |
|
|
|
public static void main(String argv[]){ |
public static void main(String argv[]){ |
String host = "localhost"; |
String host = "localhost"; |
int DataPort = 1300, ControlPort = 1200; |
int DataPort = 1300, ControlPort = 1200; |
|
boolean debug = false; |
|
|
for(int i=0;i<argv.length;i++){ |
for(int i=0;i<argv.length;i++){ |
if(argv[i].equals("-h")){ |
if(argv[i].equals("-h")){ |
Line 243 class OMproxy implements Runnable{ |
|
Line 243 class OMproxy implements Runnable{ |
|
}else if(argv[i].equals("-control")){ |
}else if(argv[i].equals("-control")){ |
ControlPort = Integer.valueOf(argv[++i]).intValue(); |
ControlPort = Integer.valueOf(argv[++i]).intValue(); |
}else if(argv[i].equals("-insecure")){ |
}else if(argv[i].equals("-insecure")){ |
}else if(argv[i].equals("-nohup")){ |
}else if(argv[i].equals("-debug")){ |
System.loadLibrary("native"); |
debug = true; |
setNoInterrupt(); |
|
}else{ |
}else{ |
System.err.println("unknown option : "+ argv[i]); |
System.err.println("unknown option : "+ argv[i]); |
System.err.print(usage()); |
System.err.print(usage()); |
Line 257 class OMproxy implements Runnable{ |
|
Line 256 class OMproxy implements Runnable{ |
|
+"("+ ControlPort +","+ DataPort +")"); |
+"("+ ControlPort +","+ DataPort +")"); |
|
|
try{ |
try{ |
new OMproxy(host,ControlPort,DataPort); |
new OMproxy(host,ControlPort,DataPort).debug = debug; |
System.out.println("connected."); |
System.out.println("connected."); |
}catch(IOException e){ |
}catch(IOException e){ |
System.err.println("Error occured: "+ e); |
System.err.println("Error occured: "+ e); |