Copyright © 2007-2015 Zuse Institute Berlin
Version: $Id$
Behaviours: gen_component.
Authors: Jan Fajerski (fajerski@zib.de).
avail_workers() = [comm:mypid()]
job() = mr_job()
message() = {do_work, Source :: comm:mypid(), job()} | {'DOWN', reference(), process, pid(), Info :: any()} | {data, pid(), [tuple()]}
mr_job() = {mr_state:fun_term(), Data :: db_ets:db(), Interval :: intervals:interval()}
state() = {avail_workers(), working(), waiting_jobs()}
waiting_jobs() = [{comm:mypid(), job()}]
working() = [{Worker :: comm:mypid(), Source :: comm:mypid()}]
init/1 | |
on/2 | |
start_gen_component/5 | |
start_link/2 |
start_gen_component(Module :: module(), Handler :: gen_component:handler(), Args :: term(), Options :: [gen_component:option()], Self :: pid()) -> no_return() | ok
init(X1 :: []) -> state()
start_link(DHTNodeGroup :: pid_groups:groupname(), Options :: tuple()) -> {ok, pid()}
Generated by EDoc, Aug 2 2016, 13:42:57.