Copyright © 2011-2015 Zuse Institute Berlin
Version: $Id$
Behaviours: gen_component.
Authors: Maik Lange (malange@informatik.hu-berlin.de).
client_version() = non_neg_integer()
kvv_list() = [{rt_chord:key(), db_dht:value(), client_version()}]
message() = {start, operation(), options(), StartTag :: atom()} | {get_entries_response, db_dht:db_as_list()} | {get_state_response, intervals:interval()} | {update_key_entries_ack, [{db_entry:entry_ex(), Exists :: boolean(), Done :: boolean()}]} | {'DOWN', MonitorRef :: reference(), process, Owner :: pid(), Info :: any()}
operation() = {103, KvvListInAnyQ :: kvv_list(), ReqKeys :: [rt_chord:key()]} | {key_upd_send, DestPid :: comm:mypid(), SendKeys :: [rt_chord:key()], ReqKeys :: [rt_chord:key()]} | {104, intervals:interval(), KvvListInAnyQ :: kvv_list()} | {interval_upd_send, intervals:interval(), DestPid :: comm:mypid()} | {interval_upd_my, intervals:interval()}
option() = {feedback_request, comm:mypid()} | {from_my_node, 0 | 1}
options() = [option()]
state() = #rr_resolve_state{ownerPid = pid(), operation = undefined | operation(), my_range = undefined | intervals:interval(), fb_dest_pid = undefined | comm:mypid(), fb_send_kvv = kvv_list(), fb_had_kvv_req = boolean(), fb_send_kvv_req = kvv_list(), other_kv_tree = gb_trees:tree(rt_chord:key(), client_version()), stats = stats(), from_my_node = 0 | 1}
stats() = #resolve_stats{session_id = rrepair:session_id() | null, diff_size = non_neg_integer(), regen_count = non_neg_integer(), update_count = non_neg_integer(), upd_fail_count = non_neg_integer(), regen_fail_count = non_neg_integer()}
get_stats_session_id/1 | |
init/1 | |
merge_stats/2 | Merges two stats records with an identical session_id (otherwise error will be raised). |
merge_stats_feeder/2 | |
on/2 | |
print_resolve_stats/1 | |
start/1 | |
start_gen_component/5 |
start_gen_component(Module :: module(), Handler :: gen_component:handler(), Args :: term(), Options :: [gen_component:option()], Self :: pid()) -> no_return() | ok
get_stats_session_id(Stats :: stats()) -> rrepair:session_id() | null
Merges two stats records with an identical session_id (otherwise error will be raised).
print_resolve_stats(Stats :: stats()) -> [any()]
start(SessionId :: rrepair:session_id() | null) -> {ok, MyPid :: pid()}
Generated by EDoc, Sep 11 2020, 15:24:57.