[freenet-cvs] r20081 - trunk/apps/WoT/src/plugins/WoT

[bato...@freenetproject.org]

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();

        }