| %%------------------------------------------------------------------------------ |
| %% Licensed to the Apache Software Foundation (ASF) under one or more |
| %% contributor license agreements. See the NOTICE file distributed with |
| %% this work for additional information regarding copyright ownership. |
| %% The ASF licenses this file to You under the Apache License, Version 2.0 |
| %% (the "License"); you may not use this file except in compliance with |
| %% the License. You may obtain a copy of the License at |
| %% |
| %% http://www.apache.org/licenses/LICENSE-2.0 |
| %% |
| %% Unless required by applicable law or agreed to in writing, software |
| %% distributed under the License is distributed on an "AS IS" BASIS, |
| %% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| %% See the License for the specific language governing permissions and |
| %% limitations under the License. |
| %%------------------------------------------------------------------------------ |
| -module(dubbo_transport_pool_sup). |
| |
| -behaviour(supervisor). |
| |
| %% API |
| -export([start_link/0, add_children/2, stop_children/1]). |
| |
| %% Supervisor callbacks |
| -export([init/1]). |
| |
| -define(SERVER, ?MODULE). |
| |
| %%%=================================================================== |
| %%% API functions |
| %%%=================================================================== |
| |
| %%-------------------------------------------------------------------- |
| %% @doc |
| %% Starts the supervisor |
| %% |
| %% @end |
| %%-------------------------------------------------------------------- |
| -spec(start_link() -> |
| {ok, Pid :: pid()} | ignore | {error, Reason :: term()}). |
| start_link() -> |
| supervisor:start_link({local, ?SERVER}, ?MODULE, []). |
| |
| %%%=================================================================== |
| %%% Supervisor callbacks |
| %%%=================================================================== |
| |
| %%-------------------------------------------------------------------- |
| %% @private |
| %% @doc |
| %% Whenever a supervisor is started using supervisor:start_link/[2,3], |
| %% this function is called by the new process to find out about |
| %% restart strategy, maximum restart frequency and child |
| %% specifications. |
| %% |
| %% @end |
| %%-------------------------------------------------------------------- |
| -spec(init(Args :: term()) -> |
| {ok, {SupFlags :: {RestartStrategy :: supervisor:strategy(), |
| MaxR :: non_neg_integer(), MaxT :: non_neg_integer()}, |
| [ChildSpec :: supervisor:child_spec()] |
| }} | |
| ignore | |
| {error, Reason :: term()}). |
| init([]) -> |
| RestartStrategy = simple_one_for_one, |
| MaxRestarts = 1000, |
| MaxSecondsBetweenRestarts = 3600, |
| |
| SupFlags = {RestartStrategy, MaxRestarts, MaxSecondsBetweenRestarts}, |
| Child = {dubbo_client_default, {dubbo_client_default, start_link, []}, permanent, 2000, worker, [dubbo_client_default]}, |
| {ok, {SupFlags, [Child]}}. |
| |
| |
| add_children(ProvideConfig, Handler) -> |
| supervisor:start_child(?SERVER, [ProvideConfig, Handler]). |
| |
| stop_children(ChildID) -> |
| supervisor:terminate_child(?SERVER, ChildID). |
| %%%=================================================================== |
| %%% Internal functions |
| %%%=================================================================== |