Packages

exos

0.0.1
2.1.0 2.0.0 1.0.3 1.0.2 1.0.1 1.0.0 0.0.1

Create a GenServer in any language. Exos contains a very simple GenServer which proxy calls and casts to a given port command, encoding and decoding the message to the port using erlang external binary term format. (see related projects : clojure|python|node_erlastic on https://github.com/kbrw)

HexDocs

Current section

Files

Jump to
Readme
7 Versions
0 Dependencies
Dependants
Files
Activity
exos lib exos.ex
Raw

lib/exos.ex 

defmodule Exos.Proc do

  use GenServer



  def start_link(cmd,init,opts \\ [],link_opts \\ []), do:

    GenServer.start_link(Exos.Proc,{cmd,init,opts},link_opts)



  def init({cmd,initarg,opts}) do

    port = Port.open({:spawn,'#{cmd}'}, [:binary,:exit_status, packet: 4] ++ opts)

    send(port,{self,{:command,:erlang.term_to_binary(initarg)}})

    {:ok,port}

  end



  def handle_info({port,{:exit_status,0}},port), do: {:stop,:normal,port}

  def handle_info({port,{:exit_status,_}},port), do: {:stop,:port_terminated,port}

  def handle_info(_,port), do: {:noreply,port}



  def handle_cast(term,port) do

    send(port,{self,{:command,:erlang.term_to_binary(term)}})

    {:noreply,port}

  end



  def handle_call(term,_reply_to,port) do

    send(port,{self,{:command,:erlang.term_to_binary(term)}})

    res = receive do 

      {^port,{:data,b}}->:erlang.binary_to_term(b)

      {^port,{:exit_status,_}}=exit_msg->send(self,exit_msg);{:error,:port_terminated} # catch exit msg and resend it

    end

    {:reply,res,port}

  end

end