From 7956f23d4e5ae4be1da85d3fd91b9823531b19b6 Mon Sep 17 00:00:00 2001 From: David Reiss Date: Wed, 11 Jun 2008 01:02:47 +0000 Subject: [PATCH] add a case clause to bubble timeouts git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@666454 13f79535-47bb-0310-9956-ffa450edef68 --- lib/alterl/src/thrift_binary_protocol.erl | 1 + lib/alterl/src/thrift_socket_transport.erl | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/alterl/src/thrift_binary_protocol.erl b/lib/alterl/src/thrift_binary_protocol.erl index da43d148..c1f9d4ec 100644 --- a/lib/alterl/src/thrift_binary_protocol.erl +++ b/lib/alterl/src/thrift_binary_protocol.erl @@ -178,6 +178,7 @@ read(This, message_begin) -> seqid = SeqId}; Err = {error, closed} -> Err; + Err = {error, timeout}-> Err; Err = {error, ebadf} -> Err end; diff --git a/lib/alterl/src/thrift_socket_transport.erl b/lib/alterl/src/thrift_socket_transport.erl index 9d15ee16..9cc0af9d 100644 --- a/lib/alterl/src/thrift_socket_transport.erl +++ b/lib/alterl/src/thrift_socket_transport.erl @@ -31,7 +31,7 @@ read(#data{socket=Socket, recv_timeout=Timeout}, Len) when is_integer(Len), Len >= 0 -> case gen_tcp:recv(Socket, Len, Timeout) of Err = {error, timeout} -> - error_logger:error_msg("read timeout for conn with ~p", [inet:peername(Socket)]), + error_logger:info_msg("read timeout: peer conn ~p", [inet:peername(Socket)]), gen_tcp:close(Socket), Err; Data -> Data -- 2.17.1