mirror of
git://projects.qi-hardware.com/openwrt-xburst.git
synced 2024-11-30 22:29:43 +02:00
61bccd5e21
when bringing up ethernet on ixp4xx, the driver may request a firmware while hotplug2 waits for the netdev bringup to complete. change the event processing loop to keep an event backlog to allow unthrottled events to pass through while throttled events are being waited for git-svn-id: svn://svn.openwrt.org/openwrt/trunk@12019 3c298f89-4303-0410-b956-a3cf2f4a3e73
136 lines
3.3 KiB
Diff
136 lines
3.3 KiB
Diff
--- a/hotplug2.c
|
|
+++ b/hotplug2.c
|
|
@@ -21,6 +21,7 @@
|
|
#include <sys/mman.h>
|
|
#include <linux/types.h>
|
|
#include <linux/netlink.h>
|
|
+#include <poll.h>
|
|
|
|
#include "mem_utils.h"
|
|
#include "filemap_utils.h"
|
|
@@ -492,6 +493,11 @@
|
|
char *coldplug_command = NULL;
|
|
char *rules_file = HOTPLUG2_RULE_PATH;
|
|
sigset_t block_mask;
|
|
+ struct pollfd msg_poll;
|
|
+
|
|
+ struct hotplug2_event_t *backlog = NULL;
|
|
+ struct hotplug2_event_t *backlog_tail = NULL;
|
|
+ int n_backlog = 0;
|
|
|
|
struct rules_t *rules = NULL;
|
|
struct filemap_t filemap;
|
|
@@ -602,6 +608,8 @@
|
|
* Open netlink socket to read the uevents
|
|
*/
|
|
netlink_socket = init_netlink_socket(NETLINK_BIND);
|
|
+ msg_poll.fd = netlink_socket;
|
|
+ msg_poll.events = POLLIN;
|
|
|
|
if (netlink_socket == -1) {
|
|
ERROR("netlink init","Unable to open netlink socket.");
|
|
@@ -642,20 +650,45 @@
|
|
* Main loop reading uevents
|
|
*/
|
|
while (!terminate) {
|
|
- /*
|
|
- * Read the uevent packet
|
|
- */
|
|
- size = recv(netlink_socket, &buffer, sizeof(buffer), 0);
|
|
- recv_errno = errno;
|
|
+ if ((n_backlog > 0) && (child_c < max_child_c)) {
|
|
+ /* dequeue backlog message */
|
|
+ tmpevent = backlog;
|
|
+ backlog = backlog->next;
|
|
+ n_backlog--;
|
|
+ if (backlog_tail == tmpevent)
|
|
+ backlog_tail = NULL;
|
|
+ } else {
|
|
+ /*
|
|
+ * Read the uevent packet
|
|
+ */
|
|
+ if (n_backlog >= HOTPLUG2_MSG_BACKLOG) {
|
|
+ usleep(HOTPLUG2_THROTTLE_INTERVAL * 1000);
|
|
+ continue;
|
|
+ }
|
|
+
|
|
+ if ((n_backlog > 0) && (child_c >= max_child_c)) {
|
|
+ int fds;
|
|
+ msg_poll.revents = 0;
|
|
+ fds = poll(&msg_poll, 1, HOTPLUG2_THROTTLE_INTERVAL);
|
|
+ if (fds < 0) {
|
|
+ perror("POLL FAILED");
|
|
+ continue;
|
|
+ }
|
|
+ if (fds == 0)
|
|
+ continue;
|
|
+ }
|
|
+ size = recv(netlink_socket, &buffer, sizeof(buffer), 0);
|
|
+ recv_errno = errno;
|
|
|
|
- /*
|
|
- * Parse the event into an event structure
|
|
- */
|
|
- tmpevent = get_hotplug2_event(buffer, size);
|
|
+ /*
|
|
+ * Parse the event into an event structure
|
|
+ */
|
|
+ tmpevent = get_hotplug2_event(buffer, size);
|
|
|
|
- if (tmpevent == NULL) {
|
|
- ERROR("reading events", "Malformed event read (missing action prefix).");
|
|
- continue;
|
|
+ if (tmpevent == NULL) {
|
|
+ ERROR("reading events", "Malformed event read (missing action prefix).");
|
|
+ continue;
|
|
+ }
|
|
}
|
|
|
|
/*
|
|
@@ -706,13 +739,16 @@
|
|
* Unless, of course, we've specified otherwise and no rules that match
|
|
* need throttling.
|
|
*/
|
|
- if (!flags & FLAG_NOTHROTTLE) {
|
|
- /*
|
|
- * Okay, throttle away!
|
|
- */
|
|
- while (child_c >= max_child_c) {
|
|
- usleep(HOTPLUG2_THROTTLE_INTERVAL);
|
|
- }
|
|
+ if (!(flags & FLAG_NOTHROTTLE) && (child_c >= max_child_c)) {
|
|
+ /* log the packet and process it later */
|
|
+ if (backlog_tail)
|
|
+ backlog_tail->next = tmpevent;
|
|
+ else
|
|
+ backlog = tmpevent;
|
|
+ tmpevent->next = NULL;
|
|
+ backlog_tail = tmpevent;
|
|
+ n_backlog++;
|
|
+ continue;
|
|
}
|
|
|
|
sigemptyset(&block_mask);
|
|
--- a/hotplug2.h
|
|
+++ b/hotplug2.h
|
|
@@ -45,9 +45,9 @@
|
|
#define DBG(action, fmt, arg...)
|
|
#endif
|
|
|
|
+#define HOTPLUG2_MSG_BACKLOG 64
|
|
#define UEVENT_BUFFER_SIZE 2048
|
|
-#define HOTPLUG2_POLL_INTERVAL 20000
|
|
-#define HOTPLUG2_THROTTLE_INTERVAL 10000
|
|
+#define HOTPLUG2_THROTTLE_INTERVAL 50
|
|
#define HOTPLUG2_RULE_PATH "/etc/hotplug2.rules"
|
|
|
|
#define ACTION_ADD 0
|
|
@@ -76,6 +76,7 @@
|
|
int env_vars_c;
|
|
char *plain;
|
|
int plain_s;
|
|
+ struct hotplug2_event_t *next;
|
|
};
|
|
|
|
struct options_t {
|