sambuc/codezero
1
0
Fork 0
mirror of https://github.com/drasko/codezero.git synced 2026-03-03 19:13:17 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added same global task management mechanism from mm0 to fs0

Browse Source
This commit is contained in:
Bahadir Balban
2008-10-24 14:59:25 +03:00
parent e875344149
commit 46fcdc9b31
2 changed files with 37 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
tasks/fs0/include/globals.h Normal file
View File

@@ -0,0 +1,13 @@
#ifndef __GLOBALS_H__
#define __GLOBALS_H__
struct global_list {
int total;
struct list_head list;
};
extern struct global_list global_vm_files;
extern struct global_list global_vm_objects;
extern struct global_list global_tasks;
#endif /* __GLOBALS_H__ */

35
tasks/fs0/src/task.c
View File

@@ -17,17 +17,32 @@
#include <sys/types.h> #include <sys/types.h>
#include <errno.h> #include <errno.h>
#include <syscalls.h> #include <syscalls.h>
#include <globals.h>
struct global_list global_tasks = {
.list = { &global_tasks.list, &global_tasks.list },
.total = 0,
};
void global_add_task(struct tcb *task)
{
BUG_ON(!list_empty(&task->list));
list_add_tail(&task->list, &global_tasks.list);
global_tasks.total++;
}
void global_remove_task(struct tcb *task)
{
BUG_ON(list_empty(&task->list));
list_del_init(&task->list);
BUG_ON(--global_tasks.total < 0);
}
struct tcb_head {
struct list_head list;
int total; /* Total threads */
} tcb_head;
struct tcb *find_task(int tid) struct tcb *find_task(int tid)
{ {
struct tcb *t; struct tcb *t;
list_for_each_entry(t, &tcb_head.list, list) list_for_each_entry(t, &global_tasks.list, list)
if (t->tid == tid) if (t->tid == tid)
return t; return t;
return 0; return 0;
@@ -43,8 +58,6 @@ struct tcb *create_tcb(void)
t->fdpool = id_pool_new_init(TASK_FILES_MAX); t->fdpool = id_pool_new_init(TASK_FILES_MAX);
INIT_LIST_HEAD(&t->list); INIT_LIST_HEAD(&t->list);
list_add_tail(&t->list, &tcb_head.list);
tcb_head.total++;
return t; return t;
} }
@@ -53,8 +66,7 @@ void destroy_tcb(struct tcb *t)
{ {
kfree(t->fdpool); kfree(t->fdpool);
list_del(&t->list); global_remove_task(t);
tcb_head.total--;
kfree(t); kfree(t);
} }
@@ -120,6 +132,8 @@ int pager_notify_fork(struct tcb *sender, l4id_t parid,
id_pool_copy(child->fdpool, parent->fdpool, TASK_FILES_MAX); id_pool_copy(child->fdpool, parent->fdpool, TASK_FILES_MAX);
memcpy(child->fd, parent->fd, TASK_FILES_MAX * sizeof(int)); memcpy(child->fd, parent->fd, TASK_FILES_MAX * sizeof(int));
global_add_task(child);
// printf("%s/%s: Exiting...\n", __TASKNAME__, __FUNCTION__); // printf("%s/%s: Exiting...\n", __TASKNAME__, __FUNCTION__);
return 0; return 0;
} }
@@ -193,6 +207,7 @@ int init_task_structs(struct task_data_head *tdata_head)
/* shm attach to the utcbs for all these tasks except own */ /* shm attach to the utcbs for all these tasks except own */
if (t->tid != self_tid()) if (t->tid != self_tid())
task_utcb_attach(t); task_utcb_attach(t);
global_add_task(t);
} }
return 0; return 0;
@@ -202,8 +217,6 @@ int init_task_data(void)
{ {
struct task_data_head *tdata_head; struct task_data_head *tdata_head;
INIT_LIST_HEAD(&tcb_head.list);
/* Read how many tasks and tids of each */ /* Read how many tasks and tids of each */
BUG_ON((tdata_head = receive_pager_taskdata()) < 0); BUG_ON((tdata_head = receive_pager_taskdata()) < 0);