version 1.39, 2000/07/03 05:57:43 |
version 1.42, 2001/01/30 05:55:13 |
|
|
/** |
/** |
* $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.38 2000/06/14 08:01:08 tam Exp $ |
* $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.41 2000/10/11 08:32:13 ohara 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.*; |
|
|
public class OMproxy extends OpenXMserver{ |
public class OMproxy extends OpenXMControlServer{ |
private Stack stack = new Stack(); |
private Stack stack = new Stack(); |
protected boolean debug = false; |
protected boolean debug = false; |
final int version = 200006130; |
final int version = 200006130; |
Line 15 public class OMproxy extends OpenXMserver{ |
|
Line 15 public class OMproxy extends OpenXMserver{ |
|
super(hostname,ControlPort,DataPort); |
super(hostname,ControlPort,DataPort); |
} |
} |
|
|
public void computeProcess(OpenXMconnection stream){ |
public void computeProcess(OpenXMstream stream){ |
OM2OXM P = new OM2OXM(); |
OM2OXM P = new OM2OXM(); |
|
|
debug("OMproxy started."); |
debug("OMproxy started."); |
Line 51 public class OMproxy extends OpenXMserver{ |
|
Line 51 public class OMproxy extends OpenXMserver{ |
|
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."); |
}finally{ |
}finally{ |
System.out.println("breaking..."); |
System.err.println("breaking..."); |
} |
} |
} |
} |
|
|
/* |
/* |
public void stop(){ |
public void stop(){ |
System.out.println("OMproxy Stoping..."); |
System.err.println("OMproxy Stoping..."); |
synchronized(ox){ |
synchronized(ox){ |
//this.stop(); |
//this.stop(); |
while(!stack.empty()){ |
while(!stack.empty()){ |
stack.pop(); |
stack.pop(); |
} |
} |
System.out.println("OMproxy Stopped"); |
System.err.println("OMproxy Stopped"); |
} |
} |
} |
} |
*/ |
*/ |
|
|
private void SM_popCMO(OpenXMconnection stream) throws java.io.IOException{ |
private void SM_popCMO(OpenXMstream stream) throws java.io.IOException{ |
try{ |
try{ |
if(stack.empty()){ |
if(stack.empty()){ |
stream.send(new CMO_NULL()); |
stream.send(new CMO_NULL()); |
Line 118 public class OMproxy extends OpenXMserver{ |
|
Line 118 public class OMproxy extends OpenXMserver{ |
|
return; |
return; |
} |
} |
|
|
private void SM_mathcap(OpenXMconnection stream) 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 167 public class OMproxy extends OpenXMserver{ |
|
Line 167 public class OMproxy extends OpenXMserver{ |
|
debug("push: "+ stack.peek()); |
debug("push: "+ stack.peek()); |
} |
} |
|
|
private void SM_setMathCap(OpenXMconnection stream) |
private void SM_setMathCap(OpenXMstream stream) |
throws java.io.IOException{ |
throws java.io.IOException{ |
Object mathcap = stack.pop(); |
Object mathcap = stack.pop(); |
|
|
Line 177 public class OMproxy extends OpenXMserver{ |
|
Line 177 public class OMproxy extends OpenXMserver{ |
|
stream.setMathCap((CMO_MATHCAP)mathcap); |
stream.setMathCap((CMO_MATHCAP)mathcap); |
} |
} |
|
|
private void StackMachine(SM mesg,OpenXMconnection stream) |
private void StackMachine(SM mesg,OpenXMstream stream) |
throws java.io.IOException{ |
throws java.io.IOException{ |
debug("receive: "+mesg); |
debug("receive: "+mesg); |
|
|
Line 199 public class OMproxy extends OpenXMserver{ |
|
Line 199 public class OMproxy extends OpenXMserver{ |
|
break; |
break; |
|
|
default: |
default: |
System.out.println("received "+ mesg); |
System.err.println("received "+ mesg); |
} |
} |
} |
} |
|
|
Line 266 public class OMproxy extends OpenXMserver{ |
|
Line 266 public class OMproxy extends OpenXMserver{ |
|
public static void main(String[] argv){ |
public static void main(String[] argv){ |
String hostname = "localhost"; |
String hostname = "localhost"; |
int ControlPort = 1200, DataPort = 1300; |
int ControlPort = 1200, DataPort = 1300; |
OpenXMserver ox; |
OpenXMControlServer ox; |
|
|
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.println(""); |
System.err.println(""); |
System.exit(0); |
System.exit(0); |
}else if(argv[i].equals("-host")){ |
}else if(argv[i].equals("-host")){ |
hostname = argv[++i]; |
hostname = argv[++i]; |
Line 302 public class OMproxy extends OpenXMserver{ |
|
Line 302 public class OMproxy extends OpenXMserver{ |
|
|
|
ox.start(); |
ox.start(); |
|
|
System.out.println("breaking..."); |
System.err.println("breaking..."); |
} |
} |
} |
} |