{ok, Sz} = read(This, i32),
{ok, Bin} = read(This, Sz);
+read(This, 0) -> {ok, <<>>};
read(This, Len) when is_integer(Len), Len >= 0 ->
thrift_transport:read(This#binary_protocol.transport, Len).
end.
init(State=#thrift_socket_server{ip=Ip, port=Port}) ->
- process_flag(trap_exit, true), %% only temporary
+ process_flag(trap_exit, true),
BaseOpts = [binary,
{reuseaddr, true},
{packet, 0},
acceptor_loop({Server, Listen, Service, Handler, SocketOpts})
when is_pid(Server), is_list(SocketOpts) ->
- case catch gen_tcp:accept(Listen) of % infiinite timeout
+ case catch gen_tcp:accept(Listen) of % infinite timeout
{ok, Socket} ->
gen_server:cast(Server, {accepted, self()}),
ProtoGen = fun() ->