blob: f2d0e83c787eabd1e6ce3b353a28b3e4fd2a97fb (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
#include <ngx_config.h>
#include <ngx_core.h>
#include <ngx_types.h>
#include <ngx_log.h>
#include <ngx_connection.h>
#include <ngx_event.h>
#include <ngx_event_timer.h>
#if (HAVE_KQUEUE)
#include <ngx_kqueue_module.h>
#endif
int ngx_aio_init(int max_connections, ngx_log_t *log)
{
#if (HAVE_KQUEUE)
int rc;
rc = ngx_kqueue_init(max_connections, log);
ngx_event_flags = NGX_HAVE_AIO_EVENT;
ngx_write_chain_proc = ngx_aio_write_chain;
return rc;
#endif
}
#if 0
/* 1 */
int ngx_posix_aio_process_events(ngx_log_t *log)
{
listen via SIGIO;
aio_* via SIGxxx;
sigsuspend()/sigwaitinfo()/sigtimedwait();
}
/* 2 */
int ngx_posix_aio_process_events(ngx_log_t *log)
{
unmask signal
listen via SIGIO;
/* BUG: SIGIO can be delivered before aio_*() */
aio_suspend()/aiowait()/aio_waitcomplete() with timeout
mask signal
if (ngx_socket_errno == NGX_EINTR)
look listen
select()/accept() nb listen sockets
else
aio
}
/* 3 */
int ngx_posix_aio_process_events(ngx_log_t *log)
{
unmask signal
/* BUG: AIO signal can be delivered before select() */
select(listen);
mask signal
if (ngx_socket_errno == NGX_EINTR)
look ready array
}
void aio_sig_handler(int signo, siginfo_t *siginfo, void *context)
{
push siginfo->si_value.sival_ptr
}
#endif
|
