[363] | 1 | /*
|
---|
| 2 | * TOPPERS/JSP Kernel
|
---|
| 3 | * Toyohashi Open Platform for Embedded Real-Time Systems/
|
---|
| 4 | * Just Standard Profile Kernel
|
---|
| 5 | *
|
---|
| 6 | * Copyright (C) 2000-2003 by Embedded and Real-Time Systems Laboratory
|
---|
| 7 | * Toyohashi Univ. of Technology, JAPAN
|
---|
| 8 | *
|
---|
| 9 | * ä¸è¨èä½æ¨©è
|
---|
| 10 | ã¯ï¼ä»¥ä¸ã® (1)ã(4) ã®æ¡ä»¶ãï¼Free Software Foundation
|
---|
| 11 | * ã«ãã£ã¦å
|
---|
| 12 | ¬è¡¨ããã¦ãã GNU General Public License ã® Version 2 ã«è¨
|
---|
| 13 | * è¿°ããã¦ããæ¡ä»¶ãæºããå ´åã«éãï¼æ¬ã½ããã¦ã§ã¢ï¼æ¬ã½ããã¦ã§ã¢
|
---|
| 14 | * ãæ¹å¤ãããã®ãå«ãï¼ä»¥ä¸åãï¼ã使ç¨ã»è¤è£½ã»æ¹å¤ã»åé
|
---|
| 15 | å¸ï¼ä»¥ä¸ï¼
|
---|
| 16 | * å©ç¨ã¨å¼ã¶ï¼ãããã¨ãç¡åã§è¨±è«¾ããï¼
|
---|
| 17 | * (1) æ¬ã½ããã¦ã§ã¢ãã½ã¼ã¹ã³ã¼ãã®å½¢ã§å©ç¨ããå ´åã«ã¯ï¼ä¸è¨ã®èä½
|
---|
| 18 | * 権表示ï¼ãã®å©ç¨æ¡ä»¶ããã³ä¸è¨ã®ç¡ä¿è¨¼è¦å®ãï¼ãã®ã¾ã¾ã®å½¢ã§ã½ã¼
|
---|
| 19 | * ã¹ã³ã¼ãä¸ã«å«ã¾ãã¦ãããã¨ï¼
|
---|
| 20 | * (2) æ¬ã½ããã¦ã§ã¢ãï¼ã©ã¤ãã©ãªå½¢å¼ãªã©ï¼ä»ã®ã½ããã¦ã§ã¢éçºã«ä½¿
|
---|
| 21 | * ç¨ã§ããå½¢ã§åé
|
---|
| 22 | å¸ããå ´åã«ã¯ï¼åé
|
---|
| 23 | å¸ã«ä¼´ãããã¥ã¡ã³ãï¼å©ç¨
|
---|
| 24 | * è
|
---|
| 25 | ããã¥ã¢ã«ãªã©ï¼ã«ï¼ä¸è¨ã®èä½æ¨©è¡¨ç¤ºï¼ãã®å©ç¨æ¡ä»¶ããã³ä¸è¨
|
---|
| 26 | * ã®ç¡ä¿è¨¼è¦å®ãæ²è¼ãããã¨ï¼
|
---|
| 27 | * (3) æ¬ã½ããã¦ã§ã¢ãï¼æ©å¨ã«çµã¿è¾¼ããªã©ï¼ä»ã®ã½ããã¦ã§ã¢éçºã«ä½¿
|
---|
| 28 | * ç¨ã§ããªãå½¢ã§åé
|
---|
| 29 | å¸ããå ´åã«ã¯ï¼æ¬¡ã®ããããã®æ¡ä»¶ãæºããã
|
---|
| 30 | * ã¨ï¼
|
---|
| 31 | * (a) åé
|
---|
| 32 | å¸ã«ä¼´ãããã¥ã¡ã³ãï¼å©ç¨è
|
---|
| 33 | ããã¥ã¢ã«ãªã©ï¼ã«ï¼ä¸è¨ã®è
|
---|
| 34 | * ä½æ¨©è¡¨ç¤ºï¼ãã®å©ç¨æ¡ä»¶ããã³ä¸è¨ã®ç¡ä¿è¨¼è¦å®ãæ²è¼ãããã¨ï¼
|
---|
| 35 | * (b) åé
|
---|
| 36 | å¸ã®å½¢æ
|
---|
| 37 | ãï¼å¥ã«å®ããæ¹æ³ã«ãã£ã¦ï¼TOPPERSããã¸ã§ã¯ãã«
|
---|
| 38 | * å ±åãããã¨ï¼
|
---|
| 39 | * (4) æ¬ã½ããã¦ã§ã¢ã®å©ç¨ã«ããç´æ¥çã¾ãã¯éæ¥çã«çãããããªãæ
|
---|
| 40 | * 害ãããï¼ä¸è¨èä½æ¨©è
|
---|
| 41 | ããã³TOPPERSããã¸ã§ã¯ããå
|
---|
| 42 | 責ãããã¨ï¼
|
---|
| 43 | *
|
---|
| 44 | * æ¬ã½ããã¦ã§ã¢ã¯ï¼ç¡ä¿è¨¼ã§æä¾ããã¦ãããã®ã§ããï¼ä¸è¨èä½æ¨©è
|
---|
| 45 | ã
|
---|
| 46 | * ãã³TOPPERSããã¸ã§ã¯ãã¯ï¼æ¬ã½ããã¦ã§ã¢ã«é¢ãã¦ï¼ãã®é©ç¨å¯è½æ§ã
|
---|
| 47 | * å«ãã¦ï¼ãããªãä¿è¨¼ãè¡ããªãï¼ã¾ãï¼æ¬ã½ããã¦ã§ã¢ã®å©ç¨ã«ããç´
|
---|
| 48 | * æ¥çã¾ãã¯éæ¥çã«çãããããªãæ害ã«é¢ãã¦ãï¼ãã®è²¬ä»»ãè² ããªãï¼
|
---|
| 49 | *
|
---|
| 50 | * @(#) $Id: primary_thread.c,v 1.10 2007/04/19 07:44:46 honda Exp $
|
---|
| 51 | */
|
---|
| 52 |
|
---|
| 53 | #include <vwindows.h>
|
---|
| 54 | #include <hal_msg.h>
|
---|
| 55 | #include <hw_timer.h>
|
---|
| 56 |
|
---|
| 57 | #include <objbase.h>
|
---|
| 58 | #include <shellapi.h>
|
---|
| 59 | #include <resource.h>
|
---|
| 60 |
|
---|
| 61 | #include "jsp_kernel.h"
|
---|
| 62 | #include "task.h"
|
---|
| 63 | #include <eventlog.h>
|
---|
| 64 | #include <cpu_rename.h>
|
---|
| 65 |
|
---|
| 66 | /* çµäºæã«ç ´æ£ãè¡ãé¢æ°ã®ãã¥ã¼ */
|
---|
| 67 | struct tagDestructionProcedureQueue
|
---|
| 68 | {
|
---|
| 69 | struct tagDestructionProcedureQueue * Next;
|
---|
| 70 | void (*DestructionProcedure)(void *);
|
---|
| 71 | void * Parameter;
|
---|
| 72 | };
|
---|
| 73 |
|
---|
| 74 | /*
|
---|
| 75 | * ãããã¿ã¤ã宣è¨
|
---|
| 76 | */
|
---|
| 77 | extern void kernel_start();
|
---|
| 78 | extern void kernel_exit();
|
---|
| 79 |
|
---|
| 80 | /*
|
---|
| 81 | * 大åå¤æ°
|
---|
| 82 | */
|
---|
| 83 | HINSTANCE ProcessInstance;
|
---|
| 84 | HANDLE PrimaryThreadHandle;
|
---|
| 85 | HWND PrimaryDialogHandle;
|
---|
| 86 | HANDLE CurrentRunningThreadHandle;
|
---|
| 87 | BOOL ShutdownPostponementRequest;
|
---|
| 88 |
|
---|
| 89 | static HANDLE WorkerThreadHandle = NULL;
|
---|
| 90 | static struct tagDestructionProcedureQueue * DestructionProcedureQueue;
|
---|
| 91 |
|
---|
| 92 |
|
---|
| 93 | /*
|
---|
| 94 | * ç¾å¨å®è¡ä¸ã®ã¹ã¬ãããæå®ãããã¿ã¹ã¯ã§ãããã©ããã®ãã§ãã¯
|
---|
| 95 | */
|
---|
| 96 | Inline
|
---|
| 97 | int isTaskThreadRunning(TCB * tcb)
|
---|
| 98 | { return (tcb != 0) && (tcb->tskctxb.ThreadHandle == CurrentRunningThreadHandle); }
|
---|
| 99 |
|
---|
| 100 |
|
---|
| 101 | /*
|
---|
| 102 | * ã«ã¼ãã«ã¹ã¿ã¼ã¿
|
---|
| 103 | * kernel_startã¯æå¾ã«exit_and_dispatchãå¼ã¶ã®ã§ãã³ã³ããã¹ãç ´æ£ã«
|
---|
| 104 | * åãã¦æ°ããã¹ã¬ãããçæããã
|
---|
| 105 | */
|
---|
| 106 |
|
---|
| 107 | static DWORD WINAPI
|
---|
| 108 | KernelStarter(LPVOID param)
|
---|
| 109 | {
|
---|
| 110 | TlsAlloc();
|
---|
| 111 | TlsSetValue(TLS_LOGMASK, (LPVOID)1);
|
---|
| 112 | TlsSetValue(TLS_THREADHANDLE, (LPVOID)CurrentRunningThreadHandle);
|
---|
| 113 |
|
---|
| 114 | kprintf(("KernelStarter begins performing kernel initialization.\n"));
|
---|
| 115 |
|
---|
| 116 | kernel_start();
|
---|
| 117 |
|
---|
| 118 | /* ããã°ã©ã ã¯ããã«ã¯æ¥ãªã */
|
---|
| 119 |
|
---|
| 120 | return 0;
|
---|
| 121 | }
|
---|
| 122 |
|
---|
| 123 | /*
|
---|
| 124 | * ã¿ã¹ã¯ä¾å¤èµ·åã«ã¼ãã³
|
---|
| 125 | * Visual C++ -> cpu_config.c ã«ç§»åãã¾ãã
|
---|
| 126 | * mingw/cygwin -> cpu_insn.S ã«ç§»åãã¾ãã
|
---|
| 127 | */
|
---|
| 128 | extern void TaskExceptionPerformer(void);
|
---|
| 129 |
|
---|
| 130 | /*
|
---|
| 131 | * å¼·å¶é®æã«ã¼ãã³
|
---|
| 132 | * å¿çãè¿ããªããªãã¸ã§ã¯ãç ´æ£ããã·ã¸ã£å¯¾ç
|
---|
| 133 | */
|
---|
| 134 | DWORD WINAPI
|
---|
| 135 | ForceShutdownHandler(LPVOID param)
|
---|
| 136 | {
|
---|
| 137 | do {
|
---|
| 138 | ShutdownPostponementRequest = FALSE;
|
---|
| 139 | Sleep(5000);
|
---|
| 140 | } while(ShutdownPostponementRequest == TRUE);
|
---|
| 141 | ExitProcess(0);
|
---|
| 142 | return 0;
|
---|
| 143 | }
|
---|
| 144 |
|
---|
| 145 | /*
|
---|
| 146 | * ãããã°æç¨ãã¤ã¢ãã°ã®ã¡ãã»ã¼ã¸ãã³ãã©
|
---|
| 147 | */
|
---|
| 148 | Inline LRESULT CALLBACK
|
---|
| 149 | PrimaryDialogCommandHandler(WPARAM wParam, LPARAM lParam)
|
---|
| 150 | {
|
---|
| 151 | static BOOL lock_flag;
|
---|
| 152 |
|
---|
| 153 | switch(wParam)
|
---|
| 154 | {
|
---|
| 155 | /* ãã¯ããã¯ã®ä¾çµ¦ãåæ¢ããããã¿ã³ */
|
---|
| 156 | case IDC_CLOCKSUPPLY:
|
---|
| 157 | {
|
---|
| 158 | int state;
|
---|
| 159 |
|
---|
| 160 | state = SendDlgItemMessage(PrimaryDialogHandle, IDC_CLOCKSUPPLY,BM_GETCHECK,0,0);
|
---|
| 161 | switch(state)
|
---|
| 162 | {
|
---|
| 163 | /* ã¯ããã¯åæ¢ -> ã¯ããã¯ãæ¢ãã and ä»åãã¦ããã¹ã¬ãããå¼·å¶åæ¢ */
|
---|
| 164 | case BST_CHECKED:
|
---|
| 165 | if((lock_flag = sense_lock()) != TRUE)
|
---|
| 166 | dis_int(0);
|
---|
| 167 | hw_timer_terminate();
|
---|
| 168 | if(CurrentRunningThreadHandle != NULL)
|
---|
| 169 | SuspendThread(CurrentRunningThreadHandle);
|
---|
| 170 | break;
|
---|
| 171 |
|
---|
| 172 | /* ã¯ããã¯ä¾çµ¦åé -> æå¾ã«æ¢ããã¹ã¬ããã®åé and ã¯ããã¯ä¾çµ¦åé */
|
---|
| 173 | case BST_UNCHECKED:
|
---|
| 174 | if(CurrentRunningThreadHandle != NULL)
|
---|
| 175 | ResumeThread(CurrentRunningThreadHandle);
|
---|
| 176 | hw_timer_initialize();
|
---|
| 177 | if(lock_flag != TRUE)
|
---|
| 178 | ena_int(0);
|
---|
| 179 | break;
|
---|
| 180 | }
|
---|
| 181 | break;
|
---|
| 182 | }
|
---|
| 183 |
|
---|
| 184 | default:
|
---|
| 185 | return FALSE;
|
---|
| 186 | }
|
---|
| 187 |
|
---|
| 188 | return TRUE;
|
---|
| 189 | }
|
---|
| 190 |
|
---|
| 191 | /*
|
---|
| 192 | * TOPPERS/JSP ã¹ã¬ããã¢ãã« ã¿ã¹ã¯ãã£ã¹ãããã£
|
---|
| 193 | */
|
---|
| 194 | static void task_dispatcher(int is_taskschedule_required)
|
---|
| 195 | {
|
---|
| 196 | /* ãã¾åãã¦ããã¹ã¬ãã(=å²è¾¼ã¿+ã¿ã¹ã¯)ãããã°ããããæ¢ãã */
|
---|
| 197 | if(CurrentRunningThreadHandle != NULL)
|
---|
| 198 | {
|
---|
| 199 | wait_for_thread_suspension_completion(CurrentRunningThreadHandle);
|
---|
| 200 |
|
---|
| 201 | //åãã¦ããã®ãã¿ã¹ã¯ã§ããã°ãå²è¾¼ã¿ãã¹ã¯ã¬ãã«ãä¿åãã
|
---|
| 202 | if(isTaskThreadRunning(runtsk))
|
---|
| 203 | vget_ims(&runtsk->tskctxb.InterruptLevel);
|
---|
| 204 | }
|
---|
| 205 |
|
---|
| 206 | /* ã¿ã¹ã¯åæ¿ */
|
---|
| 207 |
|
---|
| 208 | //ãã£ã¹ãããããå¿
|
---|
| 209 | è¦ããã
|
---|
| 210 | if(is_taskschedule_required != 0 && enadsp && runtsk != schedtsk)
|
---|
| 211 | runtsk = schedtsk;
|
---|
| 212 |
|
---|
| 213 | //åæå
|
---|
| 214 | ã¿ã¹ã¯ãåå¨ãããªãããã®ã¿ã¹ã¯ãèµ·åãã
|
---|
| 215 | if(runtsk != 0l)
|
---|
| 216 | {
|
---|
| 217 | CurrentRunningThreadHandle = runtsk->tskctxb.ThreadHandle;
|
---|
| 218 |
|
---|
| 219 | /* ã¿ã¹ã¯ä¾å¤ãããã£ãã */
|
---|
| 220 | if (runtsk->enatex && runtsk->texptn != 0)
|
---|
| 221 | {
|
---|
| 222 | /* ã¿ã¹ã¯ä¾å¤èµ·åã«ã¼ãã³ã¸ã¨å·®ãæ¿ãã */
|
---|
| 223 | CONTEXT context;
|
---|
| 224 | context.ContextFlags = CONTEXT_FULL;
|
---|
| 225 | GetThreadContext(CurrentRunningThreadHandle,&context);
|
---|
| 226 | *(DWORD *)(context.Esp -= 4) = context.Eip;
|
---|
| 227 | context.Eip = (DWORD)TaskExceptionPerformer;
|
---|
| 228 | SetThreadContext(CurrentRunningThreadHandle,&context);
|
---|
| 229 | }else
|
---|
| 230 | chg_ims(runtsk->tskctxb.InterruptLevel);
|
---|
| 231 |
|
---|
| 232 | LOG_DSP_LEAVE(runtsk);
|
---|
| 233 | ResumeThread(runtsk->tskctxb.ThreadHandle);
|
---|
| 234 | }else
|
---|
| 235 | {
|
---|
| 236 | /* åãããã®ããªããªããå²ãè¾¼ã¿ãããã¦å¾
|
---|
| 237 | 㤠*/
|
---|
| 238 | CurrentRunningThreadHandle = NULL;
|
---|
| 239 | ena_int(0);
|
---|
| 240 | }
|
---|
| 241 | }
|
---|
| 242 |
|
---|
| 243 |
|
---|
| 244 |
|
---|
| 245 | /*
|
---|
| 246 | * TOPPERS/JSP ã¹ã¬ããã¢ãã« ã«ã¼ãã«ã¡ãã»ã¼ã¸ãã³ãã©
|
---|
| 247 | */
|
---|
| 248 | Inline LRESULT CALLBACK
|
---|
| 249 | HALMessageHandler(WPARAM wParam,LPARAM lParam)
|
---|
| 250 | {
|
---|
| 251 | switch(wParam)
|
---|
| 252 | {
|
---|
| 253 | /*
|
---|
| 254 | *ãã¿ã¹ã¯ãç ´æ£ãã¦ãã ãããã¡ãã»ã¼ã¸
|
---|
| 255 | * lParam : ç ´æ£å¯¾è±¡ã¿ã¹ã¯ã®TCBã®ã¢ãã¬ã¹
|
---|
| 256 | */
|
---|
| 257 | case HALMSG_DESTROY:
|
---|
| 258 | {
|
---|
| 259 | TCB * tcb = (TCB *)lParam;
|
---|
| 260 |
|
---|
| 261 | /* tcb == 0 ãæç«ããã®ã¯ãKernelStarterãexit_and_dispatchããã¨ãã®ã¿ */
|
---|
| 262 | if(tcb == 0 || isTaskThreadRunning(tcb)){
|
---|
| 263 | CurrentRunningThreadHandle = NULL;
|
---|
| 264 |
|
---|
| 265 | /* ã¿ã¹ã¯ã次ã®èµ·åè¦æ±ãåºãã¦ext_tskããã¨ããã®æç¹ã§ãã§ã«æ°ããã¹ã¬ããã®ãã³ãã«ãå
|
---|
| 266 | ¥ã£ã¦ããã®ã§æ¶ãã¦ã¯ãããªã */
|
---|
| 267 |
|
---|
| 268 | if(tcb == runtsk)
|
---|
| 269 | runtsk = 0;
|
---|
| 270 | }
|
---|
| 271 | }
|
---|
| 272 |
|
---|
| 273 | /*
|
---|
| 274 | *ãã¿ã¹ã¯ãåãæ¿ãã¦ãã ãããã¡ãã»ã¼ã¸
|
---|
| 275 | */
|
---|
| 276 | case HALMSG_DISPATCH:
|
---|
| 277 | task_dispatcher(1);
|
---|
| 278 | break;
|
---|
| 279 |
|
---|
| 280 | /*
|
---|
| 281 | *ãå²ãè¾¼ã¿ãçºçããã¦ãã ãããã¡ãã»ã¼ã¸
|
---|
| 282 | * lParam : å²è¾¼ã¿çªå· (>0)
|
---|
| 283 | */
|
---|
| 284 | case HALMSG_INTERRUPT:
|
---|
| 285 | if(lParam == 0 || iniflg == FALSE || ras_int((unsigned int)lParam) == FALSE)
|
---|
| 286 | break;
|
---|
| 287 |
|
---|
| 288 | /* å²è¾¼ã¿åä»å¦ç : ãã®ã¾ã¾æ¬¡ã« */
|
---|
| 289 |
|
---|
| 290 | /*
|
---|
| 291 | * ã次ã«å®è¡ãã¹ãå²ãè¾¼ã¿ãæ¢ãã¦ãå²è¾¼ã¿å¦çãéå§ãã¦ãã ãããã¡ãã»ã¼ã¸
|
---|
| 292 | */
|
---|
| 293 | case HALMSG_INTERRUPT_FINISH:
|
---|
| 294 | {
|
---|
| 295 | /* ç¾å¨å®è¡ãã¦ããã¹ã¬ãããåæ¢ */
|
---|
| 296 | wait_for_thread_suspension_completion(CurrentRunningThreadHandle);
|
---|
| 297 |
|
---|
| 298 | /* å²è¾¼ã¿ã¹ã¬ããçæ and ãã£ã¹ããã */
|
---|
| 299 | if((CurrentRunningThreadHandle = sch_int()) != NULL)
|
---|
| 300 | {
|
---|
| 301 | //ããã¾ã§åããã¦ããã¿ã¹ã¯ã®å²è¾¼ã¿ãã¹ã¯ã¬ãã«ãéé¿
|
---|
| 302 | if(isTaskThreadRunning(runtsk))
|
---|
| 303 | vget_ims(&runtsk->tskctxb.InterruptLevel);
|
---|
| 304 |
|
---|
| 305 | ResumeThread(CurrentRunningThreadHandle); //å²è¾¼ã¿ã¹ã¬ããèµ·å
|
---|
| 306 | }
|
---|
| 307 | else {
|
---|
| 308 | // ã¿ã¹ã¯ã¸ã¨æ»ã
|
---|
| 309 | task_dispatcher(reqflg);
|
---|
| 310 | reqflg = 0;
|
---|
| 311 | }
|
---|
| 312 |
|
---|
| 313 | break;
|
---|
| 314 | }
|
---|
| 315 |
|
---|
| 316 | /*
|
---|
| 317 | *ã管çã¹ã¬ããã®æ¨©éã§ãã£ã¦é¢æ°ãå®è¡ãã¦ãã ãããã¡ãã»ã¼ã¸
|
---|
| 318 | * lParam : ãã©ã¡ã¼ã¿ãæ ¼ç´ããæ§é ä½ã¸ã®ãã¤ã³ã¿
|
---|
| 319 | * ãã©ã¡ã¼ã¿æ§é ä½å
|
---|
| 320 | 訳
|
---|
| 321 | * func : å®è¡ãããé¢æ°
|
---|
| 322 | * param : ãã©ã¡ã¼ã¿ã¨ãã¦æ¸¡ãä½ã§ãã¢ãª("void *")ãªå¤
|
---|
| 323 | *
|
---|
| 324 | * 注) ã¿ã¹ã¯ã§ã¦ã£ã³ãã¦ã¨ããä½ãã¨ãã¿ã¹ã¯ç ´æ£ã§ã¦ã£ã³ãã¦ãæ¶ãã¦ãã¾ãã
|
---|
| 325 | */
|
---|
| 326 | case HALMSG_EXECUTEPROCEDURE:
|
---|
| 327 | {
|
---|
| 328 | void ** work = (void **)lParam;
|
---|
| 329 | ((void (*)(void *))(*work))(*(work+1));
|
---|
| 330 | break;
|
---|
| 331 | }
|
---|
| 332 |
|
---|
| 333 | /*
|
---|
| 334 | *ãæå¾ã®æå¾ã«ãã®å¦çãåããã¦ãã ãã(onExitãã³ãã©)ãã¡ãã»ã¼ã¸
|
---|
| 335 | * lParam : é¢æ°å®è¡ã¡ãã»ã¼ã¸ã¨ãã£ãã ( func,paramã¸ã®ãã¤ã³ã¿ )
|
---|
| 336 | */
|
---|
| 337 | case HALMSG_ADDDESTRUCTIONPROCEDURE:
|
---|
| 338 | {
|
---|
| 339 | struct tagDestructionProcedureQueue * scope;
|
---|
| 340 | void ** work = (void **)lParam;
|
---|
| 341 |
|
---|
| 342 | scope = DestructionProcedureQueue;
|
---|
| 343 |
|
---|
| 344 | if((DestructionProcedureQueue = GlobalAlloc(GMEM_FIXED, sizeof(struct tagDestructionProcedureQueue))) != NULL)
|
---|
| 345 | {
|
---|
| 346 | DestructionProcedureQueue->DestructionProcedure = *(work);
|
---|
| 347 | DestructionProcedureQueue->Parameter = *(work+1);
|
---|
| 348 | DestructionProcedureQueue->Next = scope;
|
---|
| 349 | }else
|
---|
| 350 | FatalAssertion(TRUE, "GlobalAlloc could not acquire a memory block at " __FILE__);
|
---|
| 351 |
|
---|
| 352 | break;
|
---|
| 353 | }
|
---|
| 354 |
|
---|
| 355 | /*
|
---|
| 356 | *ãããã°ã©ã ãæ¢ãã¦ãã ãããã¡ãã»ã¼ã¸
|
---|
| 357 | */
|
---|
| 358 | case HALMSG_QUITREQUEST:
|
---|
| 359 | {
|
---|
| 360 | struct tagDestructionProcedureQueue * destqueue;
|
---|
| 361 | void * destarea;
|
---|
| 362 |
|
---|
| 363 | dis_int(0); // å²è¾¼ã¿åä»ããã®ã¹ã¬ãããããã®ã§ãå¥ã«ç¦æ¢ããªãã¦ã大ä¸å¤«
|
---|
| 364 |
|
---|
| 365 | // WorkerThreadHandle = CreateThread(NULL, 0, ForceShutdownHandler, 0, NULL, NULL);
|
---|
| 366 |
|
---|
| 367 | hw_timer_terminate();
|
---|
| 368 |
|
---|
| 369 | if(CurrentRunningThreadHandle != NULL)
|
---|
| 370 | wait_for_thread_suspension_completion(CurrentRunningThreadHandle);
|
---|
| 371 |
|
---|
| 372 | destqueue = DestructionProcedureQueue;
|
---|
| 373 | while(destqueue != NULL)
|
---|
| 374 | {
|
---|
| 375 | (*destqueue->DestructionProcedure)(destqueue->Parameter);
|
---|
| 376 | destarea = destqueue;
|
---|
| 377 | destqueue = destqueue->Next;
|
---|
| 378 | GlobalFree((HGLOBAL)destarea);
|
---|
| 379 | }
|
---|
| 380 |
|
---|
| 381 | DestroyWindow(PrimaryDialogHandle);
|
---|
| 382 | break;
|
---|
| 383 | }
|
---|
| 384 |
|
---|
| 385 | default:
|
---|
| 386 | return FALSE;
|
---|
| 387 | }
|
---|
| 388 | return TRUE;
|
---|
| 389 | }
|
---|
| 390 |
|
---|
| 391 | /*
|
---|
| 392 | * ã«ã¼ãã«ã·ãã¥ã¬ã¼ã¿ã®ä¸æ ¸ã¨ãªãã¹ã¬ããã®ã¡ãã»ã¼ã¸ãã³ãã©
|
---|
| 393 | */
|
---|
| 394 | LRESULT CALLBACK PrimaryDialogProc(HWND hDlg,UINT Msg,WPARAM wParam,LPARAM lParam)
|
---|
| 395 | {
|
---|
| 396 | switch(Msg)
|
---|
| 397 | {
|
---|
| 398 | /* ã¿ã¹ã¯ãã¬ã¤ã¢ã¤ã³ã³ã§å³ã¯ãªã㯠*/
|
---|
| 399 | case HALMSG_MESSAGE+1:
|
---|
| 400 | if(lParam == WM_RBUTTONUP)
|
---|
| 401 | kernel_exit();
|
---|
| 402 |
|
---|
| 403 | break;
|
---|
| 404 |
|
---|
| 405 | /* ã«ã¼ãã«ã¡ãã»ã¼ã¸ */
|
---|
| 406 | case HALMSG_MESSAGE:
|
---|
| 407 | return HALMessageHandler(wParam,lParam);
|
---|
| 408 |
|
---|
| 409 | /* ãããã°ç¨ãã¤ã¢ãã°ä¸ã®ã¢ã¤ãã ã®ã¡ãã»ã¼ã¸ */
|
---|
| 410 | case WM_COMMAND:
|
---|
| 411 | return PrimaryDialogCommandHandler(wParam,lParam);
|
---|
| 412 |
|
---|
| 413 | /* ãã¤ã¢ãã°çæ(ã¡ãã»ã¼ã¸ãã³ããªã³ã°ç¨) */
|
---|
| 414 | case WM_INITDIALOG:
|
---|
| 415 | {
|
---|
| 416 | DWORD ThreadID;
|
---|
| 417 | NOTIFYICONDATA nid;
|
---|
| 418 |
|
---|
| 419 | PrimaryDialogHandle = hDlg; //ä¸æç
|
---|
| 420 |
|
---|
| 421 | /* ã¿ã¹ã¯ãã¬ã¤ã«ã¢ã¤ã³ã³ãç»é² */
|
---|
| 422 | nid.cbSize = sizeof(NOTIFYICONDATA);
|
---|
| 423 | nid.uFlags = NIF_ICON|NIF_TIP|NIF_MESSAGE;
|
---|
| 424 | nid.uID = ID_NOTIFYICON;
|
---|
| 425 | lstrcpy(nid.szTip,"TOPPERS/JSP");
|
---|
| 426 | nid.hWnd = hDlg;
|
---|
| 427 | nid.uCallbackMessage = HALMSG_MESSAGE+1;
|
---|
| 428 | nid.hIcon = LoadIcon(ProcessInstance,MAKEINTRESOURCE(IDI_ERTLICON));
|
---|
| 429 |
|
---|
| 430 | Shell_NotifyIcon(NIM_ADD,&nid);
|
---|
| 431 |
|
---|
| 432 | /* ã«ã¼ãã«ãå¥ã¹ã¬ããã§èµ·åãã */
|
---|
| 433 | PrimaryThreadHandle = (HANDLE)hDlg;
|
---|
| 434 | CurrentRunningThreadHandle = CreateThread(NULL,0,KernelStarter,NULL,CREATE_SUSPENDED,&ThreadID);
|
---|
| 435 | ResumeThread(CurrentRunningThreadHandle);
|
---|
| 436 |
|
---|
| 437 | FatalAssertion(CurrentRunningThreadHandle != NULL, "CreateThread at " __FILE__);
|
---|
| 438 |
|
---|
| 439 | break;
|
---|
| 440 | }
|
---|
| 441 |
|
---|
| 442 | /* ãã¤ã¢ãã°ãéãããã¨ãã¦ãã¾ã */
|
---|
| 443 | case WM_CLOSE:
|
---|
| 444 | HALQuitRequest();
|
---|
| 445 | break;
|
---|
| 446 |
|
---|
| 447 | /* ãã¤ã¢ãã°ãç ´æ£ããã¾ãã */
|
---|
| 448 | case WM_DESTROY:
|
---|
| 449 | {
|
---|
| 450 | /* ã¿ã¹ã¯ãã¬ã¤å§æ« */
|
---|
| 451 | NOTIFYICONDATA nid;
|
---|
| 452 |
|
---|
| 453 | nid.cbSize = sizeof(NOTIFYICONDATA);
|
---|
| 454 | nid.uFlags = 0;
|
---|
| 455 | nid.hWnd = hDlg;
|
---|
| 456 | nid.uID = ID_NOTIFYICON;
|
---|
| 457 | Shell_NotifyIcon(NIM_DELETE,&nid);
|
---|
| 458 |
|
---|
| 459 | PrimaryThreadHandle = NULL;
|
---|
| 460 | PostQuitMessage(0);
|
---|
| 461 | break;
|
---|
| 462 | }
|
---|
| 463 |
|
---|
| 464 | /* ã¿ã¤ãå¦ç */
|
---|
| 465 | case WM_TIMER:
|
---|
| 466 | /* ä¸ä½16ããããå
|
---|
| 467 | ¨é¨1 -> ã«ã¼ãã«ã®ã¿ã¤ã */
|
---|
| 468 | if((wParam & 0xffff0000) == 0xffff0000)
|
---|
| 469 | {
|
---|
| 470 | /* ä¸ä½16ãããã¯å²è¾¼ã¿çªå· */
|
---|
| 471 | return HALMessageHandler(HALMSG_INTERRUPT,(wParam & 0x0000ffff));
|
---|
| 472 | }
|
---|
| 473 | default:
|
---|
| 474 | return FALSE;
|
---|
| 475 | }
|
---|
| 476 | return TRUE;
|
---|
| 477 | }
|
---|
| 478 |
|
---|
| 479 |
|
---|
| 480 | /* ãã«ãããã»ããµã§ãå®å®ãããããããã¨åä¸ã®ããã»ããµã®ã¿ã§å¦çãããããã«ãã */
|
---|
| 481 | void setAffinityMask(void)
|
---|
| 482 | {
|
---|
| 483 | DWORD process;
|
---|
| 484 | DWORD system;
|
---|
| 485 | DWORD newaffinitymask;
|
---|
| 486 |
|
---|
| 487 | if(GetProcessAffinityMask(GetCurrentProcess(), &process, &system) != 0) {
|
---|
| 488 | newaffinitymask = 1;
|
---|
| 489 | while((process & newaffinitymask) == 0)
|
---|
| 490 | newaffinitymask <<= 1;
|
---|
| 491 | SetProcessAffinityMask(GetCurrentProcess(), newaffinitymask);
|
---|
| 492 | }
|
---|
| 493 |
|
---|
| 494 | kprintf(("setAffinityMask : 0x%08x\n", newaffinitymask));
|
---|
| 495 | }
|
---|
| 496 |
|
---|
| 497 | static void initialize(HANDLE hInstance)
|
---|
| 498 | {
|
---|
| 499 | ProcessInstance = hInstance;
|
---|
| 500 | DestructionProcedureQueue = NULL;
|
---|
| 501 | PrimaryThreadHandle = NULL;
|
---|
| 502 | CurrentRunningThreadHandle = NULL;
|
---|
| 503 |
|
---|
| 504 | #ifdef KERNEL_DEBUG_MODE
|
---|
| 505 | AllocConsole();
|
---|
| 506 | #endif
|
---|
| 507 | /* ããã»ããµãå²ãä»ãã */
|
---|
| 508 | setAffinityMask();
|
---|
| 509 |
|
---|
| 510 | }
|
---|
| 511 |
|
---|
| 512 | static void finalRelease(void)
|
---|
| 513 | {
|
---|
| 514 | int i;
|
---|
| 515 |
|
---|
| 516 | kprintf(("finalRelease()\n"));
|
---|
| 517 |
|
---|
| 518 | /* ç ´æ£ããã¦ãªãã¿ã¹ã¯ã®å¾å§æ« */
|
---|
| 519 | for(i=0;i<_kernel_tmax_tskid;i++)
|
---|
| 520 | {
|
---|
| 521 | if(_kernel_tcb_table[i].tskctxb.ThreadHandle != NULL)
|
---|
| 522 | {
|
---|
| 523 | if(TerminateThread(_kernel_tcb_table[i].tskctxb.ThreadHandle,0) != 0)
|
---|
| 524 | CloseHandle(_kernel_tcb_table[i].tskctxb.ThreadHandle);
|
---|
| 525 | _kernel_tcb_table[i].tskctxb.ThreadHandle = NULL;
|
---|
| 526 | }
|
---|
| 527 | }
|
---|
| 528 |
|
---|
| 529 | /* COMéä¿¡ããã¦ããã¹ã¬ãããå¼·å¶åæ¢ */
|
---|
| 530 | if(WorkerThreadHandle != NULL)
|
---|
| 531 | {
|
---|
| 532 | TerminateThread(WorkerThreadHandle ,0);
|
---|
| 533 | CloseHandle(WorkerThreadHandle);
|
---|
| 534 | WorkerThreadHandle = NULL;
|
---|
| 535 | }
|
---|
| 536 |
|
---|
| 537 | #ifdef KERNEL_DEBUG_MODE
|
---|
| 538 | MessageBox(NULL, "The kernel will be shut down.", "TOPPERS/JSP", MB_OK);
|
---|
| 539 | FreeConsole();
|
---|
| 540 | #endif
|
---|
| 541 |
|
---|
| 542 | }
|
---|
| 543 |
|
---|
| 544 |
|
---|
| 545 | /*
|
---|
| 546 | * ã¡ã¤ã³é¢æ°
|
---|
| 547 | */
|
---|
| 548 | int WINAPI WinMain(HINSTANCE hInstance,HINSTANCE hPrevInstance,LPSTR lpCmdLine,int nShow)
|
---|
| 549 | {
|
---|
| 550 | MSG msg;
|
---|
| 551 | HANDLE hDlg;
|
---|
| 552 |
|
---|
| 553 | TlsAlloc();
|
---|
| 554 |
|
---|
| 555 | initialize(hInstance);
|
---|
| 556 |
|
---|
| 557 | TlsSetValue(TLS_LOGMASK, 0);
|
---|
| 558 | hDlg = CreateDialog(hInstance,"PrimaryDialog",NULL,PrimaryDialogProc);
|
---|
| 559 | if(hDlg != NULL)
|
---|
| 560 | {
|
---|
| 561 | ShowWindow(PrimaryDialogHandle,SW_HIDE);
|
---|
| 562 |
|
---|
| 563 | OnDebug(ShowWindow(PrimaryDialogHandle,SW_SHOW));
|
---|
| 564 |
|
---|
| 565 | while(GetMessage(&msg,NULL,0,0) != 0)
|
---|
| 566 | {
|
---|
| 567 | if(msg.message == WM_QUIT)
|
---|
| 568 | msg.message = 0;
|
---|
| 569 | TranslateMessage(&msg);
|
---|
| 570 | DispatchMessage(&msg);
|
---|
| 571 | }
|
---|
| 572 | }
|
---|
| 573 | else
|
---|
| 574 | FatalAssertion(hDlg != NULL, "CreateDialog at " __FILE__ "(" ")");
|
---|
| 575 |
|
---|
| 576 | finalRelease();
|
---|
| 577 |
|
---|
| 578 | ExitProcess(msg.wParam);
|
---|
| 579 | return msg.wParam;
|
---|
| 580 | }
|
---|
| 581 |
|
---|