[40769 svn/public] plugins/networks/azi2phelper/org/parg/azureus/plugins/ networks/i2p

[<pga...@vu...>]

Revision: 40769
Author:   pgardner
Date:     2014-09-16 03:41:43 +0000 (Tue, 16 Sep 2014)
Log Message:
-----------


Modified Paths:
--------------
    plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/I2PHelperPlugin.java
    plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/vuzedht/DHTTransportAZ.java

Modified: plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/I2PHelperPlugin.java
===================================================================
--- plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/I2PHelperPlugin.java	2014-09-16 01:17:37 UTC (rev 40768)
+++ plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/I2PHelperPlugin.java	2014-09-16 03:41:43 UTC (rev 40769)
@@ -1652,17 +1652,17 @@
 								
 								@Override
 								public void reportSize(long size) {
-								
+									System.out.println( "size=" + size );
 								}
 								
 								@Override
 								public void reportCompleteness(int percent) {
-								
+									System.out.println( "done=" + percent );
 								}
 								
 								@Override
 								public void reportActivity(String str) {
-								
+									System.out.println( "act=" + str );
 								}
 							},
 							test_xfer, 
@@ -1669,7 +1669,7 @@
 							key, 
 							60*1000 );
 						
-						System.out.println( "DDBValue=" + value );
+						System.out.println( "DDBValue=" + ( value == null?"null":((byte[])value.getValue(byte[].class )).length));
 					}
 					
 				}else if ( cmd.equals( "ping_node" )){

Modified: plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/vuzedht/DHTTransportAZ.java
===================================================================
--- plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/vuzedht/DHTTransportAZ.java	2014-09-16 01:17:37 UTC (rev 40768)
+++ plugins/networks/azi2phelper/org/parg/azureus/plugins/networks/i2p/vuzedht/DHTTransportAZ.java	2014-09-16 03:41:43 UTC (rev 40769)
@@ -66,7 +66,7 @@
 	private static final int	METHOD_STORE		= 3;
 	private static final int	METHOD_DATA			= 4;
 	
-	private static final int	MAX_DATA_SIZE	= 16*1024;
+	private static final int	MAX_DATA_SIZE	= 10*1024;
 	
 		// skew our time randomly so that multiple transports don't show the same clock times in requests
 	
@@ -722,6 +722,8 @@
 		payload.put( "l", packet.getLength());
 		payload.put( "t", packet.getTotalLength());
 		
+		System.out.println( "Sending " + payload );
+		
 		DHTTransportAZ.this.sendRequest(
 			new AZReplyHandlerAdapter()
 			{	
@@ -759,6 +761,8 @@
 		DHTTransportContactAZ		contact,
 		Map<String,Object>			payload )
 	{
+		System.out.println( "Received " + payload );
+		
 		long 	connection_id 	= ((Number)payload.get("c" )).longValue();
 		byte 	packet_type 	= ((Number)payload.get("p" )).byteValue();
 		byte[]	transfer_key	= (byte[])payload.get("z" );