diff options
Diffstat (limited to 'p11p-daemon/src/p11p_remote.erl')
| -rw-r--r-- | p11p-daemon/src/p11p_remote.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/p11p-daemon/src/p11p_remote.erl b/p11p-daemon/src/p11p_remote.erl index c968aad..f7bdcab 100644 --- a/p11p-daemon/src/p11p_remote.erl +++ b/p11p-daemon/src/p11p_remote.erl @@ -72,7 +72,7 @@ handle_cast(Request, State) -> %% TODO: dedup code w/ p11p_server handle_info({Port, {data, Data}}, #state{replyto = Pid} = State) when Port == State#state.port, State#state.msg == undefined -> Version = hd(Data), % First octet is version. - p11p_server:add_to_clientbuf(Pid, <<Version>>), + {ok, _BytesAdded} = p11p_server:add_to_clientbuf(Pid, <<Version>>), {noreply, handle_remote_data(State, p11p_rpc:new(), tl(Data))}; handle_info({Port, {data, Data}}, #state{msg = Msg} = State) when Port == State#state.port -> {noreply, handle_remote_data(State, Msg, Data)}; @@ -108,7 +108,7 @@ handle_remote_data(#state{replyto = Pid, timer = Timer} = State, Msg, Data) -> case p11p_rpc:parse(Msg, list_to_binary(Data)) of {done, NewMsg} -> cancel_timer(Timer), - ok = p11p_server:reply(Pid, NewMsg), + {ok, _BytesSent} = p11p_server:reply(Pid, NewMsg), State#state{msg = p11p_rpc:new(NewMsg#p11rpc_msg.buffer)}; {needmore, NewMsg} -> State#state{msg = NewMsg} |