summaryrefslogtreecommitdiffstats
path: root/rpc
diff options
context:
space:
mode:
Diffstat (limited to 'rpc')
-rw-r--r--rpc/rpc-transport/socket/src/socket.c18
1 files changed, 11 insertions, 7 deletions
diff --git a/rpc/rpc-transport/socket/src/socket.c b/rpc/rpc-transport/socket/src/socket.c
index ae574f5f5..830aece05 100644
--- a/rpc/rpc-transport/socket/src/socket.c
+++ b/rpc/rpc-transport/socket/src/socket.c
@@ -148,10 +148,12 @@ typedef int SSL_trinary_func (SSL *, void *, int);
&in->pending_count, \
&bytes_read); \
if (ret == -1) { \
- gf_log (this->name, GF_LOG_WARNING, \
- "reading from socket failed. Error (%s), " \
- "peer (%s)", strerror (errno), \
- this->peerinfo.identifier); \
+ if (priv->read_fail_log) \
+ gf_log (this->name, GF_LOG_WARNING, \
+ "reading from socket failed." \
+ "Error (%s), peer (%s)", \
+ strerror (errno), \
+ this->peerinfo.identifier); \
break; \
} \
__socket_proto_update_priv_after_read (priv, ret, bytes_read); \
@@ -496,9 +498,11 @@ __socket_rwv (rpc_transport_t *this, struct iovec *vector, int count,
if (errno == EINTR)
continue;
- gf_log (this->name, GF_LOG_WARNING,
- "%s failed (%s)", write ? "writev" : "readv",
- strerror (errno));
+ if (write || (!write && priv->read_fail_log))
+ gf_log (this->name, GF_LOG_WARNING,
+ "%s failed (%s)",
+ write ? "writev":"readv",
+ strerror (errno));
if (priv->use_ssl) {
ssl_dump_error_stack(this->name);
}