Current section
Files
Jump to
Current section
Files
lib/hyparview/messages/neighbor_rejected.ex
defmodule Hyparview.Messages.NeighborRejected do
@moduledoc """
NEIGHBOR REJECTED message
"""
alias __MODULE__
alias Hyparview.View
alias Hyparview.PeerManager
defstruct sender: Node.self(),
view: %View{}
@type t :: %NeighborRejected{
sender: Node.t(),
view: View.t()
}
@spec new(View.t()) :: t()
def new(view) do
%NeighborRejected{sender: Node.self(), view: view}
end
@spec send!(Node.t(), View.t()) :: :ok
def send!(sender, view), do: :ok = PeerManager.send_message(sender, new(view))
@doc """
view = NeighborRejected.handle(neighbor_rejected, state.view)
{:noreply, %{state | view: view}}
"""
@spec handle(t(), View.t()) :: View.t()
def handle(%NeighborRejected{view: view}, view0),
do: View.trim_and_add_to_passive(view0, view.passive)
end