mirror/alcove
1
0
Fork 0
mirror of https://github.com/uselessd/alcove.git synced 2025-12-05 23:23:08 +00:00
Code Issues Projects Releases Wiki Activity

alcove_drv: Packet -> Buf

Browse Source
This commit is contained in:
Michael Santos
2015-08-05 12:08:34 -04:00
parent 9eda1ce49a
commit b3f09ed397
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/alcove_drv.erl
View File

@@ -125,7 +125,7 @@ init([Owner, Options]) ->
(_) -> false
end, Options),
Port = open_port({spawn_executable, Cmd}, [
Port = erlang:open_port({spawn_executable, Cmd}, [
{args, Argv},
stream,
binary
@@ -133,19 +133,19 @@ init([Owner, Options]) ->
{ok, #state{port = Port, ps = dict:store([], Owner, dict:new())}}.
handle_call({send, ForkPath, Packet}, {Pid,_Tag}, #state{port = Port, ps = PS} = State) ->
handle_call({send, ForkPath, Buf}, {Pid,_Tag}, #state{port = Port, ps = PS} = State) ->
case is_monitored(Pid) of
true -> ok;
false -> monitor(process, Pid)
end,
Reply = erlang:port_command(Port, Packet),
Reply = erlang:port_command(Port, Buf),
{reply, Reply, State#state{ps = dict:store(ForkPath, Pid, PS)}};
handle_call(stop, _From, State) ->
{stop, normal, ok, State}.
handle_cast({send, _ForkPath, Packet}, #state{port = Port} = State) ->
erlang:port_command(Port, Packet),
handle_cast({send, _ForkPath, Buf}, #state{port = Port} = State) ->
erlang:port_command(Port, Buf),
{noreply, State};
handle_cast(_Msg, State) ->
{noreply, State}.