version 1.2, 2000/09/08 07:29:45 |
version 1.3, 2000/09/13 06:32:43 |
|
|
/** |
/** |
* $OpenXM: OpenXM/src/OpenMath/ORG/openxm/tam/OpenXMserver.java,v 1.1 2000/09/07 11:07:01 tam Exp $ |
* $OpenXM: OpenXM/src/OpenMath/ORG/openxm/tam/OpenXMserver.java,v 1.2 2000/09/08 07:29:45 tam Exp $ |
*/ |
*/ |
package ORG.openxm.tam; |
package ORG.openxm.tam; |
|
|
Line 12 import java.net.*; |
|
Line 12 import java.net.*; |
|
*/ |
*/ |
public abstract class OpenXMserver{ |
public abstract class OpenXMserver{ |
private OpenXMserver server = null; |
private OpenXMserver server = null; |
private OpenXMconnection control = null; |
private OpenXMstream control = null; |
private OpenXMconnection stream = null; |
private OpenXMstream stream = null; |
private Thread computeThread = null; |
private Thread computeThread = null; |
final protected boolean debug = false; |
final protected boolean debug = false; |
|
|
Line 25 public abstract class OpenXMserver{ |
|
Line 25 public abstract class OpenXMserver{ |
|
server = this; |
server = this; |
|
|
try{ |
try{ |
control = new OpenXMconnection(host,CtrlPort,true); |
control = new OpenXMstream(host,CtrlPort,true); |
stream = new OpenXMconnection(host,StreamPort,true); |
stream = new OpenXMstream(host,StreamPort,true); |
|
|
this.start(); |
this.start(); |
}catch(IOException e){} |
}catch(IOException e){} |
Line 78 public abstract class OpenXMserver{ |
|
Line 78 public abstract class OpenXMserver{ |
|
} |
} |
} |
} |
|
|
abstract protected void computeProcess(OpenXMconnection DataStream); |
abstract protected void computeProcess(OpenXMstream DataStream); |
/* |
/* |
private void computeProcess(OpenXMconnection DataStream){ |
private void computeProcess(OpenXMstream DataStream){ |
while(true){ |
while(true){ |
debug("test process executing"); |
debug("test process executing"); |
try{ |
try{ |