version 1.36, 2000/04/17 03:18:57 |
version 1.40, 2000/09/13 06:44:55 |
|
|
/** |
/** |
* $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.35 2000/03/15 15:02:06 tam Exp $ |
* $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.39 2000/07/03 05:57:43 tam Exp $ |
*/ |
*/ |
|
|
import JP.ac.kobe_u.math.tam.OpenXM.*; |
import ORG.openxm.tam.*; |
import java.util.Stack; |
import java.util.Stack; |
import java.io.*; |
import java.io.*; |
|
|
class OMproxy extends OpenXMserver{ |
public class OMproxy extends OpenXMserver{ |
private OpenXM ox; |
|
private Stack stack = new Stack(); |
private Stack stack = new Stack(); |
protected boolean debug = false; |
protected boolean debug = false; |
final int version = 200001190; |
final int version = 200006130; |
|
|
public void computeProcess(OpenXMconnection stream){ |
public OMproxy(String hostname,int ControlPort,int DataPort){ |
|
super(hostname,ControlPort,DataPort); |
|
} |
|
|
|
public void computeProcess(OpenXMstream stream){ |
OM2OXM P = new OM2OXM(); |
OM2OXM P = new OM2OXM(); |
|
|
debug("OMproxy started."); |
debug("OMproxy started."); |
Line 24 class OMproxy extends OpenXMserver{ |
|
Line 27 class OMproxy extends OpenXMserver{ |
|
|
|
switch(ox_tag){ |
switch(ox_tag){ |
case OXmessage.OX_COMMAND: |
case OXmessage.OX_COMMAND: |
StackMachine((SM)message.getBody()); |
StackMachine((SM)message.getBody(),stream); |
break; |
break; |
|
|
case OXmessage.OX_DATA: |
case OXmessage.OX_DATA: |
Line 36 class OMproxy extends OpenXMserver{ |
|
Line 39 class OMproxy extends OpenXMserver{ |
|
System.err.println(e.getMessage()); |
System.err.println(e.getMessage()); |
e.printStackTrace(); |
e.printStackTrace(); |
debug("error occured. stack was cleared."); |
debug("error occured. stack was cleared."); |
|
stack = new Stack(); |
} |
} |
} |
} |
}catch(IOException e){ |
}catch(IOException e){ |
System.err.println(e.getMessage()); |
System.err.println(e.getMessage()); |
e.printStackTrace(); |
e.printStackTrace(); |
System.err.println("error occured, and recovering processes seems to be impossible."); |
System.err.println("error occured, and recovering processes seems to be impossible."); |
|
}catch(Exception e){ |
|
System.err.println(e.getMessage()); |
|
e.printStackTrace(); |
|
System.err.println("error occured, and recovering processes seems to be impossible."); |
}finally{ |
}finally{ |
System.out.println("breaking..."); |
System.out.println("breaking..."); |
} |
} |
Line 60 class OMproxy extends OpenXMserver{ |
|
Line 68 class OMproxy extends OpenXMserver{ |
|
} |
} |
*/ |
*/ |
|
|
private void SM_popCMO() throws java.io.IOException{ |
private void SM_popCMO(OpenXMstream stream) throws java.io.IOException{ |
try{ |
try{ |
if(stack.empty()){ |
if(stack.empty()){ |
ox.send(new CMO_NULL()); |
stream.send(new CMO_NULL()); |
}else{ |
}else{ |
debug("sending CMO: "+ stack.peek()); |
debug("sending CMO: "+ stack.peek()); |
ox.send((CMO)stack.pop()); |
stream.send((CMO)stack.pop()); |
|
debug("test"); |
} |
} |
}catch(MathcapViolation e){ |
}catch(MathcapViolation e){ |
try{ |
try{ |
ox.send(new CMO_ERROR2(new CMO_STRING("MathcapViolation: "+ |
stream.send(new CMO_ERROR2(new CMO_STRING("MathcapViolation: "+ |
e.getMessage()))); |
e.getMessage()))); |
}catch(MathcapViolation tmp){} |
}catch(MathcapViolation tmp){} |
} |
} |
Line 109 class OMproxy extends OpenXMserver{ |
|
Line 118 class OMproxy extends OpenXMserver{ |
|
return; |
return; |
} |
} |
|
|
private void SM_mathcap() throws java.io.IOException{ |
private void SM_mathcap(OpenXMstream stream) throws java.io.IOException{ |
CMO[] mathcap = new CMO[3]; |
CMO[] mathcap = new CMO[3]; |
|
|
{ |
{ |
Line 153 class OMproxy extends OpenXMserver{ |
|
Line 162 class OMproxy extends OpenXMserver{ |
|
mathcap[2] = new CMO_LIST(list); |
mathcap[2] = new CMO_LIST(list); |
} |
} |
|
|
|
stack = new Stack(); |
stack.push(new CMO_MATHCAP(new CMO_LIST(mathcap))); |
stack.push(new CMO_MATHCAP(new CMO_LIST(mathcap))); |
debug("push: "+ stack.peek()); |
debug("push: "+ stack.peek()); |
} |
} |
|
|
private void SM_setMathCap() throws java.io.IOException{ |
private void SM_setMathCap(OpenXMstream stream) |
|
throws java.io.IOException{ |
Object mathcap = stack.pop(); |
Object mathcap = stack.pop(); |
|
|
if(mathcap instanceof CMO_MATHCAP){ |
if(mathcap instanceof CMO_MATHCAP){ |
stack.push(new CMO_ERROR2(new CMO_NULL())); |
stack.push(new CMO_ERROR2(new CMO_NULL())); |
} |
} |
ox.setMathCap((CMO_MATHCAP)mathcap); |
stream.setMathCap((CMO_MATHCAP)mathcap); |
} |
} |
|
|
private void StackMachine(SM mesg) throws java.io.IOException{ |
private void StackMachine(SM mesg,OpenXMstream stream) |
|
throws java.io.IOException{ |
debug("receive: "+mesg); |
debug("receive: "+mesg); |
|
|
switch(mesg.getCode()){ |
switch(mesg.getCode()){ |
case SM.SM_popCMO: |
case SM.SM_popCMO: |
SM_popCMO(); |
SM_popCMO(stream); |
break; |
break; |
|
|
case SM.SM_executeFunction: |
case SM.SM_executeFunction: |
Line 179 class OMproxy extends OpenXMserver{ |
|
Line 191 class OMproxy extends OpenXMserver{ |
|
break; |
break; |
|
|
case SM.SM_mathcap: |
case SM.SM_mathcap: |
SM_mathcap(); |
SM_mathcap(stream); |
break; |
break; |
|
|
case SM.SM_setMathCap: |
case SM.SM_setMathCap: |
SM_setMathCap(); |
SM_setMathCap(stream); |
break; |
break; |
|
|
default: |
default: |
Line 232 class OMproxy extends OpenXMserver{ |
|
Line 244 class OMproxy extends OpenXMserver{ |
|
|
|
private void debug(String str){ |
private void debug(String str){ |
if(debug){ |
if(debug){ |
System.out.println(str); |
System.err.println(str); |
} |
} |
} |
} |
|
|
Line 251 class OMproxy extends OpenXMserver{ |
|
Line 263 class OMproxy extends OpenXMserver{ |
|
return ret; |
return ret; |
} |
} |
|
|
/* |
public static void main(String[] argv){ |
public static void main(String argv[]){ |
String hostname = "localhost"; |
String host = "localhost"; |
int ControlPort = 1200, DataPort = 1300; |
int DataPort = 1300, ControlPort = 1200; |
OpenXMserver ox; |
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")){ |
System.out.print(usage()); |
System.out.println(""); |
System.exit(0); |
System.exit(0); |
}else if(argv[i].equals("-host")){ |
}else if(argv[i].equals("-host")){ |
host = argv[++i]; |
hostname = argv[++i]; |
}else if(argv[i].equals("-data")){ |
}else if(argv[i].equals("-data")){ |
DataPort = Integer.valueOf(argv[++i]).intValue(); |
DataPort = Integer.valueOf(argv[++i]).intValue(); |
}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("-debug")){ |
|
debug = true; |
|
}else{ |
}else{ |
System.err.println("unknown option : "+ argv[i]); |
System.err.println("unknown option :"+ argv[i]); |
System.err.print(usage()); |
System.exit(1); |
System.exit(1); |
|
} |
} |
} |
} |
|
|
System.out.println("host(ctrl,data): "+ host |
//ox = new OpenXMserver(hostname,ControlPort,DataPort); |
+"("+ ControlPort +","+ DataPort +")"); |
ox = new OMproxy(hostname,ControlPort,DataPort); |
|
/* |
try{ |
try{ |
new OMproxy(host,ControlPort,DataPort).debug = debug; |
}catch(java.net.UnknownHostException e){ |
System.out.println("connected."); |
System.err.println("host unknown."); |
|
System.err.println(e.getMessage()); |
|
return; |
}catch(IOException e){ |
}catch(IOException e){ |
System.err.println("Error occured: "+ e); |
System.err.println("connection failed."); |
System.err.println(e.getLocalizedMessage()); |
System.err.println("IOException occuer !!"); |
System.err.println(e.getMessage()); |
System.err.println(e.getMessage()); |
|
return; |
} |
} |
|
*/ |
|
|
|
ox.start(); |
|
|
|
System.out.println("breaking..."); |
} |
} |
*/ |
|
} |
} |