Magisk/jni/daemon/daemon.c

147 lines
3.1 KiB
C
Raw Normal View History

2017-04-08 01:37:43 +02:00
/* daemon.c - Magisk Daemon
*
* Start the daemon and wait for requests
* Connect the daemon and send requests through sockets
*/
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>
#include <errno.h>
2017-04-08 01:37:43 +02:00
#include <sys/un.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
2017-04-15 13:02:07 +02:00
#include <sys/mount.h>
2017-04-08 01:37:43 +02:00
#include "magisk.h"
#include "utils.h"
#include "daemon.h"
static void request_handler(int client) {
client_request req = read_int(client);
char *s;
int pid, status, code;
switch (req) {
case LAUNCH_MAGISKHIDE:
launch_magiskhide(client);
break;
case STOP_MAGISKHIDE:
stop_magiskhide(client);
break;
case ADD_HIDELIST:
// TODO: Add hidelist
break;
case RM_HIDELIST:
// TODO: Remove hidelist
break;
case SUPERUSER:
2017-04-14 21:23:09 +02:00
su_daemon_receiver(client);
break;
case CHECK_VERSION:
write_string(client, VERSION_STR);
close(client);
break;
case CHECK_VERSION_CODE:
write_int(client, VERSION_CODE);
close(client);
break;
2017-04-15 13:02:07 +02:00
case POST_FS:
// TODO: post-fs
break;
case POST_FS_DATA:
// TODO: post-fs-data
break;
case LATE_START_SERVICE:
// TODO: late_start service
break;
case TEST:
s = read_string(client);
LOGI("%s\n", s);
free(s);
write_int(client, 0);
2017-04-14 21:23:09 +02:00
close(client);
break;
}
2017-04-08 01:37:43 +02:00
}
/* Setup the address and return socket fd */
static int setup_socket(struct sockaddr_un *sun) {
int fd = xsocket(AF_LOCAL, SOCK_STREAM, 0);
if (fcntl(fd, F_SETFD, FD_CLOEXEC)) {
2017-04-14 21:23:09 +02:00
PLOGE("fcntl FD_CLOEXEC");
2017-04-08 01:37:43 +02:00
}
memset(sun, 0, sizeof(*sun));
sun->sun_family = AF_LOCAL;
memcpy(sun->sun_path, REQUESTOR_DAEMON_PATH, REQUESTOR_DAEMON_PATH_LEN);
return fd;
}
static void do_nothing() {}
2017-04-08 01:37:43 +02:00
void start_daemon() {
// Launch the daemon, create new session, set proper context
2017-04-14 21:23:09 +02:00
if (getuid() != UID_ROOT || getgid() != UID_ROOT) {
fprintf(stderr, "Starting daemon requires root: %s\n", strerror(errno));
PLOGE("start daemon");
2017-04-08 01:37:43 +02:00
}
switch (fork()) {
case -1:
PLOGE("fork");
case 0:
break;
default:
return;
}
xsetsid();
xsetcon("u:r:su:s0");
struct sockaddr_un sun;
int fd = setup_socket(&sun);
xbind(fd, (struct sockaddr*) &sun, sizeof(sun));
xlisten(fd, 10);
// Change process name
strcpy(argv0, "magisk_daemon");
// The root daemon should not do anything if an error occurs
2017-04-14 21:23:09 +02:00
// It should stay intact under any circumstances
err_handler = do_nothing;
// Start log monitor
monitor_logs();
2017-04-08 01:37:43 +02:00
2017-04-15 12:33:16 +02:00
// Unlock all blocks for rw
unlock_blocks();
2017-04-15 13:02:07 +02:00
// Setup links under /sbin
mount(NULL, "/", NULL, MS_REMOUNT, NULL);
create_links(NULL, "/sbin");
mount(NULL, "/", NULL, MS_REMOUNT | MS_RDONLY, NULL);
2017-04-08 01:37:43 +02:00
// Loop forever to listen to requests
while(1) {
request_handler(xaccept(fd, NULL, NULL));
}
}
/* Connect the daemon, and return a socketfd */
int connect_daemon() {
struct sockaddr_un sun;
int fd = setup_socket(&sun);
if (connect(fd, (struct sockaddr*) &sun, sizeof(sun))) {
/* If we cannot access the daemon, we start the daemon
* since there is no clear entry point when the daemon should be started
*/
start_daemon();
do {
// Wait for 10ms
usleep(10000);
} while (connect(fd, (struct sockaddr*) &sun, sizeof(sun)));
}
return fd;
}