Moving forward we're going to be supporting libseat and logind as our only launchers. We're doing this to reduce our maintenance burden, and security impact. Libseat supports all our existing use cases, and seatd can replace weston-launch so we no longer have to carry a setuid-root program. This patch removes weston-launch, and launcher-direct, leaving only libseat and logind. Signed-off-by: Derek Foreman <derek.foreman@collabora.com>dev
Derek Foreman
3 years ago
parent
87f2d09f18
commit
a96dfc7098
@ -1,370 +0,0 @@ |
||||
/*
|
||||
* Copyright © 2012 Benjamin Franzke |
||||
* Copyright © 2013 Intel Corporation |
||||
* |
||||
* Permission is hereby granted, free of charge, to any person obtaining |
||||
* a copy of this software and associated documentation files (the |
||||
* "Software"), to deal in the Software without restriction, including |
||||
* without limitation the rights to use, copy, modify, merge, publish, |
||||
* distribute, sublicense, and/or sell copies of the Software, and to |
||||
* permit persons to whom the Software is furnished to do so, subject to |
||||
* the following conditions: |
||||
* |
||||
* The above copyright notice and this permission notice (including the |
||||
* next paragraph) shall be included in all copies or substantial |
||||
* portions of the Software. |
||||
* |
||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, |
||||
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF |
||||
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
||||
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS |
||||
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN |
||||
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN |
||||
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE |
||||
* SOFTWARE. |
||||
*/ |
||||
|
||||
#include "config.h" |
||||
|
||||
#include <libweston/libweston.h> |
||||
|
||||
#include <errno.h> |
||||
#include <fcntl.h> |
||||
#include <unistd.h> |
||||
#include <signal.h> |
||||
#include <string.h> |
||||
#include <sys/stat.h> |
||||
#include <sys/ioctl.h> |
||||
#include <linux/vt.h> |
||||
#include <linux/kd.h> |
||||
#include <linux/major.h> |
||||
|
||||
#include "launcher-impl.h" |
||||
|
||||
#define DRM_MAJOR 226 |
||||
|
||||
#ifndef KDSKBMUTE |
||||
#define KDSKBMUTE 0x4B51 |
||||
#endif |
||||
|
||||
/* major()/minor() */ |
||||
#ifdef MAJOR_IN_MKDEV |
||||
#include <sys/mkdev.h> |
||||
#endif |
||||
#ifdef MAJOR_IN_SYSMACROS |
||||
#include <sys/sysmacros.h> |
||||
#endif |
||||
|
||||
#ifdef BUILD_DRM_COMPOSITOR |
||||
|
||||
#include <xf86drm.h> |
||||
|
||||
static inline int |
||||
is_drm_master(int drm_fd) |
||||
{ |
||||
drm_magic_t magic; |
||||
|
||||
return drmGetMagic(drm_fd, &magic) == 0 && |
||||
drmAuthMagic(drm_fd, magic) == 0; |
||||
} |
||||
|
||||
#else |
||||
|
||||
static inline int |
||||
drmDropMaster(int drm_fd) |
||||
{ |
||||
return 0; |
||||
} |
||||
|
||||
static inline int |
||||
drmSetMaster(int drm_fd) |
||||
{ |
||||
return 0; |
||||
} |
||||
|
||||
static inline int |
||||
is_drm_master(int drm_fd) |
||||
{ |
||||
return 0; |
||||
} |
||||
|
||||
#endif |
||||
|
||||
struct launcher_direct { |
||||
struct weston_launcher base; |
||||
struct weston_compositor *compositor; |
||||
int kb_mode, tty, drm_fd; |
||||
struct wl_event_source *vt_source; |
||||
}; |
||||
|
||||
static int |
||||
vt_handler(int signal_number, void *data) |
||||
{ |
||||
struct launcher_direct *launcher = data; |
||||
struct weston_compositor *compositor = launcher->compositor; |
||||
|
||||
if (compositor->session_active) { |
||||
compositor->session_active = false; |
||||
wl_signal_emit(&compositor->session_signal, compositor); |
||||
drmDropMaster(launcher->drm_fd); |
||||
ioctl(launcher->tty, VT_RELDISP, 1); |
||||
} else { |
||||
ioctl(launcher->tty, VT_RELDISP, VT_ACKACQ); |
||||
drmSetMaster(launcher->drm_fd); |
||||
compositor->session_active = true; |
||||
wl_signal_emit(&compositor->session_signal, compositor); |
||||
} |
||||
|
||||
return 1; |
||||
} |
||||
|
||||
static int |
||||
setup_tty(struct launcher_direct *launcher, int tty) |
||||
{ |
||||
struct wl_event_loop *loop; |
||||
struct vt_mode mode = { 0 }; |
||||
struct stat buf; |
||||
char tty_device[32] ="<stdin>"; |
||||
int ret, kd_mode; |
||||
|
||||
if (geteuid() != 0) |
||||
return -1; |
||||
|
||||
if (tty == 0) { |
||||
launcher->tty = dup(tty); |
||||
if (launcher->tty == -1) { |
||||
weston_log("couldn't dup stdin: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
} else { |
||||
snprintf(tty_device, sizeof tty_device, "/dev/tty%d", tty); |
||||
launcher->tty = open(tty_device, O_RDWR | O_CLOEXEC); |
||||
if (launcher->tty == -1) { |
||||
weston_log("couldn't open tty %s: %s\n", tty_device, |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
} |
||||
|
||||
if (fstat(launcher->tty, &buf) == -1 || |
||||
major(buf.st_rdev) != TTY_MAJOR || minor(buf.st_rdev) == 0) { |
||||
weston_log("%s not a vt\n", tty_device); |
||||
weston_log("if running weston from ssh, " |
||||
"use --tty to specify a tty\n"); |
||||
goto err_close; |
||||
} |
||||
|
||||
ret = ioctl(launcher->tty, KDGETMODE, &kd_mode); |
||||
if (ret) { |
||||
weston_log("failed to get VT mode: %s\n", strerror(errno)); |
||||
return -1; |
||||
} |
||||
if (kd_mode != KD_TEXT) { |
||||
weston_log("%s is already in graphics mode, " |
||||
"is another display server running?\n", tty_device); |
||||
} |
||||
|
||||
ioctl(launcher->tty, VT_ACTIVATE, minor(buf.st_rdev)); |
||||
ioctl(launcher->tty, VT_WAITACTIVE, minor(buf.st_rdev)); |
||||
|
||||
if (ioctl(launcher->tty, KDGKBMODE, &launcher->kb_mode)) { |
||||
weston_log("failed to read keyboard mode: %s\n", |
||||
strerror(errno)); |
||||
goto err_close; |
||||
} |
||||
|
||||
if (ioctl(launcher->tty, KDSKBMUTE, 1) && |
||||
ioctl(launcher->tty, KDSKBMODE, K_OFF)) { |
||||
weston_log("failed to set K_OFF keyboard mode: %s\n", |
||||
strerror(errno)); |
||||
goto err_close; |
||||
} |
||||
|
||||
ret = ioctl(launcher->tty, KDSETMODE, KD_GRAPHICS); |
||||
if (ret) { |
||||
weston_log("failed to set KD_GRAPHICS mode on tty: %s\n", |
||||
strerror(errno)); |
||||
goto err_close; |
||||
} |
||||
|
||||
/*
|
||||
* SIGRTMIN is used as global VT-acquire+release signal. Note that |
||||
* SIGRT* must be tested on runtime, as their exact values are not |
||||
* known at compile-time. POSIX requires 32 of them to be available. |
||||
*/ |
||||
if (SIGRTMIN > SIGRTMAX) { |
||||
weston_log("not enough RT signals available: %u-%u\n", |
||||
SIGRTMIN, SIGRTMAX); |
||||
ret = -EINVAL; |
||||
goto err_close; |
||||
} |
||||
|
||||
mode.mode = VT_PROCESS; |
||||
mode.relsig = SIGRTMIN; |
||||
mode.acqsig = SIGRTMIN; |
||||
if (ioctl(launcher->tty, VT_SETMODE, &mode) < 0) { |
||||
weston_log("failed to take control of vt handling\n"); |
||||
goto err_close; |
||||
} |
||||
|
||||
loop = wl_display_get_event_loop(launcher->compositor->wl_display); |
||||
launcher->vt_source = |
||||
wl_event_loop_add_signal(loop, SIGRTMIN, vt_handler, launcher); |
||||
if (!launcher->vt_source) { |
||||
weston_log("failed to add SIGRTMIN signal\n"); |
||||
goto err_close; |
||||
} |
||||
|
||||
return 0; |
||||
|
||||
err_close: |
||||
close(launcher->tty); |
||||
return -1; |
||||
} |
||||
|
||||
static int |
||||
launcher_direct_open(struct weston_launcher *launcher_base, const char *path, int flags) |
||||
{ |
||||
struct launcher_direct *launcher = wl_container_of(launcher_base, launcher, base); |
||||
struct stat s; |
||||
int fd; |
||||
|
||||
fd = open(path, flags | O_CLOEXEC); |
||||
if (fd == -1) { |
||||
weston_log("couldn't open: %s! error=%s\n", path, strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (geteuid() != 0) { |
||||
weston_log("WARNING! Succeeded opening %s as non-root user." |
||||
" This implies your device can be spied on.\n", |
||||
path); |
||||
} |
||||
|
||||
if (fstat(fd, &s) == -1) { |
||||
weston_log("couldn't fstat: %s! error=%s\n", path, strerror(errno)); |
||||
close(fd); |
||||
return -1; |
||||
} |
||||
|
||||
if (major(s.st_rdev) == DRM_MAJOR) { |
||||
launcher->drm_fd = fd; |
||||
if (!is_drm_master(fd)) { |
||||
weston_log("drm fd not master\n"); |
||||
close(fd); |
||||
return -1; |
||||
} |
||||
} |
||||
|
||||
return fd; |
||||
} |
||||
|
||||
static void |
||||
launcher_direct_close(struct weston_launcher *launcher_base, int fd) |
||||
{ |
||||
close(fd); |
||||
} |
||||
|
||||
static void |
||||
launcher_direct_restore(struct weston_launcher *launcher_base) |
||||
{ |
||||
struct launcher_direct *launcher = wl_container_of(launcher_base, launcher, base); |
||||
struct vt_mode mode = { 0 }; |
||||
|
||||
if (ioctl(launcher->tty, KDSKBMUTE, 0) && |
||||
ioctl(launcher->tty, KDSKBMODE, launcher->kb_mode)) |
||||
weston_log("failed to restore kb mode: %s\n", |
||||
strerror(errno)); |
||||
|
||||
if (ioctl(launcher->tty, KDSETMODE, KD_TEXT)) |
||||
weston_log("failed to set KD_TEXT mode on tty: %s\n", |
||||
strerror(errno)); |
||||
|
||||
/* We have to drop master before we switch the VT back in
|
||||
* VT_AUTO, so we don't risk switching to a VT with another |
||||
* display server, that will then fail to set drm master. */ |
||||
drmDropMaster(launcher->drm_fd); |
||||
|
||||
mode.mode = VT_AUTO; |
||||
if (ioctl(launcher->tty, VT_SETMODE, &mode) < 0) |
||||
weston_log("could not reset vt handling! error=%s\n", |
||||
strerror(errno)); |
||||
} |
||||
|
||||
static int |
||||
launcher_direct_activate_vt(struct weston_launcher *launcher_base, int vt) |
||||
{ |
||||
struct launcher_direct *launcher = wl_container_of(launcher_base, launcher, base); |
||||
return ioctl(launcher->tty, VT_ACTIVATE, vt); |
||||
} |
||||
|
||||
static int |
||||
launcher_direct_connect(struct weston_launcher **out, struct weston_compositor *compositor, |
||||
int tty, const char *seat_id, bool sync_drm) |
||||
{ |
||||
struct launcher_direct *launcher; |
||||
struct stat buf; |
||||
|
||||
launcher = zalloc(sizeof(*launcher)); |
||||
if (launcher == NULL) { |
||||
weston_log("failed to alloc for launcher\n"); |
||||
return -ENOMEM; |
||||
} |
||||
|
||||
launcher->base.iface = &launcher_direct_iface; |
||||
launcher->compositor = compositor; |
||||
|
||||
/* Checking the existance of /dev/tty0 and verifying it's a TTY
|
||||
* device, as kernels compiled with CONFIG_VT=0 do not create these |
||||
* devices. */ |
||||
if (stat("/dev/tty0", &buf) == 0 && |
||||
strcmp("seat0", seat_id) == 0 && major(buf.st_rdev) == TTY_MAJOR) { |
||||
if (setup_tty(launcher, tty) == -1) { |
||||
free(launcher); |
||||
return -1; |
||||
} |
||||
} else { |
||||
launcher->tty = -1; |
||||
} |
||||
|
||||
* (struct launcher_direct **) out = launcher; |
||||
return 0; |
||||
} |
||||
|
||||
static void |
||||
launcher_direct_destroy(struct weston_launcher *launcher_base) |
||||
{ |
||||
struct launcher_direct *launcher = wl_container_of(launcher_base, launcher, base); |
||||
|
||||
if (launcher->tty >= 0) { |
||||
launcher_direct_restore(&launcher->base); |
||||
wl_event_source_remove(launcher->vt_source); |
||||
close(launcher->tty); |
||||
} |
||||
|
||||
free(launcher); |
||||
} |
||||
|
||||
static int |
||||
launcher_direct_get_vt(struct weston_launcher *base) |
||||
{ |
||||
struct launcher_direct *launcher = wl_container_of(base, launcher, base); |
||||
struct stat s; |
||||
if (fstat(launcher->tty, &s) < 0) { |
||||
weston_log("couldn't fstat launcher tty: %s\n", strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
return minor(s.st_rdev); |
||||
} |
||||
|
||||
const struct launcher_interface launcher_direct_iface = { |
||||
.name = "direct", |
||||
.connect = launcher_direct_connect, |
||||
.destroy = launcher_direct_destroy, |
||||
.open = launcher_direct_open, |
||||
.close = launcher_direct_close, |
||||
.activate_vt = launcher_direct_activate_vt, |
||||
.get_vt = launcher_direct_get_vt, |
||||
}; |
||||
@ -1,396 +0,0 @@ |
||||
/*
|
||||
* Copyright © 2012 Benjamin Franzke |
||||
* Copyright © 2013 Intel Corporation |
||||
* |
||||
* Permission is hereby granted, free of charge, to any person obtaining |
||||
* a copy of this software and associated documentation files (the |
||||
* "Software"), to deal in the Software without restriction, including |
||||
* without limitation the rights to use, copy, modify, merge, publish, |
||||
* distribute, sublicense, and/or sell copies of the Software, and to |
||||
* permit persons to whom the Software is furnished to do so, subject to |
||||
* the following conditions: |
||||
* |
||||
* The above copyright notice and this permission notice (including the |
||||
* next paragraph) shall be included in all copies or substantial |
||||
* portions of the Software. |
||||
* |
||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, |
||||
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF |
||||
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
||||
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS |
||||
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN |
||||
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN |
||||
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE |
||||
* SOFTWARE. |
||||
*/ |
||||
|
||||
#include "config.h" |
||||
|
||||
#include <stdint.h> |
||||
#include <stdio.h> |
||||
#include <stdlib.h> |
||||
#include <string.h> |
||||
|
||||
#include <errno.h> |
||||
#include <signal.h> |
||||
#include <sys/socket.h> |
||||
#include <sys/types.h> |
||||
#include <sys/stat.h> |
||||
#include <sys/uio.h> |
||||
#include <sys/ioctl.h> |
||||
#include <fcntl.h> |
||||
#include <unistd.h> |
||||
#include <linux/vt.h> |
||||
#include <linux/kd.h> |
||||
#include <linux/major.h> |
||||
|
||||
#include <libweston/libweston.h> |
||||
#include "weston-launch.h" |
||||
#include "launcher-impl.h" |
||||
#include "shared/string-helpers.h" |
||||
|
||||
#define DRM_MAJOR 226 |
||||
|
||||
#ifndef KDSKBMUTE |
||||
#define KDSKBMUTE 0x4B51 |
||||
#endif |
||||
|
||||
#ifdef BUILD_DRM_COMPOSITOR |
||||
|
||||
#include <xf86drm.h> |
||||
|
||||
#else |
||||
|
||||
static inline int |
||||
drmDropMaster(int drm_fd) |
||||
{ |
||||
return 0; |
||||
} |
||||
|
||||
static inline int |
||||
drmSetMaster(int drm_fd) |
||||
{ |
||||
return 0; |
||||
} |
||||
|
||||
#endif |
||||
|
||||
/* major()/minor() */ |
||||
#ifdef MAJOR_IN_MKDEV |
||||
#include <sys/mkdev.h> |
||||
#endif |
||||
#ifdef MAJOR_IN_SYSMACROS |
||||
#include <sys/sysmacros.h> |
||||
#endif |
||||
|
||||
union cmsg_data { unsigned char b[4]; int fd; }; |
||||
|
||||
struct launcher_weston_launch { |
||||
struct weston_launcher base; |
||||
struct weston_compositor *compositor; |
||||
int fd; |
||||
struct wl_event_source *source; |
||||
|
||||
int kb_mode, tty, drm_fd; |
||||
int deferred_deactivate; |
||||
}; |
||||
|
||||
static ssize_t |
||||
launcher_weston_launch_send(int sockfd, void *buf, size_t buflen) |
||||
{ |
||||
ssize_t len; |
||||
|
||||
do { |
||||
len = send(sockfd, buf, buflen, 0); |
||||
} while (len < 0 && errno == EINTR); |
||||
|
||||
return len; |
||||
} |
||||
|
||||
static void |
||||
handle_deactivate(struct launcher_weston_launch *launcher) |
||||
{ |
||||
int reply; |
||||
|
||||
launcher->compositor->session_active = false; |
||||
wl_signal_emit(&launcher->compositor->session_signal, |
||||
launcher->compositor); |
||||
|
||||
reply = WESTON_LAUNCHER_DEACTIVATE_DONE; |
||||
launcher_weston_launch_send(launcher->fd, &reply, sizeof reply); |
||||
} |
||||
|
||||
static void |
||||
idle_deactivate(void *data) |
||||
{ |
||||
struct launcher_weston_launch *launcher = data; |
||||
|
||||
if (launcher->deferred_deactivate) { |
||||
launcher->deferred_deactivate = 0; |
||||
handle_deactivate((struct launcher_weston_launch*)data); |
||||
} |
||||
} |
||||
|
||||
static int |
||||
launcher_weston_launch_open(struct weston_launcher *launcher_base, |
||||
const char *path, int flags) |
||||
{ |
||||
struct launcher_weston_launch *launcher = wl_container_of(launcher_base, launcher, base); |
||||
int n; |
||||
struct msghdr msg; |
||||
struct cmsghdr *cmsg; |
||||
struct iovec iov; |
||||
union cmsg_data *data; |
||||
char control[CMSG_SPACE(sizeof data->fd)]; |
||||
ssize_t len; |
||||
struct weston_launcher_open *message; |
||||
struct { int id; int ret; } event; |
||||
|
||||
n = sizeof(*message) + strlen(path) + 1; |
||||
message = malloc(n); |
||||
if (!message) |
||||
return -1; |
||||
|
||||
message->header.opcode = WESTON_LAUNCHER_OPEN; |
||||
message->flags = flags; |
||||
strcpy(message->path, path); |
||||
|
||||
launcher_weston_launch_send(launcher->fd, message, n); |
||||
free(message); |
||||
|
||||
memset(&msg, 0, sizeof msg); |
||||
iov.iov_base = &event; |
||||
iov.iov_len = sizeof event; |
||||
msg.msg_iov = &iov; |
||||
msg.msg_iovlen = 1; |
||||
msg.msg_control = control; |
||||
|
||||
while (1) { |
||||
msg.msg_controllen = sizeof control; |
||||
|
||||
do { |
||||
len = recvmsg(launcher->fd, &msg, MSG_CMSG_CLOEXEC); |
||||
} while (len < 0 && errno == EINTR); |
||||
|
||||
// Only OPEN_REPLY and up to one DEACTIVATE message should be possible here
|
||||
if ((len == sizeof event) && (event.id == WESTON_LAUNCHER_OPEN_REPLY)) |
||||
break; |
||||
|
||||
if ((len == sizeof event.id) && (event.id == WESTON_LAUNCHER_DEACTIVATE) && (launcher->deferred_deactivate == 0)) { |
||||
wl_event_loop_add_idle(wl_display_get_event_loop(launcher->compositor->wl_display), idle_deactivate, launcher); |
||||
launcher->deferred_deactivate = 1; |
||||
} else { |
||||
weston_log("unexpected event %d (len=%zd) from weston-launch\n", event.id, len); |
||||
return -1; |
||||
} |
||||
} |
||||
|
||||
if (event.ret < 0) |
||||
return -1; |
||||
|
||||
cmsg = CMSG_FIRSTHDR(&msg); |
||||
if (!cmsg || |
||||
cmsg->cmsg_level != SOL_SOCKET || |
||||
cmsg->cmsg_type != SCM_RIGHTS) { |
||||
fprintf(stderr, "invalid control message\n"); |
||||
return -1; |
||||
} |
||||
|
||||
data = (union cmsg_data *) CMSG_DATA(cmsg); |
||||
if (data->fd == -1) { |
||||
fprintf(stderr, "missing drm fd in socket request\n"); |
||||
return -1; |
||||
} |
||||
|
||||
return data->fd; |
||||
} |
||||
|
||||
static void |
||||
launcher_weston_launch_close(struct weston_launcher *launcher_base, int fd) |
||||
{ |
||||
close(fd); |
||||
} |
||||
|
||||
static void |
||||
launcher_weston_launch_restore(struct weston_launcher *launcher_base) |
||||
{ |
||||
struct launcher_weston_launch *launcher = wl_container_of(launcher_base, launcher, base); |
||||
struct vt_mode mode = { 0 }; |
||||
|
||||
if (ioctl(launcher->tty, KDSKBMUTE, 0) && |
||||
ioctl(launcher->tty, KDSKBMODE, launcher->kb_mode)) |
||||
weston_log("failed to restore kb mode: %s\n", |
||||
strerror(errno)); |
||||
|
||||
if (ioctl(launcher->tty, KDSETMODE, KD_TEXT)) |
||||
weston_log("failed to set KD_TEXT mode on tty: %s\n", |
||||
strerror(errno)); |
||||
|
||||
/* We have to drop master before we switch the VT back in
|
||||
* VT_AUTO, so we don't risk switching to a VT with another |
||||
* display server, that will then fail to set drm master. */ |
||||
drmDropMaster(launcher->drm_fd); |
||||
|
||||
mode.mode = VT_AUTO; |
||||
if (ioctl(launcher->tty, VT_SETMODE, &mode) < 0) |
||||
weston_log("could not reset vt handling\n"); |
||||
} |
||||
|
||||
static int |
||||
launcher_weston_launch_data(int fd, uint32_t mask, void *data) |
||||
{ |
||||
struct launcher_weston_launch *launcher = data; |
||||
int len, ret; |
||||
|
||||
if (mask & (WL_EVENT_HANGUP | WL_EVENT_ERROR)) { |
||||
weston_log("launcher socket closed, exiting\n"); |
||||
/* Normally the weston-launch will reset the tty, but
|
||||
* in this case it died or something, so do it here so |
||||
* we don't end up with a stuck vt. */ |
||||
launcher_weston_launch_restore(&launcher->base); |
||||
exit(-1); |
||||
} |
||||
|
||||
if (launcher->deferred_deactivate) { |
||||
launcher->deferred_deactivate = 0; |
||||
handle_deactivate(launcher); |
||||
return 1; |
||||
} |
||||
|
||||
do { |
||||
len = recv(launcher->fd, &ret, sizeof ret, 0); |
||||
} while (len < 0 && errno == EINTR); |
||||
|
||||
switch (ret) { |
||||
case WESTON_LAUNCHER_ACTIVATE: |
||||
launcher->compositor->session_active = true; |
||||
wl_signal_emit(&launcher->compositor->session_signal, |
||||
launcher->compositor); |
||||
break; |
||||
case WESTON_LAUNCHER_DEACTIVATE: |
||||
handle_deactivate(launcher); |
||||
break; |
||||
default: |
||||
weston_log("unexpected event from weston-launch\n"); |
||||
break; |
||||
} |
||||
|
||||
return 1; |
||||
} |
||||
|
||||
static int |
||||
launcher_weston_launch_activate_vt(struct weston_launcher *launcher_base, int vt) |
||||
{ |
||||
struct launcher_weston_launch *launcher = wl_container_of(launcher_base, launcher, base); |
||||
return ioctl(launcher->tty, VT_ACTIVATE, vt); |
||||
} |
||||
|
||||
static int |
||||
launcher_weston_environment_get_fd(const char *env) |
||||
{ |
||||
char *e; |
||||
int fd, flags; |
||||
|
||||
e = getenv(env); |
||||
if (!e || !safe_strtoint(e, &fd)) { |
||||
weston_log("could not get launcher fd from env\n"); |
||||
return -1; |
||||
} |
||||
|
||||
flags = fcntl(fd, F_GETFD); |
||||
if (flags == -1) { |
||||
weston_log("could not get fd flags!, env: %s, error: %s\n", |
||||
env, strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
fcntl(fd, F_SETFD, flags | FD_CLOEXEC); |
||||
unsetenv(env); |
||||
|
||||
return fd; |
||||
} |
||||
|
||||
|
||||
static int |
||||
launcher_weston_launch_connect(struct weston_launcher **out, struct weston_compositor *compositor, |
||||
int tty, const char *seat_id, bool sync_drm) |
||||
{ |
||||
struct launcher_weston_launch *launcher; |
||||
struct wl_event_loop *loop; |
||||
|
||||
launcher = malloc(sizeof *launcher); |
||||
if (launcher == NULL) |
||||
return -ENOMEM; |
||||
|
||||
launcher->base.iface = &launcher_weston_launch_iface; |
||||
launcher->compositor = compositor; |
||||
launcher->drm_fd = -1; |
||||
launcher->deferred_deactivate = 0; |
||||
launcher->fd = launcher_weston_environment_get_fd("WESTON_LAUNCHER_SOCK"); |
||||
if (launcher->fd == -1) { |
||||
free(launcher); |
||||
return -1; |
||||
} |
||||
|
||||
launcher->tty = launcher_weston_environment_get_fd("WESTON_TTY_FD"); |
||||
/* We don't get a chance to read out the original kb
|
||||
* mode for the tty, so just hard code K_UNICODE here |
||||
* in case we have to clean if weston-launch dies. */ |
||||
launcher->kb_mode = K_UNICODE; |
||||
|
||||
loop = wl_display_get_event_loop(compositor->wl_display); |
||||
launcher->source = wl_event_loop_add_fd(loop, launcher->fd, |
||||
WL_EVENT_READABLE, |
||||
launcher_weston_launch_data, |
||||
launcher); |
||||
if (launcher->source == NULL) { |
||||
free(launcher); |
||||
weston_log("failed to get weston-launcher socket fd event source\n"); |
||||
return -ENOMEM; |
||||
} |
||||
|
||||
* (struct launcher_weston_launch **) out = launcher; |
||||
|
||||
return 0; |
||||
} |
||||
|
||||
static void |
||||
launcher_weston_launch_destroy(struct weston_launcher *launcher_base) |
||||
{ |
||||
struct launcher_weston_launch *launcher = wl_container_of(launcher_base, launcher, base); |
||||
|
||||
if (launcher->fd != -1) { |
||||
close(launcher->fd); |
||||
wl_event_source_remove(launcher->source); |
||||
} else { |
||||
launcher_weston_launch_restore(&launcher->base); |
||||
} |
||||
|
||||
if (launcher->tty >= 0) |
||||
close(launcher->tty); |
||||
|
||||
free(launcher); |
||||
} |
||||
|
||||
static int |
||||
launcher_weston_launch_get_vt(struct weston_launcher *base) |
||||
{ |
||||
struct launcher_weston_launch *launcher = wl_container_of(base, launcher, base); |
||||
struct stat s; |
||||
if (fstat(launcher->tty, &s) < 0) { |
||||
weston_log("could not fstat launcher tty: %s\n", strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
return minor(s.st_rdev); |
||||
} |
||||
|
||||
const struct launcher_interface launcher_weston_launch_iface = { |
||||
.name = "weston_launch", |
||||
.connect = launcher_weston_launch_connect, |
||||
.destroy = launcher_weston_launch_destroy, |
||||
.open = launcher_weston_launch_open, |
||||
.close = launcher_weston_launch_close, |
||||
.activate_vt = launcher_weston_launch_activate_vt, |
||||
.get_vt = launcher_weston_launch_get_vt, |
||||
}; |
||||
@ -1,917 +0,0 @@ |
||||
/*
|
||||
* Copyright © 2012 Benjamin Franzke |
||||
* |
||||
* Permission is hereby granted, free of charge, to any person obtaining |
||||
* a copy of this software and associated documentation files (the |
||||
* "Software"), to deal in the Software without restriction, including |
||||
* without limitation the rights to use, copy, modify, merge, publish, |
||||
* distribute, sublicense, and/or sell copies of the Software, and to |
||||
* permit persons to whom the Software is furnished to do so, subject to |
||||
* the following conditions: |
||||
* |
||||
* The above copyright notice and this permission notice (including the |
||||
* next paragraph) shall be included in all copies or substantial |
||||
* portions of the Software. |
||||
* |
||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, |
||||
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF |
||||
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
||||
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS |
||||
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN |
||||
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN |
||||
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE |
||||
* SOFTWARE. |
||||
*/ |
||||
|
||||
#include "config.h" |
||||
|
||||
#include <stdbool.h> |
||||
#include <stdio.h> |
||||
#include <stdlib.h> |
||||
#include <string.h> |
||||
#include <assert.h> |
||||
#include <poll.h> |
||||
#include <errno.h> |
||||
|
||||
#include <getopt.h> |
||||
|
||||
#include <sys/types.h> |
||||
#include <sys/ioctl.h> |
||||
#include <sys/stat.h> |
||||
#include <sys/wait.h> |
||||
#include <sys/socket.h> |
||||
#include <sys/signalfd.h> |
||||
#include <signal.h> |
||||
#include <unistd.h> |
||||
#include <fcntl.h> |
||||
|
||||
#include <linux/vt.h> |
||||
#include <linux/major.h> |
||||
#include <linux/kd.h> |
||||
|
||||
#include <pwd.h> |
||||
#include <grp.h> |
||||
#include <security/pam_appl.h> |
||||
|
||||
#ifdef HAVE_SYSTEMD_LOGIN |
||||
#include <systemd/sd-login.h> |
||||
#endif |
||||
|
||||
#include "weston-launch.h" |
||||
|
||||
#define DRM_MAJOR 226 |
||||
|
||||
#ifndef KDSKBMUTE |
||||
#define KDSKBMUTE 0x4B51 |
||||
#endif |
||||
|
||||
#ifndef EVIOCREVOKE |
||||
#define EVIOCREVOKE _IOW('E', 0x91, int) |
||||
#endif |
||||
|
||||
#define MAX_ARGV_SIZE 256 |
||||
|
||||
#ifdef BUILD_DRM_COMPOSITOR |
||||
|
||||
#include <xf86drm.h> |
||||
|
||||
#else |
||||
|
||||
static inline int |
||||
drmDropMaster(int drm_fd) |
||||
{ |
||||
return 0; |
||||
} |
||||
|
||||
static inline int |
||||
drmSetMaster(int drm_fd) |
||||
{ |
||||
return 0; |
||||
} |
||||
|
||||
#endif |
||||
|
||||
/* major()/minor() */ |
||||
#ifdef MAJOR_IN_MKDEV |
||||
# include <sys/mkdev.h> |
||||
#endif |
||||
#ifdef MAJOR_IN_SYSMACROS |
||||
# include <sys/sysmacros.h> |
||||
#endif |
||||
|
||||
struct weston_launch { |
||||
struct pam_conv pc; |
||||
pam_handle_t *ph; |
||||
int tty; |
||||
int ttynr; |
||||
int sock[2]; |
||||
int drm_fd; |
||||
int last_input_fd; |
||||
int kb_mode; |
||||
struct passwd *pw; |
||||
|
||||
int signalfd; |
||||
|
||||
pid_t child; |
||||
int verbose; |
||||
char *new_user; |
||||
}; |
||||
|
||||
union cmsg_data { unsigned char b[4]; int fd; }; |
||||
|
||||
static gid_t * |
||||
read_groups(int *ngroups) |
||||
{ |
||||
int n; |
||||
gid_t *groups; |
||||
|
||||
n = getgroups(0, NULL); |
||||
|
||||
if (n < 0) { |
||||
fprintf(stderr, "Unable to retrieve groups: %s\n", |
||||
strerror(errno)); |
||||
return NULL; |
||||
} |
||||
|
||||
groups = malloc(n * sizeof(gid_t)); |
||||
if (!groups) |
||||
return NULL; |
||||
|
||||
if (getgroups(n, groups) < 0) { |
||||
fprintf(stderr, "Unable to retrieve groups: %s\n", |
||||
strerror(errno)); |
||||
free(groups); |
||||
return NULL; |
||||
} |
||||
|
||||
*ngroups = n; |
||||
return groups; |
||||
} |
||||
|
||||
static bool |
||||
weston_launch_allowed(struct weston_launch *wl) |
||||
{ |
||||
struct group *gr; |
||||
gid_t *groups; |
||||
int ngroups; |
||||
#ifdef HAVE_SYSTEMD_LOGIN |
||||
char *session, *seat; |
||||
int err; |
||||
#endif |
||||
|
||||
if (getuid() == 0) |
||||
return true; |
||||
|
||||
gr = getgrnam("weston-launch"); |
||||
if (gr) { |
||||
groups = read_groups(&ngroups); |
||||
if (groups && ngroups > 0) { |
||||
while (ngroups--) { |
||||
if (groups[ngroups] == gr->gr_gid) { |
||||
free(groups); |
||||
return true; |
||||
} |
||||
} |
||||
free(groups); |
||||
} |
||||
} |
||||
|
||||
#ifdef HAVE_SYSTEMD_LOGIN |
||||
err = sd_pid_get_session(getpid(), &session); |
||||
if (err == 0 && session) { |
||||
if (sd_session_is_active(session) && |
||||
sd_session_get_seat(session, &seat) == 0) { |
||||
free(seat); |
||||
free(session); |
||||
return true; |
||||
} |
||||
free(session); |
||||
} |
||||
#endif |
||||
|
||||
return false; |
||||
} |
||||
|
||||
static int |
||||
pam_conversation_fn(int msg_count, |
||||
const struct pam_message **messages, |
||||
struct pam_response **responses, |
||||
void *user_data) |
||||
{ |
||||
return PAM_SUCCESS; |
||||
} |
||||
|
||||
static int |
||||
setup_pam(struct weston_launch *wl) |
||||
{ |
||||
int err; |
||||
|
||||
wl->pc.conv = pam_conversation_fn; |
||||
wl->pc.appdata_ptr = wl; |
||||
|
||||
err = pam_start("login", wl->pw->pw_name, &wl->pc, &wl->ph); |
||||
if (err != PAM_SUCCESS) { |
||||
fprintf(stderr, "failed to start pam transaction: %d: %s\n", |
||||
err, pam_strerror(wl->ph, err)); |
||||
return -1; |
||||
} |
||||
|
||||
err = pam_set_item(wl->ph, PAM_TTY, ttyname(wl->tty)); |
||||
if (err != PAM_SUCCESS) { |
||||
fprintf(stderr, "failed to set PAM_TTY item: %d: %s\n", |
||||
err, pam_strerror(wl->ph, err)); |
||||
return -1; |
||||
} |
||||
|
||||
err = pam_open_session(wl->ph, 0); |
||||
if (err != PAM_SUCCESS) { |
||||
fprintf(stderr, "failed to open pam session: %d: %s\n", |
||||
err, pam_strerror(wl->ph, err)); |
||||
return -1; |
||||
} |
||||
|
||||
return 0; |
||||
} |
||||
|
||||
static int |
||||
setup_launcher_socket(struct weston_launch *wl) |
||||
{ |
||||
if (socketpair(AF_LOCAL, SOCK_SEQPACKET, 0, wl->sock) < 0) { |
||||
fprintf(stderr, "weston: socketpair failed: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (fcntl(wl->sock[0], F_SETFD, FD_CLOEXEC) < 0) { |
||||
fprintf(stderr, "weston: fcntl failed: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
return 0; |
||||
} |
||||
|
||||
static int |
||||
setup_signals(struct weston_launch *wl) |
||||
{ |
||||
int ret; |
||||
sigset_t mask; |
||||
struct sigaction sa; |
||||
|
||||
memset(&sa, 0, sizeof sa); |
||||
sa.sa_handler = SIG_DFL; |
||||
sa.sa_flags = SA_NOCLDSTOP | SA_RESTART; |
||||
ret = sigaction(SIGCHLD, &sa, NULL); |
||||
assert(ret == 0); |
||||
|
||||
sa.sa_handler = SIG_IGN; |
||||
sa.sa_flags = 0; |
||||
sigaction(SIGHUP, &sa, NULL); |
||||
|
||||
ret = sigemptyset(&mask); |
||||
assert(ret == 0); |
||||
sigaddset(&mask, SIGCHLD); |
||||
sigaddset(&mask, SIGINT); |
||||
sigaddset(&mask, SIGTERM); |
||||
sigaddset(&mask, SIGUSR1); |
||||
sigaddset(&mask, SIGUSR2); |
||||
ret = sigprocmask(SIG_BLOCK, &mask, NULL); |
||||
assert(ret == 0); |
||||
|
||||
wl->signalfd = signalfd(-1, &mask, SFD_NONBLOCK | SFD_CLOEXEC); |
||||
if (wl->signalfd < 0) |
||||
return -errno; |
||||
|
||||
return 0; |
||||
} |
||||
|
||||
static void |
||||
setenv_fd(const char *env, int fd) |
||||
{ |
||||
char buf[32]; |
||||
|
||||
snprintf(buf, sizeof buf, "%d", fd); |
||||
setenv(env, buf, 1); |
||||
} |
||||
|
||||
static int |
||||
open_tty_by_number(int ttynr) |
||||
{ |
||||
int ret; |
||||
char filename[16]; |
||||
|
||||
ret = snprintf(filename, sizeof filename, "/dev/tty%d", ttynr); |
||||
if (ret < 0) |
||||
return -1; |
||||
|
||||
return open(filename, O_RDWR | O_NOCTTY); |
||||
} |
||||
|
||||
static int |
||||
send_reply(struct weston_launch *wl, int reply) |
||||
{ |
||||
int len; |
||||
|
||||
do { |
||||
len = send(wl->sock[0], &reply, sizeof reply, 0); |
||||
} while (len < 0 && errno == EINTR); |
||||
|
||||
return len; |
||||
} |
||||
|
||||
static int |
||||
handle_open(struct weston_launch *wl, struct msghdr *msg, ssize_t len) |
||||
{ |
||||
int fd = -1, ret = -1; |
||||
char control[CMSG_SPACE(sizeof(fd))]; |
||||
struct cmsghdr *cmsg; |
||||
struct stat s; |
||||
struct msghdr nmsg; |
||||
struct iovec iov; |
||||
struct weston_launcher_open *message; |
||||
union cmsg_data *data; |
||||
|
||||
message = msg->msg_iov->iov_base; |
||||
if ((size_t)len < sizeof(*message)) |
||||
goto err0; |
||||
|
||||
/* Ensure path is null-terminated */ |
||||
((char *) message)[len-1] = '\0'; |
||||
|
||||
fd = open(message->path, message->flags); |
||||
if (fd < 0) { |
||||
fprintf(stderr, "Error opening device %s: %s\n", |
||||
message->path, strerror(errno)); |
||||
goto err0; |
||||
} |
||||
|
||||
if (fstat(fd, &s) < 0) { |
||||
close(fd); |
||||
fd = -1; |
||||
fprintf(stderr, "Failed to stat %s\n", message->path); |
||||
goto err0; |
||||
} |
||||
|
||||
if (major(s.st_rdev) != INPUT_MAJOR && |
||||
major(s.st_rdev) != DRM_MAJOR) { |
||||
close(fd); |
||||
fd = -1; |
||||
fprintf(stderr, "Device %s is not an input or drm device\n", |
||||
message->path); |
||||
goto err0; |
||||
} |
||||
|
||||
err0: |
||||
memset(&nmsg, 0, sizeof nmsg); |
||||
nmsg.msg_iov = &iov; |
||||
nmsg.msg_iovlen = 1; |
||||
if (fd != -1) { |
||||
nmsg.msg_control = control; |
||||
nmsg.msg_controllen = sizeof control; |
||||
cmsg = CMSG_FIRSTHDR(&nmsg); |
||||
cmsg->cmsg_level = SOL_SOCKET; |
||||
cmsg->cmsg_type = SCM_RIGHTS; |
||||
cmsg->cmsg_len = CMSG_LEN(sizeof(fd)); |
||||
data = (union cmsg_data *) CMSG_DATA(cmsg); |
||||
data->fd = fd; |
||||
nmsg.msg_controllen = cmsg->cmsg_len; |
||||
ret = 0; |
||||
} |
||||
struct { int reply_id; int ret; } reply_iov_data = { WESTON_LAUNCHER_OPEN_REPLY, ret }; |
||||
iov.iov_base = &reply_iov_data; |
||||
iov.iov_len = sizeof reply_iov_data; |
||||
|
||||
if (wl->verbose) |
||||
fprintf(stderr, "weston-launch: opened %s: ret: %d, fd: %d\n", |
||||
message->path, ret, fd); |
||||
do { |
||||
len = sendmsg(wl->sock[0], &nmsg, 0); |
||||
} while (len < 0 && errno == EINTR); |
||||
|
||||
if (len < 0) |
||||
return -1; |
||||
|
||||
if (fd != -1 && major(s.st_rdev) == DRM_MAJOR) |
||||
wl->drm_fd = fd; |
||||
if (fd != -1 && major(s.st_rdev) == INPUT_MAJOR && |
||||
wl->last_input_fd < fd) |
||||
wl->last_input_fd = fd; |
||||
|
||||
return 0; |
||||
} |
||||
|
||||
static void |
||||
close_input_fds(struct weston_launch *wl) |
||||
{ |
||||
struct stat s; |
||||
int fd; |
||||
|
||||
for (fd = 3; fd <= wl->last_input_fd; fd++) { |
||||
if (fstat(fd, &s) == 0 && major(s.st_rdev) == INPUT_MAJOR) { |
||||
/* EVIOCREVOKE may fail if the kernel doesn't
|
||||
* support it, but all we can do is ignore it. */ |
||||
ioctl(fd, EVIOCREVOKE, 0); |
||||
close(fd); |
||||
} |
||||
} |
||||
} |
||||
|
||||
static int |
||||
handle_socket_msg(struct weston_launch *wl) |
||||
{ |
||||
char control[CMSG_SPACE(sizeof(int))]; |
||||
char buf[BUFSIZ]; |
||||
struct msghdr msg; |
||||
struct iovec iov; |
||||
int ret = -1; |
||||
ssize_t len; |
||||
struct weston_launcher_message *message; |
||||
|
||||
memset(&msg, 0, sizeof(msg)); |
||||
iov.iov_base = buf; |
||||
iov.iov_len = sizeof buf; |
||||
msg.msg_iov = &iov; |
||||
msg.msg_iovlen = 1; |
||||
msg.msg_control = control; |
||||
msg.msg_controllen = sizeof control; |
||||
|
||||
do { |
||||
len = recvmsg(wl->sock[0], &msg, 0); |
||||
} while (len < 0 && errno == EINTR); |
||||
|
||||
if (len < 1) |
||||
return -1; |
||||
|
||||
message = (void *) buf; |
||||
switch (message->opcode) { |
||||
case WESTON_LAUNCHER_OPEN: |
||||
ret = handle_open(wl, &msg, len); |
||||
break; |
||||
case WESTON_LAUNCHER_DEACTIVATE_DONE: |
||||
close_input_fds(wl); |
||||
drmDropMaster(wl->drm_fd); |
||||
ioctl(wl->tty, VT_RELDISP, 1); |
||||
break; |
||||
} |
||||
|
||||
return ret; |
||||
} |
||||
|
||||
static void |
||||
quit(struct weston_launch *wl, int status) |
||||
{ |
||||
struct vt_mode mode = { 0 }; |
||||
int err; |
||||
int oldtty; |
||||
|
||||
close(wl->signalfd); |
||||
close(wl->sock[0]); |
||||
|
||||
if (wl->new_user) { |
||||
err = pam_close_session(wl->ph, 0); |
||||
if (err) |
||||
fprintf(stderr, "pam_close_session failed: %d: %s\n", |
||||
err, pam_strerror(wl->ph, err)); |
||||
pam_end(wl->ph, err); |
||||
} |
||||
|
||||
/*
|
||||
* Get a fresh handle to the tty as the previous one is in |
||||
* hang-up state since weston (the controlling process for |
||||
* the tty) exit at this point. Reopen before closing the |
||||
* file descriptor to avoid a potential race condition. |
||||
* |
||||
* A similar fix exists in logind, see: |
||||
* https://github.com/systemd/systemd/pull/990
|
||||
*/ |
||||
oldtty = wl->tty; |
||||
wl->tty = open_tty_by_number(wl->ttynr); |
||||
close(oldtty); |
||||
|
||||
if (ioctl(wl->tty, KDSKBMUTE, 0) && |
||||
ioctl(wl->tty, KDSKBMODE, wl->kb_mode)) |
||||
fprintf(stderr, "failed to restore keyboard mode: %s\n", |
||||
strerror(errno)); |
||||
|
||||
if (ioctl(wl->tty, KDSETMODE, KD_TEXT)) |
||||
fprintf(stderr, "failed to set KD_TEXT mode on tty: %s\n", |
||||
strerror(errno)); |
||||
|
||||
/* We have to drop master before we switch the VT back in
|
||||
* VT_AUTO, so we don't risk switching to a VT with another |
||||
* display server, that will then fail to set drm master. */ |
||||
drmDropMaster(wl->drm_fd); |
||||
|
||||
mode.mode = VT_AUTO; |
||||
if (ioctl(wl->tty, VT_SETMODE, &mode) < 0) |
||||
fprintf(stderr, "could not reset vt handling\n"); |
||||
|
||||
if (wl->tty != STDIN_FILENO) |
||||
close(wl->tty); |
||||
|
||||
exit(status); |
||||
} |
||||
|
||||
static int |
||||
handle_signal(struct weston_launch *wl) |
||||
{ |
||||
struct signalfd_siginfo sig; |
||||
int pid, status, ret; |
||||
|
||||
if (read(wl->signalfd, &sig, sizeof sig) != sizeof sig) { |
||||
fprintf(stderr, "weston: reading signalfd failed: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
switch (sig.ssi_signo) { |
||||
case SIGCHLD: |
||||
pid = waitpid(-1, &status, 0); |
||||
if (pid == wl->child) { |
||||
wl->child = 0; |
||||
if (WIFEXITED(status)) |
||||
ret = WEXITSTATUS(status); |
||||
else if (WIFSIGNALED(status)) |
||||
/*
|
||||
* If weston dies because of signal N, we |
||||
* return 10+N. This is distinct from |
||||
* weston-launch dying because of a signal |
||||
* (128+N). |
||||
*/ |
||||
ret = 10 + WTERMSIG(status); |
||||
else |
||||
ret = 0; |
||||
quit(wl, ret); |
||||
} |
||||
break; |
||||
case SIGTERM: |
||||
case SIGINT: |
||||
if (!wl->child) |
||||
break; |
||||
|
||||
if (wl->verbose) |
||||
fprintf(stderr, "weston-launch: sending %s to pid %d\n", |
||||
strsignal(sig.ssi_signo), wl->child); |
||||
|
||||
kill(wl->child, sig.ssi_signo); |
||||
break; |
||||
case SIGUSR1: |
||||
send_reply(wl, WESTON_LAUNCHER_DEACTIVATE); |
||||
break; |
||||
case SIGUSR2: |
||||
ioctl(wl->tty, VT_RELDISP, VT_ACKACQ); |
||||
drmSetMaster(wl->drm_fd); |
||||
send_reply(wl, WESTON_LAUNCHER_ACTIVATE); |
||||
break; |
||||
default: |
||||
return -1; |
||||
} |
||||
|
||||
return 0; |
||||
} |
||||
|
||||
static int |
||||
setup_tty(struct weston_launch *wl, const char *tty) |
||||
{ |
||||
struct stat buf; |
||||
struct vt_mode mode = { 0 }; |
||||
char *t; |
||||
|
||||
if (!wl->new_user) { |
||||
wl->tty = STDIN_FILENO; |
||||
} else if (tty) { |
||||
t = ttyname(STDIN_FILENO); |
||||
if (t && strcmp(t, tty) == 0) |
||||
wl->tty = STDIN_FILENO; |
||||
else |
||||
wl->tty = open(tty, O_RDWR | O_NOCTTY); |
||||
} else { |
||||
int tty0 = open("/dev/tty0", O_WRONLY | O_CLOEXEC); |
||||
|
||||
if (tty0 < 0) { |
||||
fprintf(stderr, "weston: could not open tty0: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (ioctl(tty0, VT_OPENQRY, &wl->ttynr) < 0 || wl->ttynr == -1) |
||||
{ |
||||
fprintf(stderr, "weston: failed to find non-opened console: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
wl->tty = open_tty_by_number(wl->ttynr); |
||||
close(tty0); |
||||
} |
||||
|
||||
if (wl->tty < 0) { |
||||
fprintf(stderr, "weston: failed to open tty: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (fstat(wl->tty, &buf) == -1 || |
||||
major(buf.st_rdev) != TTY_MAJOR || minor(buf.st_rdev) == 0) { |
||||
fprintf(stderr, "weston: weston-launch must be run from a virtual terminal\n"); |
||||
return -1; |
||||
} |
||||
|
||||
if (!wl->new_user || tty) { |
||||
if (fstat(wl->tty, &buf) < 0) { |
||||
fprintf(stderr, "weston: stat %s failed: %s\n", tty, |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (major(buf.st_rdev) != TTY_MAJOR) { |
||||
fprintf(stderr, |
||||
"weston: invalid tty device: %s\n", tty); |
||||
return -1; |
||||
} |
||||
|
||||
wl->ttynr = minor(buf.st_rdev); |
||||
} |
||||
|
||||
if (ioctl(wl->tty, VT_ACTIVATE, wl->ttynr) < 0) { |
||||
fprintf(stderr, |
||||
"weston: failed to activate VT: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (ioctl(wl->tty, VT_WAITACTIVE, wl->ttynr) < 0) { |
||||
fprintf(stderr, |
||||
"weston: failed to wait for VT to be active: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (ioctl(wl->tty, KDGKBMODE, &wl->kb_mode)) { |
||||
fprintf(stderr, |
||||
"weston: failed to get current keyboard mode: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (ioctl(wl->tty, KDSKBMUTE, 1) && |
||||
ioctl(wl->tty, KDSKBMODE, K_OFF)) { |
||||
fprintf(stderr, |
||||
"weston: failed to set K_OFF keyboard mode: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
if (ioctl(wl->tty, KDSETMODE, KD_GRAPHICS)) { |
||||
fprintf(stderr, |
||||
"weston: failed to set KD_GRAPHICS mode on tty: %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
mode.mode = VT_PROCESS; |
||||
mode.relsig = SIGUSR1; |
||||
mode.acqsig = SIGUSR2; |
||||
if (ioctl(wl->tty, VT_SETMODE, &mode) < 0) { |
||||
fprintf(stderr, |
||||
"weston: failed to take control of vt handling %s\n", |
||||
strerror(errno)); |
||||
return -1; |
||||
} |
||||
|
||||
return 0; |
||||
} |
||||
|
||||
static int |
||||
setup_session(struct weston_launch *wl, char **child_argv) |
||||
{ |
||||
char **env; |
||||
char *term; |
||||
int i; |
||||
|
||||
if (wl->tty != STDIN_FILENO) { |
||||
if (setsid() < 0) { |
||||
fprintf(stderr, "weston: setsid failed %s\n", |
||||
strerror(errno)); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
if (ioctl(wl->tty, TIOCSCTTY, 0) < 0) { |
||||
fprintf(stderr, "TIOCSCTTY failed - tty is in use %s\n", |
||||
strerror(errno)); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
} |
||||
|
||||
term = getenv("TERM"); |
||||
clearenv(); |
||||
if (term) |
||||
setenv("TERM", term, 1); |
||||
setenv("USER", wl->pw->pw_name, 1); |
||||
setenv("LOGNAME", wl->pw->pw_name, 1); |
||||
setenv("HOME", wl->pw->pw_dir, 1); |
||||
setenv("SHELL", wl->pw->pw_shell, 1); |
||||
|
||||
env = pam_getenvlist(wl->ph); |
||||
if (env) { |
||||
for (i = 0; env[i]; ++i) { |
||||
if (putenv(env[i]) != 0) |
||||
fprintf(stderr, "putenv %s failed\n", env[i]); |
||||
} |
||||
free(env); |
||||
} |
||||
|
||||
/*
|
||||
* We open a new session, so it makes sense |
||||
* to run a new login shell |
||||
*/ |
||||
child_argv[0] = "/bin/sh"; |
||||
child_argv[1] = "-l"; |
||||
child_argv[2] = "-c"; |
||||
child_argv[3] = "exec " BINDIR "/weston \"$@\""; |
||||
child_argv[4] = "weston"; |
||||
return 5; |
||||
} |
||||
|
||||
static void |
||||
drop_privileges(struct weston_launch *wl) |
||||
{ |
||||
if (setgid(wl->pw->pw_gid) < 0 || |
||||
#ifdef HAVE_INITGROUPS |
||||
initgroups(wl->pw->pw_name, wl->pw->pw_gid) < 0 || |
||||
#endif |
||||
setuid(wl->pw->pw_uid) < 0) { |
||||
fprintf(stderr, "weston: dropping privileges failed %s\n", |
||||
strerror(errno)); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
} |
||||
|
||||
static void |
||||
launch_compositor(struct weston_launch *wl, int argc, char *argv[]) |
||||
{ |
||||
char *child_argv[MAX_ARGV_SIZE]; |
||||
sigset_t mask; |
||||
int o, i; |
||||
|
||||
if (wl->verbose) |
||||
printf("weston-launch: spawned weston with pid: %d\n", getpid()); |
||||
if (wl->new_user) { |
||||
o = setup_session(wl, child_argv); |
||||
} else { |
||||
child_argv[0] = BINDIR "/weston"; |
||||
o = 1; |
||||
} |
||||
for (i = 0; i < argc; ++i) |
||||
child_argv[o + i] = argv[i]; |
||||
child_argv[o + i] = NULL; |
||||
|
||||
if (geteuid() == 0) |
||||
drop_privileges(wl); |
||||
|
||||
setenv_fd("WESTON_TTY_FD", wl->tty); |
||||
setenv_fd("WESTON_LAUNCHER_SOCK", wl->sock[1]); |
||||
|
||||
unsetenv("DISPLAY"); |
||||
|
||||
/* Do not give our signal mask to the new process. */ |
||||
sigemptyset(&mask); |
||||
sigaddset(&mask, SIGTERM); |
||||
sigaddset(&mask, SIGCHLD); |
||||
sigaddset(&mask, SIGINT); |
||||
sigprocmask(SIG_UNBLOCK, &mask, NULL); |
||||
|
||||
|
||||
execv(child_argv[0], child_argv); |
||||
fprintf(stderr, "weston: exec failed: %s\n", strerror(errno)); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
|
||||
static void |
||||
help(const char *name) |
||||
{ |
||||
fprintf(stderr, "Usage: %s [args...] [-- [weston args..]]\n", name); |
||||
fprintf(stderr, " -u, --user Start session as specified username,\n" |
||||
" e.g. -u joe, requires root.\n"); |
||||
fprintf(stderr, " -t, --tty Start session on alternative tty,\n" |
||||
" e.g. -t /dev/tty4, requires -u option.\n"); |
||||
fprintf(stderr, " -v, --verbose Be verbose\n"); |
||||
fprintf(stderr, " -h, --help Display this help message\n"); |
||||
} |
||||
|
||||
int |
||||
main(int argc, char *argv[]) |
||||
{ |
||||
struct weston_launch wl; |
||||
int i, c; |
||||
char *tty = NULL; |
||||
struct option opts[] = { |
||||
{ "user", required_argument, NULL, 'u' }, |
||||
{ "tty", required_argument, NULL, 't' }, |
||||
{ "verbose", no_argument, NULL, 'v' }, |
||||
{ "help", no_argument, NULL, 'h' }, |
||||
{ 0, 0, NULL, 0 } |
||||
}; |
||||
|
||||
memset(&wl, 0, sizeof wl); |
||||
|
||||
while ((c = getopt_long(argc, argv, "u:t:vh", opts, &i)) != -1) { |
||||
switch (c) { |
||||
case 'u': |
||||
wl.new_user = optarg; |
||||
if (getuid() != 0) { |
||||
fprintf(stderr, "weston: Permission denied. -u allowed for root only\n"); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
break; |
||||
case 't': |
||||
tty = optarg; |
||||
break; |
||||
case 'v': |
||||
wl.verbose = 1; |
||||
break; |
||||
case 'h': |
||||
help("weston-launch"); |
||||
exit(EXIT_FAILURE); |
||||
default: |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
} |
||||
|
||||
if ((argc - optind) > (MAX_ARGV_SIZE - 6)) { |
||||
fprintf(stderr, |
||||
"weston: Too many arguments to pass to weston: %s\n", |
||||
strerror(E2BIG)); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
|
||||
if (tty && !wl.new_user) { |
||||
fprintf(stderr, "weston: -t/--tty option requires -u/--user option as well\n"); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
|
||||
if (wl.new_user) |
||||
wl.pw = getpwnam(wl.new_user); |
||||
else |
||||
wl.pw = getpwuid(getuid()); |
||||
if (wl.pw == NULL) { |
||||
fprintf(stderr, "weston: failed to get username: %s\n", |
||||
strerror(errno)); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
|
||||
if (!weston_launch_allowed(&wl)) { |
||||
fprintf(stderr, "Permission denied. You should either:\n" |
||||
#ifdef HAVE_SYSTEMD_LOGIN |
||||
" - run from an active and local (systemd) session.\n" |
||||
#else |
||||
" - enable systemd session support for weston-launch.\n" |
||||
#endif |
||||
" - or add yourself to the 'weston-launch' group.\n"); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
|
||||
if (setup_tty(&wl, tty) < 0) |
||||
exit(EXIT_FAILURE); |
||||
|
||||
if (wl.new_user && setup_pam(&wl) < 0) |
||||
exit(EXIT_FAILURE); |
||||
|
||||
if (setup_launcher_socket(&wl) < 0) |
||||
exit(EXIT_FAILURE); |
||||
|
||||
if (setup_signals(&wl) < 0) |
||||
exit(EXIT_FAILURE); |
||||
|
||||
wl.child = fork(); |
||||
if (wl.child == -1) { |
||||
fprintf(stderr, "weston: fork failed %s\n", strerror(errno)); |
||||
exit(EXIT_FAILURE); |
||||
} |
||||
|
||||
if (wl.child == 0) |
||||
launch_compositor(&wl, argc - optind, argv + optind); |
||||
|
||||
close(wl.sock[1]); |
||||
|
||||
while (1) { |
||||
struct pollfd fds[2]; |
||||
int n; |
||||
|
||||
fds[0].fd = wl.sock[0]; |
||||
fds[0].events = POLLIN; |
||||
fds[1].fd = wl.signalfd; |
||||
fds[1].events = POLLIN; |
||||
|
||||
n = poll(fds, 2, -1); |
||||
if (n < 0) { |
||||
fprintf(stderr, "poll failed: %s\n", strerror(errno)); |
||||
return -1; |
||||
} |
||||
if (fds[0].revents & POLLIN) |
||||
handle_socket_msg(&wl); |
||||
if (fds[1].revents) |
||||
handle_signal(&wl); |
||||
} |
||||
|
||||
return 0; |
||||
} |
||||
@ -1,51 +0,0 @@ |
||||
/*
|
||||
* Copyright © 2012 Benjamin Franzke |
||||
* |
||||
* Permission is hereby granted, free of charge, to any person obtaining |
||||
* a copy of this software and associated documentation files (the |
||||
* "Software"), to deal in the Software without restriction, including |
||||
* without limitation the rights to use, copy, modify, merge, publish, |
||||
* distribute, sublicense, and/or sell copies of the Software, and to |
||||
* permit persons to whom the Software is furnished to do so, subject to |
||||
* the following conditions: |
||||
* |
||||
* The above copyright notice and this permission notice (including the |
||||
* next paragraph) shall be included in all copies or substantial |
||||
* portions of the Software. |
||||
* |
||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, |
||||
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF |
||||
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
||||
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS |
||||
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN |
||||
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN |
||||
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE |
||||
* SOFTWARE. |
||||
*/ |
||||
|
||||
#ifndef _WESTON_LAUNCH_H_ |
||||
#define _WESTON_LAUNCH_H_ |
||||
|
||||
enum weston_launcher_opcode { |
||||
WESTON_LAUNCHER_OPEN, |
||||
}; |
||||
|
||||
enum weston_launcher_event { |
||||
WESTON_LAUNCHER_ACTIVATE, |
||||
WESTON_LAUNCHER_DEACTIVATE, |
||||
WESTON_LAUNCHER_DEACTIVATE_DONE, |
||||
// This event is followed by an fd handle
|
||||
WESTON_LAUNCHER_OPEN_REPLY, |
||||
}; |
||||
|
||||
struct weston_launcher_message { |
||||
int opcode; |
||||
}; |
||||
|
||||
struct weston_launcher_open { |
||||
struct weston_launcher_message header; |
||||
int flags; |
||||
char path[0]; |
||||
}; |
||||
|
||||
#endif |
||||
Loading…
Reference in new issue