Mercurial > hg > Members > kono > Cerium
annotate TaskManager/kernel/ppe/HTask.h @ 714:c42cab5ad4c3
HTask fix
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Wed, 16 Dec 2009 15:31:54 +0900 |
parents | f725c6455d19 |
children | 5df90e02e34f |
rev | line source |
---|---|
109 | 1 #ifndef INCLUDED_HTASK |
2 #define INCLUDED_HTASK | |
3 | |
307 | 4 #include "base.h" |
5 #include "types.h" | |
6 #include "Task.h" | |
7 #include "TaskQueueInfo.h" | |
109 | 8 |
9 class TaskManagerImpl; | |
507 | 10 class SchedTask; |
11 | |
519 | 12 typedef void (*PostFunction)(SchedTask *s, void *read, void *write); |
109 | 13 |
293 | 14 /*! |
15 @class | |
16 | |
17 @brief | |
18 | |
19 Cerium の Task で、spawn() でキューに格納されて順次実行される。 | |
20 cpu の指定があれば並列に実行される。 | |
21 特定の Task を待ち合わせる事が可能。 | |
22 Task の入出力は dma などで copy される。 | |
23 */ | |
683 | 24 |
25 #include "SimpleTask.h" | |
26 | |
641
0692b08f1cd6
Regression on Mac OS X
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
634
diff
changeset
|
27 class HTask : public SimpleTask { |
109 | 28 public: |
29 BASE_NEW_DELETE(HTask); | |
30 | |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
397
diff
changeset
|
31 TaskQueueInfo *wait_me; // List of task waiting for me |
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
397
diff
changeset
|
32 TaskQueueInfo *wait_i; // List of task for which I am waiting |
518 | 33 PostFunction post_func; |
507 | 34 void *post_arg1; |
35 void *post_arg2; | |
109 | 36 CPU_TYPE cpu_type; |
37 TaskManagerImpl *mimpl; | |
38 | |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
39 HTask *waiter; |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
40 HTask *next; |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
41 HTask *prev; |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
42 |
684
458a1ad91427
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
683
diff
changeset
|
43 void spawn(); |
293 | 44 void wait_for(HTask *); |
397
a4f690f44842
delete manager (in kernel/ppe/TaskManager.h)
game@henri.cr.ie.u-ryukyu.ac.jp
parents:
366
diff
changeset
|
45 void set_cpu(CPU_TYPE type); |
507 | 46 void set_post(PostFunction func, void *read, void *write); |
700 | 47 Task *create_task_array(int task_id, int num_task, int num_param, int num_inData, int num_outData); |
48 Task *next_task_array(int task_id, Task *t); | |
49 void spawn_task_array(Task *t); | |
703 | 50 |
714 | 51 |
713
f725c6455d19
remove SIMPLE_TASK conditional
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
703
diff
changeset
|
52 private: |
703 | 53 |
54 int param_index; | |
55 int in_index; | |
56 int out_index; | |
57 | |
58 // compatibility | |
59 public: // functions | |
60 void add_inData_t(memaddr addr, int size) { | |
61 Task *t = (Task*)rbuf; | |
62 t->set_inData_t(in_index++, addr,size); | |
63 } | |
64 void add_outData_t(memaddr addr, int size) { | |
65 Task *t = (Task*)rbuf; | |
66 t->set_outData_t(out_index++, addr,size); | |
67 } | |
68 void set_inData_t(int index, memaddr addr, int size) { | |
69 Task *t = (Task*)rbuf; | |
70 t->set_inData_t(index, addr,size); | |
71 } | |
72 void set_outData_t(int index, memaddr addr, int size) { | |
73 Task *t = (Task*)rbuf; | |
74 t->set_inData_t(index, addr,size); | |
75 } | |
76 void add_param_t(memaddr param) { | |
77 Task *t = (Task*)rbuf; | |
78 t->set_param_t(param_index++, param); | |
79 } | |
80 void set_param_t(int index, memaddr param) { | |
81 Task *t = (Task*)rbuf; | |
82 t->set_param_t(index, param); | |
83 } | |
84 | |
714 | 85 void init(int cmd) { |
86 next = prev = NULL; | |
87 waiter = NULL; | |
88 | |
89 command = cmd; | |
90 param_index = 0; | |
91 in_index = 0; | |
92 out_index = 0; | |
93 self = (memaddr) this; | |
94 | |
95 post_func = NULL; | |
96 mimpl = NULL; | |
97 cpu_type = CPU_PPE; | |
98 } | |
703 | 99 #define add_param(param) add_param_t((memaddr)(param)) |
100 #define set_param(index,param) set_param_t(index, (memaddr) (param)) | |
101 | |
102 #define add_inData(addr, size) \ | |
103 add_inData_t((memaddr)(addr), (size)); | |
104 #define add_outData(addr, size) \ | |
105 add_outData_t((memaddr)(addr), (size)); | |
106 | |
107 | |
109 | 108 }; |
109 | |
110 typedef HTask* HTaskPtr; | |
111 | |
112 #endif |