Adding simple averaging consensus.

Author: rcschrg

src/DistributedResourceOptimization.jl

@@ -12,6 +12,9 @@ include("algorithm/admm/flex_actor.jl")
 include("algorithm/admm/consensus_admm.jl")
 include("algorithm/admm/sharing_admm.jl")
 
+include("algorithm/consensus/averaging.jl")
+include("algorithm/consensus/economic_dispatch.jl")
+
 include("carrier/mango.jl")
 include("carrier/simple.jl")
 

src/carrier/core.jl

@@ -1,4 +1,4 @@
-export Carrier, send_to_other, reply_to_other, send_awaitable, schedule_using, others
+export Carrier, send_to_other, reply_to_other, send_awaitable, schedule_using, others, get_address
 
 mutable struct EventWithValue
     event::Base.Event
@@ -124,4 +124,8 @@ Returns a collection of participants in the given `carrier` excluding the partic
 """
 function others(carrier::Carrier, participant_id::String)
     throw("NotImplemented")
+end
+
+function get_address(carrier::Carrier)
+    throw("NotImplemented")
 end

src/carrier/mango.jl

@@ -144,4 +144,8 @@ function others(carrier::MangoCarrier, participant_id::String)
     else
         return topology_neighbors(carrier.parent, tid=carrier.parent.tid)
     end
+end
+
+function get_address(carrier::MangoCarrier)
+    return address(carrier.parent)
 end

src/carrier/simple.jl

@@ -100,6 +100,10 @@ function others(carrier::SimpleCarrier, id::String)
     return setdiff!(collect(range(1, length(carrier.container.actors))), [cid(carrier)])
 end
 
+function get_address(carrier::SimpleCarrier)
+    return cid(carrier)
+end
+
 """
     start_distributed_optimization(actors::Vector{<:DistributedAlgorithm}, start_message::Any)