-----BEGIN PGP SIGNED MESSAGE-----
Hash: SHA1
Folks-
I've been doing more testing lately, and I've got a threading problem with
castor, and I'm not sure on the proper fix. Consider this code of my test
example:
public class DBTest implements Runnable{
int number;
public DBTest(int i){
number=i; }
public void run() {
try {
Debug.printEnter(this,"Test number: "+number);
String dbname = "mediamgmt";
String confFileName="/mediamgmt-castor.xml";
JDO jdo = new JDO();
jdo.setLogWriter(Logger.getSystemLogger());
jdo.setClassLoader( getClass().getClassLoader() );
jdo.setConfiguration(getClass().getResource(confFileName).toString());
jdo.setDatabaseName(dbname);
Database db = jdo.getDatabase();
db.begin();
int name = 1;
OQLQuery oql = db.getOQLQuery("Select s from " +
"org.mv5.delivery.model.Server s where s.id = $1");
oql.bind(name);
QueryResults qr = oql.execute();
if (!qr.hasMore()){
throw new GeneralException("No such server.2");
}
Server s = (Server)qr.next();
qr.close();
oql.close();
db.commit();
db.close();
Debug.printExit(this,"Test number: "+number);
} catch (Exception e){
Debug.print(this,e.getMessage(),Debug.ERROR,e);
}
}
public static void main(String[]argv){
try {
int num = 5;
if (argv.length>0){
num = Integer.parseInt(argv[0]);
}
Thread[] testList = new Thread[num];
for (int i=0;i<testList.length;i++){
testList[i]=new Thread(new DBTest(i));
}
for (int i=0;i<testList.length;i++){
testList[i].start();
}
} catch (Exception e){
e.printStackTrace();
}
}
}
This example queries for a 'server' object, where there is only one. When I
run it with an argument of 1 (one thread), it works fine. No exceptions. But
when I run it with an argument of 2 (two threads) it fails with the following
stacktrace. (Sorry, my emailer reformats it)
java.lang.NullPointerException: Adding null value is not allowed
at
org.exolab.castor.persist.FieldMolder.addValue(FieldMolder.java:268)
at
org.exolab.castor.persist.CollectionProxy$ColProxy.add(ClassMolder.java:2943)
at
org.exolab.castor.persist.ClassMolder.revertObject(ClassMolder.java:2452)
at
org.exolab.castor.persist.LockEngine.revertObject(LockEngine.java:861)
at
org.exolab.castor.persist.TransactionContext.rollback(TransactionContext.java:
1604)
at
org.exolab.castor.jdo.engine.DatabaseImpl.commit(DatabaseImpl.java:502)
at DBTest.run(DBTest.java:42)
at java.lang.Thread.run(Thread.java:484)
7492 [Thread-1] ERROR interactive - [ ERROR ]-[ class DBTest ]-[ at
DBTest.run(DBTest.java:46) ]-[ Nested error:
org.exolab.castor.jdo.LockNotGrantedException: persist.deadlock ]
org.exolab.castor.jdo.LockNotGrantedException: persist.deadlock
at
org.exolab.castor.persist.ObjectLock.detectDeadlock(ObjectLock.java:928)
at org.exolab.castor.persist.ObjectLock.upgrade(ObjectLock.java:722)
at
org.exolab.castor.persist.LockEngine$TypeInfo.upgrade(LockEngine.java:1151)
at
org.exolab.castor.persist.LockEngine$TypeInfo.access$600(LockEngine.java:964)
at org.exolab.castor.persist.LockEngine.writeLock(LockEngine.java:806)
at
org.exolab.castor.persist.TransactionContext.writeLock(TransactionContext.java
:1183)
at
org.exolab.castor.persist.ClassMolder.preStore(ClassMolder.java:1504)
at org.exolab.castor.persist.LockEngine.preStore(LockEngine.java:724)
at
org.exolab.castor.persist.TransactionContext.prepare(TransactionContext.java:1
360)
at
org.exolab.castor.jdo.engine.DatabaseImpl.commit(DatabaseImpl.java:499)
at DBTest.run(DBTest.java:42)
at java.lang.Thread.run(Thread.java:484)
java.lang.NullPointerException: Adding null value is not allowed
at
org.exolab.castor.persist.FieldMolder.addValue(FieldMolder.java:268)
at
org.exolab.castor.persist.CollectionProxy$ColProxy.add(ClassMolder.java:2943)
at
org.exolab.castor.persist.ClassMolder.revertObject(ClassMolder.java:2452)
at
org.exolab.castor.persist.LockEngine.revertObject(LockEngine.java:861)
at
org.exolab.castor.persist.TransactionContext.rollback(TransactionContext.java:
1604)
at
org.exolab.castor.jdo.engine.DatabaseImpl.commit(DatabaseImpl.java:502)
at DBTest.run(DBTest.java:42)
at java.lang.Thread.run(Thread.java:484)
17445 [Thread-0] ERROR interactive - [ ERROR ]-[ class DBTest ]-[ at
DBTest.run(DBTest.java:46) ]-[ Nested error:
org.exolab.castor.jdo.LockNotGrantedException:
persist.writeTimeoutorg.mv5.delivery.model.Server/1/0 by
org.exolab.castor.jdo.engine.TransactionContextImpl@530cf2 ]
org.exolab.castor.jdo.LockNotGrantedException:
persist.writeTimeoutorg.mv5.delivery.model.Server/1/0 by
org.exolab.castor.jdo.engine.TransactionContextImpl@530cf2
at org.exolab.castor.persist.ObjectLock.upgrade(ObjectLock.java:714)
at
org.exolab.castor.persist.LockEngine$TypeInfo.upgrade(LockEngine.java:1151)
at
org.exolab.castor.persist.LockEngine$TypeInfo.access$600(LockEngine.java:964)
at org.exolab.castor.persist.LockEngine.writeLock(LockEngine.java:806)
at
org.exolab.castor.persist.TransactionContext.writeLock(TransactionContext.java
:1183)
at
org.exolab.castor.persist.ClassMolder.preStore(ClassMolder.java:1504)
at org.exolab.castor.persist.LockEngine.preStore(LockEngine.java:724)
at
org.exolab.castor.persist.TransactionContext.prepare(TransactionContext.java:1
360)
at
org.exolab.castor.jdo.engine.DatabaseImpl.commit(DatabaseImpl.java:499)
at DBTest.run(DBTest.java:42)
at java.lang.Thread.run(Thread.java:484)
Now, my server object is fairly complicated... and I include the xml for it
in here. (See bottom of email.) I'm not sure on why this is happening, and
I'm looking for fixes or workarounds. Any help is appreciated. (I can send
more data has requested.)
<class name="org.mv5.delivery.model.Server"
identity="id"
key-generator="SEQUENCE">
<cache-type type="none"/>
<description>Server info</description>
<map-to table="server" />
<field name="id" type="integer">
<sql name="server_id" type="integer"/>
</field>
<field name="data" type="org.mv5.delivery.model.ServerData">
<sql name="server_data_id"/>
</field>
<field name="downstreamservers" type="org.mv5.delivery.model.RemoteServer"
collection="collection"/>
<field name="dirs" type="org.mv5.delivery.model.Dir"
collection="collection"/>
<field name="jarfiles" type="org.mv5.delivery.model.Jarfile"
collection="collection" lazy="true"/>
<field name="prefs" type="org.mv5.delivery.model.Prefs">
<sql name="prefs_id"/>
</field>
</class>
Virtually,
Ned Wolpert <[EMAIL PROTECTED]>
D08C2F45: 28E7 56CB 58AC C622 5A51 3C42 8B2B 2739 D08C 2F45
-----BEGIN PGP SIGNATURE-----
Version: GnuPG v1.0.6 (GNU/Linux)
Comment: For info see http://www.gnupg.org
iD8DBQE78ESHiysnOdCML0URAlsyAJ9u5qRDTP2dKPYn6sRr90rV4GscgwCfRLOb
G+wEhmOm5JKNZNtf9ZQWBZs=
=CNKS
-----END PGP SIGNATURE-----
-----------------------------------------------------------
If you wish to unsubscribe from this mailing, send mail to
[EMAIL PROTECTED] with a subject of:
unsubscribe castor-dev
