FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
rstudio/src/cpp/server/ServerOptions.cpp at master · aakashdoiphode/rstudio · GitHub
aakashdoiphode
/
rstudio
Public
forked from
rstudio/rstudio
Notifications
You must be signed in to change notification settings
Fork
0
Star
0
Code
Pull requests
0
Actions
Projects
Wiki
Security and quality
0
Insights
Additional navigation options
Code
Pull requests
Actions
Projects
Wiki
Security and quality
Insights
Expand file tree
Breadcrumbs
rstudio
/
src
/
cpp
/
server
/
ServerOptions.cpp
Copy path
More file actions
More file actions
Latest commit
History
History
History
407 lines (352 loc) · 13.7 KB
Breadcrumbs
rstudio
/
src
/
cpp
/
server
/
ServerOptions.cpp
Copy path
File metadata and controls
407 lines (352 loc) · 13.7 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
/*
* ServerOptions.cpp
*
* Copyright (C) 2009-12 by RStudio, Inc.
*
* Unless you have received this program directly from RStudio pursuant
* to the terms of a commercial license agreement with RStudio, then
* this program is licensed to you under the terms of version 3 of the
* GNU Affero General Public License. This program is distributed WITHOUT
* ANY EXPRESS OR IMPLIED WARRANTY, INCLUDING THOSE OF NON-INFRINGEMENT,
* MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE. Please refer to the
* AGPL (http://www.gnu.org/licenses/agpl-3.0.txt) for more details.
*
*/
#
include
<
server/ServerOptions.hpp
>
#
include
<
fstream
>
#
include
<
boost/algorithm/string/trim.hpp
>
#
include
<
core/ProgramStatus.hpp
>
#
include
<
core/ProgramOptions.hpp
>
#
include
<
core/FilePath.hpp
>
#
include
<
core/system/PosixUser.hpp
>
#
include
<
core/system/PosixSystem.hpp
>
#
include
<
monitor/MonitorConstants.hpp
>
#
include
"
ServerAppArmor.hpp
"
using
namespace
rstudio
::core
;
namespace
rstudio
{
namespace
server
{
namespace
{
const
char
*
const
kDefaultProgramUser
=
"
rstudio-server
"
;
struct
Deprecated
{
Deprecated
()
: memoryLimitMb(
0
),
stackLimitMb
(
0
),
userProcessLimit(
0
),
authPamRequiresPriv(
true
)
{
}
int
memoryLimitMb;
int
stackLimitMb;
int
userProcessLimit;
bool
authPamRequiresPriv;
};
void
reportDeprecationWarning
(
const
std::string& option, std::ostream& os)
{
os <<
"
The option '
"
<< option <<
"
' is deprecated and will be discarded.
"
<< std::endl;
}
void
reportDeprecationWarnings
(
const
Deprecated& userOptions,
std::ostream& os)
{
Deprecated defaultOptions;
if
(userOptions.
memoryLimitMb
!= defaultOptions.
memoryLimitMb
)
reportDeprecationWarning
(
"
rsession-memory-limit-mb
"
, os);
if
(userOptions.
stackLimitMb
!= defaultOptions.
stackLimitMb
)
reportDeprecationWarning
(
"
rsession-stack-limit-mb
"
, os);
if
(userOptions.
userProcessLimit
!= defaultOptions.
userProcessLimit
)
reportDeprecationWarning
(
"
rsession-process-limit
"
, os);
if
(userOptions.
authPamRequiresPriv
!= defaultOptions.
authPamRequiresPriv
)
reportDeprecationWarning
(
"
auth-pam-requires-priv
"
, os);
}
unsigned
int
stringToUserId
(std::string minimumUserId,
unsigned
int
defaultMinimumId,
std::ostream& osWarnings)
{
try
{
return
boost::lexical_cast<
unsigned
int
>(minimumUserId);
}
catch
(boost::bad_lexical_cast&)
{
osWarnings <<
"
Invalid value for auth-minimum-user-id '
"
<< minimumUserId <<
"
'. Using default of
"
<< defaultMinimumId <<
"
.
"
<< std::endl;
return
defaultMinimumId;
}
}
unsigned
int
resolveMinimumUserId
(std::string minimumUserId,
std::ostream& osWarnings)
{
//
default for invalid input
const
unsigned
int
kDefaultMinimumId
=
1000
;
//
auto-detect if requested
if
(minimumUserId ==
"
auto
"
)
{
//
if /etc/login.defs exists, scan it and look for a UID_MIN setting
FilePath
loginDefs
(
"
/etc/login.defs
"
);
if
(loginDefs.
exists
())
{
const
char
uidMin[] =
"
UID_MIN
"
;
std::ifstream
defStream
(loginDefs.
absolutePath
().
c_str
());
std::string line;
while
(
std::getline
(defStream, line))
{
if
(line.
substr
(
0
,
sizeof
(uidMin) -
1
) == uidMin)
{
std::string value =
boost::algorithm::trim_copy
(
line.
substr
(
sizeof
(uidMin) +
1
));
return
stringToUserId
(value,
kDefaultMinimumId
, osWarnings);
}
}
}
//
none found, return default
return
kDefaultMinimumId
;
}
else
{
return
stringToUserId
(minimumUserId,
kDefaultMinimumId
, osWarnings);
}
}
}
//
anonymous namespace
Options&
options
()
{
static
Options instance ;
return
instance ;
}
ProgramStatus
Options::read
(
int
argc,
char
*
const
argv[],
std::ostream& osWarnings)
{
using
namespace
boost
::program_options
;
//
compute install path
Error error =
core::system::installPath
(
"
..
"
, argv[
0
], &installPath_);
if
(error)
{
LOG_ERROR_MESSAGE
(
"
Unable to determine install path:
"
+error.
summary
());
return
ProgramStatus::exitFailure
();
}
//
compute the resource and binary paths
FilePath resourcePath = installPath_;
FilePath binaryPath = installPath_.
childPath
(
"
bin
"
);
//
detect running in OSX bundle and tweak paths
#
ifdef
__APPLE__
if
(installPath_.
complete
(
"
Info.plist
"
).
exists
())
{
resourcePath = installPath_.
complete
(
"
Resources
"
);
binaryPath = installPath_.
complete
(
"
MacOS
"
);
}
#
endif
//
verify installation flag
options_description
verify
(
"
verify
"
);
verify.
add_options
()
(
"
verify-installation
"
,
value<
bool
>(&verifyInstallation_)->
default_value
(
false
),
"
verify the current installation
"
);
//
special program offline option (based on file existence at
//
startup for easy bash script enable/disable of offline state)
serverOffline_ =
FilePath
(
"
/var/lib/rstudio-server/offline
"
).
exists
();
//
generate monitor shared secret
monitorSharedSecret_ =
core::system::generateUuid
();
//
program - name and execution
options_description
server
(
"
server
"
);
server.
add_options
()
(
"
server-working-dir
"
,
value<std::string>(&serverWorkingDir_)->
default_value
(
"
/
"
),
"
program working directory
"
)
(
"
server-user
"
,
value<std::string>(&serverUser_)->
default_value
(
kDefaultProgramUser
),
"
program user
"
)
(
"
server-daemonize
"
,
value<
bool
>(&serverDaemonize_)->
default_value
(
core::system::effectiveUserIsRoot
()),
"
run program as daemon
"
)
(
"
server-app-armor-enabled
"
,
value<
bool
>(&serverAppArmorEnabled_)->
default_value
(
1
),
"
is app armor enabled for this session
"
)
(
"
server-set-umask
"
,
value<
bool
>(&serverSetUmask_)->
default_value
(
1
),
"
set the umask to 022 on startup
"
);
//
www - web server options
options_description
www
(
"
www
"
) ;
www.
add_options
()
(
"
www-address
"
,
value<std::string>(&wwwAddress_)->
default_value
(
"
0.0.0.0
"
),
"
server address
"
)
(
"
www-port
"
,
value<std::string>(&wwwPort_)->
default_value
(
"
"
),
"
port to listen on
"
)
(
"
www-local-path
"
,
value<std::string>(&wwwLocalPath_)->
default_value
(
"
www
"
),
"
www files path
"
)
(
"
www-symbol-maps-path
"
,
value<std::string>(&wwwSymbolMapsPath_)->
default_value
(
"
www-symbolmaps
"
),
"
www symbol maps path
"
)
(
"
www-use-emulated-stack
"
,
value<
bool
>(&wwwUseEmulatedStack_)->
default_value
(
false
),
"
use gwt emulated stack
"
)
(
"
www-thread-pool-size
"
,
value<
int
>(&wwwThreadPoolSize_)->
default_value
(
2
),
"
thread pool size
"
)
(
"
www-proxy-localhost
"
,
value<
bool
>(&wwwProxyLocalhost_)->
default_value
(
true
),
"
proxy requests to localhost ports over main server port
"
)
(
"
www-verify-user-agent
"
,
value<
bool
>(&wwwVerifyUserAgent_)->
default_value
(
true
),
"
verify that the user agent is compatible
"
);
//
rsession
Deprecated dep;
options_description
rsession
(
"
rsession
"
);
rsession.
add_options
()
(
"
rsession-which-r
"
,
value<std::string>(&rsessionWhichR_)->
default_value
(
"
"
),
"
path to main R program (e.g. /usr/bin/R)
"
)
(
"
rsession-path
"
,
value<std::string>(&rsessionPath_)->
default_value
(
"
rsession
"
),
"
path to rsession executable
"
)
(
"
rldpath-path
"
,
value<std::string>(&rldpathPath_)->
default_value
(
"
r-ldpath
"
),
"
path to r-ldpath script
"
)
(
"
rsession-ld-library-path
"
,
value<std::string>(&rsessionLdLibraryPath_)->
default_value
(
"
"
),
"
default LD_LIBRARY_PATH for rsession
"
)
(
"
rsession-config-file
"
,
value<std::string>(&rsessionConfigFile_)->
default_value
(
"
"
),
"
path to rsession config file
"
)
(
"
rsession-memory-limit-mb
"
,
value<
int
>(&dep.
memoryLimitMb
)->
default_value
(dep.
memoryLimitMb
),
"
rsession memory limit (mb) - DEPRECATED
"
)
(
"
rsession-stack-limit-mb
"
,
value<
int
>(&dep.
stackLimitMb
)->
default_value
(dep.
stackLimitMb
),
"
rsession stack limit (mb) - DEPRECATED
"
)
(
"
rsession-process-limit
"
,
value<
int
>(&dep.
userProcessLimit
)->
default_value
(dep.
userProcessLimit
),
"
rsession user process limit - DEPRECATED
"
);
//
still read depracated options (so we don't break config files)
std::string authMinimumUserId;
options_description
auth
(
"
auth
"
);
auth.
add_options
()
(
"
auth-none
"
,
value<
bool
>(&authNone_)->
default_value
(
!
core::system::effectiveUserIsRoot
()),
"
don't do any authentication
"
)
(
"
auth-validate-users
"
,
value<
bool
>(&authValidateUsers_)->
default_value
(
core::system::effectiveUserIsRoot
()),
"
validate that authenticated users exist on the target system
"
)
(
"
auth-stay-signed-in-days
"
,
value<
int
>(&authStaySignedInDays_)->
default_value
(
30
),
"
number of days for stay signed in option
"
)
(
"
auth-encrypt-password
"
,
value<
bool
>(&authEncryptPassword_)->
default_value
(
true
),
"
encrypt password sent from login form
"
)
(
"
auth-required-user-group
"
,
value<std::string>(&authRequiredUserGroup_)->
default_value
(
"
"
),
"
limit to users belonging to the specified group
"
)
(
"
auth-minimum-user-id
"
,
value<std::string>(&authMinimumUserId)->
default_value
(
"
auto
"
),
"
limit to users with a required minimum user id
"
)
(
"
auth-pam-helper-path
"
,
value<std::string>(&authPamHelperPath_)->
default_value
(
"
rserver-pam
"
),
"
path to PAM helper binary
"
)
(
"
auth-pam-requires-priv
"
,
value<
bool
>(&dep.
authPamRequiresPriv
)->
default_value
(
dep.
authPamRequiresPriv
),
"
deprecated: will always be true
"
);
options_description
monitor
(
"
monitor
"
);
monitor.
add_options
()
(
kMonitorIntervalSeconds
,
value<
int
>(&monitorIntervalSeconds_)->
default_value
(
300
),
"
monitoring interval
"
);
//
define program options
FilePath
defaultConfigPath
(
"
/etc/rstudio/rserver.conf
"
);
std::string configFile = defaultConfigPath.
exists
() ?
defaultConfigPath.
absolutePath
() :
"
"
;
program_options::OptionsDescription
optionsDesc
(
"
rserver
"
, configFile);
//
overlay hook
addOverlayOptions
(&server, &www, &rsession, &auth, &monitor);
optionsDesc.
commandLine
.
add
(verify).
add
(server).
add
(www).
add
(rsession).
add
(auth).
add
(monitor);
optionsDesc.
configFile
.
add
(server).
add
(www).
add
(rsession).
add
(auth).
add
(monitor);
//
read options
bool
help =
false
;
ProgramStatus status =
core::program_options::read
(optionsDesc,
argc,
argv,
&help);
//
terminate if this was a help request
if
(help)
return
ProgramStatus::exitSuccess
();
//
report deprecation warnings
reportDeprecationWarnings
(dep, osWarnings);
//
call overlay hooks
resolveOverlayOptions
();
std::string errMsg;
if
(!
validateOverlayOptions
(&errMsg, osWarnings))
{
program_options::reportError
(errMsg,
ERROR_LOCATION
);
return
ProgramStatus::exitFailure
();
}
//
exit if the call to read indicated we should -- note we don't do this
//
immediately so that we can allow overlay validation to occur (otherwise
//
a --test-config wouldn't test overlay options)
if
(status.
exit
())
return
status;
//
rationalize auth settings
if
(authNone_)
authValidateUsers_ =
false
;
//
if specified, confirm that the program user exists. however, if the
//
program user is the default and it doesn't exist then allow that to pass,
//
this just means that the user did a simple make install and hasn't setup
//
an rserver user yet. in this case the program will run as root
if
(!serverUser_.
empty
())
{
//
if we aren't running as root then forget the programUser
if
(!
core::system::realUserIsRoot
())
{
serverUser_ =
"
"
;
}
//
if there is a program user specified and it doesn't exist....
else
if
(!
core::system::user::exists
(serverUser_))
{
if
(serverUser_ ==
kDefaultProgramUser
)
{
//
administrator hasn't created an rserver system account yet
//
so we'll end up running as root
serverUser_ =
"
"
;
}
else
{
LOG_ERROR_MESSAGE
(
"
Server user
"
+ serverUser_ +
"
does not exist
"
);
return
ProgramStatus::exitFailure
();
}
}
}
//
if app armor is enabled do a further check to see whether
//
the profile exists. if it doesn't then disable it
if
(serverAppArmorEnabled_)
{
if
(!
FilePath
(
"
/etc/apparmor.d/rstudio-server
"
).
exists
())
serverAppArmorEnabled_ =
false
;
}
//
convert relative paths by completing from the system installation
//
path (this allows us to be relocatable)
resolvePath
(resourcePath, &wwwLocalPath_);
resolvePath
(resourcePath, &wwwSymbolMapsPath_);
resolvePath
(binaryPath, &authPamHelperPath_);
resolvePath
(binaryPath, &rsessionPath_);
resolvePath
(binaryPath, &rldpathPath_);
resolvePath
(resourcePath, &rsessionConfigFile_);
//
resolve minimum user id
authMinimumUserId_ =
resolveMinimumUserId
(authMinimumUserId, osWarnings);
//
return status
return
status;
}
void
Options::resolvePath
(
const
FilePath& basePath,
std::string* pPath)
const
{
if
(!pPath->
empty
())
*pPath = basePath.
complete
(*pPath).
absolutePath
();
}
}
//
namespace server
}
//
namespace rstudio
Back
|
FazBrowse Home
|
New Git URL