=================================================================== RCS file: /home/cvs/OpenXM/src/OpenMath/OMproxy.java,v retrieving revision 1.1.1.1 retrieving revision 1.34 diff -u -p -r1.1.1.1 -r1.34 --- OpenXM/src/OpenMath/OMproxy.java 1999/11/02 11:52:34 1.1.1.1 +++ OpenXM/src/OpenMath/OMproxy.java 2000/03/14 05:38:49 1.34 @@ -1,3 +1,7 @@ +/** + * $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.33 2000/03/14 05:10:37 tam Exp $ + */ + import JP.ac.kobe_u.math.tam.OpenXM.*; import java.util.Stack; import java.io.*; @@ -5,6 +9,8 @@ import java.io.*; class OMproxy implements Runnable{ private OpenXM ox; private Stack stack = new Stack(); + protected boolean debug = false; + final int version = 200001190; public OMproxy(String host,int ControlPort,int DataPort) throws IOException{ ox = new OpenXM(this,host,ControlPort,DataPort); @@ -13,9 +19,10 @@ class OMproxy implements Runnable{ public void run(){ OM2OXM P = new OM2OXM(); + debug("OMproxy started."); try{ while(true){ - synchronized(ox){ + try{ int ox_tag = ox.receiveOXtag(); switch(ox_tag){ @@ -25,19 +32,25 @@ class OMproxy implements Runnable{ case OpenXM.OX_DATA: stack.push(ox.receiveCMO()); - System.out.println("push: "+ stack.peek()); + debug("push: "+ stack.peek()); break; } + }catch(RuntimeException e){ + System.err.println(e.getMessage()); + e.printStackTrace(); + debug("error occured. stack was cleared."); } } - }catch(java.io.IOException e){ + }catch(IOException e){ System.err.println(e.getMessage()); e.printStackTrace(); + System.err.println("error occured, and recovering processes seems to be impossible."); + }finally{ + System.out.println("breaking..."); } - - System.out.println("breaking..."); } + /* public void stop(){ System.out.println("OMproxy Stoping..."); synchronized(ox){ @@ -48,12 +61,21 @@ class OMproxy implements Runnable{ System.out.println("OMproxy Stopped"); } } + */ private void SM_popCMO() throws java.io.IOException{ - if(stack.empty()){ - ox.send(new CMO_NULL()); - }else{ - ox.send(stack.pop()); + try{ + if(stack.empty()){ + ox.send(new CMO_NULL()); + }else{ + debug("sending CMO: "+ stack.peek()); + ox.send(stack.pop()); + } + }catch(MathcapViolation e){ + try{ + ox.send(new CMO_ERROR2(new CMO_STRING("MathcapViolation: "+ + e.getMessage()))); + }catch(MathcapViolation tmp){} } } @@ -63,7 +85,7 @@ class OMproxy implements Runnable{ int argc; if(!(stack.peek() instanceof CMO_STRING)){ - stack.push(new CMO_ERROR2()); + stack.push(new CMO_ERROR2(new CMO_NULL())); return; } function_name = ((CMO_STRING)stack.pop()).getString(); @@ -74,7 +96,7 @@ class OMproxy implements Runnable{ } if(argc != 1){ - stack.push(new CMO_ERROR2()); + stack.push(new CMO_ERROR2(new CMO_NULL())); return; } @@ -86,11 +108,70 @@ class OMproxy implements Runnable{ return; } - stack.push(new CMO_ERROR2()); + stack.push(new CMO_ERROR2(new CMO_NULL())); return; } + private void SM_mathcap() throws java.io.IOException{ + CMO[] mathcap = new CMO[3]; + + { + CMO[] list = {new CMO_INT32(version), + new CMO_STRING("Ox_system=OMproxy.class"), + new CMO_STRING("Version=0."+ version), + new CMO_STRING("HOSTTYPE=JAVA")}; + mathcap[0] = new CMO_LIST(list); + } + + { + CMO[] list = {new CMO_INT32(SM.SM_popCMO), + new CMO_INT32(SM.SM_executeFunction), + 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_reset_connection)}; + mathcap[1] = new CMO_LIST(list); + } + + { + CMO[] CMOFormat = {new CMO_INT32(CMO.NULL), + new CMO_INT32(CMO.INT32), + new CMO_INT32(CMO.STRING), + new CMO_INT32(CMO.LIST), + new CMO_INT32(CMO.MONOMIAL32), + new CMO_INT32(CMO.ZZ), + new CMO_INT32(CMO.QQ), + new CMO_INT32(CMO.ZERO), + new CMO_INT32(CMO.DMS_GENERIC), + new CMO_INT32(CMO.RECURSIVE_POLYNOMIAL), + new CMO_INT32(CMO.DISTRIBUTED_POLYNOMIAL), + new CMO_INT32(CMO.POLYNOMIAL_IN_ONE_VARIABLE), + new CMO_INT32(CMO.BIGFLOAT), + new CMO_INT32(CMO.INDETERMINATE), + new CMO_INT32(CMO.TREE)}; + CMO[] DataFormat1 = {new CMO_INT32(OpenXM.OX_DATA), + new CMO_LIST(CMOFormat)}; + CMO[] list = {new CMO_LIST(DataFormat1)}; + + mathcap[2] = new CMO_LIST(list); + } + + stack.push(new CMO_MATHCAP(new CMO_LIST(mathcap))); + debug("push: "+ stack.peek()); + } + + private void SM_setMathCap() throws java.io.IOException{ + Object mathcap = stack.pop(); + + if(mathcap instanceof CMO_MATHCAP){ + stack.push(new CMO_ERROR2(new CMO_NULL())); + } + ox.setMathCap((CMO_MATHCAP)mathcap); + } + private void StackMachine(SM mesg) throws java.io.IOException{ + debug("receive: "+mesg); + switch(mesg.getCode()){ case SM.SM_popCMO: SM_popCMO(); @@ -100,14 +181,29 @@ class OMproxy implements Runnable{ SM_executeFunction(); break; + case SM.SM_mathcap: + SM_mathcap(); + break; + + case SM.SM_setMathCap: + SM_setMathCap(); + break; + default: System.out.println("received "+ mesg); } } private CMO CMO2OMXML(CMO obj){ - String str = OM2OXM.CMO2OM(obj); + String str; + try{ + str = OM2OXM.CMO2OM(obj); + }catch(NumberFormatException e){ + debug("CMO2OMXML occuered error in trans"); + return new CMO_ERROR2(new CMO_STRING(e.toString())); + } + return new CMO_STRING(str); } @@ -117,27 +213,55 @@ class OMproxy implements Runnable{ ByteArrayInputStream stream; CMO ret; - if(obj instanceof CMO_STRING){ - return new CMO_ERROR2(); + debug("OMXML2CMO called: "+obj); + if(!(obj instanceof CMO_STRING)){ + return new CMO_ERROR2(new CMO_STRING("It's not CMO_STRING.")); } try{ stream = new ByteArrayInputStream(((CMO_STRING)obj).getString().getBytes()); ret = trans.parse(stream); }catch(IOException e){ + debug("OMXML2CMO occuered error in trans"); return new CMO_ERROR2(new CMO_STRING(e.toString())); + }catch(NumberFormatException e){ + debug("OMXML2CMO occuered error in trans"); + return new CMO_ERROR2(new CMO_STRING(e.toString())); } + debug("push: "+ret); return ret; } + private void debug(String str){ + if(debug){ + System.out.println(str); + } + } + + private static String usage(){ + String ret = ""; + + ret += "usage\t: java OMproxy [options]\n"; + ret += "options\t:\n"; + ret += "\t -h \t show this message\n"; + ret += "\t -host hostname \t (default localhost)\n"; + ret += "\t -data port \t (default 1300)\n"; + ret += "\t -control port \t (default 1200)\n"; + ret += "\t -insecure \t this version ignore this option\n"; + ret += "\t -debug \t display debug messages\n"; + + return ret; + } + public static void main(String argv[]){ String host = "localhost"; int DataPort = 1300, ControlPort = 1200; + boolean debug = false; for(int i=0;i