2 * Copyright 2003-2007 Niels Provos <provos@citi.umich.edu>
3 * Copyright 2007-2012 Niels Provos and Nick Mathewson
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 * 4. The name of the author may not be used to endorse or promote products
14 * derived from this software without specific prior written permission.
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28 * Mon 03/10/2003 - Modified by Davide Libenzi <davidel@xmailserver.org>
30 * Added chain event propagation to improve the sensitivity of
31 * the measure respect to the event loop efficency.
36 #include "event2/event-config.h"
38 #include <sys/types.h>
40 #ifdef _EVENT_HAVE_SYS_TIME_H
44 #define WIN32_LEAN_AND_MEAN
47 #include <sys/socket.h>
49 #include <sys/resource.h>
55 #ifdef _EVENT_HAVE_UNISTD_H
63 static int count
, writes
, fired
;
64 static evutil_socket_t
*pipes
;
65 static int num_pipes
, num_active
, num_writes
;
66 static struct event
*events
;
70 read_cb(evutil_socket_t fd
, short which
, void *arg
)
72 ev_intptr_t idx
= (ev_intptr_t
) arg
, widx
= idx
+ 1;
75 count
+= recv(fd
, (char*)&ch
, sizeof(ch
), 0);
77 if (widx
>= num_pipes
)
79 send(pipes
[2 * widx
+ 1], "e", 1, 0);
85 static struct timeval
*
88 evutil_socket_t
*cp
, space
;
90 static struct timeval ts
, te
;
92 for (cp
= pipes
, i
= 0; i
< num_pipes
; i
++, cp
+= 2) {
93 if (event_initialized(&events
[i
]))
94 event_del(&events
[i
]);
95 event_set(&events
[i
], cp
[0], EV_READ
| EV_PERSIST
, read_cb
, (void *)(ev_intptr_t
) i
);
96 event_add(&events
[i
], NULL
);
99 event_loop(EVLOOP_ONCE
| EVLOOP_NONBLOCK
);
102 space
= num_pipes
/ num_active
;
104 for (i
= 0; i
< num_active
; i
++, fired
++)
105 send(pipes
[i
* space
+ 1], "e", 1, 0);
110 evutil_gettimeofday(&ts
, NULL
);
112 event_loop(EVLOOP_ONCE
| EVLOOP_NONBLOCK
);
114 } while (count
!= fired
);
115 evutil_gettimeofday(&te
, NULL
);
117 if (xcount
!= count
) fprintf(stderr
, "Xcount: %d, Rcount: %d\n", xcount
, count
);
120 evutil_timersub(&te
, &ts
, &te
);
126 main(int argc
, char **argv
)
137 WSAStartup(0x101, &WSAData
);
141 num_writes
= num_pipes
;
142 while ((c
= getopt(argc
, argv
, "n:a:w:")) != -1) {
145 num_pipes
= atoi(optarg
);
148 num_active
= atoi(optarg
);
151 num_writes
= atoi(optarg
);
154 fprintf(stderr
, "Illegal argument \"%c\"\n", c
);
160 rl
.rlim_cur
= rl
.rlim_max
= num_pipes
* 2 + 50;
161 if (setrlimit(RLIMIT_NOFILE
, &rl
) == -1) {
167 events
= calloc(num_pipes
, sizeof(struct event
));
168 pipes
= calloc(num_pipes
* 2, sizeof(evutil_socket_t
));
169 if (events
== NULL
|| pipes
== NULL
) {
176 for (cp
= pipes
, i
= 0; i
< num_pipes
; i
++, cp
+= 2) {
178 if (pipe(cp
) == -1) {
180 if (evutil_socketpair(AF_UNIX
, SOCK_STREAM
, 0, cp
) == -1) {
187 for (i
= 0; i
< 25; i
++) {
191 fprintf(stdout
, "%ld\n",
192 tv
->tv_sec
* 1000000L + tv
->tv_usec
);