summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--udevcontrol.c60
-rw-r--r--udevd.c16
-rw-r--r--udevmonitor.c46
3 files changed, 82 insertions, 40 deletions
diff --git a/udevcontrol.c b/udevcontrol.c
index 5d8fa77683..f16f6a125a 100644
--- a/udevcontrol.c
+++ b/udevcontrol.c
@@ -64,6 +64,7 @@ int main(int argc, char *argv[], char *envp[])
const char *env;
const char *val;
int *intval;
+ int i;
int retval = 1;
env = getenv("UDEV_LOG");
@@ -73,33 +74,50 @@ int main(int argc, char *argv[], char *envp[])
logging_init("udevcontrol");
dbg("version %s", UDEV_VERSION);
- if (argc != 2) {
- err("error finding comand");
+ if (argc < 2) {
+ fprintf(stderr, "missing command\n\n");
goto exit;
}
memset(&usend_msg, 0x00, sizeof(struct udevd_msg));
strcpy(usend_msg.magic, UDEV_MAGIC);
- if (!strcmp(argv[1], "stop_exec_queue"))
- usend_msg.type = UDEVD_STOP_EXEC_QUEUE;
- else if (!strcmp(argv[1], "start_exec_queue"))
- usend_msg.type = UDEVD_START_EXEC_QUEUE;
- else if (!strncmp(argv[1], "log_priority=", strlen("log_priority="))) {
- intval = (int *) usend_msg.envbuf;
- val = &argv[1][strlen("log_priority=")];
- usend_msg.type = UDEVD_SET_LOG_LEVEL;
- *intval = log_priority(val);
- info("send log_priority=%i", *intval);
- } else if (!strncmp(argv[1], "max_childs=", strlen("max_childs="))) {
- intval = (int *) usend_msg.envbuf;
- val = &argv[1][strlen("max_childs=")];
- usend_msg.type = UDEVD_SET_MAX_CHILDS;
- *intval = atoi(val);
- info("send max_childs=%i", *intval);
- } else {
- err("error parsing command\n");
- goto exit;
+ for (i = 1 ; i < argc; i++) {
+ char *arg = argv[i];
+
+ if (!strcmp(arg, "stop_exec_queue"))
+ usend_msg.type = UDEVD_STOP_EXEC_QUEUE;
+ else if (!strcmp(arg, "start_exec_queue"))
+ usend_msg.type = UDEVD_START_EXEC_QUEUE;
+ else if (!strncmp(arg, "log_priority=", strlen("log_priority="))) {
+ intval = (int *) usend_msg.envbuf;
+ val = &arg[strlen("log_priority=")];
+ usend_msg.type = UDEVD_SET_LOG_LEVEL;
+ *intval = log_priority(val);
+ info("send log_priority=%i", *intval);
+ } else if (!strncmp(arg, "max_childs=", strlen("max_childs="))) {
+ intval = (int *) usend_msg.envbuf;
+ val = &arg[strlen("max_childs=")];
+ usend_msg.type = UDEVD_SET_MAX_CHILDS;
+ *intval = atoi(val);
+ info("send max_childs=%i", *intval);
+ } else if (strcmp(arg, "help") == 0 || strcmp(arg, "--help") == 0 || strcmp(arg, "-h") == 0) {
+ printf("Usage: udevcontrol COMMAND\n"
+ " log_priority=<level> set the udev log level for the daemon\n"
+ " stop_exec_queue keep udevd from executing events, queue only\n"
+ " start_exec_queue execute events, flush queue\n"
+ " max_childs=<N> maximum number of childs running at the same time\n"
+ " --help print this help text\n\n");
+ exit(0);
+ } else {
+ fprintf(stderr, "unknown option\n\n");
+ exit(1);
+ }
+ }
+
+ if (getuid() != 0) {
+ fprintf(stderr, "need to be root, exit\n\n");
+ exit(1);
}
sock = socket(AF_LOCAL, SOCK_DGRAM, 0);
diff --git a/udevd.c b/udevd.c
index d51ed2f7b0..1575da8d5a 100644
--- a/udevd.c
+++ b/udevd.c
@@ -54,7 +54,7 @@ static int udevd_sock;
static int uevent_netlink_sock;
static pid_t sid;
-static int pipefds[2];
+static int pipefds[2] = {-1, -1};
static volatile int sigchilds_waiting;
static volatile int run_msg_q;
static volatile int sig_flag;
@@ -843,11 +843,10 @@ int main(int argc, char *argv[], char *envp[])
/* Set fds to dev/null */
fd = open( "/dev/null", O_RDWR );
if (fd >= 0) {
- dup2(fd, 0);
- dup2(fd, 1);
- dup2(fd, 2);
- if (fd > 2)
- close(fd);
+ dup2(fd, STDIN_FILENO);
+ dup2(fd, STDOUT_FILENO);
+ dup2(fd, STDERR_FILENO);
+ close(fd);
} else
err("error opening /dev/null %s", strerror(errno));
@@ -1012,6 +1011,11 @@ int main(int argc, char *argv[], char *envp[])
}
exit:
+ if (pipefds[0] > 0)
+ close(pipefds[0]);
+ if (pipefds[1] > 0)
+ close(pipefds[1]);
+
if (udevd_sock > 0)
close(udevd_sock);
diff --git a/udevmonitor.c b/udevmonitor.c
index 3a71d002f5..2efb705b6d 100644
--- a/udevmonitor.c
+++ b/udevmonitor.c
@@ -33,6 +33,7 @@
#include "udev.h"
#include "udevd.h"
+#include "udev_utils.h"
#include "udev_libc_wrapper.h"
static int uevent_netlink_sock;
@@ -102,25 +103,42 @@ static int init_uevent_netlink_sock(void)
int main(int argc, char *argv[])
{
int env = 0;
- int maxsockplus;
fd_set readfds;
+ int i;
int retval;
+ for (i = 1 ; i < argc; i++) {
+ char *arg = argv[i];
+ if (strcmp(arg, "--env") == 0 || strcmp(arg, "-e") == 0) {
+ env = 1;
+ }
+ else if (strcmp(arg, "--help") == 0 || strcmp(arg, "-h") == 0){
+ printf("Usage: udevmonitor [--env]\n"
+ " --env print the whole event environment\n"
+ " --help print this help text\n\n");
+ exit(0);
+ } else {
+ fprintf(stderr, "unknown option\n\n");
+ exit(1);
+ }
+ }
+
if (getuid() != 0) {
- printf("need to be root, exit\n");
+ fprintf(stderr, "need to be root, exit\n\n");
exit(1);
}
- if (argc == 2 && strstr(argv[1], "--env"))
- env = 1;
-
init_uevent_netlink_sock();
init_udev_monitor_socket();
+ printf("udevmonitor prints received from the kernel [UEVENT] and after\n"
+ "the udev processing, the event which udev [UDEV] has generated\n\n");
+
FD_ZERO(&readfds);
- FD_SET(uevent_netlink_sock, &readfds);
- FD_SET(udev_monitor_sock, &readfds);
- maxsockplus = udev_monitor_sock+1;
+ if (uevent_netlink_sock > 0)
+ FD_SET(uevent_netlink_sock, &readfds);
+ if (udev_monitor_sock > 0)
+ FD_SET(udev_monitor_sock, &readfds);
while (1) {
static char buf[UEVENT_BUFFER_SIZE*2];
@@ -130,14 +148,14 @@ int main(int argc, char *argv[])
buflen = 0;
workreadfds = readfds;
- retval = select(maxsockplus, &workreadfds, NULL, NULL, NULL);
+ retval = select(UDEV_MAX(uevent_netlink_sock, udev_monitor_sock)+1, &workreadfds, NULL, NULL, NULL);
if (retval < 0) {
if (errno != EINTR)
fprintf(stderr, "error receiving uevent message\n");
continue;
}
- if (FD_ISSET(uevent_netlink_sock, &workreadfds)) {
+ if ((uevent_netlink_sock > 0) && FD_ISSET(uevent_netlink_sock, &workreadfds)) {
buflen = recv(uevent_netlink_sock, &buf, sizeof(buf), 0);
if (buflen <= 0) {
fprintf(stderr, "error receiving uevent message\n");
@@ -146,7 +164,7 @@ int main(int argc, char *argv[])
printf("UEVENT[%i] %s\n", time(NULL), buf);
}
- if (FD_ISSET(udev_monitor_sock, &workreadfds)) {
+ if ((udev_monitor_sock > 0) && FD_ISSET(udev_monitor_sock, &workreadfds)) {
buflen = recv(udev_monitor_sock, &buf, sizeof(buf), 0);
if (buflen <= 0) {
fprintf(stderr, "error receiving udev message\n");
@@ -180,7 +198,9 @@ int main(int argc, char *argv[])
}
}
- close(uevent_netlink_sock);
- close(udev_monitor_sock);
+ if (uevent_netlink_sock > 0)
+ close(uevent_netlink_sock);
+ if (udev_monitor_sock > 0)
+ close(udev_monitor_sock);
exit(1);
}
generated by cgit v1.2.3-54-g00ecf (git 2.45.2) at 2024-09-21 20:21:08 +0000