Annotation of OpenXM/src/OpenMath/OMproxy.java, Revision 1.13
1.2 tam 1: /**
1.13 ! tam 2: * $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.12 1999/11/17 08:47:55 tam Exp $
1.2 tam 3: */
4:
1.1 tam 5: import JP.ac.kobe_u.math.tam.OpenXM.*;
6: import java.util.Stack;
7: import java.io.*;
8:
9: class OMproxy implements Runnable{
10: private OpenXM ox;
11: private Stack stack = new Stack();
1.4 tam 12: private boolean debug = true;
1.9 tam 13: final int version = 199911110;
1.1 tam 14:
15: public OMproxy(String host,int ControlPort,int DataPort) throws IOException{
16: ox = new OpenXM(this,host,ControlPort,DataPort);
17: }
18:
19: public void run(){
20: OM2OXM P = new OM2OXM();
21:
1.9 tam 22: debug("OMproxy started.");
1.1 tam 23: try{
24: while(true){
1.9 tam 25: int ox_tag = ox.receiveOXtag();
1.1 tam 26:
1.9 tam 27: switch(ox_tag){
28: case OpenXM.OX_COMMAND:
29: StackMachine(ox.receiveSM());
30: break;
31:
32: case OpenXM.OX_DATA:
33: stack.push(ox.receiveCMO());
34: debug("push: "+ stack.peek());
35: break;
1.1 tam 36: }
37: }
38: }catch(java.io.IOException e){
39: System.err.println(e.getMessage());
40: e.printStackTrace();
41: }
42:
43: System.out.println("breaking...");
44: }
45:
1.9 tam 46: /*
1.1 tam 47: public void stop(){
48: System.out.println("OMproxy Stoping...");
49: synchronized(ox){
50: //this.stop();
51: while(!stack.empty()){
52: stack.pop();
53: }
54: System.out.println("OMproxy Stopped");
55: }
56: }
1.9 tam 57: */
1.1 tam 58:
59: private void SM_popCMO() throws java.io.IOException{
60: if(stack.empty()){
61: ox.send(new CMO_NULL());
62: }else{
1.13 ! tam 63: debug("sending CMO: "+ stack.peek());
1.1 tam 64: ox.send(stack.pop());
65: }
66: }
67:
68: private void SM_executeFunction() throws java.io.IOException{
69: String function_name;
70: CMO[] argv;
1.3 tam 71: int argc = 1;
1.1 tam 72:
73: if(!(stack.peek() instanceof CMO_STRING)){
74: stack.push(new CMO_ERROR2());
75: return;
76: }
77: function_name = ((CMO_STRING)stack.pop()).getString();
1.3 tam 78: //argc = ((CMO_INT32)stack.pop()).intValue();
1.1 tam 79: argv = new CMO[argc];
80: for(int i=0;i<argc;i++){
81: argv[i] = (CMO)stack.pop();
82: }
83:
84: if(argc != 1){
85: stack.push(new CMO_ERROR2());
86: return;
87: }
88:
89: if(function_name.equals("OMXML2CMO")){
90: stack.push(OMXML2CMO(argv[0]));
91: return;
92: }else if(function_name.equals("CMO2OMXML")){
93: stack.push(CMO2OMXML(argv[0]));
94: return;
95: }
96:
97: stack.push(new CMO_ERROR2());
98: return;
99: }
100:
1.7 tam 101: private void SM_mathcap() throws java.io.IOException{
102: CMO[] mathcap = new CMO[3];
103:
104: {
1.9 tam 105: CMO[] list = {new CMO_INT32(version),
1.7 tam 106: new CMO_STRING("Ox_system=OMproxy.class"),
1.9 tam 107: new CMO_STRING("Version=0."+ version),
1.7 tam 108: new CMO_STRING("HOSTTYPE=JAVA")};
109: mathcap[0] = new CMO_LIST(list);
110: }
111:
112: {
113: CMO[] list = {new CMO_INT32(SM.SM_popCMO),
114: new CMO_INT32(SM.SM_executeFunction),
1.10 tam 115: new CMO_INT32(SM.SM_mathcap),
116: new CMO_INT32(SM.SM_control_kill),
117: new CMO_INT32(SM.SM_control_reset_connection)};
1.7 tam 118: mathcap[1] = new CMO_LIST(list);
119: }
120:
121: {
122: CMO[] DataFormat = {new CMO_INT32(OpenXM.OX_DATA)};
123: CMO[] CMOFormat = {new CMO_INT32(CMO.CMO_NULL),
124: new CMO_INT32(CMO.CMO_INT32),
125: new CMO_INT32(CMO.CMO_STRING),
1.9 tam 126: new CMO_INT32(CMO.CMO_LIST),
1.7 tam 127: new CMO_INT32(CMO.CMO_MONOMIAL32),
128: new CMO_INT32(CMO.CMO_ZZ),
129: new CMO_INT32(CMO.CMO_QQ),
130: new CMO_INT32(CMO.CMO_ZERO),
1.12 tam 131: new CMO_INT32(CMO.CMO_DMS_GENERIC),
132: //new CMO_INT32(CMO.CMO_RECURSIVE_POLYNOMIAL),
1.9 tam 133: new CMO_INT32(CMO.CMO_DISTRIBUTED_POLYNOMIAL),
1.12 tam 134: //new CMO_INT32(CMO.CMO_POLYNOMIAL_IN_ONE_VARIABLE),
135: new CMO_INT32(CMO.CMO_BIGFLOAT),
136: new CMO_INT32(CMO.CMO_INDETERMINATE),
137: new CMO_INT32(CMO.CMO_TREE)};
1.7 tam 138: CMO[] list = {new CMO_LIST(DataFormat),
139: new CMO_LIST(CMOFormat)};
140: mathcap[2] = new CMO_LIST(list);
141: }
142:
1.8 tam 143: stack.push(new CMO_MATHCAP(new CMO_LIST(mathcap)));
144: debug("push: "+ stack.peek());
1.7 tam 145: }
146:
1.1 tam 147: private void StackMachine(SM mesg) throws java.io.IOException{
1.4 tam 148: debug("receive: "+mesg);
149:
1.1 tam 150: switch(mesg.getCode()){
151: case SM.SM_popCMO:
152: SM_popCMO();
153: break;
154:
155: case SM.SM_executeFunction:
156: SM_executeFunction();
1.7 tam 157: break;
158:
159: case SM.SM_mathcap:
160: SM_mathcap();
1.1 tam 161: break;
162:
163: default:
164: System.out.println("received "+ mesg);
165: }
166: }
167:
168: private CMO CMO2OMXML(CMO obj){
1.11 tam 169: String str;
170:
171: try{
172: str = OM2OXM.CMO2OM(obj);
173: }catch(NumberFormatException e){
174: debug("CMO2OMXML occuered error in trans");
175: return new CMO_ERROR2(new CMO_STRING(e.toString()));
176: }
1.1 tam 177:
178: return new CMO_STRING(str);
179: }
180:
181: private CMO OMXML2CMO(CMO obj){
182: OM2OXM trans = new OM2OXM();
183: //StringBufferInputStream stream;
184: ByteArrayInputStream stream;
185: CMO ret;
186:
1.5 tam 187: debug("OMXML2CMO called: "+obj);
1.6 tam 188: if(!(obj instanceof CMO_STRING)){
1.11 tam 189: return new CMO_ERROR2(new CMO_STRING("It's not CMO_STRING."));
1.1 tam 190: }
191:
192: try{
193: stream = new ByteArrayInputStream(((CMO_STRING)obj).getString().getBytes());
194: ret = trans.parse(stream);
195: }catch(IOException e){
1.11 tam 196: debug("OMXML2CMO occuered error in trans");
197: return new CMO_ERROR2(new CMO_STRING(e.toString()));
198: }catch(NumberFormatException e){
1.6 tam 199: debug("OMXML2CMO occuered error in trans");
1.1 tam 200: return new CMO_ERROR2(new CMO_STRING(e.toString()));
201: }
202:
1.4 tam 203: debug("push: "+ret);
1.1 tam 204: return ret;
1.4 tam 205: }
206:
207: private void debug(String str){
208: if(debug){
209: System.out.println(str);
210: }
1.1 tam 211: }
212:
1.2 tam 213: private static String usage(){
214: String ret = "";
215:
216: ret += "usage\t: java OMproxy [options]\n";
217: ret += "options\t:\n";
218: ret += "\t -h \t show this message\n";
219: ret += "\t -host hostname \t (default localhost)\n";
220: ret += "\t -data port \t (default 1300)\n";
221: ret += "\t -control port \t (default 1200)\n";
1.8 tam 222: ret += "\t -insecure \t this version ignore this option\n";
1.2 tam 223:
224: return ret;
225: }
226:
1.1 tam 227: public static void main(String argv[]){
228: String host = "localhost";
229: int DataPort = 1300, ControlPort = 1200;
230:
231: for(int i=0;i<argv.length;i++){
232: if(argv[i].equals("-h")){
1.2 tam 233: System.out.print(usage());
1.1 tam 234: System.exit(0);
235: }else if(argv[i].equals("-host")){
236: host = argv[++i];
237: }else if(argv[i].equals("-data")){
238: DataPort = Integer.valueOf(argv[++i]).intValue();
239: }else if(argv[i].equals("-control")){
240: ControlPort = Integer.valueOf(argv[++i]).intValue();
1.8 tam 241: }else if(argv[i].equals("-insecure")){
1.1 tam 242: }else{
1.2 tam 243: System.err.println("unknown option : "+ argv[i]);
244: System.err.print(usage());
1.1 tam 245: System.exit(1);
246: }
247: }
1.2 tam 248:
1.1 tam 249: System.out.println("host(ctrl,data): "+ host
250: +"("+ ControlPort +","+ DataPort +")");
251:
252: try{
253: new OMproxy(host,ControlPort,DataPort);
254: System.out.println("connected.");
255: }catch(IOException e){
256: System.err.println("Error occured: "+ e);
257: System.err.println(e.getLocalizedMessage());
258: System.err.println(e.getMessage());
259: }
260: }
261: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to OMproxy.java CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM / src / OpenMath