blob: 9a675d223334ae63a3d9adef523d99eb5543f688 (
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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
// $Id$
// ============================================================================
//
//
// = FILENAME
// NS_Resolve.java
//
// = AUTHOR
// Michael Kircher (mk1@cs.wustl.edu)
// Modified for new protocol by Hans Ridder <ridder@veritas.com>
// Further improved by Kevin Regan <kregan@infoglide.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)
{
MulticastSocket sendSocket = null;
ServerSocket listenSocket = null;
Socket replySocket = null;
try
{
// Create the multicast socket at any port
sendSocket = new MulticastSocket(0);
// Create a socket at any port for the Naming Service answer
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() + 3;
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());
msg.write(0);
// 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);
replySocket = listenSocket.accept();
// @@ The restriction right now is that the length of the IOR cannot be longer than 4096
char[] reply = new char[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++)
{
int c = in.read();
if (c == -1)
{
throw new IOException("Unexpected EOF.");
}
reply[ length ] = (char) c;
if (c == 0)
{
break;
}
}
// Convert the String into ??
return orb.string_to_object(new String(reply, 2, length-2));
}
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);
}
finally
{
// Close the sockets.
if (sendSocket != null)
{
sendSocket.close();
}
if (listenSocket != null)
{
try
{
listenSocket.close();
}
catch (IOException e) {}
}
if (replySocket != null)
{
try
{
replySocket.close();
}
catch (IOException e) {}
}
}
return null;
}
}
|
