Searched refs:event (Results 1 - 25 of 99) sorted by relevance

1234

/bind-9.11.3/lib/isc/
H A Devent.c9 /* $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 Dratelimiter.c44 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 Dtask.c22 #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 Dtask_test.c26 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 Dsock_test.c29 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 Dtimer_test.c30 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 Dratelimiter_test.c28 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 Dshutdown_test.c46 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 Devent.h12 /*! \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 Dratelimiter.h47 * 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 Dtask_test.c29 /* 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 Dlookup.c42 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 Dbyaddr.c34 * 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 Dvalidator.c175 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 Drequest.c72 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 Dclient.c138 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 Dt_tasks.c45 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 Dt_atomic.c19 #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 Dgsstest.c83 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 Ddispatch_test.c141 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 Dlookup.h43 #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 Dtcpmsg.h31 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 Dapp.c27 #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 Dlwdgnba.c29 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 Dt_timers.c54 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...]

Completed in 69 milliseconds

1234