1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/*
* Copyright (C) 2005-2008 Kay Sievers <kay.sievers@vrfy.org>
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the
* Free Software Foundation version 2 of the License.
*
* This program is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* General Public License for more details.
*
* You should have received a copy of the GNU General Public License along
* with this program; if not, write to the Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*
*/
#include "config.h"
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <stddef.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include "udev.h"
#include "udevd.h"
struct udev_ctrl {
struct udev *udev;
int sock;
struct sockaddr_un saddr;
socklen_t addrlen;
};
struct udev_ctrl *udev_ctrl_new_from_socket(struct udev *udev, const char *socket_path)
{
struct udev_ctrl *uctrl;
uctrl = malloc(sizeof(struct udev_ctrl));
if (uctrl == NULL)
return NULL;
memset(uctrl, 0x00, sizeof(struct udev_ctrl));
uctrl->udev = udev;
uctrl->sock = socket(AF_LOCAL, SOCK_DGRAM, 0);
if (uctrl->sock < 0) {
err(udev, "error getting socket: %s\n", strerror(errno));
free(uctrl);
return NULL;
}
uctrl->saddr.sun_family = AF_LOCAL;
strcpy(uctrl->saddr.sun_path, socket_path);
uctrl->addrlen = offsetof(struct sockaddr_un, sun_path) + strlen(uctrl->saddr.sun_path);
/* translate leading '@' to abstract namespace */
if (uctrl->saddr.sun_path[0] == '@')
uctrl->saddr.sun_path[0] = '\0';
return uctrl;
}
void udev_ctrl_unref(struct udev_ctrl *uctrl)
{
if (uctrl == NULL)
return;
close(uctrl->sock);
}
static int ctrl_send(struct udev_ctrl *uctrl, enum udevd_ctrl_msg_type type, int intval, const char *buf)
{
struct udevd_ctrl_msg ctrl_msg;
int err;
memset(&ctrl_msg, 0x00, sizeof(struct udevd_ctrl_msg));
strcpy(ctrl_msg.magic, UDEVD_CTRL_MAGIC);
ctrl_msg.type = type;
if (buf != NULL)
strlcpy(ctrl_msg.buf, buf, sizeof(ctrl_msg.buf));
else
ctrl_msg.intval = intval;
err = sendto(uctrl->sock, &ctrl_msg, sizeof(ctrl_msg), 0, (struct sockaddr *)&uctrl->saddr, uctrl->addrlen);
if (err == -1) {
err(uctrl->udev, "error sending message: %s\n", strerror(errno));
}
return err;
}
int udev_ctrl_set_log_level(struct udev_ctrl *uctrl, int priority)
{
ctrl_send(uctrl, UDEVD_CTRL_SET_LOG_LEVEL, priority, NULL);
return 0;
}
int udev_ctrl_stop_exec_queue(struct udev_ctrl *uctrl)
{
ctrl_send(uctrl, UDEVD_CTRL_STOP_EXEC_QUEUE, 0, NULL);
return 0;
}
int udev_ctrl_start_exec_queue(struct udev_ctrl *uctrl)
{
ctrl_send(uctrl, UDEVD_CTRL_START_EXEC_QUEUE, 0, NULL);
return 0;
}
int udev_ctrl_reload_rules(struct udev_ctrl *uctrl)
{
ctrl_send(uctrl, UDEVD_CTRL_RELOAD_RULES, 0, NULL);
return 0;
}
int udev_ctrl_set_env(struct udev_ctrl *uctrl, const char *key)
{
ctrl_send(uctrl, UDEVD_CTRL_ENV, 0, optarg);
return 0;
}
int udev_ctrl_set_max_childs(struct udev_ctrl *uctrl, int count)
{
ctrl_send(uctrl, UDEVD_CTRL_SET_MAX_CHILDS, count, NULL);
return 0;
}
int udev_ctrl_set_max_childs_running(struct udev_ctrl *uctrl, int count)
{
ctrl_send(uctrl, UDEVD_CTRL_SET_MAX_CHILDS_RUNNING, count, NULL);
return 0;
}
|
