kqqsysu/ssdb-erlang

Erlang SSDB Client

ssdb-erlang's Issues

parse receiving data exception

ssdb_conn.erl
parse_recv fun，when step =:= ?SSDB_STEP_DATA
the last message can match <<BlockData:Size/binary-unit:8, $\n:8, $\n:8, Res/binary>> or <<BlockData:Size/binary-unit:8, $\n:8, Res/binary>>
If the match <<BlockData:Size/binary-unit:8, $\n:8, Res/binary>>,step state = ?SSDB_STEP_SIZE,but it was the last message.
solution:
parse_recv(#ssdb_conn{step = ?SSDB_STEP_SIZE, data = Data} = State, InData) ->
NewData = <<Data/binary, InData/binary>>,
case binary:split(NewData, <<"\n">>) of
[<<>>, <<>>] -> %% repair
Reply = State#ssdb_conn.reply,
State#ssdb_conn{step = ?SSDB_STEP_FINISH, size = 0, data = <<>>, reply = lists:reverse(Reply)};
[BinSize, BlockData] ->
Size = erlang:binary_to_integer(BinSize),
NewState = State#ssdb_conn{data = BlockData, size = Size, step = ?SSDB_STEP_DATA},
parse_recv(NewState, <<>>); %% parse data
_ ->
%% wait for get size
State#ssdb_conn{data = NewData}
end;