ComputerSurge/bind9
3
0
Fork 0
Code Pull Requests 1 Activity

per task mctx

Browse Source
This commit is contained in:
Bob Halley
1999-01-14 20:03:54 +00:00
parent aa3a328647
commit 6a50a5b6dc
2 changed files with 21 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lib/isc/include/isc/task.h
View File

@@ -1,5 +1,5 @@
/*
* Copyright (C) 1998 Internet Software Consortium.
* Copyright (C) 1998, 1999 Internet Software Consortium.
*
* Permission to use, copy, modify, and distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
@@ -83,11 +83,13 @@ void isc_event_free(isc_event_t **);
***/
isc_result_t isc_task_create(isc_taskmgr_t *,
isc_mem_t *,
unsigned int,
isc_task_t **);
void isc_task_attach(isc_task_t *,
isc_task_t **);
void isc_task_detach(isc_task_t **);
isc_mem_t * isc_task_mem(isc_task_t *);
isc_result_t isc_task_send(isc_task_t *,
isc_event_t **);
unsigned int isc_task_purge(isc_task_t *, void *,

25
lib/isc/task.c
View File

@@ -1,5 +1,5 @@
/*
* Copyright (C) 1998 Internet Software Consortium.
* Copyright (C) 1998, 1999 Internet Software Consortium.
*
* Permission to use, copy, modify, and distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
@@ -53,6 +53,7 @@ struct isc_task {
unsigned int magic;
isc_taskmgr_t * manager;
isc_mutex_t lock;
isc_mem_t * mctx;
/* Locked by task lock. */
task_state_t state;
unsigned int references;
@@ -173,7 +174,7 @@ task_free(isc_task_t *task) {
}
isc_result_t
isc_task_create(isc_taskmgr_t *manager, unsigned int quantum,
isc_task_create(isc_taskmgr_t *manager, isc_mem_t *mctx, unsigned int quantum,
isc_task_t **taskp)
{
isc_task_t *task;
@@ -181,13 +182,15 @@ isc_task_create(isc_taskmgr_t *manager, unsigned int quantum,
REQUIRE(VALID_MANAGER(manager));
REQUIRE(taskp != NULL && *taskp == NULL);
task = isc_mem_get(manager->mctx, sizeof *task);
if (mctx == NULL)
mctx = manager->mctx;
task = isc_mem_get(mctx, sizeof *task);
if (task == NULL)
return (ISC_R_NOMEMORY);
task->manager = manager;
task->mctx = mctx;
if (isc_mutex_init(&task->lock) != ISC_R_SUCCESS) {
isc_mem_put(manager->mctx, task, sizeof *task);
isc_mem_put(mctx, task, sizeof *task);
UNEXPECTED_ERROR(__FILE__, __LINE__,
"isc_mutex_init() failed");
return (ISC_R_UNEXPECTED);
@@ -251,6 +254,14 @@ isc_task_detach(isc_task_t **taskp) {
*taskp = NULL;
}
isc_mem_t *
isc_task_mem(isc_task_t *task) {
REQUIRE(VALID_TASK(task));
return (task->mctx);
}
isc_result_t
isc_task_send(isc_task_t *task, isc_event_t **eventp) {
isc_boolean_t was_idle = ISC_FALSE;
@@ -406,7 +417,7 @@ isc_task_onshutdown(isc_task_t *task, isc_taskaction_t action, void *arg) {
REQUIRE(VALID_TASK(task));
event = event_allocate(task->manager->mctx,
event = event_allocate(task->mctx,
NULL,
ISC_TASKEVENT_SHUTDOWN,
action,
@@ -427,7 +438,7 @@ isc_task_onshutdown(isc_task_t *task, isc_taskaction_t action, void *arg) {
UNLOCK(&task->lock);
if (disallowed)
isc_mem_put(task->manager->mctx, event, sizeof *event);
isc_mem_put(task->mctx, event, sizeof *event);
return (result);
}