1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
% Licensed 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(couch_server_sup).
-behaviour(supervisor).
-export([start_link/1, couch_config_start_link_wrapper/2,
restart_core_server/0, config_change/2]).
-include("couch_db.hrl").
%% supervisor callbacks
-export([init/1]).
start_link(IniFiles) ->
case whereis(couch_server_sup) of
undefined ->
start_server(IniFiles);
_Else ->
{error, already_started}
end.
restart_core_server() ->
init:restart().
couch_config_start_link_wrapper(IniFiles, FirstConfigPid) ->
case is_process_alive(FirstConfigPid) of
true ->
link(FirstConfigPid),
{ok, FirstConfigPid};
false -> couch_config:start_link(IniFiles)
end.
start_server(IniFiles) ->
case init:get_argument(pidfile) of
{ok, [PidFile]} ->
case file:write_file(PidFile, os:getpid()) of
ok -> ok;
Error -> io:format("Failed to write PID file ~s, error: ~p", [PidFile, Error])
end;
_ -> ok
end,
{ok, ConfigPid} = couch_config:start_link(IniFiles),
LogLevel = couch_config:get("log", "level", "info"),
% announce startup
io:format("Apache CouchDB ~s (LogLevel=~s) is starting.~n", [
couch:version(),
LogLevel
]),
case LogLevel of
"debug" ->
io:format("Configuration Settings ~p:~n", [IniFiles]),
[io:format(" [~s] ~s=~p~n", [Module, Variable, Value])
|| {{Module, Variable}, Value} <- couch_config:all()];
_ -> ok
end,
BaseChildSpecs =
{{one_for_all, 10, 60},
[{couch_config,
{couch_server_sup, couch_config_start_link_wrapper, [IniFiles, ConfigPid]},
permanent,
brutal_kill,
worker,
[couch_config]},
{couch_config_event,
{couch_config_event, start_link, []},
permanent,
1000,
worker,
dynamic},
{couch_primary_services,
{couch_primary_sup, start_link, []},
permanent,
infinity,
supervisor,
[couch_primary_sup]},
{couch_secondary_services,
{couch_secondary_sup, start_link, []},
permanent,
infinity,
supervisor,
[couch_secondary_sup]}
]},
{ok, Pid} = supervisor:start_link(
{local, couch_server_sup}, couch_server_sup, BaseChildSpecs),
% just restart if one of the config settings change.
couch_config:register(fun ?MODULE:config_change/2, Pid),
unlink(ConfigPid),
Ip = couch_config:get("httpd", "bind_address"),
Port = mochiweb_socket_server:get(couch_httpd, port),
io:format("Apache CouchDB has started. Time to relax.~n"),
?LOG_INFO("Apache CouchDB has started on http://~s:~w/", [Ip, Port]),
case couch_config:get("couchdb", "uri_file", null) of
null -> ok;
UriFile ->
Line = io_lib:format("http://~s:~w/~n", [Ip, Port]),
file:write_file(UriFile, Line)
end,
{ok, Pid}.
config_change("daemons", _) ->
exit(whereis(couch_server_sup), shutdown);
config_change("couchdb", "util_driver_dir") ->
[Pid] = [P || {collation_driver,P,_,_}
<- supervisor:which_children(couch_primary_services)],
Pid ! reload_driver.
init(ChildSpecs) ->
{ok, ChildSpecs}.
|
