antville/helma
antville/helma
1
1
Fork 0
Code Issues 5 Pull requests 5 Projects Releases 5 Activity Actions

Moved Evaluator init code from typemanager to prototype.

Browse source 
Fixed evaluator not being initialized by new prototypes
This commit is contained in:
hns 2001-01-24 17:19:42 +00:00
parent 7376855af9
commit 4552af0cda
3 changed files with 35 additions and 39 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/helma/framework/core/Prototype.java
View file

@ -7,6 +7,7 @@ import java.util.*;
import java.io.*;
import helma.framework.*;
import helma.objectmodel.*;
import FESI.Data.*;
import FESI.Exceptions.EcmaScriptException;
@ -121,6 +122,30 @@ public class Prototype {
public void initRequestEvaluator (RequestEvaluator reval) {
ObjectPrototype op = null;
if ("user".equalsIgnoreCase (name))
op = reval.esUserPrototype;
else if ("global".equalsIgnoreCase (name))
op = reval.global;
else if ("hopobject".equalsIgnoreCase (name))
op = reval.esNodePrototype;
else {
op = new ObjectPrototype (reval.esNodePrototype, reval.evaluator);
try {
op.putProperty ("prototypename", new ESString (name), "prototypename".hashCode ());
} catch (EcmaScriptException ignore) {}
}
reval.putPrototype (name, op);
// Register a constructor for all types except global.
// This will first create a node and then call the actual (scripted) constructor on it.
if (!"global".equalsIgnoreCase (name)) {
try {
FunctionPrototype fp = (FunctionPrototype) reval.evaluator.getFunctionPrototype();
reval.global.putHiddenProperty (name, new NodeConstructor (name, fp, reval));
} catch (EcmaScriptException ignore) {}
}
for (Enumeration en = functions.elements(); en.hasMoreElements(); ) {
FunctionFile ff = (FunctionFile) en.nextElement ();
ff.updateRequestEvaluator (reval);

34
src/helma/framework/core/TypeManager.java
View file

@ -195,16 +195,11 @@ public class TypeManager implements Runnable {
proto.functions = nfunc;
proto.actions = nact;
// register constructor for evaluators that are already initialized.
if (!"global".equalsIgnoreCase (name)) {
// init prototype on evaluators that are already initialized.
Iterator evals = getRegisteredRequestEvaluators ();
while (evals.hasNext ()) {
try {
RequestEvaluator reval = (RequestEvaluator) evals.next ();
FunctionPrototype fp = (FunctionPrototype) reval.evaluator.getFunctionPrototype();
reval.global.putHiddenProperty (name, new NodeConstructor (name, fp, reval));
} catch (Exception ignore) {}
}
proto.initRequestEvaluator (reval);
}
}
@ -294,31 +289,6 @@ public class TypeManager implements Runnable {
registeredEvaluators.add (reval);
for (Enumeration en = prototypes.elements(); en.hasMoreElements(); ) {
Prototype p = (Prototype) en.nextElement ();
String name = p.getName ();
ObjectPrototype op = null;
if ("user".equalsIgnoreCase (name))
op = reval.esUserPrototype;
else if ("global".equalsIgnoreCase (name))
op = reval.global;
else if ("hopobject".equalsIgnoreCase (name))
op = reval.esNodePrototype;
else {
op = new ObjectPrototype (reval.esNodePrototype, reval.evaluator);
try {
op.putProperty ("prototypename", new ESString (name), "prototypename".hashCode ());
} catch (EcmaScriptException ignore) {}
}
reval.putPrototype (name, op);
// Register a constructor for all types except global.
// This will first create a node and then call the actual (scripted) constructor on it.
if (!"global".equalsIgnoreCase (name)) {
try {
FunctionPrototype fp = (FunctionPrototype) reval.evaluator.getFunctionPrototype();
reval.global.putHiddenProperty (name, new NodeConstructor (name, fp, reval));
} catch (EcmaScriptException ignore) {}
}
p.initRequestEvaluator (reval);
}
reval.initialized = true;

9
src/helma/xmlrpc/XmlRpcClient.java
View file

@ -19,14 +19,17 @@ public class XmlRpcClient implements XmlRpcHandler {
URL url;
String auth;
int maxThreads = 50;
int maxThreads = 100;
// pool of worker instances
Stack pool = new Stack ();
int workers = 0;
long calls = 0;
// average roundtrip of this method call. This is used to decide if
// additional threads are needed or not in async mode
int roundtrip = 1000;
// a queue of calls to be handled asynchronously
CallData first, last;
/**
@ -84,7 +87,6 @@ public class XmlRpcClient implements XmlRpcHandler {
try {
Object retval = worker.execute (method, params);
long end = System.currentTimeMillis ();
calls++;
roundtrip = (int) ((roundtrip*4)+(end-start))/5;
return retval;
} finally {
@ -204,7 +206,6 @@ public class XmlRpcClient implements XmlRpcHandler {
if (callback != null)
callback.handleError (x, url, method);
}
calls++;
long end = System.currentTimeMillis ();
roundtrip = (int) ((roundtrip*4)+(end-start))/5;
}