summaryrefslogtreecommitdiff
path: root/src/SocketCore.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-05-16 20:58:51 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-05-16 20:58:51 +0900
commitee129231224d7205dee311b783818470d0282e1b (patch)
tree3f66cfb6d2f8a7acdc6f6d1790460bac575fc34b /src/SocketCore.cc
parentc26da096875d609b354ea5989f62af662f9c609e (diff)
Arrange #ifdef guard so that formatter does not get fooled
Diffstat (limited to 'src/SocketCore.cc')
-rw-r--r--src/SocketCore.cc55
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;
}