Author: jflesch
Date: 2007-04-15 15:49:00 +0000 (Sun, 15 Apr 2007)
New Revision: 12750
Added:
trunk/apps/Thaw/src/thaw/fcp/FCPAddPeer.java
trunk/apps/Thaw/src/thaw/fcp/FCPRemovePeer.java
Log:
I forgot two files ...
Added: trunk/apps/Thaw/src/thaw/fcp/FCPAddPeer.java
===================================================================
--- trunk/apps/Thaw/src/thaw/fcp/FCPAddPeer.java
(rev 0)
+++ trunk/apps/Thaw/src/thaw/fcp/FCPAddPeer.java 2007-04-15 15:49:00 UTC
(rev 12750)
@@ -0,0 +1,50 @@
+package thaw.fcp;
+
+
+public class FCPAddPeer implements FCPQuery {
+ private String ref;
+
+ /**
+ * Ref can be a real ref, or URL=http://where.to-get-the-ref-on-the.net/
+ */
+ public FCPAddPeer(String ref) {
+ this.ref = ref;
+ }
+
+
+ public boolean start(FCPQueueManager queueManager) {
+ FCPMessage msg = new FCPMessage();
+
+ msg.setMessageName("AddPeer");
+
+ String[] lines = ref.split("\n");
+
+ for (int i = 0 ; i < lines.length ; i++) {
+ String[] elements = lines[i].split("=");
+
+ if (elements.length < 2) /* may happen for the word
'end' at the end of the ref */
+ continue;
+
+ String optName = elements[0];
+ String optValue = "";
+
+ for (int j = 1; j < elements.length ; j++)
+ optValue += elements[j];
+
+ msg.setValue(optName, optValue);
+ }
+
+ return queueManager.getQueryManager().writeMessage(msg);
+ }
+
+
+ public boolean stop(FCPQueueManager queueManager) {
+ /* can't stop */
+ return false;
+ }
+
+
+ public int getQueryType() {
+ return 0;
+ }
+}
Added: trunk/apps/Thaw/src/thaw/fcp/FCPRemovePeer.java
===================================================================
--- trunk/apps/Thaw/src/thaw/fcp/FCPRemovePeer.java
(rev 0)
+++ trunk/apps/Thaw/src/thaw/fcp/FCPRemovePeer.java 2007-04-15 15:49:00 UTC
(rev 12750)
@@ -0,0 +1,35 @@
+package thaw.fcp;
+
+
+public class FCPRemovePeer implements FCPQuery {
+ private String name;
+
+ /**
+ * Ref can be a real ref, or URL=http://where.to-get-the-ref-on-the.net/
+ */
+ public FCPRemovePeer(String name) {
+ this.name = name;
+ }
+
+
+ public boolean start(FCPQueueManager queueManager) {
+ FCPMessage msg = new FCPMessage();
+
+ msg.setMessageName("RemovePeer");
+
+ msg.setValue("NodeIdentifier", name);
+
+ return queueManager.getQueryManager().writeMessage(msg);
+ }
+
+
+ public boolean stop(FCPQueueManager queueManager) {
+ /* can't stop */
+ return false;
+ }
+
+
+ public int getQueryType() {
+ return 0;
+ }
+}
