diff options
| -rw-r--r-- | erlbal.erl | 51 |
1 files changed, 51 insertions, 0 deletions
diff --git a/erlbal.erl b/erlbal.erl new file mode 100644 index 0000000..417eb1c --- /dev/null +++ b/erlbal.erl @@ -0,0 +1,51 @@ +-module(erlbal). +-export([make_request/0, start_bal/0, kill_bal/0, start_server/1]). + +start_server(ID) -> + PID = spawn(fun() -> serverloop(ID) end), + balancer ! {add_node, PID}. + +serverloop(ID) -> + receive + {request, From} -> + balancer ! {response, From, ID}, + serverloop(ID); + die -> + ok + end. + +start_bal() -> + register(balancer, spawn(fun() -> balloop([], 1) end)). + +kill_bal() -> + balancer ! die. + +balloop(Serverlist, Nextserver) -> + receive + {add_node, PID} -> + balloop(Serverlist ++ [PID], Nextserver); + {request, From} -> + Serv = lists:nth(Nextserver, Serverlist), + Serv ! {request, From}, + NS = Nextserver + 1, + SLL = length(Serverlist), + if + NS > SLL -> + balloop(Serverlist, 1); + true -> + balloop(Serverlist, Nextserver+1) + end; + {response, To, ID} -> + To ! ID, + balloop(Serverlist, Nextserver); + die -> + lists:foreach(fun(X) -> X ! die end, Serverlist) + end. + + +make_request() -> + balancer ! {request, self()}, + receive + ID -> + ID + end. |