AuxXxilium/eudev
1
0
Fork 0
mirror of https://github.com/AuxXxilium/eudev.git synced 2025-01-25 08:29:59 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

libudev: monitor - add set_receive_buffer_size()

Browse Source
This commit is contained in:
Kay Sievers 2008-10-17 16:49:27 +02:00
parent d960ad1546
commit cb25a9585d
3 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
udev/lib/libudev-monitor.c
View File

@ -152,6 +152,13 @@ int udev_monitor_enable_receiving(struct udev_monitor *udev_monitor)
return 0;
}
int udev_monitor_set_receive_buffer_size(struct udev_monitor *udev_monitor, int size)
{
if (udev_monitor == NULL)
return -1;
return setsockopt(udev_monitor->sock, SOL_SOCKET, SO_RCVBUFFORCE, &size, sizeof(size));
}
/**
* udev_monitor_ref:
* @udev_monitor: udev monitor

1
udev/lib/libudev-private.h
View File

@ -91,6 +91,7 @@ extern int udev_device_rename_db(struct udev_device *udev_device, const char *de
/* libudev-monitor - netlink/unix socket communication */
extern int udev_monitor_send_device(struct udev_monitor *udev_monitor, struct udev_device *udev_device);
extern int udev_monitor_set_receive_buffer_size(struct udev_monitor *udev_monitor, int size);
/* libudev-ctrl - daemon runtime setup */
struct udev_ctrl;

20
udev/udevd.c
View File

@ -24,15 +24,11 @@
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <dirent.h>
#include <fcntl.h>
#include <syslog.h>
#include <time.h>
#include <getopt.h>
#include <sys/select.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <sys/ioctl.h>
#ifdef HAVE_INOTIFY
@ -213,7 +209,7 @@ static void event_fork(struct udev_event *event)
/* execute RUN= */
if (err == 0 && !event->ignore_device && udev_get_run(event->udev))
udev_rules_run(event);
info(event->udev, "seq %llu finished with %i\n", udev_device_get_seqnum(event->dev), err);
info(event->udev, "seq %llu exit with %i\n", udev_device_get_seqnum(event->dev), err);
logging_close();
if (err != 0)
exit(1);
@ -242,7 +238,8 @@ static void event_queue_insert(struct udev_event *event)
event->queue_time = time(NULL);
export_event_state(event, EVENT_QUEUED);
info(event->udev, "seq %llu queued, '%s' '%s'\n", udev_device_get_seqnum(event->dev), udev_device_get_action(event->dev), udev_device_get_subsystem(event->dev));
info(event->udev, "seq %llu queued, '%s' '%s'\n", udev_device_get_seqnum(event->dev),
udev_device_get_action(event->dev), udev_device_get_subsystem(event->dev));
util_strlcpy(filename, udev_get_dev_path(event->udev), sizeof(filename));
util_strlcat(filename, "/.udev/uevent_seqnum", sizeof(filename));
@ -545,7 +542,7 @@ static void udev_done(int pid, int exitstatus)
list_for_each_entry(event, &running_list, node) {
if (event->pid == pid) {
info(event->udev, "seq %llu, pid [%d] exit with %i, %ld seconds old\n",
info(event->udev, "seq %llu cleanup, pid [%d], status %i, %ld seconds old\n",
udev_device_get_seqnum(event->dev), event->pid,
exitstatus, time(NULL) - event->queue_time);
event->exitstatus = exitstatus;
@ -705,13 +702,8 @@ int main(int argc, char *argv[])
err(udev, "error initializing netlink socket\n");
rc = 3;
goto exit;
} else {
/* set receive buffersize */
const int buffersize = 32 * 1024 * 1024;
setsockopt(udev_monitor_get_fd(kernel_monitor),
SOL_SOCKET, SO_RCVBUFFORCE, &buffersize, sizeof(buffersize));
}
udev_monitor_set_receive_buffer_size(kernel_monitor, 128*1024*1024);
err = pipe(signal_pipe);
if (err < 0) {
@ -860,7 +852,6 @@ int main(int argc, char *argv[])
maxfd = UDEV_MAX(maxfd, udev_monitor_get_fd(kernel_monitor));
maxfd = UDEV_MAX(maxfd, signal_pipe[READ_END]);
maxfd = UDEV_MAX(maxfd, inotify_fd);
while (!udev_exit) {
int fdcount;
@ -870,7 +861,6 @@ int main(int argc, char *argv[])
FD_SET(udev_monitor_get_fd(kernel_monitor), &readfds);
if (inotify_fd >= 0)
FD_SET(inotify_fd, &readfds);
fdcount = select(maxfd+1, &readfds, NULL, NULL, NULL);
if (fdcount < 0) {
if (errno != EINTR)