Changeset 24c69a2


Ignore:
Timestamp:
Apr 14, 2004 11:26:59 PM (17 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
7b824e61
Parents:
7b03c95
git-author:
mihi <mihi> (04/14/04 23:26:59)
git-committer:
zzz <zzz@…> (04/14/04 23:26:59)
Message:

untabify

[mihi]

Location:
apps/tests
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • apps/tests/EchoServer.java

    r7b03c95 r24c69a2  
    1313
    1414    public static void main(String[] args) throws IOException {
    15         ServerSocket ss = new ServerSocket(Integer.parseInt(args[0]));
    16         while (true) {
    17             Socket s = ss.accept();
    18             new EchoServer(s);
    19         }
     15        ServerSocket ss = new ServerSocket(Integer.parseInt(args[0]));
     16        while (true) {
     17            Socket s = ss.accept();
     18            new EchoServer(s);
     19        }
    2020    }
    2121
     
    2323   
    2424    public EchoServer(Socket s) {
    25         this.s=s;
    26         start();
     25        this.s=s;
     26        start();
    2727    }
    2828
    2929    public void run() {
    30         try {
    31             InputStream in = s.getInputStream();
    32             OutputStream out = s.getOutputStream();
    33             byte[] b = new byte[4096];
    34             int len;
    35             while ((len = in.read(b)) != -1) {
    36                 out.write(b, 0, len);
    37             }
    38         } catch (SocketException ex) {
    39             // nothing
    40         } catch (IOException ex) {
    41             ex.printStackTrace();
    42         }
     30        try {
     31            InputStream in = s.getInputStream();
     32            OutputStream out = s.getOutputStream();
     33            byte[] b = new byte[4096];
     34            int len;
     35            while ((len = in.read(b)) != -1) {
     36                out.write(b, 0, len);
     37            }
     38        } catch (SocketException ex) {
     39            // nothing
     40        } catch (IOException ex) {
     41            ex.printStackTrace();
     42        }
    4343    }
    4444}
  • apps/tests/GuaranteedBug.java

    r7b03c95 r24c69a2  
    1111
    1212    public void reproduce() {
    13         try {
    14             Destination d1 = null;
    15             // first client (receiver)
    16             if (true) { // smaller scope for variables ...
    17                 I2PClient client = I2PClientFactory.createClient();
    18                 ByteArrayOutputStream keyStream =
    19                     new ByteArrayOutputStream(512);
    20                 d1 = client.createDestination(keyStream);
    21                 ByteArrayInputStream in =
    22                     new ByteArrayInputStream(keyStream.toByteArray());
    23                 Properties opts = new Properties();
    24                 opts.setProperty(I2PClient.PROP_RELIABILITY,
    25                                 I2PClient.PROP_RELIABILITY_GUARANTEED);
    26                 opts.setProperty(I2PClient.PROP_TCP_HOST, "127.0.0.1");
    27                 opts.setProperty(I2PClient.PROP_TCP_PORT, "7654");
    28                 I2PSession session = client.createSession(in, opts);
    29                 session.connect();
    30                 session.setSessionListener(new PacketCounter());
    31             }
    32             // second client (sender)
    33             I2PClient client = I2PClientFactory.createClient();
    34             ByteArrayOutputStream keyStream = new ByteArrayOutputStream(512);
    35             Destination d2 = client.createDestination(keyStream);
    36             ByteArrayInputStream in =
    37                 new ByteArrayInputStream(keyStream.toByteArray());
    38             Properties opts = new Properties();
    39             opts.setProperty(I2PClient.PROP_RELIABILITY,
    40                              I2PClient.PROP_RELIABILITY_GUARANTEED);
    41             opts.setProperty(I2PClient.PROP_TCP_HOST, "127.0.0.1");
    42             opts.setProperty(I2PClient.PROP_TCP_PORT, "7654");
    43             I2PSession session = client.createSession(in, opts);
    44             session.connect();
    45             session.setSessionListener(new DummyListener());
    46             for (int i=0;i<1000; i++) {
    47                 byte[] msg = (""+i).getBytes("ISO-8859-1");
    48                 session.sendMessage(d1,msg);
    49                 System.out.println(">>"+i);
    50             }
    51         } catch (IOException ex) {
    52             ex.printStackTrace();
    53         } catch (I2PException ex) {
    54             ex.printStackTrace();
    55         }
     13        try {
     14            Destination d1 = null;
     15            // first client (receiver)
     16            if (true) { // smaller scope for variables ...
     17                I2PClient client = I2PClientFactory.createClient();
     18                ByteArrayOutputStream keyStream =
     19                    new ByteArrayOutputStream(512);
     20                d1 = client.createDestination(keyStream);
     21                ByteArrayInputStream in =
     22                    new ByteArrayInputStream(keyStream.toByteArray());
     23                Properties opts = new Properties();
     24                opts.setProperty(I2PClient.PROP_RELIABILITY,
     25                                I2PClient.PROP_RELIABILITY_GUARANTEED);
     26                opts.setProperty(I2PClient.PROP_TCP_HOST, "127.0.0.1");
     27                opts.setProperty(I2PClient.PROP_TCP_PORT, "7654");
     28                I2PSession session = client.createSession(in, opts);
     29                session.connect();
     30                session.setSessionListener(new PacketCounter());
     31            }
     32            // second client (sender)
     33            I2PClient client = I2PClientFactory.createClient();
     34            ByteArrayOutputStream keyStream = new ByteArrayOutputStream(512);
     35            Destination d2 = client.createDestination(keyStream);
     36            ByteArrayInputStream in =
     37                new ByteArrayInputStream(keyStream.toByteArray());
     38            Properties opts = new Properties();
     39            opts.setProperty(I2PClient.PROP_RELIABILITY,
     40                             I2PClient.PROP_RELIABILITY_GUARANTEED);
     41            opts.setProperty(I2PClient.PROP_TCP_HOST, "127.0.0.1");
     42            opts.setProperty(I2PClient.PROP_TCP_PORT, "7654");
     43            I2PSession session = client.createSession(in, opts);
     44            session.connect();
     45            session.setSessionListener(new DummyListener());
     46            for (int i=0;i<1000; i++) {
     47                byte[] msg = (""+i).getBytes("ISO-8859-1");
     48                session.sendMessage(d1,msg);
     49                System.out.println(">>"+i);
     50            }
     51        } catch (IOException ex) {
     52            ex.printStackTrace();
     53        } catch (I2PException ex) {
     54            ex.printStackTrace();
     55        }
    5656    }
    5757
    5858    public static void main(String[] args) {
    59         new GuaranteedBug().reproduce();
     59        new GuaranteedBug().reproduce();
    6060    }
    6161   
    6262    // -------------------------------------------------------
    6363    public class DummyListener implements I2PSessionListener {
    64         public void disconnected(I2PSession session) {
    65             System.err.println("Disconnected: "+session);
    66         }
     64        public void disconnected(I2PSession session) {
     65            System.err.println("Disconnected: "+session);
     66        }
    6767   
    68         public void errorOccurred(I2PSession session, String message,
    69                                   Throwable error) {
    70             System.err.println("Error: "+session+"/"+message);
    71             error.printStackTrace();
    72         }
     68        public void errorOccurred(I2PSession session, String message,
     69                                  Throwable error) {
     70            System.err.println("Error: "+session+"/"+message);
     71            error.printStackTrace();
     72        }
    7373   
    74         public void messageAvailable(I2PSession session, int msgId,
    75                                      long size) {
    76             System.err.println("Message here? "+session);
    77         }
     74        public void messageAvailable(I2PSession session, int msgId,
     75                                     long size) {
     76            System.err.println("Message here? "+session);
     77        }
    7878   
    79         public void reportAbuse(I2PSession session, int severity) {
    80             System.err.println("Abuse: "+severity+"/"+session);
    81         }
     79        public void reportAbuse(I2PSession session, int severity) {
     80            System.err.println("Abuse: "+severity+"/"+session);
     81        }
    8282    }
    8383
    8484    public class PacketCounter extends DummyListener {
    85         private int lastPacket = -1;
    86         public void messageAvailable(I2PSession session, int msgId,
    87                                      long size) {
    88             try {
    89                 byte msg[] = session.receiveMessage(msgId);
    90                 String m = new String(msg, "ISO-8859-1");
    91                 int no = Integer.parseInt(m);
    92                 if (no != ++lastPacket) {
    93                     System.out.println("ERROR: <<"+no);
    94                 } else {
    95                     System.out.println("<<"+no);
    96                 }
    97             } catch (NumberFormatException ex) {
    98                 ex.printStackTrace();
    99             } catch (I2PException ex) {
    100                 ex.printStackTrace();
    101             } catch (IOException ex) {
    102                 ex.printStackTrace();
    103             }   
    104         }
     85        private int lastPacket = -1;
     86        public void messageAvailable(I2PSession session, int msgId,
     87                                     long size) {
     88            try {
     89                byte msg[] = session.receiveMessage(msgId);
     90                String m = new String(msg, "ISO-8859-1");
     91                int no = Integer.parseInt(m);
     92                if (no != ++lastPacket) {
     93                    System.out.println("ERROR: <<"+no);
     94                } else {
     95                    System.out.println("<<"+no);
     96                }
     97            } catch (NumberFormatException ex) {
     98                ex.printStackTrace();
     99            } catch (I2PException ex) {
     100                ex.printStackTrace();
     101            } catch (IOException ex) {
     102                ex.printStackTrace();
     103            }   
     104        }
    105105    }
    106106}
  • apps/tests/echotester/EchoTester.java

    r7b03c95 r24c69a2  
    105105        } catch (InterruptedException ex) {
    106106            ex.printStackTrace();
    107             System.exit(1); // treat these errors as fatal         
     107            System.exit(1); // treat these errors as fatal         
    108108        } catch (IOException ex) {
    109109            ex.printStackTrace();
Note: See TracChangeset for help on using the changeset viewer.