… | |
… | |
77 | epoll_eventmax = array_roundsize (epoll_events, epoll_eventmax << 1); |
77 | epoll_eventmax = array_roundsize (epoll_events, epoll_eventmax << 1); |
78 | epoll_events = (struct epoll_event *)ev_malloc (sizeof (struct epoll_event) * epoll_eventmax); |
78 | epoll_events = (struct epoll_event *)ev_malloc (sizeof (struct epoll_event) * epoll_eventmax); |
79 | } |
79 | } |
80 | } |
80 | } |
81 | |
81 | |
82 | static int |
82 | int inline_size |
83 | epoll_init (EV_P_ int flags) |
83 | epoll_init (EV_P_ int flags) |
84 | { |
84 | { |
85 | backend_fd = epoll_create (256); |
85 | backend_fd = epoll_create (256); |
86 | |
86 | |
87 | if (backend_fd < 0) |
87 | if (backend_fd < 0) |
… | |
… | |
97 | epoll_events = (struct epoll_event *)ev_malloc (sizeof (struct epoll_event) * epoll_eventmax); |
97 | epoll_events = (struct epoll_event *)ev_malloc (sizeof (struct epoll_event) * epoll_eventmax); |
98 | |
98 | |
99 | return EVBACKEND_EPOLL; |
99 | return EVBACKEND_EPOLL; |
100 | } |
100 | } |
101 | |
101 | |
102 | static void |
102 | void inline_size |
103 | epoll_destroy (EV_P) |
103 | epoll_destroy (EV_P) |
104 | { |
104 | { |
105 | close (backend_fd); |
|
|
106 | |
|
|
107 | ev_free (epoll_events); |
105 | ev_free (epoll_events); |
108 | } |
106 | } |
109 | |
107 | |
110 | static void |
108 | void inline_size |
111 | epoll_fork (EV_P) |
109 | epoll_fork (EV_P) |
112 | { |
110 | { |
113 | close (backend_fd); |
111 | close (backend_fd); |
114 | |
112 | |
115 | while ((backend_fd = epoll_create (256)) < 0) |
113 | while ((backend_fd = epoll_create (256)) < 0) |