2 * Copyright (C) 2009-2012 Internet Systems Consortium, Inc. ("ISC")
4 * Permission to use, copy, modify, and/or distribute this software for any
5 * purpose with or without fee is hereby granted, provided that the above
6 * copyright notice and this permission notice appear in all copies.
8 * THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
9 * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
10 * AND FITNESS. IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
11 * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
12 * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
13 * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
14 * PERFORMANCE OF THIS SOFTWARE.
24 #include <isc/magic.h>
25 #include <isc/mutex.h>
30 static isc_mutex_t createlock;
31 static isc_once_t once = ISC_ONCE_INIT;
32 static isc_taskmgrcreatefunc_t taskmgr_createfunc = NULL;
36 RUNTIME_CHECK(isc_mutex_init(&createlock) == ISC_R_SUCCESS);
40 isc_task_register(isc_taskmgrcreatefunc_t createfunc) {
41 isc_result_t result = ISC_R_SUCCESS;
43 RUNTIME_CHECK(isc_once_do(&once, initialize) == ISC_R_SUCCESS);
46 if (taskmgr_createfunc == NULL)
47 taskmgr_createfunc = createfunc;
49 result = ISC_R_EXISTS;
56 isc_taskmgr_createinctx(isc_mem_t *mctx, isc_appctx_t *actx,
57 unsigned int workers, unsigned int default_quantum,
58 isc_taskmgr_t **managerp)
64 REQUIRE(taskmgr_createfunc != NULL);
65 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
70 if (result == ISC_R_SUCCESS)
71 isc_appctx_settaskmgr(actx, *managerp);
77 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers,
78 unsigned int default_quantum, isc_taskmgr_t **managerp)
84 REQUIRE(taskmgr_createfunc != NULL);
85 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
94 isc_taskmgr_destroy(isc_taskmgr_t **managerp) {
95 REQUIRE(managerp != NULL && ISCAPI_TASKMGR_VALID(*managerp));
97 (*managerp)->methods->destroy(managerp);
99 ENSURE(*managerp == NULL);
103 isc_taskmgr_setmode(isc_taskmgr_t *manager, isc_taskmgrmode_t mode) {
104 REQUIRE(ISCAPI_TASKMGR_VALID(manager));
106 manager->methods->setmode(manager, mode);
110 isc_taskmgr_mode(isc_taskmgr_t *manager) {
111 REQUIRE(ISCAPI_TASKMGR_VALID(manager));
113 return (manager->methods->mode(manager));
117 isc_task_create(isc_taskmgr_t *manager, unsigned int quantum,
120 REQUIRE(ISCAPI_TASKMGR_VALID(manager));
121 REQUIRE(taskp != NULL && *taskp == NULL);
123 return (manager->methods->taskcreate(manager, quantum, taskp));
127 isc_task_attach(isc_task_t *source, isc_task_t **targetp) {
128 REQUIRE(ISCAPI_TASK_VALID(source));
129 REQUIRE(targetp != NULL && *targetp == NULL);
131 source->methods->attach(source, targetp);
133 ENSURE(*targetp == source);
137 isc_task_detach(isc_task_t **taskp) {
138 REQUIRE(taskp != NULL && ISCAPI_TASK_VALID(*taskp));
140 (*taskp)->methods->detach(taskp);
142 ENSURE(*taskp == NULL);
146 isc_task_send(isc_task_t *task, isc_event_t **eventp) {
147 REQUIRE(ISCAPI_TASK_VALID(task));
148 REQUIRE(eventp != NULL && *eventp != NULL);
150 task->methods->send(task, eventp);
152 ENSURE(*eventp == NULL);
156 isc_task_sendanddetach(isc_task_t **taskp, isc_event_t **eventp) {
157 REQUIRE(taskp != NULL && ISCAPI_TASK_VALID(*taskp));
158 REQUIRE(eventp != NULL && *eventp != NULL);
160 (*taskp)->methods->sendanddetach(taskp, eventp);
162 ENSURE(*taskp == NULL && *eventp == NULL);
166 isc_task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type,
167 void *tag, isc_eventlist_t *events)
169 REQUIRE(ISCAPI_TASK_VALID(task));
171 return (task->methods->unsend(task, sender, type, tag, events));
175 isc_task_onshutdown(isc_task_t *task, isc_taskaction_t action, const void *arg)
177 REQUIRE(ISCAPI_TASK_VALID(task));
179 return (task->methods->onshutdown(task, action, arg));
183 isc_task_shutdown(isc_task_t *task) {
184 REQUIRE(ISCAPI_TASK_VALID(task));
186 task->methods->shutdown(task);
190 isc_task_setname(isc_task_t *task, const char *name, void *tag) {
191 REQUIRE(ISCAPI_TASK_VALID(task));
193 task->methods->setname(task, name, tag);
197 isc_task_purge(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag)
199 REQUIRE(ISCAPI_TASK_VALID(task));
201 return (task->methods->purgeevents(task, sender, type, tag));
205 isc_taskmgr_setexcltask(isc_taskmgr_t *mgr, isc_task_t *task) {
206 REQUIRE(ISCAPI_TASK_VALID(task));
207 return (mgr->methods->setexcltask(mgr, task));
211 isc_taskmgr_excltask(isc_taskmgr_t *mgr, isc_task_t **taskp) {
212 return (mgr->methods->excltask(mgr, taskp));
216 isc_task_beginexclusive(isc_task_t *task) {
217 REQUIRE(ISCAPI_TASK_VALID(task));
219 return (task->methods->beginexclusive(task));
223 isc_task_endexclusive(isc_task_t *task) {
224 REQUIRE(ISCAPI_TASK_VALID(task));
226 task->methods->endexclusive(task);
230 isc_task_setprivilege(isc_task_t *task, isc_boolean_t priv) {
231 REQUIRE(ISCAPI_TASK_VALID(task));
233 task->methods->setprivilege(task, priv);
237 isc_task_privilege(isc_task_t *task) {
238 REQUIRE(ISCAPI_TASK_VALID(task));
240 return (task->methods->privilege(task));
245 * This is necessary for libisc's internal timer implementation. Other
246 * implementation might skip implementing this.
249 isc_task_purgerange(isc_task_t *task, void *sender, isc_eventtype_t first,
250 isc_eventtype_t last, void *tag)
252 REQUIRE(ISCAPI_TASK_VALID(task));
254 return (task->methods->purgerange(task, sender, first, last, tag));