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