=================================================================== RCS file: /home/cvs/OpenXM/src/OpenMath/OMproxy.java,v retrieving revision 1.22 retrieving revision 1.34 diff -u -p -r1.22 -r1.34 --- OpenXM/src/OpenMath/OMproxy.java 2000/01/19 15:32:50 1.22 +++ OpenXM/src/OpenMath/OMproxy.java 2000/03/14 05:38:49 1.34 @@ -1,5 +1,5 @@ /** - * $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.21 2000/01/19 15:21:58 tam Exp $ + * $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.*; @@ -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(Exception 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..."); } /* @@ -57,32 +64,39 @@ class OMproxy implements Runnable{ */ private void SM_popCMO() throws java.io.IOException{ - if(stack.empty()){ - ox.send(new CMO_NULL()); - }else{ - debug("sending CMO: "+ stack.peek()); - 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){} } } private void SM_executeFunction() throws java.io.IOException{ String function_name; CMO[] argv; - int argc = 1; + 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(); - //argc = ((CMO_INT32)stack.pop()).intValue(); + argc = ((CMO_INT32)stack.pop()).intValue(); argv = new CMO[argc]; for(int i=0;i