Copyright © 2007-2013 Zuse Institute Berlin
Version: $Id$
Authors: Jan Fajerski (fajerski@informatik.hu-berlin.de).
bulk_message() = {mr, job, mr_state:jobid(), MasterId :: rt_chord:key(), Client :: comm:mypid(), mr_state:job_description(), mr_state:data()} | {mr, next_phase_data, mr_state:jobid(), comm:mypid(), mr_state:data()}
message() = {bulk_distribute, uid:global_uid(), intervals:interval(), bulk_message(), Parents :: [comm:mypid(), ...]} | {mr, phase_results, mr_state:jobid(), comm:message(), intervals:interval()} | {mr, next_phase_data_ack, {mr_state:jobid(), reference(), intervals:interval()}, intervals:interval()} | {mr, next_phase, mr_state:jobid()} | {mr, terminate_job, mr_state:jobid()}
neighborhood_succ_crash/5 | |
neighborhood_succ_crash_filter/3 | |
on/2 | |
work_on_phase/3 |
on(Msg :: message(), State :: dht_node_state:state()) -> dht_node_state:state()
work_on_phase(JobId :: mr_state:jobid(), State :: mr_state:state(), Round :: pos_integer()) -> mr_state:state()
neighborhood_succ_crash_filter(Old :: nodelist:neighborhood(), New :: nodelist:neighborhood(), X3 :: rm_loop:reason()) -> boolean()
neighborhood_succ_crash(Pid :: comm:mypid(), X2 :: {string(), mr_state:jobid(), rt_chord:key(), comm:mypid()}, Old :: nodelist:neighborhood(), New :: nodelist:neighborhood(), Reason :: rm_loop:reason()) -> ok
Generated by EDoc, Sep 11 2020, 15:26:08.