1 /* $NetBSD: test-dumpevents.c,v 1.5 2020/05/25 20:47:34 christos Exp $ */ 2 3 /* 4 * Copyright (c) 2012 Niels Provos and Nick Mathewson 5 * 6 * Redistribution and use in source and binary forms, with or without 7 * modification, are permitted provided that the following conditions 8 * are met: 9 * 1. Redistributions of source code must retain the above copyright 10 * notice, this list of conditions and the following disclaimer. 11 * 2. Redistributions in binary form must reproduce the above copyright 12 * notice, this list of conditions and the following disclaimer in the 13 * documentation and/or other materials provided with the distribution. 14 * 3. The name of the author may not be used to endorse or promote products 15 * derived from this software without specific prior written permission. 16 * 17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR 18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. 20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, 21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT 22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF 26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 27 */ 28 #include "util-internal.h" 29 #include "event2/event-config.h" 30 31 #ifdef _WIN32 32 #include <winsock2.h> 33 #include <windows.h> 34 #else 35 #include <unistd.h> 36 #endif 37 38 #include <stdio.h> 39 #include <event2/event.h> 40 #include <signal.h> 41 42 static void 43 sock_perror(const char *s) 44 { 45 #ifdef _WIN32 46 const char *err = evutil_socket_error_to_string(EVUTIL_SOCKET_ERROR()); 47 fprintf(stderr, "%s: %s\n", s, err); 48 #else 49 perror(s); 50 #endif 51 } 52 53 static void 54 callback1(evutil_socket_t fd, short events, void *arg) 55 { 56 } 57 static void 58 callback2(evutil_socket_t fd, short events, void *arg) 59 { 60 } 61 62 /* Testing code for event_base_dump_events(). 63 64 Notes that just because we have code to exercise this function, 65 doesn't mean that *ANYTHING* about the output format is guaranteed to 66 remain in the future. 67 */ 68 int 69 main(int argc, char **argv) 70 { 71 #define N_EVENTS 13 72 int i; 73 struct event *ev[N_EVENTS]; 74 evutil_socket_t pair1[2]; 75 evutil_socket_t pair2[2]; 76 struct timeval tv_onesec = {1,0}; 77 struct timeval tv_two5sec = {2,500*1000}; 78 const struct timeval *tv_onesec_common; 79 const struct timeval *tv_two5sec_common; 80 struct event_base *base; 81 struct timeval now; 82 83 #ifdef _WIN32 84 WORD wVersionRequested; 85 WSADATA wsaData; 86 87 wVersionRequested = MAKEWORD(2, 2); 88 89 WSAStartup(wVersionRequested, &wsaData); 90 #endif 91 92 #ifdef _WIN32 93 #define LOCAL_SOCKETPAIR_AF AF_INET 94 #else 95 #define LOCAL_SOCKETPAIR_AF AF_UNIX 96 #endif 97 98 if (evutil_make_internal_pipe_(pair1) < 0 || 99 evutil_make_internal_pipe_(pair2) < 0) { 100 sock_perror("evutil_make_internal_pipe_"); 101 return 1; 102 } 103 104 if (!(base = event_base_new())) { 105 fprintf(stderr,"Couldn't make event_base\n"); 106 return 2; 107 } 108 109 tv_onesec_common = event_base_init_common_timeout(base, &tv_onesec); 110 tv_two5sec_common = event_base_init_common_timeout(base, &tv_two5sec); 111 112 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL); 113 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); 114 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL); 115 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); 116 117 /* For timers */ 118 ev[4] = evtimer_new(base, callback1, NULL); 119 ev[5] = evtimer_new(base, callback1, NULL); 120 ev[6] = evtimer_new(base, callback1, NULL); 121 ev[7] = event_new(base, -1, EV_PERSIST, callback2, NULL); 122 ev[8] = event_new(base, -1, EV_PERSIST, callback2, NULL); 123 ev[9] = event_new(base, -1, EV_PERSIST, callback2, NULL); 124 125 /* To activate */ 126 ev[10] = event_new(base, -1, 0, callback1, NULL); 127 ev[11] = event_new(base, -1, 0, callback2, NULL); 128 129 /* Signals */ 130 ev[12] = evsignal_new(base, SIGINT, callback2, NULL); 131 132 event_add(ev[0], NULL); 133 event_add(ev[1], &tv_onesec); 134 event_add(ev[2], tv_onesec_common); 135 event_add(ev[3], tv_two5sec_common); 136 137 event_add(ev[4], tv_onesec_common); 138 event_add(ev[5], tv_onesec_common); 139 event_add(ev[6], &tv_onesec); 140 event_add(ev[7], tv_two5sec_common); 141 event_add(ev[8], tv_onesec_common); 142 event_add(ev[9], &tv_two5sec); 143 144 event_active(ev[10], EV_READ, 1); 145 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); 146 event_active(ev[1], EV_READ, 1); 147 148 event_add(ev[12], NULL); 149 150 evutil_gettimeofday(&now,NULL); 151 puts("=====expected"); 152 printf("Now= %ld.%06d\n",(long)now.tv_sec,(int)now.tv_usec); 153 puts("Inserted:"); 154 printf(" %p [fd %ld] Write\n",ev[0],(long)pair1[0]); 155 printf(" %p [fd %ld] Read Persist Timeout=T+1\n",ev[1],(long)pair1[1]); 156 printf(" %p [fd %ld] Write Persist Timeout=T+1\n",ev[2],(long)pair2[0]); 157 printf(" %p [fd %ld] Read Timeout=T+2.5\n",ev[3],(long)pair2[1]); 158 printf(" %p [fd -1] Timeout=T+1\n",ev[4]); 159 printf(" %p [fd -1] Timeout=T+1\n",ev[5]); 160 printf(" %p [fd -1] Timeout=T+1\n",ev[6]); 161 printf(" %p [fd -1] Persist Timeout=T+2.5\n",ev[7]); 162 printf(" %p [fd -1] Persist Timeout=T+1\n",ev[8]); 163 printf(" %p [fd -1] Persist Timeout=T+2.5\n",ev[9]); 164 printf(" %p [sig %d] Signal Persist\n", ev[12], (int)SIGINT); 165 166 puts("Active:"); 167 printf(" %p [fd -1, priority=0] Read active\n", ev[10]); 168 printf(" %p [fd -1, priority=0] Read Write Timeout active\n", ev[11]); 169 printf(" %p [fd %ld, priority=0] Read active\n", ev[1], (long)pair1[1]); 170 171 puts("======received"); 172 event_base_dump_events(base, stdout); 173 174 for (i = 0; i < N_EVENTS; ++i) { 175 event_free(ev[i]); 176 } 177 event_base_free(base); 178 179 return 0; 180 } 181 182
Indexes created Sat Feb 28 05:31:39 UTC 2026