Mercurial > hg > Members > kono > Cerium
annotate TaskManager/kernel/ppe/HTask.h @ 818:19c6cdeb23d6
too few template-parameter-lists
| author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Sun, 23 May 2010 10:55:25 +0900 |
| parents | 821ab210cafa |
| children | bed529c55eda |
| 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 |
|
684
458a1ad91427
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
683
diff
changeset
|
44 void spawn(); |
| 293 | 45 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
|
46 void set_cpu(CPU_TYPE type); |
| 507 | 47 void set_post(PostFunction func, void *read, void *write); |
| 700 | 48 Task *create_task_array(int task_id, int num_task, int num_param, int num_inData, int num_outData); |
| 49 Task *next_task_array(int task_id, Task *t); | |
| 50 void spawn_task_array(Task *t); | |
| 703 | 51 |
| 714 | 52 |
|
713
f725c6455d19
remove SIMPLE_TASK conditional
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
703
diff
changeset
|
53 private: |
| 703 | 54 |
| 55 int param_index; | |
| 56 int in_index; | |
| 57 int out_index; | |
| 58 | |
| 59 // compatibility | |
| 60 public: // functions | |
| 61 void add_inData_t(memaddr addr, int size) { | |
| 62 Task *t = (Task*)rbuf; | |
| 63 t->set_inData_t(in_index++, addr,size); | |
| 64 } | |
| 65 void add_outData_t(memaddr addr, int size) { | |
| 66 Task *t = (Task*)rbuf; | |
| 67 t->set_outData_t(out_index++, addr,size); | |
| 68 } | |
| 69 void set_inData_t(int index, memaddr addr, int size) { | |
| 787 | 70 if ((unsigned long)addr&0xf) { |
| 71 printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n", | |
| 72 command, index, (unsigned long)addr, size); | |
| 73 } | |
| 703 | 74 Task *t = (Task*)rbuf; |
| 75 t->set_inData_t(index, addr,size); | |
| 76 } | |
| 77 void set_outData_t(int index, memaddr addr, int size) { | |
| 787 | 78 if ((unsigned long)addr&0xf) { |
| 79 printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n", | |
| 80 command, index, (unsigned long)addr, size); | |
| 81 } | |
| 703 | 82 Task *t = (Task*)rbuf; |
| 788 | 83 t->set_outData_t(index, addr,size); |
| 703 | 84 } |
| 85 void add_param_t(memaddr param) { | |
| 86 Task *t = (Task*)rbuf; | |
| 87 t->set_param_t(param_index++, param); | |
| 88 } | |
| 89 void set_param_t(int index, memaddr param) { | |
| 90 Task *t = (Task*)rbuf; | |
| 91 t->set_param_t(index, param); | |
| 92 } | |
| 93 | |
| 714 | 94 void init(int cmd) { |
| 95 next = prev = NULL; | |
| 96 waiter = NULL; | |
| 97 | |
| 98 command = cmd; | |
| 99 param_index = 0; | |
| 100 in_index = 0; | |
| 101 out_index = 0; | |
| 102 self = (memaddr) this; | |
| 103 | |
| 104 post_func = NULL; | |
| 105 mimpl = NULL; | |
| 106 cpu_type = CPU_PPE; | |
| 107 } | |
| 703 | 108 #define add_param(param) add_param_t((memaddr)(param)) |
| 109 #define set_param(index,param) set_param_t(index, (memaddr) (param)) | |
| 110 | |
| 111 #define add_inData(addr, size) \ | |
| 112 add_inData_t((memaddr)(addr), (size)); | |
| 113 #define add_outData(addr, size) \ | |
| 114 add_outData_t((memaddr)(addr), (size)); | |
| 115 | |
| 116 | |
| 109 | 117 }; |
| 118 | |
| 119 typedef HTask* HTaskPtr; | |
| 120 | |
| 121 #endif |