Consumer rotate stream
[lttng-tools.git] / src / common / runas.c
1 /*
2 * Copyright (C) 2011 - David Goulet <david.goulet@polymtl.ca>
3 * Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
4 *
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License, version 2 only,
7 * as published by the Free Software Foundation.
8 *
9 * This program is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
12 * more details.
13 *
14 * You should have received a copy of the GNU General Public License along
15 * with this program; if not, write to the Free Software Foundation, Inc.,
16 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
17 */
18
19 #define _LGPL_SOURCE
20 #include <errno.h>
21 #include <limits.h>
22 #include <stdio.h>
23 #include <stdlib.h>
24 #include <string.h>
25 #include <sys/wait.h>
26 #include <sys/types.h>
27 #include <sys/stat.h>
28 #include <unistd.h>
29 #include <fcntl.h>
30 #include <sched.h>
31 #include <signal.h>
32 #include <assert.h>
33 #include <signal.h>
34
35 #include <common/common.h>
36 #include <common/utils.h>
37 #include <common/compat/getenv.h>
38 #include <common/compat/prctl.h>
39 #include <common/unix.h>
40 #include <common/defaults.h>
41
42 #include "runas.h"
43
44 struct run_as_data;
45 typedef int (*run_as_fct)(struct run_as_data *data);
46
47 struct run_as_mkdir_data {
48 char path[PATH_MAX];
49 mode_t mode;
50 };
51
52 struct run_as_open_data {
53 char path[PATH_MAX];
54 int flags;
55 mode_t mode;
56 };
57
58 struct run_as_unlink_data {
59 char path[PATH_MAX];
60 };
61
62 struct run_as_rmdir_recursive_data {
63 char path[PATH_MAX];
64 };
65
66 enum run_as_cmd {
67 RUN_AS_MKDIR,
68 RUN_AS_OPEN,
69 RUN_AS_UNLINK,
70 RUN_AS_RMDIR_RECURSIVE,
71 RUN_AS_MKDIR_RECURSIVE,
72 };
73
74 struct run_as_data {
75 enum run_as_cmd cmd;
76 union {
77 struct run_as_mkdir_data mkdir;
78 struct run_as_open_data open;
79 struct run_as_unlink_data unlink;
80 struct run_as_rmdir_recursive_data rmdir_recursive;
81 } u;
82 uid_t uid;
83 gid_t gid;
84 };
85
86 struct run_as_ret {
87 int ret;
88 int _errno;
89 };
90
91 struct run_as_worker {
92 pid_t pid; /* Worker PID. */
93 int sockpair[2];
94 char *procname;
95 };
96
97 /* Single global worker per process (for now). */
98 static struct run_as_worker *global_worker;
99 /* Lock protecting the worker. */
100 static pthread_mutex_t worker_lock = PTHREAD_MUTEX_INITIALIZER;
101
102 #ifdef VALGRIND
103 static
104 int use_clone(void)
105 {
106 return 0;
107 }
108 #else
109 static
110 int use_clone(void)
111 {
112 return !lttng_secure_getenv("LTTNG_DEBUG_NOCLONE");
113 }
114 #endif
115
116 LTTNG_HIDDEN
117 int _utils_mkdir_recursive_unsafe(const char *path, mode_t mode);
118
119 /*
120 * Create recursively directory using the FULL path.
121 */
122 static
123 int _mkdir_recursive(struct run_as_data *data)
124 {
125 const char *path;
126 mode_t mode;
127
128 path = data->u.mkdir.path;
129 mode = data->u.mkdir.mode;
130
131 /* Safe to call as we have transitioned to the requested uid/gid. */
132 return _utils_mkdir_recursive_unsafe(path, mode);
133 }
134
135 static
136 int _mkdir(struct run_as_data *data)
137 {
138 return mkdir(data->u.mkdir.path, data->u.mkdir.mode);
139 }
140
141 static
142 int _open(struct run_as_data *data)
143 {
144 return open(data->u.open.path, data->u.open.flags, data->u.open.mode);
145 }
146
147 static
148 int _unlink(struct run_as_data *data)
149 {
150 return unlink(data->u.unlink.path);
151 }
152
153 static
154 int _rmdir_recursive(struct run_as_data *data)
155 {
156 return utils_recursive_rmdir(data->u.rmdir_recursive.path);
157 }
158
159 static
160 run_as_fct run_as_enum_to_fct(enum run_as_cmd cmd)
161 {
162 switch (cmd) {
163 case RUN_AS_MKDIR:
164 return _mkdir;
165 case RUN_AS_OPEN:
166 return _open;
167 case RUN_AS_UNLINK:
168 return _unlink;
169 case RUN_AS_RMDIR_RECURSIVE:
170 return _rmdir_recursive;
171 case RUN_AS_MKDIR_RECURSIVE:
172 return _mkdir_recursive;
173 default:
174 ERR("Unknown command %d", (int) cmd);
175 return NULL;
176 }
177 }
178
179 static
180 int do_send_fd(struct run_as_worker *worker,
181 enum run_as_cmd cmd, int fd)
182 {
183 ssize_t len;
184
185 switch (cmd) {
186 case RUN_AS_OPEN:
187 break;
188 default:
189 return 0;
190 }
191 if (fd < 0) {
192 return 0;
193 }
194 len = lttcomm_send_fds_unix_sock(worker->sockpair[1], &fd, 1);
195 if (len < 0) {
196 PERROR("lttcomm_send_fds_unix_sock");
197 return -1;
198 }
199 if (close(fd) < 0) {
200 PERROR("close");
201 return -1;
202 }
203 return 0;
204 }
205
206 static
207 int do_recv_fd(struct run_as_worker *worker,
208 enum run_as_cmd cmd, int *fd)
209 {
210 ssize_t len;
211
212 switch (cmd) {
213 case RUN_AS_OPEN:
214 break;
215 default:
216 return 0;
217 }
218 if (*fd < 0) {
219 return 0;
220 }
221 len = lttcomm_recv_fds_unix_sock(worker->sockpair[0], fd, 1);
222 if (!len) {
223 return -1;
224 } else if (len < 0) {
225 PERROR("lttcomm_recv_fds_unix_sock");
226 return -1;
227 }
228 return 0;
229 }
230
231 /*
232 * Return < 0 on error, 0 if OK, 1 on hangup.
233 */
234 static
235 int handle_one_cmd(struct run_as_worker *worker)
236 {
237 int ret = 0;
238 struct run_as_data data;
239 ssize_t readlen, writelen;
240 struct run_as_ret sendret;
241 run_as_fct cmd;
242 uid_t prev_euid;
243
244 /* Read data */
245 readlen = lttcomm_recv_unix_sock(worker->sockpair[1], &data,
246 sizeof(data));
247 if (readlen == 0) {
248 /* hang up */
249 ret = 1;
250 goto end;
251 }
252 if (readlen < sizeof(data)) {
253 PERROR("lttcomm_recv_unix_sock error");
254 ret = -1;
255 goto end;
256 }
257
258 cmd = run_as_enum_to_fct(data.cmd);
259 if (!cmd) {
260 ret = -1;
261 goto end;
262 }
263
264 prev_euid = getuid();
265 if (data.gid != getegid()) {
266 ret = setegid(data.gid);
267 if (ret < 0) {
268 PERROR("setegid");
269 goto write_return;
270 }
271 }
272 if (data.uid != prev_euid) {
273 ret = seteuid(data.uid);
274 if (ret < 0) {
275 PERROR("seteuid");
276 goto write_return;
277 }
278 }
279 /*
280 * Also set umask to 0 for mkdir executable bit.
281 */
282 umask(0);
283 ret = (*cmd)(&data);
284
285 write_return:
286 sendret.ret = ret;
287 sendret._errno = errno;
288 /* send back return value */
289 writelen = lttcomm_send_unix_sock(worker->sockpair[1], &sendret,
290 sizeof(sendret));
291 if (writelen < sizeof(sendret)) {
292 PERROR("lttcomm_send_unix_sock error");
293 ret = -1;
294 goto end;
295 }
296 ret = do_send_fd(worker, data.cmd, ret);
297 if (ret) {
298 PERROR("do_send_fd error");
299 ret = -1;
300 goto end;
301 }
302 if (seteuid(prev_euid) < 0) {
303 PERROR("seteuid");
304 ret = -1;
305 goto end;
306 }
307 ret = 0;
308 end:
309 return ret;
310 }
311
312 static
313 int run_as_worker(struct run_as_worker *worker)
314 {
315 int ret;
316 ssize_t writelen;
317 struct run_as_ret sendret;
318 size_t proc_orig_len;
319
320 /*
321 * Initialize worker. Set a different process cmdline.
322 */
323 proc_orig_len = strlen(worker->procname);
324 memset(worker->procname, 0, proc_orig_len);
325 strncpy(worker->procname, DEFAULT_RUN_AS_WORKER_NAME, proc_orig_len);
326
327 ret = lttng_prctl(PR_SET_NAME,
328 (unsigned long) DEFAULT_RUN_AS_WORKER_NAME, 0, 0, 0);
329 if (ret && ret != -ENOSYS) {
330 /* Don't fail as this is not essential. */
331 PERROR("prctl PR_SET_NAME");
332 }
333
334 sendret.ret = 0;
335 sendret._errno = 0;
336 writelen = lttcomm_send_unix_sock(worker->sockpair[1], &sendret,
337 sizeof(sendret));
338 if (writelen < sizeof(sendret)) {
339 PERROR("lttcomm_send_unix_sock error");
340 ret = EXIT_FAILURE;
341 goto end;
342 }
343
344 for (;;) {
345 ret = handle_one_cmd(worker);
346 if (ret < 0) {
347 ret = EXIT_FAILURE;
348 goto end;
349 } else if (ret > 0) {
350 break;
351 } else {
352 continue; /* Next command. */
353 }
354 }
355 ret = EXIT_SUCCESS;
356 end:
357 return ret;
358 }
359
360 static
361 int run_as_cmd(struct run_as_worker *worker,
362 enum run_as_cmd cmd,
363 struct run_as_data *data,
364 uid_t uid, gid_t gid)
365 {
366 ssize_t readlen, writelen;
367 struct run_as_ret recvret;
368
369 /*
370 * If we are non-root, we can only deal with our own uid.
371 */
372 if (geteuid() != 0) {
373 if (uid != geteuid()) {
374 recvret.ret = -1;
375 recvret._errno = EPERM;
376 ERR("Client (%d)/Server (%d) UID mismatch (and sessiond is not root)",
377 (int) uid, (int) geteuid());
378 goto end;
379 }
380 }
381
382 data->cmd = cmd;
383 data->uid = uid;
384 data->gid = gid;
385
386 writelen = lttcomm_send_unix_sock(worker->sockpair[0], data,
387 sizeof(*data));
388 if (writelen < sizeof(*data)) {
389 PERROR("Error writing message to run_as");
390 recvret.ret = -1;
391 recvret._errno = errno;
392 goto end;
393 }
394
395 /* receive return value */
396 readlen = lttcomm_recv_unix_sock(worker->sockpair[0], &recvret,
397 sizeof(recvret));
398 if (!readlen) {
399 ERR("Run-as worker has hung-up during run_as_cmd");
400 recvret.ret = -1;
401 recvret._errno = EIO;
402 goto end;
403 } else if (readlen < sizeof(recvret)) {
404 PERROR("Error reading response from run_as");
405 recvret.ret = -1;
406 recvret._errno = errno;
407 }
408 if (do_recv_fd(worker, cmd, &recvret.ret)) {
409 recvret.ret = -1;
410 recvret._errno = EIO;
411 }
412
413 end:
414 errno = recvret._errno;
415 return recvret.ret;
416 }
417
418 /*
419 * This is for debugging ONLY and should not be considered secure.
420 */
421 static
422 int run_as_noworker(enum run_as_cmd cmd,
423 struct run_as_data *data, uid_t uid, gid_t gid)
424 {
425 int ret, saved_errno;
426 mode_t old_mask;
427 run_as_fct fct;
428
429 fct = run_as_enum_to_fct(cmd);
430 if (!fct) {
431 errno = -ENOSYS;
432 ret = -1;
433 goto end;
434 }
435 old_mask = umask(0);
436 ret = fct(data);
437 saved_errno = errno;
438 umask(old_mask);
439 errno = saved_errno;
440 end:
441 return ret;
442 }
443
444 static
445 int run_as(enum run_as_cmd cmd, struct run_as_data *data, uid_t uid, gid_t gid)
446 {
447 int ret;
448
449 if (use_clone()) {
450 DBG("Using run_as worker");
451 pthread_mutex_lock(&worker_lock);
452 assert(global_worker);
453 ret = run_as_cmd(global_worker, cmd, data, uid, gid);
454 pthread_mutex_unlock(&worker_lock);
455
456 } else {
457 DBG("Using run_as without worker");
458 ret = run_as_noworker(cmd, data, uid, gid);
459 }
460 return ret;
461 }
462
463 LTTNG_HIDDEN
464 int run_as_mkdir_recursive(const char *path, mode_t mode, uid_t uid, gid_t gid)
465 {
466 struct run_as_data data;
467
468 memset(&data, 0, sizeof(data));
469 DBG3("mkdir() recursive %s with mode %d for uid %d and gid %d",
470 path, (int) mode, (int) uid, (int) gid);
471 strncpy(data.u.mkdir.path, path, PATH_MAX - 1);
472 data.u.mkdir.path[PATH_MAX - 1] = '\0';
473 data.u.mkdir.mode = mode;
474 return run_as(RUN_AS_MKDIR_RECURSIVE, &data, uid, gid);
475 }
476
477 LTTNG_HIDDEN
478 int run_as_mkdir(const char *path, mode_t mode, uid_t uid, gid_t gid)
479 {
480 struct run_as_data data;
481
482 memset(&data, 0, sizeof(data));
483 DBG3("mkdir() %s with mode %d for uid %d and gid %d",
484 path, (int) mode, (int) uid, (int) gid);
485 strncpy(data.u.mkdir.path, path, PATH_MAX - 1);
486 data.u.mkdir.path[PATH_MAX - 1] = '\0';
487 data.u.mkdir.mode = mode;
488 return run_as(RUN_AS_MKDIR, &data, uid, gid);
489 }
490
491 LTTNG_HIDDEN
492 int run_as_open(const char *path, int flags, mode_t mode, uid_t uid, gid_t gid)
493 {
494 struct run_as_data data;
495
496 memset(&data, 0, sizeof(data));
497 DBG3("open() %s with flags %X mode %d for uid %d and gid %d",
498 path, flags, (int) mode, (int) uid, (int) gid);
499 strncpy(data.u.open.path, path, PATH_MAX - 1);
500 data.u.open.path[PATH_MAX - 1] = '\0';
501 data.u.open.flags = flags;
502 data.u.open.mode = mode;
503 return run_as(RUN_AS_OPEN, &data, uid, gid);
504 }
505
506 LTTNG_HIDDEN
507 int run_as_unlink(const char *path, uid_t uid, gid_t gid)
508 {
509 struct run_as_data data;
510
511 memset(&data, 0, sizeof(data));
512 DBG3("unlink() %s with for uid %d and gid %d",
513 path, (int) uid, (int) gid);
514 strncpy(data.u.unlink.path, path, PATH_MAX - 1);
515 data.u.unlink.path[PATH_MAX - 1] = '\0';
516 return run_as(RUN_AS_UNLINK, &data, uid, gid);
517 }
518
519 LTTNG_HIDDEN
520 int run_as_rmdir_recursive(const char *path, uid_t uid, gid_t gid)
521 {
522 struct run_as_data data;
523
524 DBG3("rmdir_recursive() %s with for uid %d and gid %d",
525 path, (int) uid, (int) gid);
526 strncpy(data.u.rmdir_recursive.path, path, PATH_MAX - 1);
527 data.u.rmdir_recursive.path[PATH_MAX - 1] = '\0';
528 return run_as(RUN_AS_RMDIR_RECURSIVE, &data, uid, gid);
529 }
530
531 static
532 int reset_sighandler(void)
533 {
534 int sig;
535
536 DBG("Resetting run_as worker signal handlers to default");
537 for (sig = 1; sig <= 31; sig++) {
538 (void) signal(sig, SIG_DFL);
539 }
540 return 0;
541 }
542
543 static
544 void worker_sighandler(int sig)
545 {
546 const char *signame;
547
548 /*
549 * The worker will inherit its parent's signals since they are part of
550 * the same process group. However, in the case of SIGINT and SIGTERM,
551 * we want to give the worker a chance to teardown gracefully when its
552 * parent closes the command socket.
553 */
554 switch (sig) {
555 case SIGINT:
556 signame = "SIGINT";
557 break;
558 case SIGTERM:
559 signame = "SIGTERM";
560 break;
561 default:
562 signame = NULL;
563 }
564
565 if (signame) {
566 DBG("run_as worker received signal %s", signame);
567 } else {
568 DBG("run_as_worker received signal %d", sig);
569 }
570 }
571
572 static
573 int set_worker_sighandlers(void)
574 {
575 int ret = 0;
576 sigset_t sigset;
577 struct sigaction sa;
578
579 if ((ret = sigemptyset(&sigset)) < 0) {
580 PERROR("sigemptyset");
581 goto end;
582 }
583
584 sa.sa_handler = worker_sighandler;
585 sa.sa_mask = sigset;
586 sa.sa_flags = 0;
587 if ((ret = sigaction(SIGINT, &sa, NULL)) < 0) {
588 PERROR("sigaction SIGINT");
589 goto end;
590 }
591
592 if ((ret = sigaction(SIGTERM, &sa, NULL)) < 0) {
593 PERROR("sigaction SIGTERM");
594 goto end;
595 }
596
597 DBG("run_as signal handler set for SIGTERM and SIGINT");
598 end:
599 return ret;
600 }
601
602 LTTNG_HIDDEN
603 int run_as_create_worker(char *procname)
604 {
605 pid_t pid;
606 int i, ret = 0;
607 ssize_t readlen;
608 struct run_as_ret recvret;
609 struct run_as_worker *worker;
610
611 pthread_mutex_lock(&worker_lock);
612 assert(!global_worker);
613 if (!use_clone()) {
614 /*
615 * Don't initialize a worker, all run_as tasks will be performed
616 * in the current process.
617 */
618 ret = 0;
619 goto end;
620 }
621 worker = zmalloc(sizeof(*worker));
622 if (!worker) {
623 ret = -ENOMEM;
624 goto end;
625 }
626 worker->procname = procname;
627 /* Create unix socket. */
628 if (lttcomm_create_anon_unix_socketpair(worker->sockpair) < 0) {
629 ret = -1;
630 goto error_sock;
631 }
632 /* Fork worker. */
633 pid = fork();
634 if (pid < 0) {
635 PERROR("fork");
636 ret = -1;
637 goto error_fork;
638 } else if (pid == 0) {
639 /* Child */
640
641 reset_sighandler();
642
643 set_worker_sighandlers();
644
645 /* The child has no use for this lock. */
646 pthread_mutex_unlock(&worker_lock);
647 /* Just close, no shutdown. */
648 if (close(worker->sockpair[0])) {
649 PERROR("close");
650 exit(EXIT_FAILURE);
651 }
652 worker->sockpair[0] = -1;
653 ret = run_as_worker(worker);
654 if (lttcomm_close_unix_sock(worker->sockpair[1])) {
655 PERROR("close");
656 ret = -1;
657 }
658 worker->sockpair[1] = -1;
659 LOG(ret ? PRINT_ERR : PRINT_DBG, "run_as worker exiting (ret = %d)", ret);
660 exit(ret ? EXIT_FAILURE : EXIT_SUCCESS);
661 } else {
662 /* Parent */
663
664 /* Just close, no shutdown. */
665 if (close(worker->sockpair[1])) {
666 PERROR("close");
667 ret = -1;
668 goto error_fork;
669 }
670 worker->sockpair[1] = -1;
671 worker->pid = pid;
672 /* Wait for worker to become ready. */
673 readlen = lttcomm_recv_unix_sock(worker->sockpair[0],
674 &recvret, sizeof(recvret));
675 if (readlen < sizeof(recvret)) {
676 ERR("readlen: %zd", readlen);
677 PERROR("Error reading response from run_as at creation");
678 ret = -1;
679 goto error_fork;
680 }
681 global_worker = worker;
682 }
683 end:
684 pthread_mutex_unlock(&worker_lock);
685 return ret;
686
687 /* Error handling. */
688 error_fork:
689 for (i = 0; i < 2; i++) {
690 if (worker->sockpair[i] < 0) {
691 continue;
692 }
693 if (lttcomm_close_unix_sock(worker->sockpair[i])) {
694 PERROR("close");
695 }
696 worker->sockpair[i] = -1;
697 }
698 error_sock:
699 free(worker);
700 pthread_mutex_unlock(&worker_lock);
701 return ret;
702 }
703
704 LTTNG_HIDDEN
705 void run_as_destroy_worker(void)
706 {
707 struct run_as_worker *worker = global_worker;
708
709 DBG("Destroying run_as worker");
710 pthread_mutex_lock(&worker_lock);
711 if (!worker) {
712 goto end;
713 }
714 /* Close unix socket */
715 DBG("Closing run_as worker socket");
716 if (lttcomm_close_unix_sock(worker->sockpair[0])) {
717 PERROR("close");
718 }
719 worker->sockpair[0] = -1;
720 /* Wait for worker. */
721 for (;;) {
722 int status;
723 pid_t wait_ret;
724
725 wait_ret = waitpid(worker->pid, &status, 0);
726 if (wait_ret < 0) {
727 if (errno == EINTR) {
728 continue;
729 }
730 PERROR("waitpid");
731 break;
732 }
733
734 if (WIFEXITED(status)) {
735 LOG(WEXITSTATUS(status) == 0 ? PRINT_DBG : PRINT_ERR,
736 DEFAULT_RUN_AS_WORKER_NAME " terminated with status code %d",
737 WEXITSTATUS(status));
738 break;
739 } else if (WIFSIGNALED(status)) {
740 ERR(DEFAULT_RUN_AS_WORKER_NAME " was killed by signal %d",
741 WTERMSIG(status));
742 break;
743 }
744 }
745 free(worker);
746 global_worker = NULL;
747 end:
748 pthread_mutex_unlock(&worker_lock);
749 }
This page took 0.046435 seconds and 4 git commands to generate.