/bind-9.11.3/lib/isc/ |
H A D | event.c | 9 /* $Id: event.c,v 1.21 2007/06/19 23:47:17 tbox Exp $ */ 18 #include <isc/event.h> 27 destroy(isc_event_t *event) { argument 28 isc_mem_t *mctx = event->ev_destroy_arg; 30 isc_mem_put(mctx, event, event->ev_size); 37 isc_event_t *event; local 42 event = isc_mem_get(mctx, size); 43 if (event == NULL) 46 ISC_EVENT_INIT(event, siz 56 isc_event_t *event; local 88 isc_event_t *event; local [all...] |
H A D | ratelimiter.c | 44 ratelimiter_tick(isc_task_t *task, isc_event_t *event); 47 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event); 179 isc_ratelimiter_dequeue(isc_ratelimiter_t *rl, isc_event_t *event) { argument 183 REQUIRE(event != NULL); 186 if (ISC_LINK_LINKED(event, ev_ratelink)) { 187 ISC_LIST_UNLINK(rl->pending, event, ev_ratelink); 188 event->ev_sender = NULL; 196 ratelimiter_tick(isc_task_t *task, isc_event_t *event) { argument 198 isc_ratelimiter_t *rl = (isc_ratelimiter_t *)event->ev_arg; 204 isc_event_free(&event); 267 ratelimiter_shutdowncomplete(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | task.c | 22 #include <isc/event.h> 46 * an integrated event loop for socket, timer, and other generic task events. 199 isc_task_purgeevent(isc_task_t *task0, isc_event_t *event); 419 isc_event_t *event, *prev; local 442 for (event = TAIL(task->on_shutdown); 443 event != NULL; 444 event = prev) { 445 prev = PREV(event, ev_link); 446 DEQUEUE(task->on_shutdown, event, ev_link); 447 ENQUEUE(task->events, event, ev_lin 538 isc_event_t *event; local 650 isc_event_t *event, *next_event; local 693 isc_event_t *event, *next_event; local 733 isc_task_purgeevent(isc_task_t *task0, isc_event_t *event) argument 812 isc_event_t *event; local 1105 isc_event_t *event; local [all...] |
/bind-9.11.3/bin/tests/ |
H A D | task_test.c | 26 my_callback(isc_task_t *task, isc_event_t *event) { argument 28 char *name = event->ev_arg; 34 isc_event_free(&event); 38 my_shutdown(isc_task_t *task, isc_event_t *event) { argument 39 char *name = event->ev_arg; 42 isc_event_free(&event); 46 my_tick(isc_task_t *task, isc_event_t *event) { argument 47 char *name = event->ev_arg; 50 isc_event_free(&event); 65 isc_event_t *event; local [all...] |
H A D | sock_test.c | 29 my_shutdown(isc_task_t *task, isc_event_t *event) { argument 30 char *name = event->ev_arg; 34 isc_event_free(&event); 38 my_send(isc_task_t *task, isc_event_t *event) { argument 42 sock = event->ev_sender; 43 dev = (isc_socketevent_t *)event; 47 (char *)(event->ev_arg), task, sock, 59 isc_event_free(&event); 63 my_recv(isc_task_t *task, isc_event_t *event) { argument 70 sock = event 126 my_http_get(isc_task_t *task, isc_event_t *event) argument 154 my_connect(isc_task_t *task, isc_event_t *event) argument 194 my_listen(isc_task_t *task, isc_event_t *event) argument 243 timeout(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | timer_test.c | 30 shutdown_task(isc_task_t *task, isc_event_t *event) { argument 31 char *name = event->ev_arg; 34 isc_event_free(&event); 38 tick(isc_task_t *task, isc_event_t *event) { argument 39 char *name = event->ev_arg; 41 INSIST(event->ev_type == ISC_TIMEREVENT_TICK); 62 isc_event_free(&event); 66 timeout(isc_task_t *task, isc_event_t *event) { argument 67 char *name = event->ev_arg; 70 INSIST(event [all...] |
H A D | ratelimiter_test.c | 28 static void utick(isc_task_t *task, isc_event_t *event); 29 static void shutdown_rl(isc_task_t *task, isc_event_t *event); 30 static void shutdown_all(isc_task_t *task, isc_event_t *event); 54 ltick(isc_task_t *task, isc_event_t *event) { argument 57 (event->ev_attributes & ISC_EVENTATTR_CANCELED) != 0 ? 59 isc_event_free(&event); 63 utick(isc_task_t *task, isc_event_t *event) { argument 66 event->ev_action = ltick; 67 event->ev_sender = NULL; 68 result = isc_ratelimiter_enqueue(rlim, g_task, &event); 74 shutdown_rl(isc_task_t *task, isc_event_t *event) argument 82 shutdown_all(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | shutdown_test.c | 46 t1_shutdown(isc_task_t *task, isc_event_t *event) { argument 47 t_info *info = event->ev_arg; 51 isc_event_free(&event); 55 t2_shutdown(isc_task_t *task, isc_event_t *event) { argument 56 t_info *info = event->ev_arg; 60 isc_event_free(&event); 64 shutdown_action(isc_task_t *task, isc_event_t *event) { argument 65 t_info *info = event->ev_arg; 68 INSIST(event->ev_type == ISC_TASKEVENT_SHUTDOWN); 75 sizeof(*event)); 84 foo_event(isc_task_t *task, isc_event_t *event) argument 90 tick(isc_task_t *task, isc_event_t *event) argument [all...] |
/bind-9.11.3/lib/isc/include/isc/ |
H A D | event.h | 12 /*! \file isc/event.h */ 45 * that an event is delivered as a result of a canceled operation 52 #define ISC_EVENT_INIT(event, sz, at, ta, ty, ac, ar, sn, df, da) \ 54 (event)->ev_size = (sz); \ 55 (event)->ev_attributes = (at); \ 56 (event)->ev_tag = (ta); \ 57 (event)->ev_type = (ty); \ 58 (event)->ev_action = (ac); \ 59 (event)->ev_arg = (ar); \ 60 (event) [all...] |
H A D | ratelimiter.h | 47 * Set the minimum interval between event executions. 72 * Queue an event for rate-limited execution. 80 * must ensure that the task exists until the event is delivered. 91 isc_ratelimiter_dequeue(isc_ratelimiter_t *rl, isc_event_t *event); 93 * Dequeue a event off the ratelimiter queue. 96 * \li ISC_R_NOTFOUND if the event is no longer linked to the rate limiter. 131 * Stall event processing.
|
/bind-9.11.3/lib/isc/tests/ |
H A D | task_test.c | 29 /* task event handler, sets a boolean to true */ 34 set(isc_task_t *task, isc_event_t *event) { argument 35 int *value = (int *) event->ev_arg; 39 isc_event_free(&event); 46 set_and_drop(isc_task_t *task, isc_event_t *event) { argument 47 int *value = (int *) event->ev_arg; 51 isc_event_free(&event); 94 isc_event_t *event; local 111 /* First event */ 112 event 151 isc_event_t *event; local 280 isc_event_t *event; local [all...] |
/bind-9.11.3/lib/dns/ |
H A D | lookup.c | 42 dns_lookupevent_t * event; member in struct:dns_lookup 55 static void lookup_find(dns_lookup_t *lookup, dns_fetchevent_t *event); 58 fetch_done(isc_task_t *task, isc_event_t *event) { argument 59 dns_lookup_t *lookup = event->ev_arg; 63 REQUIRE(event->ev_type == DNS_EVENT_FETCHDONE); 66 fevent = (dns_fetchevent_t *)event; 133 lookup->event->name = name; 134 lookup->event->rdataset = rdataset; 135 lookup->event->sigrdataset = sigrdataset; 165 &lookup->event 172 lookup_find(dns_lookup_t *lookup, dns_fetchevent_t *event) argument 347 levent_destroy(isc_event_t *event) argument [all...] |
H A D | byaddr.c | 34 * XXXRTH We could use a static event... 117 dns_byaddrevent_t * event; member in struct:dns_byaddr 155 ISC_LIST_APPEND(byaddr->event->names, name, link); 166 lookup_done(isc_task_t *task, isc_event_t *event) { argument 167 dns_byaddr_t *byaddr = event->ev_arg; 171 REQUIRE(event->ev_type == DNS_EVENT_LOOKUPDONE); 177 levent = (dns_lookupevent_t *)event; 181 byaddr->event->result = result; 183 byaddr->event->result = levent->result; 184 isc_event_free(&event); 189 bevent_destroy(isc_event_t *event) argument [all...] |
H A D | validator.c | 175 if (val->event->rdataset != NULL) 176 dns_rdataset_settrust(val->event->rdataset, dns_trust_answer); 177 if (val->event->sigrdataset != NULL) 178 dns_rdataset_settrust(val->event->sigrdataset, 183 marksecure(dns_validatorevent_t *event) { argument 184 dns_rdataset_settrust(event->rdataset, dns_trust_secure); 185 if (event->sigrdataset != NULL) 186 dns_rdataset_settrust(event->sigrdataset, dns_trust_secure); 187 event->secure = ISC_TRUE; 194 if (val->event 381 fetch_callback_validator(isc_task_t *task, isc_event_t *event) argument 464 dsfetched(isc_task_t *task, isc_event_t *event) argument 546 dsfetched2(isc_task_t *task, isc_event_t *event) argument 640 keyvalidated(isc_task_t *task, isc_event_t *event) argument 711 dsvalidated(isc_task_t *task, isc_event_t *event) argument 788 cnamevalidated(isc_task_t *task, isc_event_t *event) argument 844 authvalidated(isc_task_t *task, isc_event_t *event) argument 1562 dns_validatorevent_t *event; local 1935 dns_validatorevent_t *event; local 2911 dlvvalidated(isc_task_t *task, isc_event_t *event) argument 2969 dlvfetched(isc_task_t *task, isc_event_t *event) argument 3587 isc_event_t *event; local 3614 validator_start(isc_task_t *task, isc_event_t *event) argument 3738 dns_validatorevent_t *event; local 3834 isc_event_t *event; local [all...] |
H A D | request.c | 72 dns_requestevent_t *event; member in struct:dns_request 113 static void req_senddone(isc_task_t *task, isc_event_t *event); 114 static void req_response(isc_task_t *task, isc_event_t *event); 115 static void req_timeout(isc_task_t *task, isc_event_t *event); 117 static void req_connected(isc_task_t *task, isc_event_t *event); 122 static void do_cancel(isc_task_t *task, isc_event_t *event); 211 isc_event_t *event; local 218 event = *eventp; 225 * We're already shutdown. Send the event. 227 event 366 isc_event_t *event, *next_event; local 1246 do_cancel(isc_task_t *task, isc_event_t *event) argument 1360 req_connected(isc_task_t *task, isc_event_t *event) argument 1398 req_senddone(isc_task_t *task, isc_event_t *event) argument 1431 req_response(isc_task_t *task, isc_event_t *event) argument 1475 req_timeout(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | client.c | 138 dns_clientresevent_t *event; member in struct:resctx 145 * Argument of an internal event for synchronous name resolution. 176 dns_clientreqevent_t *event; member in struct:reqctx 180 * Argument of an internal event for synchronous DNS request. 195 * Argument of an internal event for synchronous name resolution. 233 dns_clientupdateevent_t *event; member in struct:updatectx 248 static void client_resfind(resctx_t *rctx, dns_fetchevent_t *event); 753 fetch_done(isc_task_t *task, isc_event_t *event) { argument 754 resctx_t *rctx = event->ev_arg; 757 REQUIRE(event 816 client_resfind(resctx_t *rctx, dns_fetchevent_t *event) argument 1174 suspend(isc_task_t *task, isc_event_t *event) argument 1184 resolve_done(isc_task_t *task, isc_event_t *event) argument 1322 dns_clientresevent_t *event = NULL; local 1567 request_done(isc_task_t *task, isc_event_t *event) argument 1606 localrequest_done(isc_task_t *task, isc_event_t *event) argument 1730 dns_clientreqevent_t *event = NULL; local 1941 update_done(isc_task_t *task, isc_event_t *event) argument 2083 resolveaddr_done(isc_task_t *task, isc_event_t *event) argument 2268 receive_soa(isc_task_t *task, isc_event_t *event) argument 2510 resolvesoa_done(isc_task_t *task, isc_event_t *event) argument 2665 internal_update_callback(isc_task_t *task, isc_event_t *event) argument 2776 startupdate(isc_task_t *task, isc_event_t *event) argument 2979 isc_event_t *event; local [all...] |
/bind-9.11.3/bin/tests/tasks/ |
H A D | t_tasks.c | 45 t1_callback(isc_task_t *task, isc_event_t *event) { argument 56 t_info("task %s\n", (char *)event->ev_arg); 57 isc_event_free(&event); 61 t1_shutdown(isc_task_t *task, isc_event_t *event) { argument 65 t_info("shutdown %s\n", (char *)event->ev_arg); 66 isc_event_free(&event); 70 my_tick(isc_task_t *task, isc_event_t *event) { argument 74 t_info("%s\n", (char *)event->ev_arg); 75 isc_event_free(&event); 98 isc_event_t *event; local 407 t2_shutdown(isc_task_t *task, isc_event_t *event) argument 444 t2_callback(isc_task_t *task, isc_event_t *event) argument 492 isc_event_t *event; local 604 t3_sde1(isc_task_t *task, isc_event_t *event) argument 622 t3_sde2(isc_task_t *task, isc_event_t *event) argument 640 t3_event1(isc_task_t *task, isc_event_t *event) argument 665 t3_event2(isc_task_t *task, isc_event_t *event) argument 681 isc_event_t *event; local 869 t4_event1(isc_task_t *task, isc_event_t *event) argument 894 t4_sde(isc_task_t *task, isc_event_t *event) argument 914 isc_event_t *event; local 1081 t7_event1(isc_task_t *task, isc_event_t *event) argument 1090 t7_sde(isc_task_t *task, isc_event_t *event) argument 1131 isc_event_t *event; local 1321 t10_event1(isc_task_t *task, isc_event_t *event) argument 1353 t10_event2(isc_task_t *task, isc_event_t *event) argument 1412 t10_sde(isc_task_t *task, isc_event_t *event) argument 1454 isc_event_t *event; local 1799 t11_event1(isc_task_t *task, isc_event_t *event) argument 1831 t11_event2(isc_task_t *task, isc_event_t *event) argument 1840 t11_sde(isc_task_t *task, isc_event_t *event) argument 2226 t14_callback(isc_task_t *task, isc_event_t *event) argument 2309 isc_event_t *event; local [all...] |
/bind-9.11.3/bin/tests/atomic/ |
H A D | t_atomic.c | 19 #include <isc/event.h> 84 isc_event_t *event; local 96 * Create our tasks, and allocate an event to get the counters going. 101 event = isc_event_allocate(mctx, NULL, 1000, do_xadd, 103 isc_task_sendanddetach(&tasks[i], &event); 142 isc_event_t *event; local 154 * Create our tasks, and allocate an event to get the counters going. 159 event = isc_event_allocate(mctx, NULL, 1000, do_xaddq, 161 isc_task_sendanddetach(&tasks[i], &event); 206 isc_event_t *event; local 280 isc_event_t *event; local [all...] |
/bind-9.11.3/bin/tests/dst/ |
H A D | gsstest.c | 83 static void initctx1(isc_task_t *task, isc_event_t *event); 84 static void sendquery(isc_task_t *task, isc_event_t *event); 88 console(isc_task_t *task, isc_event_t *event) argument 95 isc_event_free(&event); 108 NULL, sizeof(*event)); 115 NULL, sizeof(*event)); 125 recvresponse(isc_task_t *task, isc_event_t *event) { argument 126 dns_requestevent_t *reqev = (dns_requestevent_t *)event; 143 fprintf(stderr, "I:request event result: %s\n", 175 isc_event_free(&event); 185 sendquery(isc_task_t *task, isc_event_t *event) argument 261 initctx2(isc_task_t *task, isc_event_t *event) argument 341 initctx1(isc_task_t *task, isc_event_t *event) argument [all...] |
/bind-9.11.3/lib/dns/tests/ |
H A D | dispatch_test.c | 141 senddone(isc_task_t *task, isc_event_t *event) { argument 142 isc_socket_t *sock = event->ev_arg; 147 isc_event_free(&event); 151 nameserver(isc_task_t *task, isc_event_t *event) { argument 155 isc_socket_t *sock = event->ev_arg; 156 isc_socketevent_t *ev = (isc_socketevent_t *)event; 191 isc_event_free(&event); 202 response(isc_task_t *task, isc_event_t *event) { argument 203 dns_dispatchevent_t *devent = (dns_dispatchevent_t *)event; 225 startit(isc_task_t *task, isc_event_t *event) { argument [all...] |
/bind-9.11.3/lib/dns/include/dns/ |
H A D | lookup.h | 43 #include <isc/event.h> 53 * with the address. The recipient of the event must not change the list 54 * and must not refer to any of the name data after the event is freed. 101 *\li If 'lookup' has not completed, post its LOOKUPDONE event with a 118 *\li The caller has received the LOOKUPDONE event (either because the
|
H A D | tcpmsg.h | 31 isc_event_t event; member in struct:dns_tcpmsg 74 * Schedule an event to be delivered when a DNS message is readable, or 90 *\li The event delivered is a fully generic event. It will contain no 99 * Cancel a readmessage() call. The event will still be posted with a
|
/bind-9.11.3/lib/isc/win32/ |
H A D | app.c | 27 #include <isc/event.h> 170 /* Create the reload event in a non-signaled state */ 173 /* Create the shutdown event in a non-signaled state */ 204 isc_event_t *event; local 216 * Note that we store the task to which we're going to send the event 217 * in the event's "sender" field. 220 event = isc_event_allocate(mctx, cloned_task, ISC_APPEVENT_SHUTDOWN, 221 action, arg, sizeof(*event)); 222 if (event == NULL) { 227 ISC_LINK_INIT(event, ev_lin 241 isc_event_t *event, *next_event; local [all...] |
/bind-9.11.3/bin/named/ |
H A D | lwdgnba.c | 29 byaddr_done(isc_task_t *task, isc_event_t *event) { argument 46 client = event->ev_arg; 48 INSIST(client->byaddr == (dns_byaddr_t *)event->ev_sender); 50 bevent = (dns_byaddrevent_t *)event; 53 ns_lwdclient_log(50, "byaddr event result = %s", 59 isc_event_free(&event); 112 isc_event_free(&event); 146 if (event != NULL) 147 isc_event_free(&event);
|
/bind-9.11.3/bin/tests/timers/ |
H A D | t_timers.c | 54 tx_sde(isc_task_t *task, isc_event_t *event) { argument 58 UNUSED(event); 84 isc_event_free(&event); 88 tx_te(isc_task_t *task, isc_event_t *event) { argument 102 if ((isc_timertype_t) event->ev_arg == isc_timertype_ticker) 105 if (event->ev_type != expected_event_type) { 106 t_info("expected event type %d, got %d\n", 107 expected_event_type, (int) event->ev_type); 172 isc_event_free(&event); 351 "creates a timer that posts an ISC_TIMEREVENT_TICK event t 436 t3_te(isc_task_t *task, isc_event_t *event) argument 565 t4_te(isc_task_t *task, isc_event_t *event) argument 734 t5_start_event(isc_task_t *task, isc_event_t *event) argument 762 t5_tick_event(isc_task_t *task, isc_event_t *event) argument 793 t5_once_event(isc_task_t *task, isc_event_t *event) argument 830 t5_shutdown_event(isc_task_t *task, isc_event_t *event) argument 876 isc_event_t *event; local [all...] |