[freenet-cvs] r18615 - trunk/freenet/src/freenet/io/comm

[t...@freenetproject.org]

Author: toad
Date: 2008-03-19 16:48:23 +0000 (Wed, 19 Mar 2008)
New Revision: 18615

Modified:
   trunk/freenet/src/freenet/io/comm/DMT.java
Log:
Messages for SSK insert split

Modified: trunk/freenet/src/freenet/io/comm/DMT.java
===================================================================
--- trunk/freenet/src/freenet/io/comm/DMT.java  2008-03-19 16:42:07 UTC (rev 
18614)
+++ trunk/freenet/src/freenet/io/comm/DMT.java  2008-03-19 16:48:23 UTC (rev 
18615)
@@ -634,7 +634,45 @@
                msg.set(DATA, new ShortBuffer(data));
                return msg;
        }
+       
+       public static final MessageType FNPSSKInsertRequestNew = new 
MessageType("FNPSSKInsertRequestNew", PRIORITY_BULK_DATA) {{
+               addField(UID, Long.class);
+               addField(HTL, Short.class);
+               addField(FREENET_ROUTING_KEY, NodeSSK.class);
+       }};
+       
+       public static Message createFNPSSKInsertRequestNew(long uid, short htl, 
NodeSSK myKey) {
+               Message msg = new Message(FNPSSKInsertRequestNew);
+               msg.set(UID, uid);
+               msg.set(HTL, htl);
+               msg.set(FREENET_ROUTING_KEY, myKey);
+               return msg;
+       }

+       public static final MessageType FNPSSKInsertRequestHeaders = new 
MessageType("FNPSSKInsertRequestHeaders", PRIORITY_HIGH) {{
+               addField(UID, Long.class);
+               addField(BLOCK_HEADERS, ShortBuffer.class);
+       }};
+       
+       public static final Message createFNPSSKInsertRequestHeaders(long uid, 
byte[] headers) {
+               Message msg = new Message(FNPSSKInsertRequestHeaders);
+               msg.set(UID, uid);
+               msg.set(BLOCK_HEADERS, new ShortBuffer(headers));
+               return msg;
+       }
+       
+       public static final MessageType FNPSSKInsertRequestData = new 
MessageType("FNPSSKInsertRequestData", PRIORITY_BULK_DATA) {{
+               addField(UID, Long.class);
+               addField(BLOCK_HEADERS, ShortBuffer.class);
+       }};
+       
+       public static final Message createFNPSSKInsertRequestData(long uid, 
byte[] data) {
+               Message msg = new Message(FNPSSKInsertRequestHeaders);
+               msg.set(UID, uid);
+               msg.set(DATA, new ShortBuffer(data));
+               return msg;
+       }
+       
        public static final MessageType FNPSSKDataFound = new 
MessageType("FNPSSKDataFound", PRIORITY_BULK_DATA) {{
                addField(UID, Long.class);
                addField(BLOCK_HEADERS, ShortBuffer.class);