Packages

rafted_value

0.1.7
0.12.0 0.11.2 0.11.1 0.11.0 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.3 0.9.2 0.9.1 retired 0.9.0 0.8.0 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.0 0.4.0 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Replicated and synchronized values wrapped by processes

HexDocs

Current section

Files

Jump to
Readme
37 Versions
1 Dependency
Dependants
Files
Activity
rafted_value lib rafted_value remote_message_gateway.ex
Raw

lib/rafted_value/remote_message_gateway.ex 

use Croma



defmodule RaftedValue.RemoteMessageGateway do

  @moduledoc """

  Replacement of `:gen_fsm.send_event/2` and `:gen_fsm.reply/2` as the default of `:communication_module`.



  This is introduced in order to work-around slow message passing to unreachable nodes of `:gen_fsm`, using temporary processes.

  In other words, it behaves in the same way as `:gen_server.cast/2` for unreachable nodes.

  """



  def send_event(fsm_ref, event) do

    do_send(fsm_ref, {:"$gen_event", event})

  end



  def reply({pid, tag}, reply) do

    do_send(pid, {tag, reply})

  end



  defp do_send(dest, msg) do

    case :erlang.send(dest, msg, [:noconnect]) do

      :noconnect ->

        spawn(:erlang, :send, [dest, msg])

        :ok

      _otherwise -> :ok

    end

  end

end