test/java/net/DatagramSocket/PortUnreachable.java

Print this page

        

*** 1,7 **** /* ! * Copyright (c) 2000, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. --- 1,7 ---- /* ! * Copyright (c) 2000, 2013 Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation.
*** 29,64 **** * exception on Windows 2000. */ import java.net.InetAddress; import java.net.DatagramSocket; import java.net.DatagramPacket; - import java.io.InterruptedIOException; ! public class PortUnreachable implements Runnable { DatagramSocket clientSock; int serverPort; int clientPort; ! public void run() { try { InetAddress addr = InetAddress.getLocalHost(); ! ! Thread.currentThread().sleep(2000); ! // send a delayed packet which should mean a delayed icmp // port unreachable byte b[] = "A late msg".getBytes(); DatagramPacket packet = new DatagramPacket(b, b.length, addr, serverPort); clientSock.send(packet); - // wait before bringing the server up - Thread.currentThread().sleep(5000); - DatagramSocket sock = new DatagramSocket(serverPort); ! b = "Grettings from the server".getBytes(); packet = new DatagramPacket(b, b.length, addr, clientPort); sock.send(packet); sock.close(); } catch (Exception e) { e.printStackTrace(); --- 29,58 ---- * exception on Windows 2000. */ import java.net.InetAddress; import java.net.DatagramSocket; import java.net.DatagramPacket; ! public class PortUnreachable { DatagramSocket clientSock; int serverPort; int clientPort; ! public void serverSend() { try { InetAddress addr = InetAddress.getLocalHost(); ! Thread.currentThread().sleep(1000); // send a delayed packet which should mean a delayed icmp // port unreachable byte b[] = "A late msg".getBytes(); DatagramPacket packet = new DatagramPacket(b, b.length, addr, serverPort); clientSock.send(packet); DatagramSocket sock = new DatagramSocket(serverPort); ! b = "Greetings from the server".getBytes(); packet = new DatagramPacket(b, b.length, addr, clientPort); sock.send(packet); sock.close(); } catch (Exception e) { e.printStackTrace();
*** 68,104 **** PortUnreachable() throws Exception { clientSock = new DatagramSocket(); clientPort = clientSock.getLocalPort(); // pick a port for the server DatagramSocket sock2 = new DatagramSocket(); serverPort = sock2.getLocalPort(); - sock2.close(); // send a burst of packets to the unbound port - we should get back // icmp port unreachable messages // InetAddress addr = InetAddress.getLocalHost(); byte b[] = "Hello me".getBytes(); DatagramPacket packet = new DatagramPacket(b, b.length, addr, serverPort); for (int i=0; i<100; i++) clientSock.send(packet); ! // start the server thread ! Thread thr = new Thread(this); ! thr.start(); ! // try to receive clientSock.setSoTimeout(10000); clientSock.receive(packet); // done clientSock.close(); } public static void main(String[] args) throws Exception { ! new PortUnreachable(); } } --- 62,104 ---- PortUnreachable() throws Exception { clientSock = new DatagramSocket(); clientPort = clientSock.getLocalPort(); + } + + void execute () throws Exception{ + // pick a port for the server DatagramSocket sock2 = new DatagramSocket(); serverPort = sock2.getLocalPort(); // send a burst of packets to the unbound port - we should get back // icmp port unreachable messages // InetAddress addr = InetAddress.getLocalHost(); byte b[] = "Hello me".getBytes(); DatagramPacket packet = new DatagramPacket(b, b.length, addr, serverPort); + //close just before sending + sock2.close(); for (int i=0; i<100; i++) clientSock.send(packet); ! serverSend(); // try to receive + b = new byte[25]; + packet = new DatagramPacket(b, b.length, addr, serverPort); clientSock.setSoTimeout(10000); clientSock.receive(packet); + System.out.println("client received data packet " + new String(packet.getData())); // done clientSock.close(); } public static void main(String[] args) throws Exception { ! PortUnreachable test = new PortUnreachable(); ! test.execute(); } }