diff options
| author | Mark Spruiell <mes@zeroc.com> | 2004-12-17 18:23:27 +0000 |
|---|---|---|
| committer | Mark Spruiell <mes@zeroc.com> | 2004-12-17 18:23:27 +0000 |
| commit | 7cee383b15fb8205808152d0a5de7fd22bef6db7 (patch) | |
| tree | 6594849759a11d0e0b706abaa0d551d19d771e28 /java/src/IceInternal/TcpConnector.java | |
| parent | compression fix (diff) | |
| download | ice-7cee383b15fb8205808152d0a5de7fd22bef6db7.tar.bz2 ice-7cee383b15fb8205808152d0a5de7fd22bef6db7.tar.xz ice-7cee383b15fb8205808152d0a5de7fd22bef6db7.zip | |
use blocking mode for thread-per-connection
Diffstat (limited to 'java/src/IceInternal/TcpConnector.java')
| -rw-r--r-- | java/src/IceInternal/TcpConnector.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/java/src/IceInternal/TcpConnector.java b/java/src/IceInternal/TcpConnector.java index b8f001b9648..7db462169d9 100644 --- a/java/src/IceInternal/TcpConnector.java +++ b/java/src/IceInternal/TcpConnector.java @@ -21,7 +21,10 @@ final class TcpConnector implements Connector } java.nio.channels.SocketChannel fd = Network.createTcpSocket(); - Network.setBlock(fd, false); + if(!_instance.threadPerConnection()) + { + Network.setBlock(fd, false); + } Network.doConnect(fd, _addr, timeout); if(_traceLevels.network >= 1) |