TAO/examples/Simulator/DOVEBrowser/NS_Resolve.java

   1 // ============================================================================
   2 //
   3 // = FILENAME
   4 //    NS_Resolve.java
   5 //
   6 // = AUTHOR
   7 //    Michael Kircher (mk1@cs.wustl.edu)
   8 //    Modified for new protocol by Hans Ridder <ridder@veritas.com>
   9 //    Further improved by Kevin Regan <kregan@infoglide.com>
  10 //
  11 // = DESCRIPTION
  12 //   Resolves the initial reference to the Naming service,
  13 //   the orb has to be given as a parameter to the
  14 //   resolve_name_service call.
  15 //
  16 // ============================================================================
  17
  18 import org.omg.CORBA.*;
  19 import java.net.*;
  20 import java.io.*;
  21
  22 public class NS_Resolve
  23 {
  24   private static final String ACE_DEFAULT_MULTICAST_ADDR = "224.9.9.2";
  25   private static final int TAO_DEFAULT_NAME_SERVER_REQUEST_PORT = 10013;
  26   private static final String TAO_SERVICEID_NAMESERVICE = "NameService";
  27
  28   int nameServicePort_;
  29
  30   public NS_Resolve (String nameServicePort)
  31   {
  32     if (nameServicePort != null)
  33       {
  34         // If a name service port string was given, parse it
  35         nameServicePort_ = Integer.parseInt (nameServicePort);
  36       }
  37     else
  38       {
  39         // Otherwise, just use the default TAO name service port
  40         nameServicePort_ = TAO_DEFAULT_NAME_SERVER_REQUEST_PORT;
  41       }
  42   }
  43
  44   public org.omg.CORBA.Object resolve_name_service (org.omg.CORBA.ORB orb)
  45   {
  46     MulticastSocket sendSocket = null;
  47     ServerSocket listenSocket = null;
  48     Socket replySocket = null;
  49
  50     try
  51       {
  52         // Create the multicast socket at any port
  53         sendSocket = new MulticastSocket(0);
  54
  55         // Create a socket at any port for the Naming Service answer
  56         listenSocket = new ServerSocket(0);
  57
  58         // Create a message with the port and service name in it,
  59         // length and port number are in network byte order
  60         ByteArrayOutputStream msg = new ByteArrayOutputStream();
  61         int dataLength = TAO_SERVICEID_NAMESERVICE.length() + 3;
  62         msg.write((dataLength >> 8) & 0xff);
  63         msg.write(dataLength & 0xff);
  64         msg.write((listenSocket.getLocalPort() >> 8) & 0xff);
  65         msg.write(listenSocket.getLocalPort() & 0xff);
  66         msg.write(TAO_SERVICEID_NAMESERVICE.getBytes());
  67         msg.write(0);
  68
  69         // Define the group for the multicast
  70         InetAddress group = InetAddress.getByName(ACE_DEFAULT_MULTICAST_ADDR);
  71         // Create a datagram with the message and send it
  72         sendSocket.send(new DatagramPacket(msg.toByteArray(),
  73                                            msg.size(),
  74                                            group, nameServicePort_));
  75
  76         // Wait 3 seconds for the Naming Service to connect
  77         listenSocket.setSoTimeout(3000);
  78         replySocket = listenSocket.accept();
  79
  80         // @@ The restriction right now is that the length of the IOR cannot be longer than 4096
  81         char[] reply = new char[4096];
  82
  83         // Receive the reply (0 terminated string) or time out
  84         replySocket.setSoTimeout(3000);
  85         InputStream in = replySocket.getInputStream();
  86         int length;
  87         for (length = 0; length < reply.length; length++)
  88           {
  89             int c = in.read();
  90
  91             if (c == -1)
  92               {
  93                 throw new IOException("Unexpected EOF.");
  94               }
  95
  96             reply[ length ] = (char) c;
  97
  98             if (c == 0)
  99               {
 100                 break;
 101               }
 102           }
 103
 104         // Convert the String into ??
 105         return orb.string_to_object(new String(reply, 2, length-2));
 106       }
 107     catch (SocketException e)
 108       {
 109         System.err.println (e);
 110       }
 111     catch (java.io.InterruptedIOException e)
 112       {
 113         System.err.println ("NS_Resolve: The receive lasted too long");
 114       }
 115     catch(org.omg.CORBA.SystemException e)
 116       {
 117         System.err.println(e);
 118       }
 119     catch (java.io.IOException e)
 120       {
 121         System.err.println (e);
 122       }
 123     finally
 124       {
 125         // Close the sockets.
 126
 127         if (sendSocket != null)
 128           {
 129             sendSocket.close();
 130           }
 131
 132         if (listenSocket != null)
 133           {
 134             try
 135               {
 136                 listenSocket.close();
 137               }
 138             catch (IOException e) {}
 139           }
 140
 141         if (replySocket != null)
 142           {
 143             try
 144               {
 145                 replySocket.close();
 146               }
 147             catch (IOException e) {}
 148           }
 149       }
 150
 151     return null;
 152   }
 153 }