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


Reply via email to