Author: batosai
Date: 2008-05-23 19:16:28 +0000 (Fri, 23 May 2008)
New Revision: 20081
Modified:
trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java
trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java
trunk/apps/WoT/src/plugins/WoT/WoT.java
Log:
Pass the FCP connection to the insert thread so it can insert identities.
Modified: trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java
===================================================================
--- trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java 2008-05-23
18:18:25 UTC (rev 20080)
+++ trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java 2008-05-23
19:16:28 UTC (rev 20081)
@@ -8,6 +8,8 @@
import java.util.Iterator;
import java.util.List;
+import net.pterodactylus.fcp.FcpConnection;
+
import com.db4o.ObjectContainer;
import com.db4o.query.Predicate;
@@ -19,6 +21,7 @@
public class IdentityInserter implements Runnable{
private ObjectContainer db;
+ private FcpConnection fcp;
private Thread inserter;
/**
@@ -26,8 +29,9 @@
*
* @param db Connection to the database
*/
- public IdentityInserter(ObjectContainer db) {
+ public IdentityInserter(ObjectContainer db, FcpConnection fcp) {
this.db = db;
+ this.fcp = fcp;
}
/**
@@ -47,7 +51,7 @@
while(it.hasNext()) {
OwnIdentity identityToInsert = it.next();
- //TODO Insert the identity
+ identityToInsert.insert(fcp);
}
try {
Modified: trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java
===================================================================
--- trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java 2008-05-23 18:18:25 UTC
(rev 20080)
+++ trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java 2008-05-23 19:16:28 UTC
(rev 20081)
@@ -141,6 +141,10 @@
fos.close();
}
+ public void insert(FcpConnection fcp) {
+ //TODO Export and insert the identity
+ }
+
/**
*
* @return Whether the identity has been updated since the last insert
Modified: trunk/apps/WoT/src/plugins/WoT/WoT.java
===================================================================
--- trunk/apps/WoT/src/plugins/WoT/WoT.java 2008-05-23 18:18:25 UTC (rev
20080)
+++ trunk/apps/WoT/src/plugins/WoT/WoT.java 2008-05-23 19:16:28 UTC (rev
20081)
@@ -59,7 +59,7 @@
initFCPConnection(host, port);
db = Db4o.openFile("WoT.db4o");
- identityInserter = new IdentityInserter(db);
+ identityInserter = new IdentityInserter(db, fcp);
identityInserter.start();
}
_______________________________________________
cvs mailing list
[email protected]
http://emu.freenetproject.org/cgi-bin/mailman/listinfo/cvs
