Copyright © 2009-2015 Zuse Institute Berlin
Version: $Id$
Behaviours: rm_beh.
Authors: Christian Hennig (hennig@zib.de).
References
custom_message() = {rm, once, {cy_cache, Cache :: [node:node_type()]}} | {rm, {cy_cache, Cache :: [node:node_type()]}} | {rm, node_info_response, NodeDetails :: node_details:node_details()} | {rm, buffer, OtherNeighbors :: nodelist:neighborhood(), RequestPredsMinCount :: non_neg_integer(), RequestSuccsMinCount :: non_neg_integer()} | {rm, buffer_response, OtherNodes :: nodelist:non_empty_snodelist()}
abstract datatype: state()
get_neighbors/1 | |
init_first/0 | Initializes the cyclon cache retrieval "trigger" (un-infected). |
init/3 | Initialises the state when rm_loop receives an init_rm message. |
unittest_create_state/1 | |
handle_custom_message/2 | Message handler when the module is fully initialized. |
trigger_action/1 | |
new_pred/2 | |
new_succ/2 | |
update_node/2 | |
contact_new_nodes/1 | |
fd_notify/4 | Failure detector reported dead/changed node. |
zombie_node/2 | |
get_web_debug_info/1 | |
check_config/0 | Checks whether config parameters of the rm_tman process exist and are valid. |
trigger_interval/0 |
get_neighbors(X1 :: state()) -> nodelist:neighborhood()
init_first() -> ok
Initializes the cyclon cache retrieval "trigger" (un-infected).
init(Me :: node:node_type(), Pred :: node:node_type(), Succ :: node:node_type()) -> state()
Initialises the state when rm_loop receives an init_rm message.
unittest_create_state(Neighbors :: nodelist:neighborhood()) -> state()
handle_custom_message(X1 :: custom_message(), State :: state()) -> {ChangeReason :: {unknown} | {node_discovery}, state()} | unknown_event
Message handler when the module is fully initialized.
trigger_action(State :: state()) -> {ChangeReason :: rm_loop:reason(), state()}
new_pred(State :: state(), NewPred :: node:node_type()) -> {ChangeReason :: rm_loop:reason(), state()}
new_succ(State :: state(), NewSucc :: node:node_type()) -> {ChangeReason :: rm_loop:reason(), state()}
update_node(State :: state(), NewMe :: node:node_type()) -> {ChangeReason :: rm_loop:reason(), state()}
contact_new_nodes(NewNodes :: [node:node_type()]) -> ok
fd_notify(State :: state(), Event :: fd:event(), DeadPid :: comm:mypid(), Data :: term()) -> {ChangeReason :: rm_loop:reason(), state()}
Failure detector reported dead/changed node.
zombie_node(State :: state(), Node :: node:node_type()) -> {ChangeReason :: rm_loop:reason(), state()}
get_web_debug_info(State :: state()) -> [{string(), string()}]
check_config() -> boolean()
Checks whether config parameters of the rm_tman process exist and are valid.
trigger_interval() -> pos_integer()
Generated by EDoc, Aug 2 2016, 13:43:25.