=================================================================== RCS file: /home/cvs/OpenXM/src/OpenMath/OMproxy.java,v retrieving revision 1.26 retrieving revision 1.30 diff -u -p -r1.26 -r1.30 --- OpenXM/src/OpenMath/OMproxy.java 2000/01/21 06:27:24 1.26 +++ OpenXM/src/OpenMath/OMproxy.java 2000/03/12 14:24:21 1.30 @@ -1,5 +1,5 @@ /** - * $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.25 2000/01/20 18:55:22 tam Exp $ + * $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.29 2000/01/21 07:33:18 tam Exp $ */ import JP.ac.kobe_u.math.tam.OpenXM.*; @@ -20,27 +20,34 @@ class OMproxy implements Runnable{ OM2OXM P = new OM2OXM(); debug("OMproxy started."); - while(true){ - try{ - int ox_tag = ox.receiveOXtag(); + try{ + while(true){ + try{ + int ox_tag = ox.receiveOXtag(); - switch(ox_tag){ - case OpenXM.OX_COMMAND: - StackMachine(ox.receiveSM()); - break; + switch(ox_tag){ + case OpenXM.OX_COMMAND: + StackMachine(ox.receiveSM()); + break; - case OpenXM.OX_DATA: - stack.push(ox.receiveCMO()); - debug("push: "+ stack.peek()); - break; + case OpenXM.OX_DATA: + stack.push(ox.receiveCMO()); + debug("push: "+ stack.peek()); + break; + } + }catch(RuntimeException e){ + System.err.println(e.getMessage()); + e.printStackTrace(); + debug("error occured. stack was cleared."); } - }catch(Throwable e){ - System.err.println(e.getMessage()); - e.printStackTrace(); - debug("error occured. stack was cleared."); } + }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..."); } /* @@ -65,7 +72,10 @@ class OMproxy implements Runnable{ ox.send(stack.pop()); } }catch(MathcapViolation e){ - stack.push(new CMO_STRING(e.getMessage())); + try{ + ox.send(new cmoError2(new CMO_STRING("MathcapViolation: "+ + e.getMessage()))); + }catch(MathcapViolation tmp){} } } @@ -75,7 +85,7 @@ class OMproxy implements Runnable{ int argc; if(!(stack.peek() instanceof CMO_STRING)){ - stack.push(new CMO_ERROR2()); + stack.push(new cmoError2(new cmoNull())); return; } function_name = ((CMO_STRING)stack.pop()).getString(); @@ -86,7 +96,7 @@ class OMproxy implements Runnable{ } if(argc != 1){ - stack.push(new CMO_ERROR2()); + stack.push(new cmoError2(new cmoNull())); return; } @@ -98,7 +108,7 @@ class OMproxy implements Runnable{ return; } - stack.push(new CMO_ERROR2()); + stack.push(new cmoError2(new cmoNull())); return; } @@ -154,7 +164,7 @@ class OMproxy implements Runnable{ Object mathcap = stack.pop(); if(mathcap instanceof CMO_MATHCAP){ - stack.push(new CMO_ERROR2()); + stack.push(new cmoError2(new cmoNull())); } ox.setMathCap((CMO_MATHCAP)mathcap); } @@ -191,7 +201,7 @@ class OMproxy implements Runnable{ str = OM2OXM.CMO2OM(obj); }catch(NumberFormatException e){ debug("CMO2OMXML occuered error in trans"); - return new CMO_ERROR2(new CMO_STRING(e.toString())); + return new cmoError2(new CMO_STRING(e.toString())); } return new CMO_STRING(str); @@ -205,7 +215,7 @@ class OMproxy implements Runnable{ debug("OMXML2CMO called: "+obj); if(!(obj instanceof CMO_STRING)){ - return new CMO_ERROR2(new CMO_STRING("It's not CMO_STRING.")); + return new cmoError2(new CMO_STRING("It's not CMO_STRING.")); } try{ @@ -213,10 +223,10 @@ class OMproxy implements Runnable{ ret = trans.parse(stream); }catch(IOException e){ debug("OMXML2CMO occuered error in trans"); - return new CMO_ERROR2(new CMO_STRING(e.toString())); + return new cmoError2(new CMO_STRING(e.toString())); }catch(NumberFormatException e){ debug("OMXML2CMO occuered error in trans"); - return new CMO_ERROR2(new CMO_STRING(e.toString())); + return new cmoError2(new CMO_STRING(e.toString())); } debug("push: "+ret);