Mercurial > hg > Members > kono > Cerium
annotate TaskManager/kernel/ppe/HTask.h @ 954:6d3c954e510a
auto_free
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Tue, 03 Aug 2010 15:32:49 +0900 |
parents | 86aea6affe6c |
children | 9989dd7b9ac2 |
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" | |
787 | 8 #include <stdio.h> |
109 | 9 |
10 class TaskManagerImpl; | |
507 | 11 class SchedTask; |
12 | |
519 | 13 typedef void (*PostFunction)(SchedTask *s, void *read, void *write); |
109 | 14 |
293 | 15 /*! |
16 @class | |
17 | |
18 @brief | |
19 | |
20 Cerium の Task で、spawn() でキューに格納されて順次実行される。 | |
21 cpu の指定があれば並列に実行される。 | |
22 特定の Task を待ち合わせる事が可能。 | |
23 Task の入出力は dma などで copy される。 | |
24 */ | |
683 | 25 |
26 #include "SimpleTask.h" | |
27 | |
641
0692b08f1cd6
Regression on Mac OS X
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
634
diff
changeset
|
28 class HTask : public SimpleTask { |
109 | 29 public: |
30 BASE_NEW_DELETE(HTask); | |
31 | |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
397
diff
changeset
|
32 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
|
33 TaskQueueInfo *wait_i; // List of task for which I am waiting |
518 | 34 PostFunction post_func; |
507 | 35 void *post_arg1; |
36 void *post_arg2; | |
109 | 37 CPU_TYPE cpu_type; |
38 TaskManagerImpl *mimpl; | |
39 | |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
40 HTask *waiter; |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
41 HTask *next; |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
42 HTask *prev; |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
43 |
941
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
44 struct { |
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
45 unsigned no_auto_free:1; // bit 0 auto free flag (0 .. auto, 1 manual) |
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
46 } flag; |
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
47 |
684
458a1ad91427
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
683
diff
changeset
|
48 void spawn(); |
293 | 49 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
|
50 void set_cpu(CPU_TYPE type); |
507 | 51 void set_post(PostFunction func, void *read, void *write); |
700 | 52 Task *create_task_array(int task_id, int num_task, int num_param, int num_inData, int num_outData); |
53 Task *next_task_array(int task_id, Task *t); | |
54 void spawn_task_array(Task *t); | |
703 | 55 |
714 | 56 |
713
f725c6455d19
remove SIMPLE_TASK conditional
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
703
diff
changeset
|
57 private: |
703 | 58 |
59 int param_index; | |
60 int in_index; | |
61 int out_index; | |
62 | |
63 // compatibility | |
64 public: // functions | |
65 void add_inData_t(memaddr addr, int size) { | |
66 Task *t = (Task*)rbuf; | |
67 t->set_inData_t(in_index++, addr,size); | |
68 } | |
69 void add_outData_t(memaddr addr, int size) { | |
70 Task *t = (Task*)rbuf; | |
71 t->set_outData_t(out_index++, addr,size); | |
72 } | |
73 void set_inData_t(int index, memaddr addr, int size) { | |
949 | 74 #ifdef EARLY_TOUCH |
75 if ((unsigned long)addr&0xf) { | |
787 | 76 printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n", |
77 command, index, (unsigned long)addr, size); | |
78 } | |
949 | 79 char *p = (char *)addr; char b = *p; |
80 p = (char *)(addr+size-1); b += *p; | |
81 #endif | |
703 | 82 Task *t = (Task*)rbuf; |
83 t->set_inData_t(index, addr,size); | |
84 } | |
85 void set_outData_t(int index, memaddr addr, int size) { | |
949 | 86 #ifdef EARLY_TOUCH |
87 if ((unsigned long)addr&0xf) { | |
787 | 88 printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n", |
89 command, index, (unsigned long)addr, size); | |
90 } | |
949 | 91 char *p = (char *)addr; char b = *p; |
92 p = (char *)(addr+size-1); b += *p; | |
93 #endif | |
703 | 94 Task *t = (Task*)rbuf; |
788 | 95 t->set_outData_t(index, addr,size); |
703 | 96 } |
97 void add_param_t(memaddr param) { | |
98 Task *t = (Task*)rbuf; | |
99 t->set_param_t(param_index++, param); | |
100 } | |
101 void set_param_t(int index, memaddr param) { | |
945
a9c7784e5dae
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
102 if (command==TaskArray1) { |
a9c7784e5dae
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
103 Task *t = (Task*)rbuf; |
a9c7784e5dae
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
104 t->set_param_t(index, param); |
a9c7784e5dae
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
105 } else { |
a9c7784e5dae
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
106 this->param = param; |
a9c7784e5dae
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
107 } |
703 | 108 } |
109 | |
941
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
110 void no_auto_free() { |
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
111 flag.no_auto_free = 1; |
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
112 } |
954 | 113 void auto_free() { |
114 flag.no_auto_free = 0; | |
115 } | |
941
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
116 |
714 | 117 void init(int cmd) { |
118 next = prev = NULL; | |
119 waiter = NULL; | |
120 | |
121 command = cmd; | |
122 param_index = 0; | |
123 in_index = 0; | |
124 out_index = 0; | |
941
0c11c2fd7e63
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
895
diff
changeset
|
125 flag.no_auto_free = 0; |
714 | 126 self = (memaddr) this; |
127 | |
128 post_func = NULL; | |
129 mimpl = NULL; | |
130 cpu_type = CPU_PPE; | |
131 } | |
703 | 132 #define add_param(param) add_param_t((memaddr)(param)) |
133 #define set_param(index,param) set_param_t(index, (memaddr) (param)) | |
134 | |
135 #define add_inData(addr, size) \ | |
136 add_inData_t((memaddr)(addr), (size)); | |
137 #define add_outData(addr, size) \ | |
138 add_outData_t((memaddr)(addr), (size)); | |
139 | |
140 | |
895
bed529c55eda
add alignment of classes in SPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
788
diff
changeset
|
141 } __attribute__ ((aligned (DEFAULT_ALIGNMENT))); |
109 | 142 |
143 typedef HTask* HTaskPtr; | |
144 | |
145 #endif |