|
42
|
1 #ifndef INCLUDED_SCHEDULER
|
|
|
2 #define INCLUDED_SCHEDULER
|
|
|
3
|
|
109
|
4 #ifndef INCLUDED_BASE_H_
|
|
|
5 # include "base.h"
|
|
|
6 #endif
|
|
|
7
|
|
|
8 #ifndef INCLUDED_TASKLIST
|
|
|
9 # include "TaskList.h"
|
|
|
10 #endif
|
|
|
11
|
|
|
12 #ifndef INCLUDED_LIST_DATA
|
|
|
13 # include "ListData.h"
|
|
42
|
14 #endif
|
|
|
15
|
|
|
16 #ifndef INCLUDED_DMA_MANAGER
|
|
|
17 # include "DmaManager.h"
|
|
|
18 #endif
|
|
|
19
|
|
|
20 #ifndef INCLUDED_SCHED_TASK_BASE
|
|
|
21 # include "SchedTaskBase.h"
|
|
|
22 #endif
|
|
|
23
|
|
109
|
24 #ifndef INCLUDED_SCHED_TASK
|
|
|
25 # include "SchedTask.h"
|
|
|
26 #endif
|
|
|
27
|
|
184
|
28 #ifndef INCLUDED_SCHED_TASKLIST
|
|
|
29 # include "SchedTaskList.h"
|
|
|
30 #endif
|
|
|
31
|
|
109
|
32 #ifndef INCLUDED_TASK_GROUP
|
|
|
33 # include "TaskGroup.h"
|
|
|
34 #endif
|
|
|
35
|
|
|
36 #define MAX_USER_TASK 32
|
|
|
37 #define MAX_SYSTEM_TASK 2
|
|
|
38 #define MAX_TASK_OBJECT MAX_USER_TASK + MAX_SYSTEM_TASK
|
|
|
39 #define MAX_GLOBAL_AREA 32
|
|
|
40 #define MAX_MAINMEM_AREA 32
|
|
|
41
|
|
42
|
42 class SchedTaskBase;
|
|
109
|
43 class SchedTask;
|
|
184
|
44 class SchedTaskList;
|
|
42
|
45
|
|
|
46 class Scheduler {
|
|
|
47 public:
|
|
109
|
48 virtual ~Scheduler(void);
|
|
|
49
|
|
|
50 BASE_NEW_DELETE(Scheduler);
|
|
42
|
51
|
|
|
52 /* variables */
|
|
109
|
53
|
|
|
54 // double buffering
|
|
|
55 TaskListPtr buff_taskList[2];
|
|
|
56 ListDataPtr buff_inListData[2];
|
|
|
57 ListDataPtr buff_outListData[2];
|
|
|
58
|
|
|
59 int buffFlag_taskList;
|
|
|
60 int buffFlag_inListData;
|
|
|
61 int buffFlag_outListData;
|
|
|
62
|
|
|
63 /* TaskList 関連 */
|
|
|
64
|
|
|
65 /**
|
|
|
66 * 実行中 TaskList の現在の位置 (list->tasks[index])
|
|
184
|
67 *
|
|
|
68 * bakIndex_taskList がある理由
|
|
|
69 * taskList の途中で renew task が作られたとき、
|
|
|
70 * 即座に実行するため、TaskList -> RenewTaskList と移って処理する。
|
|
|
71 * RenewTaskList が終了したとき、再び TaskList に戻ってくるが
|
|
|
72 * Renew Task を生成した所から再スタートするため、
|
|
|
73 * taskList の index を覚えておく (backup)
|
|
|
74 * 同様に TaskList も覚えておく
|
|
109
|
75 */
|
|
184
|
76 int bakIndex_taskList;
|
|
|
77 TaskListPtr bak_curTaskList;
|
|
|
78
|
|
109
|
79
|
|
|
80 /**
|
|
|
81 * タスク内で生成されたタスクを入れる
|
|
|
82 * Linked List で管理
|
|
|
83 */
|
|
|
84 TaskListPtr renewCur_taskList;
|
|
|
85 TaskListPtr renewTop_taskList;
|
|
|
86
|
|
|
87 /**
|
|
|
88 * 実行中 TaskList が Renew されたものかどうかのフラグ
|
|
|
89 * Renew の場合、ListData は DMA する必要ないとか
|
|
|
90 * いろいろな判定に使えるかもしれん
|
|
|
91 * if (flag == 1) taskList is Renew
|
|
|
92 */
|
|
|
93 int flag_renewTaskList;
|
|
|
94
|
|
|
95 /**
|
|
|
96 * タスク内 (T1) でタスク (Tc = T2, T3, ..) が複数生成された場合、
|
|
|
97 * Tc が全て終わってから、T1 の終了コマンドを PPE に送る。
|
|
|
98 * なので、Tc を process group として記憶しておく。
|
|
|
99 *
|
|
|
100 * Tc が taskGroup のアドレスを持つので
|
|
|
101 * Scheduler が持つ taskGroup 変数は一つだけで(多分)おk
|
|
|
102 */
|
|
|
103 TaskGroupPtr taskGroup;
|
|
|
104
|
|
|
105 /* GlobalMemoryList */
|
|
|
106 void* globalList[MAX_GLOBAL_AREA];
|
|
|
107
|
|
|
108 /* MainMemory Allocate Command List */
|
|
|
109 void* mainMemList[MAX_MAINMEM_AREA];
|
|
|
110
|
|
|
111 // Task Object Table
|
|
184
|
112 typedef SchedTask* (*TaskObject)(void);
|
|
42
|
113
|
|
|
114 DmaManager* connector;
|
|
109
|
115
|
|
|
116 // Pipeline Stage
|
|
42
|
117 SchedTaskBase* task1;
|
|
|
118 SchedTaskBase* task2;
|
|
|
119 SchedTaskBase* task3;
|
|
|
120
|
|
|
121 /* functions */
|
|
|
122 void init(void);
|
|
|
123 void run(void);
|
|
109
|
124 virtual void init_impl(void) {};
|
|
50
|
125 void finish(void);
|
|
42
|
126
|
|
|
127 TaskListPtr get_curListBuf(void);
|
|
109
|
128 ListDataPtr get_curReadBuf(void);
|
|
|
129 ListDataPtr get_curWriteBuf(void);
|
|
|
130 TaskListPtr get_renewListBuf(void);
|
|
|
131
|
|
184
|
132 SchedTaskList* get_nextRenewTaskList(TaskListPtr curList, int curIndex);
|
|
|
133 TaskListPtr get_backupTaskList(void);
|
|
|
134
|
|
109
|
135 // なんか名前が変だが。。。
|
|
|
136 /* TaskGroup */
|
|
|
137 TaskGroupPtr set_groupTask(uint32 command);
|
|
|
138 void add_groupTask(TaskGroupPtr group, TaskPtr task);
|
|
|
139 void remove_groupTask(TaskGroupPtr group, TaskPtr task);
|
|
|
140 void reload_groupTask(void);
|
|
|
141 uint32 status_groupTask(TaskGroupPtr group);
|
|
|
142
|
|
|
143 /* GlobalMemory */
|
|
|
144 void* global_alloc(int id, int size);
|
|
|
145 void* global_get(int id);
|
|
|
146 void global_free(int id);
|
|
|
147
|
|
|
148 virtual void *allocate(int size) { return NULL; };
|
|
|
149
|
|
|
150 virtual void mainMem_alloc(int id, int size) {};
|
|
|
151 virtual void mainMem_wait(void) {};
|
|
|
152 void *mainMem_get(int id);
|
|
|
153
|
|
|
154 /* DMA Transfer */
|
|
|
155 void dma_load(void *buf, uint32 addr, uint32 size, uint32 mask);
|
|
|
156 void dma_store(void *buf,uint32 addr, uint32 size, uint32 mask);
|
|
|
157 void dma_wait(uint32 mask);
|
|
|
158 void mail_write(uint32 data);
|
|
|
159 uint32 mail_read(void);
|
|
|
160 void dma_loadList(ListDataPtr list, void *, uint32 mask);
|
|
|
161 void dma_storeList(ListDataPtr list, void *, uint32 mask);
|
|
42
|
162 };
|
|
|
163
|
|
|
164 #endif
|
|
109
|
165
|
|
|
166 extern void register_task(int cmd, Scheduler::TaskObject task);
|
|
|
167
|
|
|
168 #define SchedConstructor(str) \
|
|
184
|
169 str(void) {} \
|
|
109
|
170 BASE_NEW_DELETE(str) \
|
|
|
171
|
|
|
172 #define SchedDefineTask(str) \
|
|
184
|
173 SchedTask* createTask_##str(void) \
|
|
109
|
174 { \
|
|
184
|
175 return new str(); \
|
|
109
|
176 }
|
|
|
177
|
|
|
178 #define SchedExternTask(str) \
|
|
|
179 extern \
|
|
184
|
180 SchedTask* createTask_##str(void);
|
|
109
|
181
|
|
|
182 #define SchedRegisterTask(cmd, str) \
|
|
|
183 register_task(cmd, createTask_##str);
|
