Team/image stuff now uses lists instead of kqueues.

The kernel_daemon now utilizes the updated list API.


git-svn-id: file:///srv/svn/repos/haiku/trunk/current@2567 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
Axel Dörfler 2003-01-26 23:31:38 +00:00
parent 878c4156af
commit 429578fb0b
3 changed files with 19 additions and 20 deletions

View File

@ -49,7 +49,7 @@ register_image(team_id teamID, image_info *_info, size_t size)
team = team_get_team_struct_locked(teamID); team = team_get_team_struct_locked(teamID);
if (team) { if (team) {
image->info.id = id; image->info.id = id;
insque(image, &team->image_queue); list_add_item(&team->image_list, image);
} }
RELEASE_TEAM_LOCK(); RELEASE_TEAM_LOCK();
@ -67,7 +67,6 @@ status_t
unregister_image(team_id teamID, image_id id) unregister_image(team_id teamID, image_id id)
{ {
status_t status = B_ENTRY_NOT_FOUND; status_t status = B_ENTRY_NOT_FOUND;
struct image *image;
struct team *team; struct team *team;
cpu_status state; cpu_status state;
@ -76,9 +75,11 @@ unregister_image(team_id teamID, image_id id)
team = team_get_team_struct_locked(teamID); team = team_get_team_struct_locked(teamID);
if (team) { if (team) {
kqueue_foreach (&team->image_queue, image) { struct image *image = NULL;
while ((image = list_get_next_item(&team->image_list, image)) != NULL) {
if (image->info.id == id) { if (image->info.id == id) {
remque(image); list_remove_link(image);
free(image); free(image);
status = B_OK; status = B_OK;
break; break;
@ -100,10 +101,10 @@ unregister_image(team_id teamID, image_id id)
int32 int32
count_images(struct team *team) count_images(struct team *team)
{ {
struct image *image; struct image *image = NULL;
int32 count = 0; int32 count = 0;
kqueue_foreach (&team->image_queue, image) { while ((image = list_get_next_item(&team->image_list, image)) != NULL) {
count++; count++;
} }
@ -119,15 +120,11 @@ count_images(struct team *team)
status_t status_t
remove_images(struct team *team) remove_images(struct team *team)
{ {
struct image *image, *nextImage; struct image *image;
ASSERT(team != NULL); ASSERT(team != NULL);
// can't use kqueue_foreach() because "image" gets freed while ((image = list_remove_head_item(&team->image_list)) != NULL) {
for (image = (struct image *)team->image_queue.next;
image != (void *)&team->image_queue; image = nextImage) {
nextImage = image->next;
free(image); free(image);
} }
return B_OK; return B_OK;
@ -138,7 +135,6 @@ status_t
_get_image_info(image_id id, image_info *info, size_t size) _get_image_info(image_id id, image_info *info, size_t size)
{ {
status_t status = B_ENTRY_NOT_FOUND; status_t status = B_ENTRY_NOT_FOUND;
struct image *image;
struct team *team; struct team *team;
cpu_status state; cpu_status state;
@ -147,7 +143,9 @@ _get_image_info(image_id id, image_info *info, size_t size)
team = thread_get_current_thread()->team; team = thread_get_current_thread()->team;
if (team) { if (team) {
kqueue_foreach (&team->image_queue, image) { struct image *image = NULL;
while ((image = list_get_next_item(&team->image_list, image)) != NULL) {
if (image->info.id == id) { if (image->info.id == id) {
memcpy(info, &image->info, size); memcpy(info, &image->info, size);
status = B_OK; status = B_OK;
@ -167,7 +165,6 @@ status_t
_get_next_image_info(team_id teamID, int32 *cookie, image_info *info, size_t size) _get_next_image_info(team_id teamID, int32 *cookie, image_info *info, size_t size)
{ {
status_t status = B_ENTRY_NOT_FOUND; status_t status = B_ENTRY_NOT_FOUND;
struct image *image;
struct team *team; struct team *team;
cpu_status state; cpu_status state;
@ -176,8 +173,10 @@ _get_next_image_info(team_id teamID, int32 *cookie, image_info *info, size_t siz
team = team_get_team_struct_locked(teamID); team = team_get_team_struct_locked(teamID);
if (team) { if (team) {
struct image *image = NULL;
int32 count = 0; int32 count = 0;
kqueue_foreach (&team->image_queue, image) {
while ((image = list_get_next_item(&team->image_list, image)) != NULL) {
if (count == *cookie) { if (count == *cookie) {
memcpy(info, &image->info, size); memcpy(info, &image->info, size);
status = B_OK; status = B_OK;

View File

@ -66,7 +66,7 @@ unregister_kernel_daemon(void (*function)(void *, int), void *arg)
while ((daemon = list_get_next_item(&gDaemons, daemon)) != NULL) { while ((daemon = list_get_next_item(&gDaemons, daemon)) != NULL) {
if (daemon->function == function && daemon->arg == arg) { if (daemon->function == function && daemon->arg == arg) {
// found it! // found it!
list_remove_link(daemon); list_remove_item(&gDaemons, daemon);
free(daemon); free(daemon);
break; break;
} }
@ -113,7 +113,7 @@ register_kernel_daemon(void (*function)(void *, int), void *arg, int frequency)
} else } else
daemon->offset = 0; daemon->offset = 0;
list_add_link_to_tail(&gDaemons, daemon); list_add_item(&gDaemons, daemon);
mutex_lock(&gDaemonMutex); mutex_lock(&gDaemonMutex);
return B_OK; return B_OK;

View File

@ -356,7 +356,7 @@ create_team_struct(const char *name, bool kernel)
team->pending_signals = 0; team->pending_signals = 0;
team->death_sem = -1; team->death_sem = -1;
team->user_env_base = 0; team->user_env_base = 0;
initque(&team->image_queue); list_init(&team->image_list);
if (arch_team_init_team_struct(team, kernel) < 0) if (arch_team_init_team_struct(team, kernel) < 0)
goto error1; goto error1;