Author: toad
Date: 2008-03-19 16:55:32 +0000 (Wed, 19 Mar 2008)
New Revision: 18617
Modified:
trunk/freenet/src/freenet/node/NodeDispatcher.java
Log:
Handle FNPSSKInsertRequestNew
Modified: trunk/freenet/src/freenet/node/NodeDispatcher.java
===================================================================
--- trunk/freenet/src/freenet/node/NodeDispatcher.java 2008-03-19 16:55:06 UTC
(rev 18616)
+++ trunk/freenet/src/freenet/node/NodeDispatcher.java 2008-03-19 16:55:32 UTC
(rev 18617)
@@ -168,6 +168,8 @@
return handleInsertRequest(m, source, false);
} else if(spec == DMT.FNPSSKInsertRequest) {
return handleInsertRequest(m, source, true);
+ } else if(spec == DMT.FNPSSKInsertRequestNew) {
+ return handleInsertRequest(m, source, true);
} else if(spec == DMT.FNPRHProbeRequest) {
return handleProbeRequest(m, source);
} else if(spec == DMT.FNPRoutedPing) {
@@ -396,6 +398,12 @@
SSKInsertHandler rh = new SSKInsertHandler(key, data,
headers, htl, source, id, node, now);
rh.receivedBytes(m.receivedByteCount());
node.executor.execute(rh, "SSKInsertHandler for "+id+"
on "+node.getDarknetPortNumber());
+ } else if(m.getSpec().equals(DMT.FNPSSKInsertRequestNew)) {
+ NodeSSK key = (NodeSSK)
m.getObject(DMT.FREENET_ROUTING_KEY);
+ short htl = m.getShort(DMT.HTL);
+ SSKInsertHandler rh = new SSKInsertHandler(key, null,
null, htl, source, id, node, now);
+ rh.receivedBytes(m.receivedByteCount());
+ node.executor.execute(rh, "SSKInsertHandler for "+id+"
on "+node.getDarknetPortNumber());
} else {
CHKInsertHandler rh = new CHKInsertHandler(m, source,
id, node, now);
node.executor.execute(rh, "CHKInsertHandler for "+id+"
on "+node.getDarknetPortNumber());