Skip to content

Commit

Permalink
Revert "Update thrift_socket_transport.erl"
Browse files Browse the repository at this point in the history
This reverts commit 60fef43.
  • Loading branch information
Jens-G committed Aug 30, 2022
1 parent 60fef43 commit bce985b
Showing 1 changed file with 1 addition and 18 deletions.
19 changes: 1 addition & 18 deletions lib/erl/src/thrift_socket_transport.erl
Original file line number Diff line number Diff line change
Expand Up @@ -70,24 +70,7 @@ when is_integer(Len), Len >= 0 ->
X when X >= Len ->
{Result, Remaining} = split_binary(Binary, Len),
{State#t_socket{buffer = Remaining}, {ok, Result}};
_ ->
%%recv(State, Len)
loop_recv(State,Len,Len)
end.

loop_recv(State=#t_socket{buffer = Buf},ReadLen,NextReadLen) when NextReadLen =< 0->
{Result,Remaining}=split_binary(Buf,ReadLen),
{State#t_socket{buffer = Remaining},{ok,Result}};

loop_recv(State=#t_socket{socket = Socket,buffer = Buf},ReadLen,NextReadLen) when NextReadLen >0 ->
case gen_tcp:recv(Socket,0,State#t_socket.recv_timeout) of
{error,Error}->
gen_tcp:close(Socket),
{State,{error,Error}};
{ok,Data}->
Binary=iolist_to_binary([Buf,Data]),
Give=min(iolist_size(Binary),ReadLen),
loop_recv(State#t_socket{buffer = Binary},ReadLen,ReadLen-Give)
_ -> recv(State, Len)
end.

recv(State = #t_socket{socket = Socket, buffer = Buf}, Len) ->
Expand Down

0 comments on commit bce985b

Please sign in to comment.