- int msgid;
- key_t key;
- struct hotplug_msg *pmsg;
- char buf[BUFFER_SIZE];
- int ret;
-
- key = ftok(DEFAULT_EXEC_PROGRAM, IPC_KEY_ID);
- pmsg = (struct hotplug_msg *) buf;
- msgid = msgget(key, IPC_CREAT);
- if (msgid == -1) {
- dbg("open message queue error");
+ int ssock;
+ struct sockaddr_un saddr;
+ socklen_t addrlen;
+ int retval;
+ const int on = 1;
+ struct sigaction act;
+
+ init_logging("udevd");
+ dbg("version %s", UDEV_VERSION);
+
+ if (getuid() != 0) {
+ dbg("need to be root, exit");
+ exit(1);
+ }
+
+ /* set signal handler */
+ act.sa_handler = sig_handler;
+ sigemptyset (&act.sa_mask);
+ act.sa_flags = SA_RESTART;
+ sigaction(SIGINT, &act, NULL);
+ sigaction(SIGTERM, &act, NULL);
+
+ /* we want these two to interrupt system calls */
+ act.sa_flags = 0;
+ sigaction(SIGALRM, &act, NULL);
+ sigaction(SIGCHLD, &act, NULL);
+
+ memset(&saddr, 0x00, sizeof(saddr));
+ saddr.sun_family = AF_LOCAL;
+ /* use abstract namespace for socket path */
+ strcpy(&saddr.sun_path[1], UDEVD_SOCK_PATH);
+ addrlen = offsetof(struct sockaddr_un, sun_path) + strlen(saddr.sun_path+1) + 1;
+
+ ssock = socket(AF_LOCAL, SOCK_DGRAM, 0);
+ if (ssock == -1) {
+ dbg("error getting socket, exit");
+ exit(1);
+ }
+
+ /* the bind takes care of ensuring only one copy running */
+ retval = bind(ssock, (struct sockaddr *) &saddr, addrlen);
+ if (retval < 0) {
+ dbg("bind failed, exit");