diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-05-16 20:58:51 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-05-16 20:58:51 +0900 |
| commit | ee129231224d7205dee311b783818470d0282e1b (patch) | |
| tree | 3f66cfb6d2f8a7acdc6f6d1790460bac575fc34b /src/SocketCore.cc | |
| parent | c26da096875d609b354ea5989f62af662f9c609e (diff) | |
Arrange #ifdef guard so that formatter does not get fooled
Diffstat (limited to 'src/SocketCore.cc')
| -rw-r--r-- | src/SocketCore.cc | 55 |
1 files changed, 28 insertions, 27 deletions
diff --git a/src/SocketCore.cc b/src/SocketCore.cc index 701fc33e..46a3eece 100644 --- a/src/SocketCore.cc +++ b/src/SocketCore.cc @@ -823,38 +823,39 @@ void SocketCore::readData(void* data, size_t& len) } ret = 0; } - } else if(!secure_) { -#else - if(!secure_) { + } else #endif // HAVE_LIBSSH2 - // Cast for Windows recv() - while((ret = recv(sockfd_, reinterpret_cast<char*>(data), len, 0)) == -1 && - SOCKET_ERRNO == A2_EINTR); - int errNum = SOCKET_ERRNO; - if(ret == -1) { - if(!A2_WOULDBLOCK(errNum)) { - throw DL_RETRY_EX(fmt(EX_SOCKET_RECV, errorMsg(errNum).c_str())); + if(!secure_) { + // Cast for Windows recv() + while((ret = recv(sockfd_, + reinterpret_cast<char*>(data), len, 0)) == -1 && + SOCKET_ERRNO == A2_EINTR); + int errNum = SOCKET_ERRNO; + if(ret == -1) { + if(!A2_WOULDBLOCK(errNum)) { + throw DL_RETRY_EX(fmt(EX_SOCKET_RECV, errorMsg(errNum).c_str())); + } + wantRead_ = true; + ret = 0; } - wantRead_ = true; - ret = 0; - } - } else { + } else { #ifdef ENABLE_SSL - ret = tlsSession_->readData(data, len); - if(ret < 0) { - if(ret != TLS_ERR_WOULDBLOCK) { - throw DL_RETRY_EX(fmt(EX_SOCKET_RECV, - tlsSession_->getLastErrorString().c_str())); - } - if(tlsSession_->checkDirection() == TLS_WANT_READ) { - wantRead_ = true; - } else { - wantWrite_ = true; + ret = tlsSession_->readData(data, len); + if(ret < 0) { + if(ret != TLS_ERR_WOULDBLOCK) { + throw DL_RETRY_EX(fmt(EX_SOCKET_RECV, + tlsSession_->getLastErrorString().c_str())); + } + if(tlsSession_->checkDirection() == TLS_WANT_READ) { + wantRead_ = true; + } else { + wantWrite_ = true; + } + ret = 0; } - ret = 0; - } #endif // ENABLE_SSL - } + } + len = ret; } |
