diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2006-02-20 10:31:57 +0000 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2006-02-20 10:31:57 +0000 |
| commit | e1d3d16e0fb475d771fbc476a3f1e88c9bcdc10f (patch) | |
| tree | 03017261521ec7c308e3e092b15a74edcd6ca8e2 /cppe/src/TcpTransport/Connector.cpp | |
| parent | porting new proxy methods for connection mgmt (diff) | |
| download | ice-e1d3d16e0fb475d771fbc476a3f1e88c9bcdc10f.tar.bz2 ice-e1d3d16e0fb475d771fbc476a3f1e88c9bcdc10f.tar.xz ice-e1d3d16e0fb475d771fbc476a3f1e88c9bcdc10f.zip | |
Use socket timeouts by default.
Diffstat (limited to 'cppe/src/TcpTransport/Connector.cpp')
| -rw-r--r-- | cppe/src/TcpTransport/Connector.cpp | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/cppe/src/TcpTransport/Connector.cpp b/cppe/src/TcpTransport/Connector.cpp index 33f5876b34c..de2ea96f2d9 100644 --- a/cppe/src/TcpTransport/Connector.cpp +++ b/cppe/src/TcpTransport/Connector.cpp @@ -34,12 +34,7 @@ Connector::connect(int timeout) SOCKET fd = createSocket(); setBlock(fd, false); doConnect(fd, _addr, timeout); -#if !defined(_WIN32) || defined(ICEE_USE_SOCKET_TIMEOUT) - // - // TODO: We can't use blocking sockets on Windows yet because - // the transceiver is using WSAEventSelect (which doesn't play - // well with blocking sockets). - // +#ifndef ICEE_USE_SELECT_FOR_TIMEOUTS setBlock(fd, true); #endif @@ -49,7 +44,7 @@ Connector::connect(int timeout) out << "tcp connection established\n" << fdToString(fd); } - return new Transceiver(_instance, fd); + return new Transceiver(_instance, fd, _timeout); } string @@ -58,10 +53,11 @@ Connector::toString() const return addrToString(_addr); } -Connector::Connector(const InstancePtr& instance, const string& host, int port) : +Connector::Connector(const InstancePtr& instance, const string& host, int port, int timeout) : _instance(instance), _traceLevels(instance->traceLevels()), - _logger(instance->logger()) + _logger(instance->logger()), + _timeout(timeout) { getAddress(host, port, _addr); } |