i2p.itoopie/apps/tests/GuaranteedBug.java

// compile & run this file against i2p.jar

import java.io.*;
import java.util.*;
import net.i2p.*;
import net.i2p.client.*;
import net.i2p.data.*;

public class GuaranteedBug {


    public void reproduce() {
	try {
	    Destination d1 = null;
	    // first client (receiver)
	    if (true) { // smaller scope for variables ...
		I2PClient client = I2PClientFactory.createClient();
		ByteArrayOutputStream keyStream =
		    new ByteArrayOutputStream(512);
		d1 = client.createDestination(keyStream);
		ByteArrayInputStream in =
		    new ByteArrayInputStream(keyStream.toByteArray());
		Properties opts = new Properties();
		opts.setProperty(I2PClient.PROP_RELIABILITY,
				 I2PClient.PROP_RELIABILITY_GUARANTEED);
		opts.setProperty(I2PClient.PROP_TCP_HOST, "127.0.0.1");
		opts.setProperty(I2PClient.PROP_TCP_PORT, "7654");
		I2PSession session = client.createSession(in, opts);
		session.connect();
		session.setSessionListener(new PacketCounter());
	    }
	    // second client (sender)
	    I2PClient client = I2PClientFactory.createClient();
	    ByteArrayOutputStream keyStream = new ByteArrayOutputStream(512);
	    Destination d2 = client.createDestination(keyStream);
	    ByteArrayInputStream in =
		new ByteArrayInputStream(keyStream.toByteArray());
	    Properties opts = new Properties();
	    opts.setProperty(I2PClient.PROP_RELIABILITY,
			     I2PClient.PROP_RELIABILITY_GUARANTEED);
	    opts.setProperty(I2PClient.PROP_TCP_HOST, "127.0.0.1");
	    opts.setProperty(I2PClient.PROP_TCP_PORT, "7654");
	    I2PSession session = client.createSession(in, opts);
	    session.connect();
	    session.setSessionListener(new DummyListener());
	    for (int i=0;i<1000; i++) {
		byte[] msg = (""+i).getBytes("ISO-8859-1");
		session.sendMessage(d1,msg);
		System.out.println(">>"+i);
	    }
	} catch (IOException ex) {
	    ex.printStackTrace();
	} catch (I2PException ex) {
	    ex.printStackTrace();
	}
    }

    public static void main(String[] args) {
	new GuaranteedBug().reproduce();
    }
    
    // -------------------------------------------------------
    public class DummyListener implements I2PSessionListener {
	public void disconnected(I2PSession session) {
	    System.err.println("Disconnected: "+session);
	}
    
	public void errorOccurred(I2PSession session, String message,
				  Throwable error) {
	    System.err.println("Error: "+session+"/"+message);
	    error.printStackTrace();
	}
    
	public void messageAvailable(I2PSession session, int msgId,
				     long size) {
	    System.err.println("Message here? "+session);
	}
    
	public void reportAbuse(I2PSession session, int severity) {
	    System.err.println("Abuse: "+severity+"/"+session);
	}
    }

    public class PacketCounter extends DummyListener {
	private int lastPacket = -1;
	public void messageAvailable(I2PSession session, int msgId,
				     long size) {
	    try {
		byte msg[] = session.receiveMessage(msgId);
		String m = new String(msg, "ISO-8859-1");
		int no = Integer.parseInt(m);
		if (no != ++lastPacket) {
		    System.out.println("ERROR: <<"+no);
		} else {
		    System.out.println("<<"+no);
		}
	    } catch (NumberFormatException ex) {
		ex.printStackTrace();
	    } catch (I2PException ex) {
		ex.printStackTrace();
	    } catch (IOException ex) {
		ex.printStackTrace();
	    }    
	}
    }
}