annotate src/event/modules/ngx_eventport_module.c @ 6806:75dbab4ea930

Events: improved error event handling for UDP sockets. Normally, the epoll module calls the read and write handlers depending on whether EPOLLIN and EPOLLOUT are reported by epoll_wait(). No error processing is done in the module, the handlers are expected to get an error when doing I/O. If an error event is reported without EPOLLIN and EPOLLOUT, the module set both EPOLLIN and EPOLLOUT to ensure the error event is handled at least in one active handler. This works well unless the error is delivered along with only one of EPOLLIN or EPOLLOUT, and the corresponding handler does not do any I/O. For example, it happened when getting EPOLLERR|EPOLLOUT from epoll_wait() upon receiving "ICMP port unreachable" while proxying UDP. As the write handler had nothing to send it was not able to detect and log an error, and did not switch to the next upstream. The fix is to unconditionally set EPOLLIN and EPOLLOUT in case of an error event. In the aforementioned case, this causes the read handler to be called which does recv() and detects an error. In addition to the epoll module, analogous changes were made in devpoll/eventport/poll.
author Dmitry Volyntsev <xeioex@nginx.com>
date Mon, 21 Nov 2016 16:03:42 +0300
parents dc92298b1852
children a72886067bbb
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
1
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
2 /*
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
3 * Copyright (C) Igor Sysoev
4412
d620f497c50f Copyright updated.
Maxim Konovalov <maxim@nginx.com>
parents: 3475
diff changeset
4 * Copyright (C) Nginx, Inc.
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
5 */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
6
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
7
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
8 #include <ngx_config.h>
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
9 #include <ngx_core.h>
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
10 #include <ngx_event.h>
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
11
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
12
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
13 #if (NGX_TEST_BUILD_EVENTPORT)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
14
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
15 #define ushort_t u_short
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
16 #define uint_t u_int
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
17
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
18 #ifndef CLOCK_REALTIME
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
19 #define CLOCK_REALTIME 0
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
20 typedef int clockid_t;
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
21 typedef void * timer_t;
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
22 #endif
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
23
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
24 /* Solaris declarations */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
25
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
26 #define PORT_SOURCE_AIO 1
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
27 #define PORT_SOURCE_TIMER 2
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
28 #define PORT_SOURCE_USER 3
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
29 #define PORT_SOURCE_FD 4
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
30 #define PORT_SOURCE_ALERT 5
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
31 #define PORT_SOURCE_MQ 6
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
32
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
33 #ifndef ETIME
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
34 #define ETIME 64
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
35 #endif
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
36
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
37 #define SIGEV_PORT 4
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
38
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
39 typedef struct {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
40 int portev_events; /* event data is source specific */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
41 ushort_t portev_source; /* event source */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
42 ushort_t portev_pad; /* port internal use */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
43 uintptr_t portev_object; /* source specific object */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
44 void *portev_user; /* user cookie */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
45 } port_event_t;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
46
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
47 typedef struct port_notify {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
48 int portnfy_port; /* bind request(s) to port */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
49 void *portnfy_user; /* user defined */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
50 } port_notify_t;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
51
6475
7d6970ba5209 Events: fixed test building with eventport on OS X.
Ruslan Ermilov <ru@nginx.com>
parents: 6447
diff changeset
52 #if (__FreeBSD__ && __FreeBSD_version < 700005) || (NGX_DARWIN)
1939
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
53
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
54 typedef struct itimerspec { /* definition per POSIX.4 */
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
55 struct timespec it_interval;/* timer period */
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
56 struct timespec it_value; /* timer expiration */
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
57 } itimerspec_t;
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
58
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
59 #endif
6e7daf852eec restore building --test-build-rtsig and --test-build-eventport on FreeBSD 6
Igor Sysoev <igor@sysoev.ru>
parents: 1870
diff changeset
60
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
61 int port_create(void);
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
62
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
63 int port_create(void)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
64 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
65 return -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
66 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
67
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
68
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
69 int port_associate(int port, int source, uintptr_t object, int events,
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
70 void *user);
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
71
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
72 int port_associate(int port, int source, uintptr_t object, int events,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
73 void *user)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
74 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
75 return -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
76 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
77
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
78
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
79 int port_dissociate(int port, int source, uintptr_t object);
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
80
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
81 int port_dissociate(int port, int source, uintptr_t object)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
82 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
83 return -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
84 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
85
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
86
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
87 int port_getn(int port, port_event_t list[], uint_t max, uint_t *nget,
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
88 struct timespec *timeout);
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
89
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
90 int port_getn(int port, port_event_t list[], uint_t max, uint_t *nget,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
91 struct timespec *timeout)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
92 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
93 return -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
94 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
95
6021
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
96 int port_send(int port, int events, void *user);
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
97
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
98 int port_send(int port, int events, void *user)
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
99 {
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
100 return -1;
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
101 }
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
102
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
103
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
104 int timer_create(clockid_t clock_id, struct sigevent *evp, timer_t *timerid);
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
105
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
106 int timer_create(clockid_t clock_id, struct sigevent *evp, timer_t *timerid)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
107 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
108 return -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
109 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
110
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
111
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
112 int timer_settime(timer_t timerid, int flags, const struct itimerspec *value,
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
113 struct itimerspec *ovalue);
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
114
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
115 int timer_settime(timer_t timerid, int flags, const struct itimerspec *value,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
116 struct itimerspec *ovalue)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
117 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
118 return -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
119 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
120
4759
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
121
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
122 int timer_delete(timer_t timerid);
4c36e15651f7 Fixed compilation with -Wmissing-prototypes.
Ruslan Ermilov <ru@nginx.com>
parents: 4572
diff changeset
123
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
124 int timer_delete(timer_t timerid)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
125 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
126 return -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
127 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
128
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
129 #endif
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
130
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
131
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
132 typedef struct {
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
133 ngx_uint_t events;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
134 } ngx_eventport_conf_t;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
135
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
136
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
137 static ngx_int_t ngx_eventport_init(ngx_cycle_t *cycle, ngx_msec_t timer);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
138 static void ngx_eventport_done(ngx_cycle_t *cycle);
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
139 static ngx_int_t ngx_eventport_add_event(ngx_event_t *ev, ngx_int_t event,
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
140 ngx_uint_t flags);
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
141 static ngx_int_t ngx_eventport_del_event(ngx_event_t *ev, ngx_int_t event,
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
142 ngx_uint_t flags);
6021
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
143 static ngx_int_t ngx_eventport_notify(ngx_event_handler_pt handler);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
144 static ngx_int_t ngx_eventport_process_events(ngx_cycle_t *cycle,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
145 ngx_msec_t timer, ngx_uint_t flags);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
146
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
147 static void *ngx_eventport_create_conf(ngx_cycle_t *cycle);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
148 static char *ngx_eventport_init_conf(ngx_cycle_t *cycle, void *conf);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
149
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
150 static int ep = -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
151 static port_event_t *event_list;
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
152 static ngx_uint_t nevents;
1870
a62fb6c156c5 fix building --test-build-rtsig and --test-build-eventport on FreeBSD 7
Igor Sysoev <igor@sysoev.ru>
parents: 1354
diff changeset
153 static timer_t event_timer = (timer_t) -1;
6021
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
154 static ngx_event_t notify_event;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
155
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
156 static ngx_str_t eventport_name = ngx_string("eventport");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
157
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
158
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
159 static ngx_command_t ngx_eventport_commands[] = {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
160
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
161 { ngx_string("eventport_events"),
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
162 NGX_EVENT_CONF|NGX_CONF_TAKE1,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
163 ngx_conf_set_num_slot,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
164 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
165 offsetof(ngx_eventport_conf_t, events),
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
166 NULL },
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
167
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
168 ngx_null_command
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
169 };
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
170
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
171
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
172 ngx_event_module_t ngx_eventport_module_ctx = {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
173 &eventport_name,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
174 ngx_eventport_create_conf, /* create configuration */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
175 ngx_eventport_init_conf, /* init configuration */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
176
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
177 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
178 ngx_eventport_add_event, /* add an event */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
179 ngx_eventport_del_event, /* delete an event */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
180 ngx_eventport_add_event, /* enable an event */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
181 ngx_eventport_del_event, /* disable an event */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
182 NULL, /* add an connection */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
183 NULL, /* delete an connection */
6021
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
184 ngx_eventport_notify, /* trigger a notify */
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
185 ngx_eventport_process_events, /* process the events */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
186 ngx_eventport_init, /* init the events */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
187 ngx_eventport_done, /* done the events */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
188 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
189
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
190 };
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
191
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
192 ngx_module_t ngx_eventport_module = {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
193 NGX_MODULE_V1,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
194 &ngx_eventport_module_ctx, /* module context */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
195 ngx_eventport_commands, /* module directives */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
196 NGX_EVENT_MODULE, /* module type */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
197 NULL, /* init master */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
198 NULL, /* init module */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
199 NULL, /* init process */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
200 NULL, /* init thread */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
201 NULL, /* exit thread */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
202 NULL, /* exit process */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
203 NULL, /* exit master */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
204 NGX_MODULE_V1_PADDING
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
205 };
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
206
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
207
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
208 static ngx_int_t
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
209 ngx_eventport_init(ngx_cycle_t *cycle, ngx_msec_t timer)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
210 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
211 port_notify_t pn;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
212 struct itimerspec its;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
213 struct sigevent sev;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
214 ngx_eventport_conf_t *epcf;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
215
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
216 epcf = ngx_event_get_conf(cycle->conf_ctx, ngx_eventport_module);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
217
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
218 if (ep == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
219 ep = port_create();
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
220
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
221 if (ep == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
222 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
223 "port_create() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
224 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
225 }
6021
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
226
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
227 notify_event.active = 1;
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
228 notify_event.log = cycle->log;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
229 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
230
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
231 if (nevents < epcf->events) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
232 if (event_list) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
233 ngx_free(event_list);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
234 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
235
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
236 event_list = ngx_alloc(sizeof(port_event_t) * epcf->events,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
237 cycle->log);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
238 if (event_list == NULL) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
239 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
240 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
241 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
242
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
243 ngx_event_flags = NGX_USE_EVENTPORT_EVENT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
244
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
245 if (timer) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
246 ngx_memzero(&pn, sizeof(port_notify_t));
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
247 pn.portnfy_port = ep;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
248
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
249 ngx_memzero(&sev, sizeof(struct sigevent));
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
250 sev.sigev_notify = SIGEV_PORT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
251 #if !(NGX_TEST_BUILD_EVENTPORT)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
252 sev.sigev_value.sival_ptr = &pn;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
253 #endif
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
254
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
255 if (timer_create(CLOCK_REALTIME, &sev, &event_timer) == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
256 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
257 "timer_create() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
258 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
259 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
260
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
261 its.it_interval.tv_sec = timer / 1000;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
262 its.it_interval.tv_nsec = (timer % 1000) * 1000000;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
263 its.it_value.tv_sec = timer / 1000;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
264 its.it_value.tv_nsec = (timer % 1000) * 1000000;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
265
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
266 if (timer_settime(event_timer, 0, &its, NULL) == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
267 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
268 "timer_settime() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
269 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
270 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
271
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
272 ngx_event_flags |= NGX_USE_TIMER_EVENT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
273 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
274
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
275 nevents = epcf->events;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
276
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
277 ngx_io = ngx_os_io;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
278
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
279 ngx_event_actions = ngx_eventport_module_ctx.actions;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
280
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
281 return NGX_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
282 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
283
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
284
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
285 static void
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
286 ngx_eventport_done(ngx_cycle_t *cycle)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
287 {
1870
a62fb6c156c5 fix building --test-build-rtsig and --test-build-eventport on FreeBSD 7
Igor Sysoev <igor@sysoev.ru>
parents: 1354
diff changeset
288 if (event_timer != (timer_t) -1) {
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
289 if (timer_delete(event_timer) == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
290 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
291 "timer_delete() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
292 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
293
1870
a62fb6c156c5 fix building --test-build-rtsig and --test-build-eventport on FreeBSD 7
Igor Sysoev <igor@sysoev.ru>
parents: 1354
diff changeset
294 event_timer = (timer_t) -1;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
295 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
296
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
297 if (close(ep) == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
298 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
299 "close() event port failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
300 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
301
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
302 ep = -1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
303
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
304 ngx_free(event_list);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
305
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
306 event_list = NULL;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
307 nevents = 0;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
308 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
309
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
310
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
311 static ngx_int_t
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
312 ngx_eventport_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags)
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
313 {
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
314 ngx_int_t events, prev;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
315 ngx_event_t *e;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
316 ngx_connection_t *c;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
317
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
318 c = ev->data;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
319
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
320 events = event;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
321
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
322 if (event == NGX_READ_EVENT) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
323 e = c->write;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
324 prev = POLLOUT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
325 #if (NGX_READ_EVENT != POLLIN)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
326 events = POLLIN;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
327 #endif
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
328
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
329 } else {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
330 e = c->read;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
331 prev = POLLIN;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
332 #if (NGX_WRITE_EVENT != POLLOUT)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
333 events = POLLOUT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
334 #endif
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
335 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
336
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
337 if (e->oneshot) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
338 events |= prev;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
339 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
340
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
341 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
342 "eventport add event: fd:%d ev:%04Xi", c->fd, events);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
343
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
344 if (port_associate(ep, PORT_SOURCE_FD, c->fd, events,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
345 (void *) ((uintptr_t) ev | ev->instance))
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
346 == -1)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
347 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
348 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
349 "port_associate() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
350 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
351 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
352
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
353 ev->active = 1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
354 ev->oneshot = 1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
355
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
356 return NGX_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
357 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
358
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
359
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
360 static ngx_int_t
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
361 ngx_eventport_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags)
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
362 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
363 ngx_event_t *e;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
364 ngx_connection_t *c;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
365
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
366 /*
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
367 * when the file descriptor is closed, the event port automatically
4572
67653855682e Fixed spelling in multiline C comments.
Ruslan Ermilov <ru@nginx.com>
parents: 4412
diff changeset
368 * dissociates it from the port, so we do not need to dissociate explicitly
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
369 * the event before the closing the file descriptor
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
370 */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
371
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
372 if (flags & NGX_CLOSE_EVENT) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
373 ev->active = 0;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
374 ev->oneshot = 0;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
375 return NGX_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
376 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
377
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
378 c = ev->data;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
379
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
380 if (event == NGX_READ_EVENT) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
381 e = c->write;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
382 event = POLLOUT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
383
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
384 } else {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
385 e = c->read;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
386 event = POLLIN;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
387 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
388
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
389 if (e->oneshot) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
390 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
391 "eventport change event: fd:%d ev:%04Xi", c->fd, event);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
392
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
393 if (port_associate(ep, PORT_SOURCE_FD, c->fd, event,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
394 (void *) ((uintptr_t) ev | ev->instance))
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
395 == -1)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
396 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
397 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
398 "port_associate() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
399 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
400 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
401
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
402 } else {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
403 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
404 "eventport del event: fd:%d", c->fd);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
405
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
406 if (port_dissociate(ep, PORT_SOURCE_FD, c->fd) == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
407 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
408 "port_dissociate() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
409 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
410 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
411 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
412
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
413 ev->active = 0;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
414 ev->oneshot = 0;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
415
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
416 return NGX_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
417 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
418
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
419
6021
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
420 static ngx_int_t
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
421 ngx_eventport_notify(ngx_event_handler_pt handler)
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
422 {
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
423 notify_event.handler = handler;
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
424
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
425 if (port_send(ep, 0, &notify_event) != 0) {
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
426 ngx_log_error(NGX_LOG_ALERT, notify_event.log, ngx_errno,
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
427 "port_send() failed");
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
428 return NGX_ERROR;
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
429 }
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
430
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
431 return NGX_OK;
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
432 }
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
433
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
434
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
435 ngx_int_t
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
436 ngx_eventport_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
437 ngx_uint_t flags)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
438 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
439 int n, revents;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
440 u_int events;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
441 ngx_err_t err;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
442 ngx_int_t instance;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
443 ngx_uint_t i, level;
5821
3f5f0ab59b35 Events: processing of posted events changed from LIFO to FIFO.
Valentin Bartenev <vbart@nginx.com>
parents: 5820
diff changeset
444 ngx_event_t *ev, *rev, *wev;
3f5f0ab59b35 Events: processing of posted events changed from LIFO to FIFO.
Valentin Bartenev <vbart@nginx.com>
parents: 5820
diff changeset
445 ngx_queue_t *queue;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
446 ngx_connection_t *c;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
447 struct timespec ts, *tp;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
448
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
449 if (timer == NGX_TIMER_INFINITE) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
450 tp = NULL;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
451
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
452 } else {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
453 ts.tv_sec = timer / 1000;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
454 ts.tv_nsec = (timer % 1000) * 1000000;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
455 tp = &ts;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
456 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
457
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
458 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
459 "eventport timer: %M", timer);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
460
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
461 events = 1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
462
1354
f69d1aab6a0f make 64-bit ngx_int_t on 64-bit platforms
Igor Sysoev <igor@sysoev.ru>
parents: 1287
diff changeset
463 n = port_getn(ep, event_list, (u_int) nevents, &events, tp);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
464
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
465 err = ngx_errno;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
466
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
467 if (flags & NGX_UPDATE_TIME) {
3475
ab353d7dc182 *) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents: 3474
diff changeset
468 ngx_time_update();
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
469 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
470
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
471 if (n == -1) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
472 if (err == ETIME) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
473 if (timer != NGX_TIMER_INFINITE) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
474 return NGX_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
475 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
476
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
477 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
478 "port_getn() returned no events without timeout");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
479 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
480 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
481
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
482 level = (err == NGX_EINTR) ? NGX_LOG_INFO : NGX_LOG_ALERT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
483 ngx_log_error(level, cycle->log, err, "port_getn() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
484 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
485 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
486
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
487 if (events == 0) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
488 if (timer != NGX_TIMER_INFINITE) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
489 return NGX_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
490 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
491
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
492 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
493 "port_getn() returned no events without timeout");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
494 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
495 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
496
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
497 for (i = 0; i < events; i++) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
498
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
499 if (event_list[i].portev_source == PORT_SOURCE_TIMER) {
3475
ab353d7dc182 *) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents: 3474
diff changeset
500 ngx_time_update();
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
501 continue;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
502 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
503
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
504 ev = event_list[i].portev_user;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
505
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
506 switch (event_list[i].portev_source) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
507
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
508 case PORT_SOURCE_FD:
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
509
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
510 instance = (uintptr_t) ev & 1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
511 ev = (ngx_event_t *) ((uintptr_t) ev & (uintptr_t) ~1);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
512
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
513 if (ev->closed || ev->instance != instance) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
514
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
515 /*
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
516 * the stale event from a file descriptor
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
517 * that was just closed in this iteration
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
518 */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
519
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
520 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
521 "eventport: stale event %p", ev);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
522 continue;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
523 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
524
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
525 revents = event_list[i].portev_events;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
526
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
527 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
528 "eventport: fd:%d, ev:%04Xd",
6479
dc92298b1852 Events: fixed logging.
Sergey Kandaurov <pluknet@nginx.com>
parents: 6475
diff changeset
529 (int) event_list[i].portev_object, revents);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
530
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
531 if (revents & (POLLERR|POLLHUP|POLLNVAL)) {
1128
06479b01caff decrease log level from alert to debug for POLLERR|POLLHUP|POLLNVAL
Igor Sysoev <igor@sysoev.ru>
parents: 929
diff changeset
532 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
06479b01caff decrease log level from alert to debug for POLLERR|POLLHUP|POLLNVAL
Igor Sysoev <igor@sysoev.ru>
parents: 929
diff changeset
533 "port_getn() error fd:%d ev:%04Xd",
6479
dc92298b1852 Events: fixed logging.
Sergey Kandaurov <pluknet@nginx.com>
parents: 6475
diff changeset
534 (int) event_list[i].portev_object, revents);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
535 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
536
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
537 if (revents & ~(POLLIN|POLLOUT|POLLERR|POLLHUP|POLLNVAL)) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
538 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
539 "strange port_getn() events fd:%d ev:%04Xd",
6479
dc92298b1852 Events: fixed logging.
Sergey Kandaurov <pluknet@nginx.com>
parents: 6475
diff changeset
540 (int) event_list[i].portev_object, revents);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
541 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
542
6806
75dbab4ea930 Events: improved error event handling for UDP sockets.
Dmitry Volyntsev <xeioex@nginx.com>
parents: 6479
diff changeset
543 if (revents & (POLLERR|POLLHUP|POLLNVAL)) {
75dbab4ea930 Events: improved error event handling for UDP sockets.
Dmitry Volyntsev <xeioex@nginx.com>
parents: 6479
diff changeset
544
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
545 /*
6806
75dbab4ea930 Events: improved error event handling for UDP sockets.
Dmitry Volyntsev <xeioex@nginx.com>
parents: 6479
diff changeset
546 * if the error events were returned, add POLLIN and POLLOUT
75dbab4ea930 Events: improved error event handling for UDP sockets.
Dmitry Volyntsev <xeioex@nginx.com>
parents: 6479
diff changeset
547 * to handle the events at least in one active handler
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
548 */
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
549
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
550 revents |= POLLIN|POLLOUT;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
551 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
552
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
553 c = ev->data;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
554 rev = c->read;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
555 wev = c->write;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
556
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
557 rev->active = 0;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
558 wev->active = 0;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
559
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
560 if (revents & POLLIN) {
5820
3377f9459e99 Events: removed broken thread support from posted events.
Valentin Bartenev <vbart@nginx.com>
parents: 5175
diff changeset
561 rev->ready = 1;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
562
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
563 if (flags & NGX_POST_EVENTS) {
5820
3377f9459e99 Events: removed broken thread support from posted events.
Valentin Bartenev <vbart@nginx.com>
parents: 5175
diff changeset
564 queue = rev->accept ? &ngx_posted_accept_events
3377f9459e99 Events: removed broken thread support from posted events.
Valentin Bartenev <vbart@nginx.com>
parents: 5175
diff changeset
565 : &ngx_posted_events;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
566
5820
3377f9459e99 Events: removed broken thread support from posted events.
Valentin Bartenev <vbart@nginx.com>
parents: 5175
diff changeset
567 ngx_post_event(rev, queue);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
568
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
569 } else {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
570 rev->handler(rev);
1287
3dd9883fa121 fix segfault when event port returns POLLERR without POLLIN or POLLOUT
Igor Sysoev <igor@sysoev.ru>
parents: 1128
diff changeset
571
5170
6362bd26e4b0 Events: protection from stale events in eventport and devpoll.
Valentin Bartenev <vbart@nginx.com>
parents: 4759
diff changeset
572 if (ev->closed || ev->instance != instance) {
1287
3dd9883fa121 fix segfault when event port returns POLLERR without POLLIN or POLLOUT
Igor Sysoev <igor@sysoev.ru>
parents: 1128
diff changeset
573 continue;
3dd9883fa121 fix segfault when event port returns POLLERR without POLLIN or POLLOUT
Igor Sysoev <igor@sysoev.ru>
parents: 1128
diff changeset
574 }
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
575 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
576
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
577 if (rev->accept) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
578 if (ngx_use_accept_mutex) {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
579 ngx_accept_events = 1;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
580 continue;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
581 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
582
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
583 if (port_associate(ep, PORT_SOURCE_FD, c->fd, POLLIN,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
584 (void *) ((uintptr_t) ev | ev->instance))
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
585 == -1)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
586 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
587 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
588 "port_associate() failed");
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
589 return NGX_ERROR;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
590 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
591 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
592 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
593
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
594 if (revents & POLLOUT) {
5820
3377f9459e99 Events: removed broken thread support from posted events.
Valentin Bartenev <vbart@nginx.com>
parents: 5175
diff changeset
595 wev->ready = 1;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
596
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
597 if (flags & NGX_POST_EVENTS) {
5820
3377f9459e99 Events: removed broken thread support from posted events.
Valentin Bartenev <vbart@nginx.com>
parents: 5175
diff changeset
598 ngx_post_event(wev, &ngx_posted_events);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
599
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
600 } else {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
601 wev->handler(wev);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
602 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
603 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
604
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
605 continue;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
606
6021
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
607 case PORT_SOURCE_USER:
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
608
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
609 ev->handler(ev);
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
610
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
611 continue;
117c77b22db1 Events: implemented eventport notification mechanism.
Ruslan Ermilov <ru@nginx.com>
parents: 6018
diff changeset
612
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
613 default:
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
614 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0,
6005
d84f0abd4a53 Events: fixed typo in the error message.
Ruslan Ermilov <ru@nginx.com>
parents: 5821
diff changeset
615 "unexpected eventport object %d",
6479
dc92298b1852 Events: fixed logging.
Sergey Kandaurov <pluknet@nginx.com>
parents: 6475
diff changeset
616 (int) event_list[i].portev_object);
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
617 continue;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
618 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
619 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
620
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
621 return NGX_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
622 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
623
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
624
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
625 static void *
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
626 ngx_eventport_create_conf(ngx_cycle_t *cycle)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
627 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
628 ngx_eventport_conf_t *epcf;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
629
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
630 epcf = ngx_palloc(cycle->pool, sizeof(ngx_eventport_conf_t));
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
631 if (epcf == NULL) {
2912
c7d57b539248 return NULL instead of NGX_CONF_ERROR on a create conf failure
Igor Sysoev <igor@sysoev.ru>
parents: 1939
diff changeset
632 return NULL;
719
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
633 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
634
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
635 epcf->events = NGX_CONF_UNSET;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
636
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
637 return epcf;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
638 }
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
639
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
640
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
641 static char *
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
642 ngx_eventport_init_conf(ngx_cycle_t *cycle, void *conf)
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
643 {
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
644 ngx_eventport_conf_t *epcf = conf;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
645
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
646 ngx_conf_init_uint_value(epcf->events, 32);
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
647
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
648 return NGX_CONF_OK;
f30b1a75fd3b Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
diff changeset
649 }