Changeset 34986

Timestamp:

08/23/09 20:54:21 (4 years ago)

Author:

kazuho

Message:

receive 1024 events by default

Files:

• lang/c/picoev/trunk/picoev_epoll.c (modified) (3 diffs)

lang/c/picoev/trunk/picoev_epoll.c

@@ -6 +6 @@
   picoev_loop loop;
   int epfd;
+  struct epoll_event events[1024];
 } picoev_loop_epoll;
 
@@ -70 +71 @@
 {
   picoev_loop_epoll* loop = (picoev_loop_epoll*)_loop;
-  struct epoll_event events[100];
   int i, nevents, timeout_secs;
   
@@ -77 +77 @@
     timeout_secs = max_wait;
   }
-  nevents = epoll_wait(loop->epfd, events, sizeof(events) / sizeof(events[0]),
+  nevents = epoll_wait(loop->epfd, loop->events,
+                       sizeof(loop->events) / sizeof(loop->events[0]),
                        timeout_secs * 1000);
   for (i = 0; i < nevents; ++i) {
-    picoev_fd* target = picoev.fds + events[i].data.fd;
+    struct epoll_event* event = loop->events + i;
+    picoev_fd* target = picoev.fds + event->data.fd;
     if (loop->loop.loop_id == target->loop_id
-        && (events[i].events & (EPOLLIN | EPOLLOUT)) != 0) {
-      int revents = ((events[i].events & EPOLLIN) != 0 ? PICOEV_READ : 0)
-        | ((events[i].events & EPOLLOUT) != 0 ? PICOEV_WRITE : 0);
-      (*target->callback)(&loop->loop, events[i].data.fd, revents,
+        && (event->events & (EPOLLIN | EPOLLOUT)) != 0) {
+      int revents = ((event->events & EPOLLIN) != 0 ? PICOEV_READ : 0)
+        | ((event->events & EPOLLOUT) != 0 ? PICOEV_WRITE : 0);
+      (*target->callback)(&loop->loop, event->data.fd, revents,
                           target->cb_arg);
     }