Sancaros/egs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Universes start lobby quests automatically which in turn start their zones.

Browse Source 
Universes are all stored in a single process; on the other hand, each quest
and each zone have their own process.
This commit is contained in:
Loïc Hoguin 2011-02-15 01:15:28 +01:00
parent ffd27bda46
commit ea25d1bd74
7 changed files with 242 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
src/egs_quests.erl Normal file
View File

@ -0,0 +1,66 @@
%% @author Loïc Hoguin <essen@dev-extend.eu>
%% @copyright 2011 Loïc Hoguin.
%% @doc Quest handler.
%%
%% This file is part of EGS.
%%
%% EGS is free software: you can redistribute it and/or modify
%% it under the terms of the GNU Affero General Public License as
%% published by the Free Software Foundation, either version 3 of the
%% License, or (at your option) any later version.
%%
%% EGS is distributed in the hope that it will be useful,
%% but WITHOUT ANY WARRANTY; without even the implied warranty of
%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
%% GNU Affero General Public License for more details.
%%
%% You should have received a copy of the GNU Affero General Public License
%% along with EGS. If not, see <http://www.gnu.org/licenses/>.
-module(egs_quests).
-behaviour(gen_server).
-export([start_link/2, stop/0]). %% API.
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]). %% gen_server.
-record(state, {zones}).
-define(SERVER, ?MODULE).
%% API.
%% @spec start_link(UniID, QuestID) -> {ok,Pid::pid()}
start_link(UniID, QuestID) ->
gen_server:start_link(?MODULE, [UniID, QuestID], []).
%% @spec stop() -> stopped
stop() ->
gen_server:call(?SERVER, stop).
%% gen_server.
init([UniID, QuestID]) ->
Zones = egs_quests_db:quest_zones(QuestID),
ZonesPids = lists:map(fun({ZoneID, _Params}) ->
{ok, Pid} = supervisor:start_child(egs_zones_sup, {{zone, UniID, QuestID, ZoneID}, {egs_zones, start_link, [UniID, QuestID, ZoneID]}, permanent, 5000, worker, dynamic}),
{ZoneID, Pid}
end, Zones),
{ok, #state{zones=ZonesPids}}.
handle_call(stop, _From, State) ->
{stop, normal, stopped, State};
handle_call(_Request, _From, State) ->
{reply, ignored, State}.
handle_cast(_Msg, State) ->
{noreply, State}.
handle_info(_Info, State) ->
{noreply, State}.
terminate(_Reason, _State) ->
ok.
code_change(_OldVsn, State, _Extra) ->
{ok, State}.

10
src/egs_quests_db.erl
View File

@ -19,7 +19,7 @@
-module(egs_quests_db).
-behavior(gen_server).
-export([start_link/0, stop/0, quest_nbl/1, zone_nbl/2, area_type/2, reload/0]). %% API.
-export([start_link/0, stop/0, quest_nbl/1, zone_nbl/2, area_type/2, quest_zones/1, reload/0]). %% API.
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]). %% gen_server.
-record(state, {quests=[], quests_bin=[], zones_bin=[]}).
@ -48,6 +48,9 @@ zone_nbl(QuestID, ZoneID) ->
area_type(QuestID, ZoneID) ->
gen_server:call(?SERVER, {area_type, QuestID, ZoneID}).
quest_zones(QuestID) ->
gen_server:call(?SERVER, {quest_zones, QuestID}).
%% @spec reload() -> ok
reload() ->
gen_server:cast(?SERVER, reload).
@ -129,6 +132,11 @@ handle_call({area_type, QuestID, ZoneID}, _From, State=#state{quests=QuestsCache
end,
{reply, AreaType, State};
handle_call({quest_zones, QuestID}, _From, State=#state{quests=QuestsCache}) ->
{_, Quest} = lists:keyfind(QuestID, 1, QuestsCache),
{_, Zones} = lists:keyfind(zones, 1, Quest),
{reply, Zones, State};
handle_call(stop, _From, State) ->
{stop, normal, stopped, State};

38
src/egs_quests_sup.erl Normal file
View File

@ -0,0 +1,38 @@
%% @author Loïc Hoguin <essen@dev-extend.eu>
%% @copyright 2011 Loïc Hoguin.
%% @doc Supervisor for the egs_quests gen_server.
%%
%% This file is part of EGS.
%%
%% EGS is free software: you can redistribute it and/or modify
%% it under the terms of the GNU Affero General Public License as
%% published by the Free Software Foundation, either version 3 of the
%% License, or (at your option) any later version.
%%
%% EGS is distributed in the hope that it will be useful,
%% but WITHOUT ANY WARRANTY; without even the implied warranty of
%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
%% GNU Affero General Public License for more details.
%%
%% You should have received a copy of the GNU Affero General Public License
%% along with EGS. If not, see <http://www.gnu.org/licenses/>.
-module(egs_quests_sup).
-behaviour(supervisor).
-export([start_link/0]). %% API.
-export([init/1]). %% supervisor.
-define(SUPERVISOR, ?MODULE).
%% API.
-spec start_link() -> {ok, Pid::pid()}.
start_link() ->
supervisor:start_link({local, ?SUPERVISOR}, ?MODULE, []).
%% supervisor.
init([]) ->
Procs = [],
{ok, {{one_for_one, 10, 10}, Procs}}.

2
src/egs_sup.erl
View File

@ -54,6 +54,8 @@ init([]) ->
PatchProcs = [{{egs_patch_server, Port}, {egs_patch_server, start_link, [Port]}, permanent, 5000, worker, dynamic} || Port <- PatchPorts],
LoginProcs = [{{egs_login_server, Port}, {egs_login_server, start_link, [Port]}, permanent, 5000, worker, dynamic} || Port <- LoginPorts],
OtherProcs = [
{egs_quests_sup, {egs_quests_sup, start_link, []}, permanent, 5000, supervisor, [egs_quests_sup]},
{egs_zones_sup, {egs_zones_sup, start_link, []}, permanent, 5000, supervisor, [egs_zones_sup]},
{egs_seasons, {egs_seasons, start_link, []}, permanent, 5000, worker, dynamic},
{egs_counters_db, {egs_counters_db, start_link, []}, permanent, 5000, worker, dynamic},
{egs_items_db, {egs_items_db, start_link, []}, permanent, 5000, worker, dynamic},

44
src/egs_universes.erl
View File

@ -22,6 +22,8 @@
-export([start_link/0, stop/0, all/0, defaultid/0, enter/1, leave/1, myroomid/0, read/1, reload/0]). %% API.
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]). %% gen_server.
-record(state, {unis=[], lobbies=[]}).
%% Use the module name for the server's name.
-define(SERVER, ?MODULE).
@ -29,6 +31,9 @@
-define(MYROOM_ID, 21).
-define(DEFAULT_ID, 26).
%% Lobbies: permanent quests to start with the universe.
-define(LOBBIES, [1100000]).
%% API.
%% @spec start_link() -> {ok,Pid::pid()}
@ -71,14 +76,18 @@ reload() ->
%% gen_server.
%% @doc Create the unis, then load all the permanent quests nbl files, then create processes for all the needed quests.
init([]) ->
{ok, [create_myroom()|create_unis()]}.
State = #state{unis=[create_myroom()|create_unis()]},
[egs_quests_db:quest_nbl(QuestID) || QuestID <- ?LOBBIES],
Lobbies = lists:flatten([init_lobbies(UniID) || {UniID, {Type, _Name, _NbPlayers, _MaxPlayers}} <- State#state.unis, Type =:= universe]),
{ok, State#state{lobbies=Lobbies}}.
handle_call(all, _From, State) ->
{reply, State, State};
{reply, State#state.unis, State};
handle_call({read, UniID}, _From, State) ->
{reply, proplists:get_value(UniID, State), State};
{reply, proplists:get_value(UniID, State#state.unis), State};
handle_call(stop, _From, State) ->
{stop, normal, stopped, State};
@ -87,21 +96,21 @@ handle_call(_Request, _From, State) ->
{reply, ignored, State}.
handle_cast({enter, UniID}, State) ->
{Type, Name, NbPlayers, MaxPlayers} = proplists:get_value(UniID, State),
State2 = proplists:delete(UniID, State),
State3 = [{UniID, {Type, Name, NbPlayers + 1, MaxPlayers}}|State2],
State4 = lists:keysort(1, State3),
{noreply, State4};
{Type, Name, NbPlayers, MaxPlayers} = proplists:get_value(UniID, State#state.unis),
Unis = proplists:delete(UniID, State#state.unis),
Unis2 = [{UniID, {Type, Name, NbPlayers + 1, MaxPlayers}}|Unis],
Unis3 = lists:keysort(1, Unis2),
{noreply, State#state{unis=Unis3}};
handle_cast({leave, UniID}, State) ->
{Type, Name, NbPlayers, MaxPlayers} = proplists:get_value(UniID, State),
State2 = proplists:delete(UniID, State),
State3 = [{UniID, {Type, Name, NbPlayers - 1, MaxPlayers}}|State2],
State4 = lists:keysort(1, State3),
{noreply, State4};
{Type, Name, NbPlayers, MaxPlayers} = proplists:get_value(UniID, State#state.unis),
Unis = proplists:delete(UniID, State#state.unis),
Unis2 = [{UniID, {Type, Name, NbPlayers - 1, MaxPlayers}}|Unis],
Unis3 = lists:keysort(1, Unis2),
{noreply, State#state{unis=Unis3}};
handle_cast(reload, _State) ->
{noreply, [create_myroom()|create_unis()]};
{noreply, #state{unis=[create_myroom()|create_unis()]}};
handle_cast(_Msg, State) ->
{noreply, State}.
@ -131,3 +140,10 @@ create_unis([], _UniID, Acc) ->
lists:reverse(Acc);
create_unis([Name|Tail], UniID, Acc) ->
create_unis(Tail, UniID + 2, [{UniID, {universe, Name, 0, 1000}}|Acc]).
%% @doc Start lobbies for the given universe.
init_lobbies(UniID) ->
lists:map(fun(QuestID) ->
{ok, Pid} = supervisor:start_child(egs_quests_sup, {{quest, UniID, QuestID}, {egs_quests, start_link, [UniID, QuestID]}, permanent, 5000, worker, dynamic}),
{{UniID, QuestID}, Pid}
end, ?LOBBIES).

59
src/egs_zones.erl Normal file
View File

@ -0,0 +1,59 @@
%% @author Loïc Hoguin <essen@dev-extend.eu>
%% @copyright 2011 Loïc Hoguin.
%% @doc Zone handler.
%%
%% This file is part of EGS.
%%
%% EGS is free software: you can redistribute it and/or modify
%% it under the terms of the GNU Affero General Public License as
%% published by the Free Software Foundation, either version 3 of the
%% License, or (at your option) any later version.
%%
%% EGS is distributed in the hope that it will be useful,
%% but WITHOUT ANY WARRANTY; without even the implied warranty of
%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
%% GNU Affero General Public License for more details.
%%
%% You should have received a copy of the GNU Affero General Public License
%% along with EGS. If not, see <http://www.gnu.org/licenses/>.
-module(egs_zones).
-behaviour(gen_server).
-export([start_link/3, stop/0]). %% API.
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]). %% gen_server.
-define(SERVER, ?MODULE).
%% API.
%% @spec start_link(UniID, QuestID, ZoneID) -> {ok,Pid::pid()}
start_link(UniID, QuestID, ZoneID) ->
gen_server:start_link(?MODULE, [UniID, QuestID, ZoneID], []).
%% @spec stop() -> stopped
stop() ->
gen_server:call(?SERVER, stop).
%% gen_server.
init([UniID, QuestID, ZoneID]) ->
{ok, undefined}.
handle_call(stop, _From, State) ->
{stop, normal, stopped, State};
handle_call(_Request, _From, State) ->
{reply, ignored, State}.
handle_cast(_Msg, State) ->
{noreply, State}.
handle_info(_Info, State) ->
{noreply, State}.
terminate(_Reason, _State) ->
ok.
code_change(_OldVsn, State, _Extra) ->
{ok, State}.

38
src/egs_zones_sup.erl Normal file
View File

@ -0,0 +1,38 @@
%% @author Loïc Hoguin <essen@dev-extend.eu>
%% @copyright 2011 Loïc Hoguin.
%% @doc Supervisor for the egs_zones gen_server.
%%
%% This file is part of EGS.
%%
%% EGS is free software: you can redistribute it and/or modify
%% it under the terms of the GNU Affero General Public License as
%% published by the Free Software Foundation, either version 3 of the
%% License, or (at your option) any later version.
%%
%% EGS is distributed in the hope that it will be useful,
%% but WITHOUT ANY WARRANTY; without even the implied warranty of
%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
%% GNU Affero General Public License for more details.
%%
%% You should have received a copy of the GNU Affero General Public License
%% along with EGS. If not, see <http://www.gnu.org/licenses/>.
-module(egs_zones_sup).
-behaviour(supervisor).
-export([start_link/0]). %% API.
-export([init/1]). %% supervisor.
-define(SUPERVISOR, ?MODULE).
%% API.
-spec start_link() -> {ok, Pid::pid()}.
start_link() ->
supervisor:start_link({local, ?SUPERVISOR}, ?MODULE, []).
%% supervisor.
init([]) ->
Procs = [],
{ok, {{one_for_one, 10, 10}, Procs}}.