/bind-9.6-ESV-R11/lib/isc/ |
H A D | event.c | 18 /* $Id: event.c,v 1.21 2007/06/19 23:47:17 tbox Exp $ */ 27 #include <isc/event.h> 36 destroy(isc_event_t *event) { argument 37 isc_mem_t *mctx = event->ev_destroy_arg; 39 isc_mem_put(mctx, event, event->ev_size); 46 isc_event_t *event; local 52 event = isc_mem_get(mctx, size); 53 if (event == NULL) 58 * evils here. If the event 78 isc_event_t *event; local [all...] |
H A D | task.c | 32 #include <isc/event.h> 248 isc_event_t *event, *prev; local 270 for (event = TAIL(task->on_shutdown); 271 event != NULL; 272 event = prev) { 273 prev = PREV(event, ev_link); 274 DEQUEUE(task->on_shutdown, event, ev_link); 275 ENQUEUE(task->events, event, ev_link); 320 * make the task ready and allow run() or the event 358 isc_event_t *event; local 467 isc_event_t *event, *next_event; local 508 isc_event_t *event, *next_event; local 547 isc_task_purgeevent(isc_task_t *task, isc_event_t *event) argument 622 isc_event_t *event; local 826 isc_event_t *event; local [all...] |
/bind-9.6-ESV-R11/bin/tests/ |
H A D | task_test.c | 34 my_callback(isc_task_t *task, isc_event_t *event) { argument 36 char *name = event->ev_arg; 42 isc_event_free(&event); 46 my_shutdown(isc_task_t *task, isc_event_t *event) { argument 47 char *name = event->ev_arg; 50 isc_event_free(&event); 54 my_tick(isc_task_t *task, isc_event_t *event) { argument 55 char *name = event->ev_arg; 58 isc_event_free(&event); 66 isc_event_t *event; local [all...] |
H A D | sock_test.c | 37 my_shutdown(isc_task_t *task, isc_event_t *event) { argument 38 char *name = event->ev_arg; 42 isc_event_free(&event); 46 my_send(isc_task_t *task, isc_event_t *event) { argument 50 sock = event->ev_sender; 51 dev = (isc_socketevent_t *)event; 55 (char *)(event->ev_arg), task, sock, 66 isc_event_free(&event); 70 my_recv(isc_task_t *task, isc_event_t *event) { argument 77 sock = event 130 my_http_get(isc_task_t *task, isc_event_t *event) argument 156 my_connect(isc_task_t *task, isc_event_t *event) argument 191 my_listen(isc_task_t *task, isc_event_t *event) argument 240 timeout(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | ratelimiter_test.c | 36 static void utick(isc_task_t *task, isc_event_t *event); 37 static void shutdown_rl(isc_task_t *task, isc_event_t *event); 38 static void shutdown_all(isc_task_t *task, isc_event_t *event); 62 ltick(isc_task_t *task, isc_event_t *event) { argument 65 (event->ev_attributes & ISC_EVENTATTR_CANCELED) != 0 ? 67 isc_event_free(&event); 71 utick(isc_task_t *task, isc_event_t *event) { argument 74 event->ev_action = ltick; 75 event->ev_sender = NULL; 76 result = isc_ratelimiter_enqueue(rlim, g_task, &event); 82 shutdown_rl(isc_task_t *task, isc_event_t *event) argument 90 shutdown_all(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | timer_test.c | 38 shutdown_task(isc_task_t *task, isc_event_t *event) { argument 39 char *name = event->ev_arg; 42 isc_event_free(&event); 46 tick(isc_task_t *task, isc_event_t *event) { argument 47 char *name = event->ev_arg; 49 INSIST(event->ev_type == ISC_TIMEREVENT_TICK); 70 isc_event_free(&event); 74 timeout(isc_task_t *task, isc_event_t *event) { argument 75 char *name = event->ev_arg; 78 INSIST(event [all...] |
H A D | shutdown_test.c | 54 t1_shutdown(isc_task_t *task, isc_event_t *event) { argument 55 t_info *info = event->ev_arg; 59 isc_event_free(&event); 63 t2_shutdown(isc_task_t *task, isc_event_t *event) { argument 64 t_info *info = event->ev_arg; 68 isc_event_free(&event); 72 shutdown_action(isc_task_t *task, isc_event_t *event) { argument 73 t_info *info = event->ev_arg; 76 INSIST(event->ev_type == ISC_TASKEVENT_SHUTDOWN); 83 sizeof(*event)); 92 foo_event(isc_task_t *task, isc_event_t *event) argument 98 tick(isc_task_t *task, isc_event_t *event) argument [all...] |
/bind-9.6-ESV-R11/lib/isc/include/isc/ |
H A D | event.h | 18 /* $Id: event.h,v 1.34 2007/06/19 23:47:18 tbox Exp $ */ 23 /*! \file isc/event.h */ 55 * that an event is delivered as a result of a canceled operation 62 #define ISC_EVENT_INIT(event, sz, at, ta, ty, ac, ar, sn, df, da) \ 64 (event)->ev_size = (sz); \ 65 (event)->ev_attributes = (at); \ 66 (event)->ev_tag = (ta); \ 67 (event)->ev_type = (ty); \ 68 (event)->ev_action = (ac); \ 69 (event) [all...] |
H A D | httpd.h | 24 #include <isc/event.h>
|
/bind-9.6-ESV-R11/lib/dns/ |
H A D | lookup.c | 51 dns_lookupevent_t * event; member in struct:dns_lookup 64 static void lookup_find(dns_lookup_t *lookup, dns_fetchevent_t *event); 67 fetch_done(isc_task_t *task, isc_event_t *event) { argument 68 dns_lookup_t *lookup = event->ev_arg; 72 REQUIRE(event->ev_type == DNS_EVENT_FETCHDONE); 75 fevent = (dns_fetchevent_t *)event; 142 lookup->event->name = name; 143 lookup->event->rdataset = rdataset; 144 lookup->event->sigrdataset = sigrdataset; 174 &lookup->event 181 lookup_find(dns_lookup_t *lookup, dns_fetchevent_t *event) argument 356 levent_destroy(isc_event_t *event) argument [all...] |
H A D | byaddr.c | 43 * XXXRTH We could use a static event... 56 dns_byaddrevent_t * event; member in struct:dns_byaddr 161 ISC_LIST_APPEND(byaddr->event->names, name, link); 172 lookup_done(isc_task_t *task, isc_event_t *event) { argument 173 dns_byaddr_t *byaddr = event->ev_arg; 177 REQUIRE(event->ev_type == DNS_EVENT_LOOKUPDONE); 183 levent = (dns_lookupevent_t *)event; 187 byaddr->event->result = result; 189 byaddr->event->result = levent->result; 190 isc_event_free(&event); 195 bevent_destroy(isc_event_t *event) argument [all...] |
H A D | validator.c | 186 if (val->event->rdataset != NULL) 187 dns_rdataset_settrust(val->event->rdataset, dns_trust_answer); 188 if (val->event->sigrdataset != NULL) 189 dns_rdataset_settrust(val->event->sigrdataset, 194 marksecure(dns_validatorevent_t *event) { argument 195 dns_rdataset_settrust(event->rdataset, dns_trust_secure); 196 if (event->sigrdataset != NULL) 197 dns_rdataset_settrust(event->sigrdataset, dns_trust_secure); 198 event->secure = ISC_TRUE; 205 if (val->event 391 fetch_callback_validator(isc_task_t *task, isc_event_t *event) argument 474 dsfetched(isc_task_t *task, isc_event_t *event) argument 556 dsfetched2(isc_task_t *task, isc_event_t *event) argument 649 keyvalidated(isc_task_t *task, isc_event_t *event) argument 720 dsvalidated(isc_task_t *task, isc_event_t *event) argument 797 cnamevalidated(isc_task_t *task, isc_event_t *event) argument 853 authvalidated(isc_task_t *task, isc_event_t *event) argument 1515 dns_validatorevent_t *event; local 1847 dns_validatorevent_t *event; local 2862 dlvvalidated(isc_task_t *task, isc_event_t *event) argument 2920 dlvfetched(isc_task_t *task, isc_event_t *event) argument 3504 isc_event_t *event; local 3531 validator_start(isc_task_t *task, isc_event_t *event) argument 3651 dns_validatorevent_t *event; local 3740 isc_event_t *event; local [all...] |
H A D | request.c | 81 dns_requestevent_t *event; member in struct:dns_request 121 static void req_senddone(isc_task_t *task, isc_event_t *event); 122 static void req_response(isc_task_t *task, isc_event_t *event); 123 static void req_timeout(isc_task_t *task, isc_event_t *event); 125 static void req_connected(isc_task_t *task, isc_event_t *event); 130 static void do_cancel(isc_task_t *task, isc_event_t *event); 219 isc_event_t *event; local 226 event = *eventp; 233 * We're already shutdown. Send the event. 235 event 374 isc_event_t *event, *next_event; local 1142 do_cancel(isc_task_t *task, isc_event_t *event) argument 1256 req_connected(isc_task_t *task, isc_event_t *event) argument 1294 req_senddone(isc_task_t *task, isc_event_t *event) argument 1327 req_response(isc_task_t *task, isc_event_t *event) argument 1371 req_timeout(isc_task_t *task, isc_event_t *event) argument [all...] |
H A D | cache.c | 89 * task/event serialization, or locked from the cache object. 153 cleaning_timer_action(isc_task_t *task, isc_event_t *event); 156 incremental_cleaning_action(isc_task_t *task, isc_event_t *event); 159 cleaner_shutdown_action(isc_task_t *task, isc_event_t *event); 162 overmem_cleaning_action(isc_task_t *task, isc_event_t *event); 707 end_cleaning(cache_cleaner_t *cleaner, isc_event_t *event) { argument 711 REQUIRE(event != NULL); 725 cleaner->resched_event = event; 732 cleaning_timer_action(isc_task_t *task, isc_event_t *event) { argument 733 cache_cleaner_t *cleaner = event 755 overmem_cleaning_action(isc_task_t *task, isc_event_t *event) argument 800 incremental_cleaning_action(isc_task_t *task, isc_event_t *event) argument 1028 cleaner_shutdown_action(isc_task_t *task, isc_event_t *event) argument [all...] |
/bind-9.6-ESV-R11/lib/isc/win32/ |
H A D | app.c | 35 #include <isc/event.h> 91 /* Create the reload event in a non-signaled state */ 94 /* Create the shutdown event in a non-signaled state */ 104 isc_event_t *event; local 116 * Note that we store the task to which we're going to send the event 117 * in the event's "sender" field. 120 event = isc_event_allocate(mctx, cloned_task, ISC_APPEVENT_SHUTDOWN, 121 action, arg, sizeof(*event)); 122 if (event == NULL) { 127 ISC_LIST_APPEND(on_run, event, ev_lin 137 isc_event_t *event, *next_event; local [all...] |
/bind-9.6-ESV-R11/bin/tests/tasks/ |
H A D | t_tasks.c | 54 t1_callback(isc_task_t *task, isc_event_t *event) { argument 65 t_info("task %s\n", (char *)event->ev_arg); 66 isc_event_free(&event); 70 t1_shutdown(isc_task_t *task, isc_event_t *event) { argument 74 t_info("shutdown %s\n", (char *)event->ev_arg); 75 isc_event_free(&event); 79 my_tick(isc_task_t *task, isc_event_t *event) { argument 83 t_info("%s\n", (char *)event->ev_arg); 84 isc_event_free(&event); 100 isc_event_t *event; local 401 t2_shutdown(isc_task_t *task, isc_event_t *event) argument 438 t2_callback(isc_task_t *task, isc_event_t *event) argument 486 isc_event_t *event; local 598 t3_sde1(isc_task_t *task, isc_event_t *event) argument 616 t3_sde2(isc_task_t *task, isc_event_t *event) argument 634 t3_event1(isc_task_t *task, isc_event_t *event) argument 659 t3_event2(isc_task_t *task, isc_event_t *event) argument 675 isc_event_t *event; local 863 t4_event1(isc_task_t *task, isc_event_t *event) argument 888 t4_sde(isc_task_t *task, isc_event_t *event) argument 908 isc_event_t *event; local 1063 t7_event1(isc_task_t *task, isc_event_t *event) argument 1072 t7_sde(isc_task_t *task, isc_event_t *event) argument 1113 isc_event_t *event; local 1304 t10_event1(isc_task_t *task, isc_event_t *event) argument 1336 t10_event2(isc_task_t *task, isc_event_t *event) argument 1395 t10_sde(isc_task_t *task, isc_event_t *event) argument 1437 isc_event_t *event; local 1783 t11_event1(isc_task_t *task, isc_event_t *event) argument 1815 t11_event2(isc_task_t *task, isc_event_t *event) argument 1824 t11_sde(isc_task_t *task, isc_event_t *event) argument 2211 t14_callback(isc_task_t *task, isc_event_t *event) argument 2294 isc_event_t *event; local [all...] |
/bind-9.6-ESV-R11/bin/tests/dst/ |
H A D | gsstest.c | 93 static void initctx1(isc_task_t *task, isc_event_t *event); 94 static void sendquery(isc_task_t *task, isc_event_t *event); 98 console(isc_task_t *task, isc_event_t *event) argument 103 isc_event_free(&event); 116 NULL, sizeof(*event)); 123 NULL, sizeof(*event)); 133 recvresponse(isc_task_t *task, isc_event_t *event) { argument 134 dns_requestevent_t *reqev = (dns_requestevent_t *)event; 151 fprintf(stderr, "I:request event result: %s\n", 183 isc_event_free(&event); 193 sendquery(isc_task_t *task, isc_event_t *event) argument 268 initctx2(isc_task_t *task, isc_event_t *event) argument 348 initctx1(isc_task_t *task, isc_event_t *event) argument [all...] |
/bind-9.6-ESV-R11/lib/dns/include/dns/ |
H A D | lookup.h | 52 #include <isc/event.h> 62 * with the address. The recipient of the event must not change the list 63 * and must not refer to any of the name data after the event is freed. 110 *\li If 'lookup' has not completed, post its LOOKUPDONE event with a 127 *\li The caller has received the LOOKUPDONE event (either because the
|
H A D | byaddr.h | 51 #include <isc/event.h> 61 * with the address. The recipient of the event must not change the list 62 * and must not refer to any of the name data after the event is freed. 125 * event with a result code of #ISC_R_CANCELED. 141 *\li The caller has received the #DNS_EVENT_BYADDRDONE event (either because
|
H A D | tcpmsg.h | 40 isc_event_t event; member in struct:dns_tcpmsg 83 * Schedule an event to be delivered when a DNS message is readable, or 99 *\li The event delivered is a fully generic event. It will contain no 108 * Cancel a readmessage() call. The event will still be posted with a
|
H A D | validator.h | 59 #include <isc/event.h> 133 dns_validatorevent_t * event; member in struct:dns_validator 242 * event, it will send it with result code ISC_R_CANCELED. 253 * event.
|
/bind-9.6-ESV-R11/lib/isc/unix/ |
H A D | app.c | 42 #include <isc/event.h> 265 isc_event_t *event; local 277 * Note that we store the task to which we're going to send the event 278 * in the event's "sender" field. 281 event = isc_event_allocate(mctx, cloned_task, ISC_APPEVENT_SHUTDOWN, 282 action, arg, sizeof(*event)); 283 if (event == NULL) { 288 ISC_LIST_APPEND(on_run, event, ev_link); 347 * timeout event actually, but there is no other way 373 * event loo 433 isc_event_t *event, *next_event; local [all...] |
/bind-9.6-ESV-R11/bin/named/ |
H A D | lwdgnba.c | 38 byaddr_done(isc_task_t *task, isc_event_t *event) { argument 55 client = event->ev_arg; 57 INSIST(client->byaddr == (dns_byaddr_t *)event->ev_sender); 59 bevent = (dns_byaddrevent_t *)event; 62 ns_lwdclient_log(50, "byaddr event result = %s", 68 isc_event_free(&event); 121 isc_event_free(&event); 155 if (event != NULL) 156 isc_event_free(&event);
|
/bind-9.6-ESV-R11/bin/tests/timers/ |
H A D | t_timers.c | 63 tx_sde(isc_task_t *task, isc_event_t *event) { argument 67 UNUSED(event); 93 isc_event_free(&event); 97 tx_te(isc_task_t *task, isc_event_t *event) { argument 111 if ((isc_timertype_t) event->ev_arg == isc_timertype_ticker) 114 if (event->ev_type != expected_event_type) { 115 t_info("expected event type %d, got %d\n", 116 expected_event_type, (int) event->ev_type); 182 isc_event_free(&event); 361 "creates a timer that posts an ISC_TIMEREVENT_TICK event t 446 t3_te(isc_task_t *task, isc_event_t *event) argument 576 t4_te(isc_task_t *task, isc_event_t *event) argument 746 t5_start_event(isc_task_t *task, isc_event_t *event) argument 774 t5_tick_event(isc_task_t *task, isc_event_t *event) argument 805 t5_once_event(isc_task_t *task, isc_event_t *event) argument 842 t5_shutdown_event(isc_task_t *task, isc_event_t *event) argument 888 isc_event_t *event; local [all...] |
/bind-9.6-ESV-R11/lib/isccc/include/isccc/ |
H A D | ccmsg.h | 55 isc_event_t event; member in struct:isccc_ccmsg 98 * Schedule an event to be delivered when a command channel message is 114 *\li The event delivered is a fully generic event. It will contain no 123 * Cancel a readmessage() call. The event will still be posted with a
|