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

[t...@freenetproject.org]

Author: toad
Date: 2008-03-19 15:13:28 +0000 (Wed, 19 Mar 2008)
New Revision: 18597

Modified:
   trunk/freenet/src/freenet/io/comm/DMT.java
Log:
FNPSSKDataFound split into two messages. Just the messages in this commit.

Modified: trunk/freenet/src/freenet/io/comm/DMT.java
===================================================================
--- trunk/freenet/src/freenet/io/comm/DMT.java  2008-03-19 13:30:40 UTC (rev 
18596)
+++ trunk/freenet/src/freenet/io/comm/DMT.java  2008-03-19 15:13:28 UTC (rev 
18597)
@@ -649,6 +649,30 @@
                return msg;
        }

+       public static final MessageType FNPSSKDataFoundHeaders = new 
MessageType("FNPSSKDataFoundHeaders", PRIORITY_BULK_DATA) {{
+               addField(UID, Long.class);
+               addField(BLOCK_HEADERS, ShortBuffer.class);
+       }};
+       
+       public static Message createFNPSSKDataFoundHeaders(long uid, byte[] 
headers) {
+               Message msg = new Message(FNPSSKDataFound);
+               msg.set(UID, uid);
+               msg.set(BLOCK_HEADERS, new ShortBuffer(headers));
+               return msg;
+       }
+       
+       public static final MessageType FNPSSKDataFoundData = new 
MessageType("FNPSSKDataFoundData", PRIORITY_BULK_DATA) {{
+               addField(UID, Long.class);
+               addField(DATA, ShortBuffer.class);
+       }};
+       
+       public static Message createFNPSSKDataFoundData(long uid, byte[] data) {
+               Message msg = new Message(FNPSSKDataFoundData);
+               msg.set(UID, uid);
+               msg.set(DATA, new ShortBuffer(data));
+               return msg;
+       }
+       
        public static MessageType FNPSSKAccepted = new 
MessageType("FNPSSKAccepted", PRIORITY_HIGH) {{
                addField(UID, Long.class);
                addField(NEED_PUB_KEY, Boolean.class);