From d3dd0ee7cce770cc7b5089943d043a9b3da0af50 Mon Sep 17 00:00:00 2001 From: Nathan Lasseter Date: Thu, 27 Jan 2011 21:57:12 +0000 Subject: RPCs and no registering. --- erlbal.erl | 21 +++++++++++++-------- 1 file changed, 13 insertions(+), 8 deletions(-) diff --git a/erlbal.erl b/erlbal.erl index 6dfefad..e24dd26 100644 --- a/erlbal.erl +++ b/erlbal.erl @@ -1,10 +1,18 @@ -module(erlbal). --export([make_request/2, start_bal/1, kill_bal/1, start_server/2]). +-export([make_request/2, start_bal/0, stop_bal/1, start_server/2, stop_server/2, list_servers/1]). start_server(Balancer, Fun) -> PID = spawn(fun() -> server_loop(Balancer, Fun) end), Balancer ! {add_node, PID}. +stop_server(Balancer, PID) -> + Balancer ! {del_node, PID}, + PID ! die. + +list_servers(Balancer) -> + Balancer ! {list_nodes, self()}, + receive Nodes -> Nodes end. + server_loop(Balancer, Fun) -> receive {request, From, ARGS} -> @@ -15,10 +23,10 @@ server_loop(Balancer, Fun) -> ok end. -start_bal(Name) -> - register(Name, spawn(fun() -> bal_loop([], 1) end)). +start_bal() -> + spawn(fun() -> bal_loop([], 1) end). -kill_bal(Balancer) -> +stop_bal(Balancer) -> Balancer ! die, unregister(Balancer). @@ -52,7 +60,4 @@ bal_loop(Serverlist, Nextserver) -> make_request(Balancer, ARGS) -> Balancer ! {request, self(), ARGS}, - receive - Ret -> - Ret - end. + receive Ret -> Ret end. -- cgit v1.2.3