summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/UdpConnector.java
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2007-11-27 11:58:35 +0100
committerBenoit Foucher <benoit@zeroc.com>2007-11-27 11:58:35 +0100
commit47f800495093fd7679a315e2d730fea22f6135b7 (patch)
treea7b8d3488f3841367dd03d10cae293f36fd10481 /java/src/IceInternal/UdpConnector.java
parentFixed SystemException to no longer derive from LocalException (diff)
downloadice-47f800495093fd7679a315e2d730fea22f6135b7.tar.bz2
ice-47f800495093fd7679a315e2d730fea22f6135b7.tar.xz
ice-47f800495093fd7679a315e2d730fea22f6135b7.zip
- Added support for non-blocking AMI/batch requests, connection
creation. - Added support for AMI oneway requests. - Changed collocation optimization to not perform any DNS lookups.
Diffstat (limited to 'java/src/IceInternal/UdpConnector.java')
-rw-r--r--java/src/IceInternal/UdpConnector.java26
1 files changed, 8 insertions, 18 deletions
diff --git a/java/src/IceInternal/UdpConnector.java b/java/src/IceInternal/UdpConnector.java
index e3c49b6955b..37964024236 100644
--- a/java/src/IceInternal/UdpConnector.java
+++ b/java/src/IceInternal/UdpConnector.java
@@ -11,18 +11,23 @@ package IceInternal;
final class UdpConnector implements Connector, java.lang.Comparable
{
- final static short TYPE = 3;
-
public Transceiver
connect(int timeout)
{
return new UdpTransceiver(_instance, _addr, _mcastInterface, _mcastTtl);
}
+ public java.nio.channels.SelectableChannel
+ fd()
+ {
+ assert(false); // Shouldn't be called, startConnect always completes immediately.
+ return null;
+ }
+
public short
type()
{
- return TYPE;
+ return UdpEndpointI.TYPE;
}
public String
@@ -37,21 +42,6 @@ final class UdpConnector implements Connector, java.lang.Comparable
return _hashCode;
}
- final public boolean
- equivalent(String host, int port)
- {
- java.net.InetSocketAddress addr;
- try
- {
- addr = Network.getAddress(host, port);
- }
- catch(Ice.DNSException ex)
- {
- return false;
- }
- return addr.equals(_addr);
- }
-
//
// Only for use by TcpEndpoint
//