Lines Matching +full:cm +full:- +full:poll +full:- +full:mode
1 /*-
2 * SPDX-License-Identifier: BSD-2-Clause
44 #include <poll.h>
63 struct ctrl_msg_hdr *cm;
71 cm = (struct ctrl_msg_hdr *)buf;
72 msg = (char *)buf + sizeof(*cm);
78 i = poll(pfds, nitems(pfds),
85 syslog(LOG_ERR, "<%s> poll error: %s",
91 n = read(fd, cm, sizeof(*cm));
101 if (n != (ssize_t)sizeof(*cm)) {
106 if (cm->cm_len > CM_MSG_MAXLEN) {
111 if (cm->cm_version != CM_VERSION) {
116 if (cm->cm_type >= CM_TYPE_MAX) {
124 cm->cm_type);
126 if (cm->cm_len > sizeof(*cm)) {
127 size_t msglen = cm->cm_len - sizeof(*cm);
134 i = poll(pfds, nitems(pfds),
141 syslog(LOG_ERR, "<%s> poll error: %s",
161 buf[CM_MSG_MAXLEN - 1] = '\0';
168 return (-1);
178 struct ctrl_msg_hdr *cm;
181 cm = (struct ctrl_msg_hdr *)buf;
182 msg = (char *)buf + sizeof(*cm);
185 iov[0].iov_base = cm;
186 iov[0].iov_len = sizeof(*cm);
188 if (cm->cm_len > sizeof(*cm)) {
191 iov[1].iov_len = cm->cm_len - iov[0].iov_len;
197 cm->cm_type, iovcnt, iov_len_total);
203 if (len == -1) {
208 return (-1);
218 return (-1);
232 if ((fd = accept(s->si_fd, (struct sockaddr *)&sun,
233 (socklen_t *)&sun.sun_len)) == -1) {
237 return (-1);
239 if ((flags = fcntl(fd, F_GETFL, 0)) == -1) {
241 close(s->si_fd);
242 return (-1);
244 if ((flags = fcntl(fd, F_SETFL, flags | O_NONBLOCK)) == -1) {
246 return (-1);
249 fd, s->si_fd);
257 close(s->si_fd);
258 unlink(s->si_name);
259 syslog(LOG_DEBUG, "<%s> remove %s", __func__, s->si_name);
266 if (s->si_fd == -1) {
268 return (-1);
270 if (listen(s->si_fd, SOCK_BACKLOG) == -1) {
272 return (-1);
279 csock_open(struct sockinfo *s, mode_t mode)
289 if (s->si_name == NULL)
290 s->si_name = _PATH_CTRL_SOCK;
292 if ((s->si_fd = socket(PF_UNIX, SOCK_STREAM, 0)) == -1) {
295 return (-1);
300 strlcpy(sun.sun_path, s->si_name, sizeof(sun.sun_path));
302 if (unlink(s->si_name) == -1)
305 "<%s> unlink %s", __func__, s->si_name);
306 close(s->si_fd);
307 return (-1);
310 if (bind(s->si_fd, (struct sockaddr *)&sun, sizeof(sun)) == -1) {
312 "<%s> bind failed: %s", __func__, s->si_name);
313 close(s->si_fd);
315 return (-1);
318 if (chmod(s->si_name, mode) == -1) {
320 "<%s> chmod failed: %s", __func__, s->si_name);
323 if ((flags = fcntl(s->si_fd, F_GETFL, 0)) == -1) {
325 "<%s> fcntl F_GETFL failed: %s", __func__, s->si_name);
328 if ((flags = fcntl(s->si_fd, F_SETFL, flags | O_NONBLOCK)) == -1) {
330 "<%s> fcntl F_SETFL failed: %s", __func__, s->si_name);
334 return (s->si_fd);
337 close(s->si_fd);
338 unlink(s->si_name);
339 return (-1);
358 cp->cp_ifname = malloc(len + 1);
359 if (cp->cp_ifname == NULL) {
363 memcpy(cp->cp_ifname, p, len);
364 cp->cp_ifname[len] = '\0';
373 cp->cp_key = malloc(len + 1);
374 if (cp->cp_key == NULL) {
378 memcpy(cp->cp_key, p, len);
379 cp->cp_key[len] = '\0';
388 cp->cp_val = malloc(len + 1);
389 if (cp->cp_val == NULL) {
393 memcpy(cp->cp_val, p, len);
394 cp->cp_val[len] = '\0';
395 cp->cp_val_len = len;
397 cp->cp_val_len = 0;
408 struct ctrl_msg_hdr *cm;
411 if (cp->cp_ifname != NULL)
412 len += strlen(cp->cp_ifname);
414 if (cp->cp_key != NULL)
415 len += strlen(cp->cp_key);
417 if (cp->cp_val != NULL && cp->cp_val_len > 0)
418 len += cp->cp_val_len;
420 if (len > CM_MSG_MAXLEN - sizeof(*cm)) {
430 if (cp->cp_ifname != NULL) {
431 *lenp++ = strlen(cp->cp_ifname);
433 memcpy(p, cp->cp_ifname, strlen(cp->cp_ifname));
434 p += strlen(cp->cp_ifname);
441 if (cp->cp_key != NULL) {
442 *lenp++ = strlen(cp->cp_key);
444 memcpy(p, cp->cp_key, strlen(cp->cp_key));
445 p += strlen(cp->cp_key);
452 if (cp->cp_val != NULL && cp->cp_val_len > 0) {
453 *lenp++ = cp->cp_val_len;
455 memcpy(p, cp->cp_val, cp->cp_val_len);
456 p += cp->cp_val_len;
468 struct ctrl_msg_hdr *cm;
472 if (len > CM_MSG_MAXLEN - sizeof(*cm)) {