diff options
author | Benoit Foucher <benoit@zeroc.com> | 2007-11-27 11:58:35 +0100 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2007-11-27 11:58:35 +0100 |
commit | 47f800495093fd7679a315e2d730fea22f6135b7 (patch) | |
tree | a7b8d3488f3841367dd03d10cae293f36fd10481 /java/src/IceInternal/UdpConnector.java | |
parent | Fixed SystemException to no longer derive from LocalException (diff) | |
download | ice-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.java | 26 |
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 // |