[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: com_support.cpp,v 1.10 2003/12/15 07:19:22 takayuki Exp $
|
---|
| 51 | */
|
---|
| 52 |
|
---|
| 53 | #include <vitron.h>
|
---|
| 54 | #include <com_support.h>
|
---|
| 55 | #include <eventlog.h>
|
---|
| 56 | #include "syslog.h"
|
---|
| 57 |
|
---|
| 58 | #include <resource.h>
|
---|
| 59 |
|
---|
| 60 | #include <commctrl.h>
|
---|
| 61 |
|
---|
| 62 | /*
|
---|
| 63 | * åã«èãããäºã®èª¬æ
|
---|
| 64 | * Q: Cã¹ã¿ã¤ã«ã³ã¡ã³ãã¨C++ã¹ã¿ã¤ã«ã³ã¡ã³ããæ··ãã£ã¦ãã¾ãã?
|
---|
| 65 | * A: æ°æ¥½ã«ã³ã¡ã³ãã¢ã¦ããããã¨å°ãå¦çãCã¹ã¿ã¤ã«ã³ã¡ã³ãã§ãä¼¼ããããªå¦çãããå ´æã®èª¬æã«C++ã¹ã¿ã¤ã«ã³ã¡ã³ãã使ã£ã¦ãã¾ãã
|
---|
| 66 | *
|
---|
| 67 | * Q: å¤æ°ã®åã¥ãè¦åããã¡ããã¡ãã§ãã?
|
---|
| 68 | * A: åºæ¬çã«ã¹ã³ã¼ãç¯å²ã§ä½¿ãåãã¦ãã¾ãã
|
---|
| 69 | * ãã¼ã«ã«ãå°æå+"_", ã°ãã¼ãã«ã大æåå°æå, ã¡ã³ããJavaã£ã½ãã¹ã¿ã¤ã«
|
---|
| 70 | *
|
---|
| 71 | * Q: INVALID_HANDLE_VALUE 㨠NULL ãã©ã使ãåãã¦ããã®ã§ãã?
|
---|
| 72 | * A: CreateXxxxã失ææã«è¿å´ããå¤ã§ãããã¾ããã
|
---|
| 73 | * å
|
---|
| 74 | ·ä½çã«ã¯ããã¡ã¤ã«ã¯INVALID_HANDLE_VALUE(CreateFile)ã§ããã以å¤ãNULLã«ãªã£ã¦ã¾ãã
|
---|
| 75 | */
|
---|
| 76 |
|
---|
| 77 | #ifndef __COM_NOT_REQUIRED__
|
---|
| 78 |
|
---|
| 79 |
|
---|
| 80 | //===================================================
|
---|
| 81 | /*
|
---|
| 82 | * å
|
---|
| 83 | ±éé¨
|
---|
| 84 | */
|
---|
| 85 | extern "C" SYSTIM _kernel_systim_offset;
|
---|
| 86 | extern "C" SYSTIM _kernel_current_time;
|
---|
| 87 | extern "C" HINSTANCE ProcessInstance;
|
---|
| 88 | extern "C" HANDLE PrimaryDialogHandle;
|
---|
| 89 | extern "C" BOOL ShutdownPostponementRequest;
|
---|
| 90 | extern "C" int CPUStatus;
|
---|
| 91 |
|
---|
| 92 | extern "C" void FatalAssertion(int exp, LPCSTR format, ... );
|
---|
| 93 |
|
---|
| 94 | extern "C" void enter_system_critical_section(BOOL * cookie);
|
---|
| 95 | extern "C" void leave_system_critiacl_section(BOOL * cookie);
|
---|
| 96 |
|
---|
| 97 | #ifdef KERNEL_DEBUG_MODE
|
---|
| 98 | extern "C" _kernel_debugprintf(const char * format, ... );
|
---|
| 99 | # define kprintf(x) _kernel_debugprintf x
|
---|
| 100 | #else
|
---|
| 101 | # define kprintf(x)
|
---|
| 102 | #endif
|
---|
| 103 |
|
---|
| 104 | //===================================================
|
---|
| 105 |
|
---|
| 106 | /* ã¦ã¼ã¶å®ç¾©ã®ãã° */
|
---|
| 107 | #define USERDEFINED 0x60
|
---|
| 108 | #define LOG_MODULENAME (0 | USERDEFINED) /* ã¢ã¸ã¥ã¼ã«ã®åå */
|
---|
| 109 | #define LOG_TIMESTAMP (1 | USERDEFINED) /* è¨é²ãéå§ããæå» (SYSTEMTIMEæ§é ä½ããã®ã¾ã¾ãã³ã) */
|
---|
| 110 |
|
---|
| 111 | #define __HAL_MSG_MSGONLY
|
---|
| 112 | #include <hal_msg.h>
|
---|
| 113 |
|
---|
| 114 | #include <string>
|
---|
| 115 |
|
---|
| 116 | namespace
|
---|
| 117 | {
|
---|
| 118 | /*
|
---|
| 119 | * COMã¤ã³ã¿ã¼ãã§ã¼ã¹é¢é£ã®å®ç¾©
|
---|
| 120 | */
|
---|
| 121 |
|
---|
| 122 | //諸ã
|
---|
| 123 | ã®IDã®å®£è¨
|
---|
| 124 | const IID IID_IKernelEvents = {0x1353969D,0xE84F,0x463F,{0xB2,0x11,0x33,0x7E,0x9B,0xCF,0xB9,0x9E}};
|
---|
| 125 | const IID IID_IKernel = {0xD3E42099,0x3FDD,0x4A78,{0xBD,0xBD,0x4E,0x57,0xD3,0x62,0xF5,0xED}};
|
---|
| 126 | const CLSID CLSID_Kernel = {0x51789667,0x9F20,0x40AF,{0xAF,0x7F,0x98,0x56,0x32,0x5D,0xFB,0x0B}};
|
---|
| 127 |
|
---|
| 128 | // IKernelã¤ã³ã¿ã¼ãã§ã¼ã¹å®ç¾©
|
---|
| 129 | class IKernel : public IUnknown
|
---|
| 130 | {
|
---|
| 131 | public:
|
---|
| 132 | STDMETHOD(Read)(unsigned long address,unsigned long sz,char __RPC_FAR data[]) PURE;
|
---|
| 133 | STDMETHOD(IsValid)(BOOL __RPC_FAR * valid) PURE;
|
---|
| 134 | STDMETHOD(Write)(unsigned long address,unsigned long sz,char __RPC_FAR data[]) PURE;
|
---|
| 135 | STDMETHOD(OnLogEvent)(long sz, unsigned char __RPC_FAR data[]) PURE;
|
---|
| 136 | };
|
---|
| 137 |
|
---|
| 138 | // IKernelEventsã¤ã³ã¿ãã§ã¼ã¹å®ç¾©
|
---|
| 139 | class IKernelEvents : public IUnknown
|
---|
| 140 | {
|
---|
| 141 | public:
|
---|
| 142 | STDMETHOD(QueryInterface)(REFIID iid, void ** unk);
|
---|
| 143 | STDMETHOD_(ULONG,AddRef)();
|
---|
| 144 | STDMETHOD_(ULONG,Release)();
|
---|
| 145 | STDMETHOD(OnInterruptRequest)(long inhno);
|
---|
| 146 |
|
---|
| 147 | IKernelEvents(void);
|
---|
| 148 |
|
---|
| 149 | long RefCount;
|
---|
| 150 | };
|
---|
| 151 |
|
---|
| 152 | /*
|
---|
| 153 | * IKernelEventså®è£
|
---|
| 154 |
|
---|
| 155 | */
|
---|
| 156 |
|
---|
| 157 | IKernelEvents::IKernelEvents(void) : RefCount(0)
|
---|
| 158 | {}
|
---|
| 159 |
|
---|
| 160 | STDMETHODIMP IKernelEvents::QueryInterface(REFIID iid, void ** unk)
|
---|
| 161 | {
|
---|
| 162 | if( iid == IID_IKernelEvents || iid == IID_IUnknown )
|
---|
| 163 | {
|
---|
| 164 | *unk = this;
|
---|
| 165 | ::InterlockedIncrement(&RefCount);
|
---|
| 166 | return S_OK;
|
---|
| 167 | }
|
---|
| 168 |
|
---|
| 169 | return E_NOINTERFACE;
|
---|
| 170 | }
|
---|
| 171 |
|
---|
| 172 | STDMETHODIMP_(ULONG) IKernelEvents::AddRef()
|
---|
| 173 | { return ::InterlockedIncrement(&RefCount); }
|
---|
| 174 |
|
---|
| 175 | STDMETHODIMP_(ULONG) IKernelEvents::Release()
|
---|
| 176 | {
|
---|
| 177 | if( ::InterlockedDecrement(&RefCount) == 0)
|
---|
| 178 | delete this;
|
---|
| 179 | return RefCount;
|
---|
| 180 | }
|
---|
| 181 |
|
---|
| 182 | STDMETHODIMP IKernelEvents::OnInterruptRequest(long inhno)
|
---|
| 183 | {
|
---|
| 184 |
|
---|
| 185 | if(inhno < 0)
|
---|
| 186 | {
|
---|
| 187 | /* inhno < 0 ã¯ç¹æ®ãªæå³ãæ㤠*/
|
---|
| 188 |
|
---|
| 189 | /* inhno = -1 : keep-alive */
|
---|
| 190 | }else
|
---|
| 191 | ::PostMessage((HWND)PrimaryDialogHandle,HALMSG_MESSAGE,HALMSG_INTERRUPT,(LPARAM)inhno);
|
---|
| 192 | return S_OK;
|
---|
| 193 | }
|
---|
| 194 | }
|
---|
| 195 |
|
---|
| 196 | namespace {
|
---|
| 197 | /*
|
---|
| 198 | * COMéä¿¡ç¨ä½æ¥ã¹ã¬ããã«é¢ããå®ç¾©
|
---|
| 199 | */
|
---|
| 200 |
|
---|
| 201 | HANDLE request_semaphore = NULL; //è¦æ±å¾
|
---|
| 202 | ã¡ã»ããã©
|
---|
| 203 | HANDLE worker_thread_handle = NULL; //ä½æ¥ã¹ã¬ããã®ãã³ãã«
|
---|
| 204 |
|
---|
| 205 | //==============================================================================
|
---|
| 206 |
|
---|
| 207 | //COMä½æ¥ã¹ã¬ãããæ£å¸¸ã«ä½åãã¦ãããå¦ã
|
---|
| 208 | inline bool IsValid(void)
|
---|
| 209 | { return (request_semaphore != NULL) && (worker_thread_handle != NULL); }
|
---|
| 210 |
|
---|
| 211 | //===================================================
|
---|
| 212 |
|
---|
| 213 | /*
|
---|
| 214 | * Q: ã©ããã¦ã·ã¹ãã ããã¯ãå¿
|
---|
| 215 | è¦ãªã®?
|
---|
| 216 | * A: ãã°ã¤ãã³ãããã¥ã¼ã¤ã³ã°ããããã«åã¿ã¹ã¯/å²è¾¼ã¿ã¹ã¬ãããã¡ã¢ãªãåã
|
---|
| 217 | * -> VisualC++ã®ãã«ãã¹ã¬ããç¨ã¡ã¢ãªç¢ºä¿ã©ã¤ãã©ãªã¯å
|
---|
| 218 | é¨ã§ã¯ãªãã£ã«ã«ã»ã¯ã·ã§ã³ãªãã¸ã§ã¯ãã使ã£ã¦æä»å¶å¾¡ãã¦ãã
|
---|
| 219 | * -> TOPPERS/JSP Windowsã®ãã£ã¹ãããã£(管çã¹ã¬ãã)ã¯è¦æ±ãæ¥ãã¨ä»åãã¦ããã¹ã¬ãããæ¢ãã«ããã
|
---|
| 220 | * -> ã¡ã¢ãªç¢ºä¿ç¨ã®ã¯ãªãã£ã«ã«ã»ã¯ã·ã§ã³ãæã£ãã¾ã¾SuspendThreadããã¦ãã¾ããã¡ã¢ãªç¢ºä¿è¦æ±ãåºããä»ã®ã¹ã¬ããå
|
---|
| 221 | ¨ã¦ãããã¯
|
---|
| 222 | * -> 管çã¹ã¬ããããã°ãåºãããã«ã¡ã¢ãªãã¨ãã«æ¥ãã®ã§ã管çã¹ã¬ãããããã¯
|
---|
| 223 | * -> 管çã¹ã¬ãããããã¯ãããã¨ãæåã«SuspendThreadãããã¤ããèµ·ããã¹ã¬ãããããªã
|
---|
| 224 | * -> ãããããã¯
|
---|
| 225 | * è£è¶³ : COMéä¿¡ä½æ¥ã¹ã¬ãããã³ã³ã½ã¼ã«ç®¡çã¹ã¬ããã®ããã«ç®¡çã¹ã¬ããã®SuspendThreadã®å¯¾è±¡ã«ãªããªãã¹ã¬ããã¯ããã¯ããªãã¦ããã
|
---|
| 226 | */
|
---|
| 227 |
|
---|
| 228 | //===================================================
|
---|
| 229 |
|
---|
| 230 | /* ä½æ¥ã¹ã¬ããã«ä¸ãããã¼ã¿ãä¿æããã¯ã©ã¹ */
|
---|
| 231 | class Request
|
---|
| 232 | {
|
---|
| 233 | public:
|
---|
| 234 | enum tagRequestType
|
---|
| 235 | {
|
---|
| 236 | Confirmation = 0x00, /* ã¯ã¼ã«ã¹ã¬ããã®åä½ç¢ºèª (ã»ããã©ããããã ã) */
|
---|
| 237 |
|
---|
| 238 | DeviceRead = 0x01, /* ããã¤ã¹ã¨ãã¥ã¬ã¼ã·ã§ã³ èªåºãæä½ */
|
---|
| 239 | DeviceWrite = 0x02, /* ããã¤ã¹ã¨ãã¥ã¬ã¼ã·ã§ã³ æ¸è¾¼ã¿æä½ */
|
---|
| 240 |
|
---|
| 241 | EventLog = 0x03, /* ã¤ãã³ããã°éåº */
|
---|
| 242 |
|
---|
| 243 | QuitThread = 0xff /* ä½æ¥ã¹ã¬ããã®çµäº */
|
---|
| 244 | };
|
---|
| 245 |
|
---|
| 246 | protected:
|
---|
| 247 | bool blocking;
|
---|
| 248 | bool allocated;
|
---|
| 249 | enum tagRequestType type;
|
---|
| 250 | unsigned long address; /* ããã¤ã¹ : ããã¤ã¹ã®ããã¢ãã¬ã¹ */
|
---|
| 251 | unsigned long size; /* å
|
---|
| 252 | ±é : storageãæã¤ãã¼ã¿ã®ãµã¤ãº */
|
---|
| 253 | HGLOBAL storage; /* å
|
---|
| 254 | ±é : ãã¼ã¿ãæ ¼ç´ãã¦ããé åã®ã¢ãã¬ã¹(ãã³ãã«) */
|
---|
| 255 | int result; /* å
|
---|
| 256 | ±é : ããããã³ã°å®è¡æã®è¿å´å° */
|
---|
| 257 | HANDLE signalobject; /* å
|
---|
| 258 | ±é : ããããã³ã°å®è¡æã®ã¹ã¬ãããã³ãã« */
|
---|
| 259 |
|
---|
| 260 | Request * next; /* ãã¥ã¼ã«ããããã®ãªã³ã¯ */
|
---|
| 261 |
|
---|
| 262 | static LONG RequestCount; //ãã¥ã¼ã«ã¤ãªãã£ã¦ãããªã¯ã¨ã¹ãã®æ°
|
---|
| 263 | static Request * top; //ãªã¯ã¨ã¹ããã¥ã¼ã®å
|
---|
| 264 | é (ãã£ã¨ãå¤ããªã¯ã¨ã¹ã)
|
---|
| 265 | static Request * tail; //ãªã¯ã¨ã¹ããã¥ã¼ã®æ«å°¾ (ãã£ã¨ãæ°ãããªã¯ã¨ã¹ã)
|
---|
| 266 | static CRITICAL_SECTION cs; //æä»ãã¥ã¼æä½ç¨å±éºé åãªãã¸ã§ã¯ã
|
---|
| 267 |
|
---|
| 268 | void connect(void)
|
---|
| 269 | {
|
---|
| 270 | //è¦æ±ããã¥ã¼ã«ã¤ãªã
|
---|
| 271 | ::EnterCriticalSection(&cs);
|
---|
| 272 | next = NULL;
|
---|
| 273 | if(tail != NULL)
|
---|
| 274 | tail->next = this;
|
---|
| 275 | tail = this;
|
---|
| 276 | if(top == NULL)
|
---|
| 277 | top = tail;
|
---|
| 278 | ::LeaveCriticalSection(&cs);
|
---|
| 279 |
|
---|
| 280 | ::InterlockedIncrement(&RequestCount);
|
---|
| 281 | }
|
---|
| 282 |
|
---|
| 283 | protected:
|
---|
| 284 | //ã³ã³ã¹ãã©ã¯ã¿
|
---|
| 285 | Request(enum tagRequestType _type, bool _block, unsigned int _size = 0, void * _storage = NULL, unsigned long _address = 0)
|
---|
| 286 | : blocking(_block), allocated(false), type(_type), address(_address),
|
---|
| 287 | size(0), storage(NULL), result(-1), signalobject(NULL), next(NULL)
|
---|
| 288 | {
|
---|
| 289 | size = _size;
|
---|
| 290 |
|
---|
| 291 | if(size != 0)
|
---|
| 292 | {
|
---|
| 293 | //é åãæå®ããã¦ãªãå ´åãåçã«ç¢ºä¿ãã
|
---|
| 294 | if(_storage != NULL)
|
---|
| 295 | storage = static_cast<HGLOBAL>(_storage);
|
---|
| 296 | else
|
---|
| 297 | allocate(size, false);
|
---|
| 298 | }
|
---|
| 299 | }
|
---|
| 300 |
|
---|
| 301 | public:
|
---|
| 302 | //ãã¹ãã©ã¯ã¿
|
---|
| 303 | virtual ~Request(void)
|
---|
| 304 | {
|
---|
| 305 |
|
---|
| 306 | //é åãåç確ä¿ããã¦ããå ´åãç ´æ£ãè¡ã
|
---|
| 307 | if(storage != NULL && allocated)
|
---|
| 308 | {
|
---|
| 309 | BOOL lock;
|
---|
| 310 |
|
---|
| 311 | enter_system_critical_section(&lock);
|
---|
| 312 | ::GlobalFree(storage);
|
---|
| 313 | leave_system_critiacl_section(&lock);
|
---|
| 314 | }
|
---|
| 315 | }
|
---|
| 316 |
|
---|
| 317 | static void initialize(void)
|
---|
| 318 | {
|
---|
| 319 | kprintf(("Request::initialize()\n"));
|
---|
| 320 | if(RequestCount == -1)
|
---|
| 321 | {
|
---|
| 322 | ::InitializeCriticalSection(&cs);
|
---|
| 323 | RequestCount = 0;
|
---|
| 324 | top = NULL;
|
---|
| 325 | tail = NULL;
|
---|
| 326 | }
|
---|
| 327 | }
|
---|
| 328 |
|
---|
| 329 | static void finalize(void)
|
---|
| 330 | {
|
---|
| 331 | kprintf(("Request::finalize()\n"));
|
---|
| 332 | if(RequestCount != -1)
|
---|
| 333 | {
|
---|
| 334 | while(top != NULL)
|
---|
| 335 | {
|
---|
| 336 | Request * target = top;
|
---|
| 337 | top = top->next;
|
---|
| 338 | delete target;
|
---|
| 339 | }
|
---|
| 340 |
|
---|
| 341 | ::DeleteCriticalSection(&cs);
|
---|
| 342 | RequestCount = -1;
|
---|
| 343 | }
|
---|
| 344 | }
|
---|
| 345 |
|
---|
| 346 | // ã·ã¹ãã ãããã¯ããªãã§ã¡ã¢ãªéæ¾
|
---|
| 347 | inline void release(void)
|
---|
| 348 | {
|
---|
| 349 | if(storage != NULL && allocated)
|
---|
| 350 | {
|
---|
| 351 | ::GlobalFree(storage);
|
---|
| 352 | storage = 0;
|
---|
| 353 | }
|
---|
| 354 | }
|
---|
| 355 |
|
---|
| 356 | inline bool isBlockingRequest(void) const
|
---|
| 357 | { return blocking; }
|
---|
| 358 |
|
---|
| 359 | inline enum tagRequestType getType(void) const
|
---|
| 360 | { return type; }
|
---|
| 361 |
|
---|
| 362 | inline bool operator == (enum tagRequestType _type) const
|
---|
| 363 | { return type == _type; }
|
---|
| 364 |
|
---|
| 365 | inline bool operator != (enum tagRequestType _type) const
|
---|
| 366 | { return !(operator ==(_type)); }
|
---|
| 367 |
|
---|
| 368 | inline void * getStorage(void)
|
---|
| 369 | { return reinterpret_cast<void *>(storage); }
|
---|
| 370 |
|
---|
| 371 | inline unsigned long getAddress(void) const
|
---|
| 372 | { return address; }
|
---|
| 373 |
|
---|
| 374 | inline unsigned long getSize(void) const
|
---|
| 375 | { return size; }
|
---|
| 376 |
|
---|
| 377 | inline int getResult(void) const
|
---|
| 378 | { return result; }
|
---|
| 379 |
|
---|
| 380 | static inline LONG getRequestCount(void)
|
---|
| 381 | { return RequestCount; }
|
---|
| 382 |
|
---|
| 383 | //é åã®ç¢ºä¿
|
---|
| 384 | // _size : å¿
|
---|
| 385 | è¦ã¨ããé åã®ãµã¤ãº
|
---|
| 386 | // realloc : å
|
---|
| 387 | 容ãä¿æãããå¦ã
|
---|
| 388 | bool allocate(unsigned int _size, bool realloc = false)
|
---|
| 389 | {
|
---|
| 390 | unsigned long old_size;
|
---|
| 391 | HGLOBAL old_storage;
|
---|
| 392 | BOOL lock;
|
---|
| 393 |
|
---|
| 394 | FatalAssertion(type != Confirmation, "Request::allocate was performed with Confirmation Request Object.");
|
---|
| 395 |
|
---|
| 396 | old_size = size;
|
---|
| 397 | old_storage = storage;
|
---|
| 398 |
|
---|
| 399 | enter_system_critical_section(&lock);
|
---|
| 400 | storage = ::GlobalAlloc(GMEM_FIXED, _size);
|
---|
| 401 |
|
---|
| 402 | FatalAssertion(storage != NULL, "Request::allocate failed to allocate a memory block.");
|
---|
| 403 |
|
---|
| 404 | //åã®å
|
---|
| 405 | 容ã®ä¿æ ããã³é åç ´æ£
|
---|
| 406 | if(old_storage != NULL)
|
---|
| 407 | {
|
---|
| 408 | if(realloc)
|
---|
| 409 | ::CopyMemory(storage, old_storage, old_size);
|
---|
| 410 |
|
---|
| 411 | if(allocated)
|
---|
| 412 | ::GlobalFree(old_storage);
|
---|
| 413 | }
|
---|
| 414 | leave_system_critiacl_section(&lock);
|
---|
| 415 |
|
---|
| 416 | allocated = true;
|
---|
| 417 | size = _size;
|
---|
| 418 |
|
---|
| 419 | return true;
|
---|
| 420 | }
|
---|
| 421 |
|
---|
| 422 | //å
|
---|
| 423 | 容ãä¿æããã¾ã¾åã¢ãã±ã¼ã
|
---|
| 424 | inline bool reallocate(unsigned int _size)
|
---|
| 425 | { return allocate(_size, true); }
|
---|
| 426 |
|
---|
| 427 | //ä¿æé åã«å¯¾ããæ¸è¾¼ã¿
|
---|
| 428 | inline void set(void * data, unsigned int sz, unsigned int offset = 0)
|
---|
| 429 | {
|
---|
| 430 | if(size < sz)
|
---|
| 431 | reallocate(sz + offset);
|
---|
| 432 |
|
---|
| 433 | ::CopyMemory(reinterpret_cast<char *>(storage) + offset, data, sz);
|
---|
| 434 | }
|
---|
| 435 |
|
---|
| 436 | //ä¿æé åã«å¯¾ããèªè¾¼ã¿
|
---|
| 437 | inline bool get(void * data, unsigned int sz, unsigned int offset = 0)
|
---|
| 438 | {
|
---|
| 439 | if(size < sz + offset)
|
---|
| 440 | return false;
|
---|
| 441 |
|
---|
| 442 | ::CopyMemory(data, reinterpret_cast<char *>(storage) + offset, sz);
|
---|
| 443 | }
|
---|
| 444 |
|
---|
| 445 | //ä¿æé åã®ä»»æã®ä½ç½®ã«å¯¾ãããã¤ã³ã¿åå¾
|
---|
| 446 | // offset : å
|
---|
| 447 | é ããã®ãã¤ããªãã»ãã
|
---|
| 448 | void * getptr(unsigned int offset = 0)
|
---|
| 449 | {
|
---|
| 450 | if(offset > size || storage == NULL)
|
---|
| 451 | return NULL;
|
---|
| 452 |
|
---|
| 453 | return reinterpret_cast<void *>(reinterpret_cast<char *>(storage) + offset);
|
---|
| 454 | }
|
---|
| 455 |
|
---|
| 456 | /*
|
---|
| 457 | * Requestãªãã¸ã§ã¯ããã¡ã¯ããª
|
---|
| 458 | * Q: ã©ããã¦ãã¡ã¯ããªãå¿
|
---|
| 459 | è¦ãªã®ã?
|
---|
| 460 | * A: ã¡ã¢ãªç¢ºä¿ãããå
|
---|
| 461 | ã«CPUãããã¯ããå¿
|
---|
| 462 | è¦ããããã (詳細ã¯ä¸è¨CPUããã¯ããçç±ãåç
|
---|
| 463 | §)
|
---|
| 464 | */
|
---|
| 465 | static Request * Create(enum tagRequestType _type, bool _block, unsigned int _size = 0, void * _storage = NULL, unsigned long _address = 0)
|
---|
| 466 | {
|
---|
| 467 | Request * request;
|
---|
| 468 | BOOL lock;
|
---|
| 469 |
|
---|
| 470 | enter_system_critical_section(&lock);
|
---|
| 471 | request = new Request(_type, _block, _size, _storage, _address);
|
---|
| 472 | leave_system_critiacl_section(&lock);
|
---|
| 473 |
|
---|
| 474 | return request;
|
---|
| 475 | }
|
---|
| 476 |
|
---|
| 477 | static Request * GetRequest(void)
|
---|
| 478 | {
|
---|
| 479 | Request * result;
|
---|
| 480 |
|
---|
| 481 | ::EnterCriticalSection(&cs);
|
---|
| 482 | result = top;
|
---|
| 483 | if(top != NULL)
|
---|
| 484 | {
|
---|
| 485 | top = top->next;
|
---|
| 486 | if(top == NULL)
|
---|
| 487 | tail = NULL;
|
---|
| 488 | }
|
---|
| 489 | ::LeaveCriticalSection(&cs);
|
---|
| 490 |
|
---|
| 491 | ::InterlockedDecrement(&RequestCount);
|
---|
| 492 |
|
---|
| 493 | return result;
|
---|
| 494 | }
|
---|
| 495 |
|
---|
| 496 | void Finalize(bool succeeded)
|
---|
| 497 | {
|
---|
| 498 | if(this != 0) {
|
---|
| 499 | if(isBlockingRequest())
|
---|
| 500 | signal(succeeded ? getSize() : -1);
|
---|
| 501 | else
|
---|
| 502 | {
|
---|
| 503 | BOOL lock;
|
---|
| 504 |
|
---|
| 505 | enter_system_critical_section(&lock);
|
---|
| 506 | delete this;
|
---|
| 507 | leave_system_critiacl_section(&lock);
|
---|
| 508 | }
|
---|
| 509 | }
|
---|
| 510 | }
|
---|
| 511 |
|
---|
| 512 | virtual void signal(int _result = 0)
|
---|
| 513 | {
|
---|
| 514 | result = _result;
|
---|
| 515 | if(signalobject != NULL)
|
---|
| 516 | ::PostThreadMessage((DWORD)signalobject, WM_QUIT, 0, 0);
|
---|
| 517 | }
|
---|
| 518 |
|
---|
| 519 | /*
|
---|
| 520 | * æ°ããè¦æ±ã®çºè¡
|
---|
| 521 | * (ãã®é¢æ°ã使ãã¹ã¬ãã : 管çã¹ã¬ãã, å²è¾¼ã¿ã¹ã¬ãã, ã¿ã¹ã¯ã¹ã¬ãã)
|
---|
| 522 | */
|
---|
| 523 | virtual int invoke(void)
|
---|
| 524 | {
|
---|
| 525 | int _result;
|
---|
| 526 | BOOL lock;
|
---|
| 527 | MSG msg;
|
---|
| 528 |
|
---|
| 529 | _result = 0;
|
---|
| 530 |
|
---|
| 531 | if(!IsValid())
|
---|
| 532 | return -1;
|
---|
| 533 |
|
---|
| 534 | enter_system_critical_section(&lock);
|
---|
| 535 |
|
---|
| 536 | connect();
|
---|
| 537 |
|
---|
| 538 | //è¦æ±ã®å®è¡å¾
|
---|
| 539 | ã¡
|
---|
| 540 | if(blocking)
|
---|
| 541 | {
|
---|
| 542 | signalobject = (HANDLE)::GetCurrentThreadId();
|
---|
| 543 |
|
---|
| 544 | //æ°ããè¦æ±ãã ãããã¨ãéç¥
|
---|
| 545 | ::ReleaseSemaphore(request_semaphore,1,NULL);
|
---|
| 546 | leave_system_critiacl_section(&lock);
|
---|
| 547 |
|
---|
| 548 | //WM_QUITã¡ãã»ã¼ã¸ã使ã£ã¦åæãåã
|
---|
| 549 | while(::GetMessage(&msg, 0, 0, 0) != 0)
|
---|
| 550 | ::DispatchMessage(&msg);
|
---|
| 551 |
|
---|
| 552 | //ãã®ãªãã¸ã§ã¯ããç ´æ£ããã®ã§ããã¯ã¢ãããåã
|
---|
| 553 | _result = result;
|
---|
| 554 |
|
---|
| 555 | //ãã¥ã¼ããã¯ããå¦çã¯ä½æ¥ã¹ã¬ããããã
|
---|
| 556 | //delete requestã¯ããã³ããããã³ã°ãªãä½æ¥ã¹ã¬ãã責任ãããããã³ã°ãªãããã§ãã
|
---|
| 557 | enter_system_critical_section(&lock);
|
---|
| 558 | delete this;
|
---|
| 559 | leave_system_critiacl_section(&lock);
|
---|
| 560 | }else
|
---|
| 561 | {
|
---|
| 562 | //æ°ããè¦æ±ãã ãããã¨ãéç¥
|
---|
| 563 | ::ReleaseSemaphore(request_semaphore,1,NULL);
|
---|
| 564 | leave_system_critiacl_section(&lock);
|
---|
| 565 | }
|
---|
| 566 |
|
---|
| 567 | return _result;
|
---|
| 568 | }
|
---|
| 569 | };
|
---|
| 570 |
|
---|
| 571 | class EventDumpRequest : public Request
|
---|
| 572 | {
|
---|
| 573 | protected:
|
---|
| 574 | static HANDLE FileHandle;
|
---|
| 575 |
|
---|
| 576 | EventDumpRequest(enum tagRequestType _type, bool _block, unsigned int _size = 0, void * _storage = NULL, unsigned long _address = 0) : Request(_type, _block, _size, _storage, _address)
|
---|
| 577 | {}
|
---|
| 578 |
|
---|
| 579 | public:
|
---|
| 580 | static void initialize(void)
|
---|
| 581 | {
|
---|
| 582 | SYSTEMTIME systim;
|
---|
| 583 | DWORD written;
|
---|
| 584 | char buffer[1024];
|
---|
| 585 | char * top;
|
---|
| 586 | char * work;
|
---|
| 587 |
|
---|
| 588 | ::GetLocalTime(&systim);
|
---|
| 589 | ::wsprintf(buffer, "kernel-log-%04d%02d%02d-%02d%02d%02d.log", systim.wYear, systim.wMonth, systim.wDay, systim.wHour, systim.wMinute, systim.wSecond);
|
---|
| 590 | FileHandle = ::CreateFile(buffer, GENERIC_WRITE, FILE_SHARE_READ, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL|FILE_FLAG_SEQUENTIAL_SCAN, NULL);
|
---|
| 591 |
|
---|
| 592 | kprintf(("EventDumpRequest : initialize (filename = '%s')\n", buffer));
|
---|
| 593 |
|
---|
| 594 | T_RGLOG_HEADER log;
|
---|
| 595 |
|
---|
| 596 | log.logtype = LOG_TIMESTAMP;
|
---|
| 597 | log.logtim = 0;
|
---|
| 598 | log.bufsz = sizeof(SYSTEMTIME);
|
---|
| 599 | log.valid = 1;
|
---|
| 600 | ::WriteFile(FileHandle, &log, sizeof(log), &written, NULL);
|
---|
| 601 | ::WriteFile(FileHandle, &systim, sizeof(SYSTEMTIME), &written, NULL);
|
---|
| 602 |
|
---|
| 603 | /* ã¢ã¸ã¥ã¼ã«åãåãåºã */
|
---|
| 604 | ::lstrcpyn(buffer, ::GetCommandLine(), 1023);
|
---|
| 605 | top = buffer;
|
---|
| 606 | buffer[1023] = '\x0'; //ãµã¼ãç¨çªå
|
---|
| 607 | µ
|
---|
| 608 |
|
---|
| 609 | if(*top == '"')
|
---|
| 610 | {
|
---|
| 611 | ++ top;
|
---|
| 612 | for(work = top; *work != '\x0' && *work != '"'; ++work);
|
---|
| 613 | }
|
---|
| 614 | else
|
---|
| 615 | for(work = top; *work != '\x0' && *work != ' '; ++work);
|
---|
| 616 |
|
---|
| 617 | *work = '\x0'; //ã¿ã¼ããã¼ãå¦ç
|
---|
| 618 |
|
---|
| 619 | log.logtype = LOG_MODULENAME;
|
---|
| 620 | log.logtim = 0;
|
---|
| 621 | log.bufsz = work - top + 1; //ã¿ã¼ããã¼ã¿ã®å
|
---|
| 622 | log.valid = 1;
|
---|
| 623 | ::WriteFile(FileHandle, &log, sizeof(log), &written, NULL);
|
---|
| 624 | ::WriteFile(FileHandle, top, log.bufsz, &written, NULL);
|
---|
| 625 | }
|
---|
| 626 |
|
---|
| 627 | static void finalize(void)
|
---|
| 628 | {
|
---|
| 629 | kprintf(("EventDumpRequest : finalize()\n"));
|
---|
| 630 |
|
---|
| 631 | if(FileHandle != INVALID_HANDLE_VALUE) //CreateFile returns INVALID_HANDLE_VALUE if it failed
|
---|
| 632 | ::CloseHandle(FileHandle);
|
---|
| 633 | }
|
---|
| 634 |
|
---|
| 635 | static EventDumpRequest * Create(enum tagRequestType _type, bool _block, unsigned int _size = 0, void * _storage = NULL, unsigned long _address = 0)
|
---|
| 636 | {
|
---|
| 637 | EventDumpRequest * request;
|
---|
| 638 | BOOL lock;
|
---|
| 639 |
|
---|
| 640 | enter_system_critical_section(&lock);
|
---|
| 641 | request = new EventDumpRequest(_type, _block, _size, _storage, _address);
|
---|
| 642 | leave_system_critiacl_section(&lock);
|
---|
| 643 |
|
---|
| 644 | return request;
|
---|
| 645 | }
|
---|
| 646 |
|
---|
| 647 | virtual int invoke(void)
|
---|
| 648 | {
|
---|
| 649 | DWORD written;
|
---|
| 650 | BOOL lock;
|
---|
| 651 |
|
---|
| 652 | enter_system_critical_section(&lock);
|
---|
| 653 | if(FileHandle != INVALID_HANDLE_VALUE) //CreateFile return INVALID_HANDLE_VALUE, not NULL, if it failed its operatation.
|
---|
| 654 | ::WriteFile(FileHandle, storage, size, &written, NULL);
|
---|
| 655 | delete this;
|
---|
| 656 | leave_system_critiacl_section(&lock);
|
---|
| 657 |
|
---|
| 658 | return 0;
|
---|
| 659 | }
|
---|
| 660 | };
|
---|
| 661 |
|
---|
| 662 | class ExclusiveDeviceRequest : public Request
|
---|
| 663 | {
|
---|
| 664 | protected:
|
---|
| 665 | static HANDLE blocker;
|
---|
| 666 | public:
|
---|
| 667 |
|
---|
| 668 | static void initialize(void) throw()
|
---|
| 669 | {
|
---|
| 670 | kprintf(("ExclusiveDeviceRequest::initialize()\n"));
|
---|
| 671 |
|
---|
| 672 | if(blocker == NULL) {
|
---|
| 673 | blocker = ::CreateEvent(NULL, FALSE, FALSE, NULL);
|
---|
| 674 | }
|
---|
| 675 | }
|
---|
| 676 |
|
---|
| 677 | static void finalize(void) throw()
|
---|
| 678 | {
|
---|
| 679 | kprintf(("ExclusiveDeviceRequest::finalize()\n"));
|
---|
| 680 |
|
---|
| 681 | if(blocker != NULL) {
|
---|
| 682 | ::CloseHandle(blocker);
|
---|
| 683 | }
|
---|
| 684 | }
|
---|
| 685 |
|
---|
| 686 | virtual void signal(int _result = 0)
|
---|
| 687 | {
|
---|
| 688 | result = _result;
|
---|
| 689 | ::SetEvent(blocker);
|
---|
| 690 | }
|
---|
| 691 |
|
---|
| 692 | virtual int invoke(void)
|
---|
| 693 | {
|
---|
| 694 | int _result = 0;
|
---|
| 695 | BOOL lock;
|
---|
| 696 | BOOL cpustate;
|
---|
| 697 |
|
---|
| 698 | //å²ãè¾¼ã¿ãç¦æ¢ãã
|
---|
| 699 | if((cpustate = CPUStatus) == 0)
|
---|
| 700 | dis_int(0);
|
---|
| 701 |
|
---|
| 702 | enter_system_critical_section(&lock);
|
---|
| 703 |
|
---|
| 704 | //è¦æ±ããã¥ã¼ã®å
|
---|
| 705 | é ã«ã¤ãªã
|
---|
| 706 | ::EnterCriticalSection(&cs);
|
---|
| 707 | next = top;
|
---|
| 708 | top = this;
|
---|
| 709 | if(tail == NULL)
|
---|
| 710 | tail = this;
|
---|
| 711 | ::LeaveCriticalSection(&cs);
|
---|
| 712 | ::InterlockedIncrement(&RequestCount);
|
---|
| 713 |
|
---|
| 714 | ::ReleaseSemaphore(request_semaphore, 1, NULL);
|
---|
| 715 | leave_system_critiacl_section(&lock);
|
---|
| 716 |
|
---|
| 717 | if(blocking) {
|
---|
| 718 | ::WaitForSingleObject(blocker, INFINITE);
|
---|
| 719 |
|
---|
| 720 | _result = result;
|
---|
| 721 |
|
---|
| 722 | enter_system_critical_section(&lock);
|
---|
| 723 | delete this;
|
---|
| 724 | leave_system_critiacl_section(&lock);
|
---|
| 725 | }
|
---|
| 726 |
|
---|
| 727 | if(cpustate == 0)
|
---|
| 728 | ena_int(0);
|
---|
| 729 |
|
---|
| 730 | return _result;
|
---|
| 731 | }
|
---|
| 732 | };
|
---|
| 733 |
|
---|
| 734 | // typedef class EventDumpRequest EventRequest;
|
---|
| 735 | typedef class Request EventRequest; //ã¤ãã³ããã°åºåè¦æ±ã§ä½¿ç¨ããããªã¯ã¨ã¹ã
|
---|
| 736 | // typedef class Request DeviceRequest; //ããã¤ã¹éä¿¡è¦æ±ã§ä½¿ç¨ããããªã¯ã¨ã¹ã
|
---|
| 737 | typedef class ExclusiveDeviceRequest DeviceRequest; //ããã¤ã¹éä¿¡è¦æ±ã§ä½¿ç¨ããããªã¯ã¨ã¹ã
|
---|
| 738 |
|
---|
| 739 | //==============================================================================
|
---|
| 740 |
|
---|
| 741 | LONG Request::RequestCount = -1; //ãã¥ã¼ã«ã¤ãªãã£ã¦ãããªã¯ã¨ã¹ãã®æ°
|
---|
| 742 | Request * Request::top = NULL; //ãªã¯ã¨ã¹ããã¥ã¼ã®å
|
---|
| 743 | é (ãã£ã¨ãå¤ããªã¯ã¨ã¹ã)
|
---|
| 744 | Request * Request::tail = NULL; //ãªã¯ã¨ã¹ããã¥ã¼ã®æ«å°¾ (ãã£ã¨ãæ°ãããªã¯ã¨ã¹ã)
|
---|
| 745 | CRITICAL_SECTION Request::cs; //æä»ãã¥ã¼æä½ç¨å±éºé åãªãã¸ã§ã¯ã
|
---|
| 746 |
|
---|
| 747 | HANDLE EventDumpRequest::FileHandle = INVALID_HANDLE_VALUE; //CreateFile uses INVALID_HANDLE_VALUE for identifying an invalid instance
|
---|
| 748 | HANDLE ExclusiveDeviceRequest::blocker = NULL;
|
---|
| 749 |
|
---|
| 750 | //==============================================================================
|
---|
| 751 |
|
---|
| 752 | /*
|
---|
| 753 | * ä½æ¥ã¹ã¬ããã使ç¨ããä½æ¥é¢æ°ã®å®ç¾©
|
---|
| 754 | */
|
---|
| 755 |
|
---|
| 756 | //ã³ãã¯ã·ã§ã³ãã¤ã³ãã¸ã®æ¥ç¶
|
---|
| 757 | bool Advise(IUnknown * container, REFIID iid, IUnknown * sink, DWORD * cookie, IConnectionPoint ** p_cp = NULL)
|
---|
| 758 | {
|
---|
| 759 | IConnectionPointContainer * cp_container;
|
---|
| 760 | IConnectionPoint * cp;
|
---|
| 761 |
|
---|
| 762 | if(container == 0 || sink == 0 || cookie == 0)
|
---|
| 763 | return false;
|
---|
| 764 |
|
---|
| 765 | if(p_cp == 0)
|
---|
| 766 | p_cp = &cp;
|
---|
| 767 |
|
---|
| 768 | //IUnknownã¤ã³ã¿ãã§ã¼ã¹ããIConnectionPointContainerã¸ãã£ã¹ã
|
---|
| 769 | container->QueryInterface(IID_IConnectionPointContainer, (void **)&cp_container);
|
---|
| 770 | if(cp_container == 0)
|
---|
| 771 | return false;
|
---|
| 772 |
|
---|
| 773 | //ConnectionPointContainerããè¦æ±ã«åãConnectionPointãæ¢ã
|
---|
| 774 | cp_container->FindConnectionPoint(iid, p_cp);
|
---|
| 775 | cp_container->Release();
|
---|
| 776 | if(*p_cp == 0)
|
---|
| 777 | return false;
|
---|
| 778 |
|
---|
| 779 | //ã³ãã¯ã·ã§ã³ãã¤ã³ãæ¥ç¶
|
---|
| 780 | if(FAILED((*p_cp)->Advise(sink, cookie)))
|
---|
| 781 | return false;
|
---|
| 782 |
|
---|
| 783 | if(p_cp == &cp)
|
---|
| 784 | cp->Release();
|
---|
| 785 | return true;
|
---|
| 786 | }
|
---|
| 787 |
|
---|
| 788 | //==============================================================================
|
---|
| 789 |
|
---|
| 790 | /*
|
---|
| 791 | * PerformRequest : è¦æ±ã®å®è¡
|
---|
| 792 | * è¿å´å¤ : ã¤ãã³ãå¦çãç¶ç¶ãã(true) or ä½æ¥ã¹ã¬ãããåæ¢ããã(false)
|
---|
| 793 | */
|
---|
| 794 |
|
---|
| 795 | bool PerformRequest(IKernel * manager)
|
---|
| 796 | {
|
---|
| 797 | Request * request;
|
---|
| 798 | bool succeeded;
|
---|
| 799 |
|
---|
| 800 | //ãã¥ã¼ãããªã¯ã¨ã¹ããæãåã
|
---|
| 801 | request = Request::GetRequest();
|
---|
| 802 | FatalAssertion(request != NULL,"");
|
---|
| 803 |
|
---|
| 804 | //çµäºè¦æ±
|
---|
| 805 | if(request->getType() == Request::QuitThread)
|
---|
| 806 | {
|
---|
| 807 | if(!request->isBlockingRequest())
|
---|
| 808 | {
|
---|
| 809 | BOOL lock;
|
---|
| 810 |
|
---|
| 811 | enter_system_critical_section(&lock);
|
---|
| 812 | delete request;
|
---|
| 813 | leave_system_critiacl_section(&lock);
|
---|
| 814 | }
|
---|
| 815 | return false;
|
---|
| 816 | }
|
---|
| 817 |
|
---|
| 818 | //è¦æ±æ¯ã®å¦ç
|
---|
| 819 | switch(request->getType())
|
---|
| 820 | {
|
---|
| 821 | case Request::Confirmation:
|
---|
| 822 | succeeded = true;
|
---|
| 823 | break;
|
---|
| 824 |
|
---|
| 825 | case Request::DeviceRead:
|
---|
| 826 | succeeded = SUCCEEDED(manager->Read(request->getAddress(), request->getSize(), reinterpret_cast<char *>(request->getStorage())));
|
---|
| 827 | break;
|
---|
| 828 |
|
---|
| 829 | case Request::DeviceWrite:
|
---|
| 830 | succeeded = SUCCEEDED(manager->Write(request->getAddress(), request->getSize(), reinterpret_cast<char *>(request->getStorage())));
|
---|
| 831 | break;
|
---|
| 832 |
|
---|
| 833 | case Request::EventLog:
|
---|
| 834 | succeeded = SUCCEEDED(manager->OnLogEvent(request->getSize(), reinterpret_cast<unsigned char *>(request->getStorage())));
|
---|
| 835 |
|
---|
| 836 | //ã·ã£ãããã¦ã³ä¸ãªããã°ãå
|
---|
| 837 | ¨é¨ã¯ãçµãã¾ã§å¾
|
---|
| 838 | ã£ã¦ããã
|
---|
| 839 | ShutdownPostponementRequest = TRUE;
|
---|
| 840 | break;
|
---|
| 841 |
|
---|
| 842 | default:
|
---|
| 843 | succeeded = false;
|
---|
| 844 | }
|
---|
| 845 |
|
---|
| 846 | request->Finalize(succeeded);
|
---|
| 847 |
|
---|
| 848 | return true;
|
---|
| 849 | }
|
---|
| 850 |
|
---|
| 851 | /*
|
---|
| 852 | * COMéä¿¡ãè¡ãããã®ä½æ¥ã¹ã¬ãã æ¬ä½
|
---|
| 853 | */
|
---|
| 854 | DWORD WINAPI WorkerThreadProcess(LPVOID _param)
|
---|
| 855 | {
|
---|
| 856 | IKernel * manager;
|
---|
| 857 | IKernelEvents * sink;
|
---|
| 858 | IConnectionPoint * cp;
|
---|
| 859 | DWORD cookie;
|
---|
| 860 | BOOL Success;
|
---|
| 861 |
|
---|
| 862 | kprintf(("WorkerThreadProcess : start\n"));
|
---|
| 863 |
|
---|
| 864 | /* åæå */
|
---|
| 865 | ::CoInitialize(NULL);
|
---|
| 866 |
|
---|
| 867 | // ããã¤ã¹ããã¼ã¸ã£ã¨æ¥ç¶
|
---|
| 868 | manager = 0;
|
---|
| 869 | if(FAILED(::CoCreateInstance(CLSID_Kernel, NULL, CLSCTX_ALL, IID_IKernel, (void **)&manager)))
|
---|
| 870 | goto _WorkerThreadProc_Cleanup;
|
---|
| 871 |
|
---|
| 872 | cp = 0;
|
---|
| 873 | sink = new(std::nothrow) IKernelEvents;
|
---|
| 874 | if(!Advise(manager, IID_IKernelEvents, sink, &cookie,&cp))
|
---|
| 875 | {
|
---|
| 876 | if(sink != 0)
|
---|
| 877 | delete sink;
|
---|
| 878 | goto _WorkerThreadProc_Cleanup;
|
---|
| 879 | }
|
---|
| 880 |
|
---|
| 881 | /* ã¡ã¤ã³ã«ã¼ãã³ */
|
---|
| 882 | manager->IsValid(&Success);
|
---|
| 883 | if(Success != 0)
|
---|
| 884 | {
|
---|
| 885 | MSG msg;
|
---|
| 886 | DWORD work;
|
---|
| 887 | bool loop_flag = true;
|
---|
| 888 |
|
---|
| 889 | do {
|
---|
| 890 | /*
|
---|
| 891 | * å¤é¨ããCOMããããã¨ã¡ãã»ã¼ã¸ã¨ãã¦é£ãã§ãããããWaitForSingleObjectã§ã»ããã©ãå¾
|
---|
| 892 | ã¤ã¨å¤é¨ããã®è¦æ±ãå®è¡ã§ããªããªãã
|
---|
| 893 | * ãã®ãããMsgWaitFor...ãç¨ããã¡ãã»ã¼ã¸ãé£ãã§ããå ´åã¯ããã«å¯¾å¦ã§ããããã«ããã
|
---|
| 894 | */
|
---|
| 895 |
|
---|
| 896 | /*
|
---|
| 897 | * cygwinç°å¢ã ã¨QS_ALLPOSTMESSAGEãå®ç¾©ãããªãã®ã§ãããã§å¯¾å¦
|
---|
| 898 | */
|
---|
| 899 | #ifndef QS_ALLPOSTMESSAGE
|
---|
| 900 | #define QS_ALLPOSTMESSAGE (0x0100)
|
---|
| 901 | #endif
|
---|
| 902 |
|
---|
| 903 | //è¦æ±å¾
|
---|
| 904 | ã¡
|
---|
| 905 | work = ::MsgWaitForMultipleObjects(1, &request_semaphore, FALSE, INFINITE, QS_ALLPOSTMESSAGE);
|
---|
| 906 |
|
---|
| 907 | switch(work) {
|
---|
| 908 |
|
---|
| 909 | //å¦çè¦æ±ã®å®è¡
|
---|
| 910 | case WAIT_OBJECT_0:
|
---|
| 911 | loop_flag = PerformRequest(manager);
|
---|
| 912 | break;
|
---|
| 913 |
|
---|
| 914 | //å¤é¨ããã®è¦æ± (å²è¾¼ã¿ãªã©)
|
---|
| 915 | case WAIT_OBJECT_0 + 1:
|
---|
| 916 | GetMessage(&msg, 0, 0, 0);
|
---|
| 917 | TranslateMessage(&msg);
|
---|
| 918 | DispatchMessage(&msg);
|
---|
| 919 | break;
|
---|
| 920 |
|
---|
| 921 | default:
|
---|
| 922 | loop_flag = false;
|
---|
| 923 | }
|
---|
| 924 |
|
---|
| 925 | } while(loop_flag);
|
---|
| 926 | }
|
---|
| 927 |
|
---|
| 928 | /*
|
---|
| 929 | * Finalize
|
---|
| 930 | */
|
---|
| 931 |
|
---|
| 932 | if(cp != 0)
|
---|
| 933 | {
|
---|
| 934 | cp->Unadvise(cookie);
|
---|
| 935 | cp->Release();
|
---|
| 936 | cp = 0;
|
---|
| 937 | sink = 0;
|
---|
| 938 | }
|
---|
| 939 |
|
---|
| 940 | _WorkerThreadProc_Cleanup:
|
---|
| 941 |
|
---|
| 942 | if(manager != 0)
|
---|
| 943 | manager->Release();
|
---|
| 944 |
|
---|
| 945 | CloseHandle(worker_thread_handle);
|
---|
| 946 | worker_thread_handle = NULL;
|
---|
| 947 | manager = 0l;
|
---|
| 948 | ::CoUninitialize();
|
---|
| 949 |
|
---|
| 950 | /* ãã¥ã¼ã空ã«ãã (å¾
|
---|
| 951 | ã¡è§£é¤) */
|
---|
| 952 |
|
---|
| 953 | Request * request;
|
---|
| 954 | while((request = Request::GetRequest()) != 0)
|
---|
| 955 | request->Finalize(false);
|
---|
| 956 |
|
---|
| 957 | kprintf(("WorkerThreadProcess : exit\n"));
|
---|
| 958 |
|
---|
| 959 | return 0;
|
---|
| 960 | }
|
---|
| 961 | }
|
---|
| 962 |
|
---|
| 963 | //==============================================================================
|
---|
| 964 |
|
---|
| 965 | /****************************************************
|
---|
| 966 | * *
|
---|
| 967 | * TOPPERS/JSP - Windowsã·ãã¥ã¬ã¼ã·ã§ã³ç°å¢ *
|
---|
| 968 | * COMãç¨ããããã¤ã¹ã¨ãã¥ã¬ã¼ã·ã§ã³æ©è½ *
|
---|
| 969 | * *
|
---|
| 970 | ****************************************************/
|
---|
| 971 |
|
---|
| 972 | #ifdef DEVICE_ENABLE
|
---|
| 973 |
|
---|
| 974 | extern "C"
|
---|
| 975 | int _cdecl DeviceRead(unsigned long address, unsigned long size, void * storage)
|
---|
| 976 | {
|
---|
| 977 | if(!IsValid() || storage == NULL)
|
---|
| 978 | return -1;
|
---|
| 979 |
|
---|
| 980 | return DeviceRequest::Create(Request::DeviceRead, true, size, storage, address)->invoke();
|
---|
| 981 | }
|
---|
| 982 |
|
---|
| 983 | extern "C"
|
---|
| 984 | int _cdecl DeviceWrite(unsigned long address, unsigned long size, void * storage)
|
---|
| 985 | {
|
---|
| 986 | if(!IsValid() || storage == NULL)
|
---|
| 987 | return -1;
|
---|
| 988 |
|
---|
| 989 | return DeviceRequest::Create(Request::DeviceWrite, true, size, storage, address)->invoke();
|
---|
| 990 | }
|
---|
| 991 |
|
---|
| 992 | #endif
|
---|
| 993 |
|
---|
| 994 |
|
---|
| 995 | /****************************************************
|
---|
| 996 | * *
|
---|
| 997 | * TOPPERS/JSP - Windowsã·ãã¥ã¬ã¼ã·ã§ã³ç°å¢ *
|
---|
| 998 | * COMãç¨ããã«ã¼ãã«ãã°åå¾æ©è½ *
|
---|
| 999 | * *
|
---|
| 1000 | ****************************************************/
|
---|
| 1001 |
|
---|
| 1002 | #ifdef EVENTLOG_ENABLE
|
---|
| 1003 |
|
---|
| 1004 | /* å¤éãã°åºåé²æ¢ç¨ã»ããã© : 1ã足ããçµæã1ã§ãã£ãã¨ãã ãããã°ãåºåã§ãã */
|
---|
| 1005 | static LONG event_write_semaphore = 0;
|
---|
| 1006 |
|
---|
| 1007 | void event_write(unsigned int logtype, unsigned int valid, UINT bufsz, ... )
|
---|
| 1008 | {
|
---|
| 1009 | EventRequest * event_request;
|
---|
| 1010 | DBIFLOG * log;
|
---|
| 1011 | va_list vl;
|
---|
| 1012 |
|
---|
| 1013 | if(IsValid() && TlsGetValue(TLS_LOGMASK) == 0)
|
---|
| 1014 | {
|
---|
| 1015 | // ãªã¯ã¨ã¹ãé å確ä¿
|
---|
| 1016 | event_request = EventRequest::Create(EventRequest::EventLog, false, sizeof(T_RGLOG_HEADER) + bufsz);
|
---|
| 1017 | log = reinterpret_cast<DBIFLOG *>(event_request->getptr());
|
---|
| 1018 |
|
---|
| 1019 | // ãããçæ
|
---|
| 1020 | log->header.logtype = logtype;
|
---|
| 1021 | log->header.logtim = _kernel_systim_offset + _kernel_current_time;
|
---|
| 1022 | log->header.valid = valid;
|
---|
| 1023 | log->header.bufsz = bufsz;
|
---|
| 1024 |
|
---|
| 1025 | // æ¬ä½ã®æ ¼ç´
|
---|
| 1026 | va_start(vl, bufsz);
|
---|
| 1027 | for(unsigned int i=0;i<bufsz/sizeof(int);i++)
|
---|
| 1028 | *((int *)&log->body + i) = va_arg(vl, int);
|
---|
| 1029 |
|
---|
| 1030 | // è¦æ±ã®éä» (Non-blocking)
|
---|
| 1031 | event_request->invoke();
|
---|
| 1032 | }
|
---|
| 1033 | }
|
---|
| 1034 |
|
---|
| 1035 | extern "C"
|
---|
| 1036 | void event_write_svc_enter(int fncd, unsigned int params, ... )
|
---|
| 1037 | {
|
---|
| 1038 | EventRequest * event_request;
|
---|
| 1039 | DBIFLOG * log;
|
---|
| 1040 | va_list vl;
|
---|
| 1041 | unsigned int i;
|
---|
| 1042 |
|
---|
| 1043 | if(IsValid() && TlsGetValue(TLS_LOGMASK) == 0)
|
---|
| 1044 | {
|
---|
| 1045 | //é åç¢ºä¿ : 確ä¿ãããµã¤ãºã¯ãã©ã¡ã¼ã¿ç·æ°ããä¸ååå¤ã (å¼ã³åºãå
|
---|
| 1046 | ã¢ãã¬ã¹ãæ ¼ç´)
|
---|
| 1047 | event_request = EventRequest::Create(EventRequest::EventLog, false, sizeof(T_RGLOG_HEADER) + sizeof(T_RGLOG_SVC) + params * sizeof(VP_INT));
|
---|
| 1048 | log = reinterpret_cast<DBIFLOG *>(event_request->getptr());
|
---|
| 1049 |
|
---|
| 1050 | //ãã±ããçæ
|
---|
| 1051 | log->header.logtype = LOG_TYPE_SVC;
|
---|
| 1052 | log->header.logtim = _kernel_systim_offset + _kernel_current_time;
|
---|
| 1053 | log->header.valid = 0x7fffffff >> (29 - params);
|
---|
| 1054 | log->header.bufsz = (params+3) * sizeof(int);
|
---|
| 1055 |
|
---|
| 1056 | va_start(vl, params);
|
---|
| 1057 |
|
---|
| 1058 | log->body.svc.fncno = fncd;
|
---|
| 1059 | log->body.svc.prmcnt = params;
|
---|
| 1060 |
|
---|
| 1061 | /* ä¸åã«ã¼ããå¤ãã®ã¯æå¾ã«å¼åºå
|
---|
| 1062 | ã¢ãã¬ã¹ãç©ãã§ãããã */
|
---|
| 1063 | for(i=0;i<params+1;i++)
|
---|
| 1064 | log->body.svc.prmary[i] = va_arg(vl, VP_INT);
|
---|
| 1065 |
|
---|
| 1066 | event_request->invoke();
|
---|
| 1067 | }
|
---|
| 1068 | }
|
---|
| 1069 |
|
---|
| 1070 | extern "C"
|
---|
| 1071 | void event_write_svc_leave(int fncd, unsigned int ercd, unsigned int retaddr)
|
---|
| 1072 | {
|
---|
| 1073 | EventRequest * event_request;
|
---|
| 1074 | DBIFLOG * log;
|
---|
| 1075 |
|
---|
| 1076 | if(IsValid() && TlsGetValue(TLS_LOGMASK) == 0)
|
---|
| 1077 | {
|
---|
| 1078 | //é åç¢ºä¿ : 確ä¿ãããµã¤ãºã¯ãã©ã¡ã¼ã¿ç·æ°(è¿å´å¤ã®ã¿ãªã®ã§ï¼ã¤)ããä¸ååå¤ã (å¼ã³åºãå
|
---|
| 1079 | ã¢ãã¬ã¹ãæ ¼ç´)
|
---|
| 1080 | event_request = EventRequest::Create(EventRequest::EventLog, false, sizeof(T_RGLOG_HEADER) + sizeof(T_RGLOG_SVC) + sizeof(VP_INT));
|
---|
| 1081 | log = reinterpret_cast<DBIFLOG *>(event_request->getptr());
|
---|
| 1082 |
|
---|
| 1083 | //ãããé¨çæ
|
---|
| 1084 | log->header.logtype = LOG_TYPE_SVC|LOG_LEAVE;
|
---|
| 1085 | log->header.logtim = _kernel_systim_offset + _kernel_current_time;
|
---|
| 1086 | log->header.valid = 0x7;
|
---|
| 1087 | log->header.bufsz = 4 * sizeof(int);
|
---|
| 1088 |
|
---|
| 1089 | //ããã£é¨çæ
|
---|
| 1090 | log->body.svc.fncno = fncd;
|
---|
| 1091 | log->body.svc.prmcnt = 1;
|
---|
| 1092 | log->body.svc.prmary[0] = (VP_INT)ercd;
|
---|
| 1093 | log->body.svc.prmary[1] = (VP_INT)retaddr;
|
---|
| 1094 |
|
---|
| 1095 | event_request->invoke();
|
---|
| 1096 | }
|
---|
| 1097 | }
|
---|
| 1098 |
|
---|
| 1099 | extern "C" void decode_taskstatus(void * tcb, int * tskid, unsigned int * tskstat, unsigned int * objtype, int * objid);
|
---|
| 1100 |
|
---|
| 1101 | extern "C"
|
---|
| 1102 | void event_write_tskstat(void * tcb)
|
---|
| 1103 | {
|
---|
| 1104 | EventRequest * event_request;
|
---|
| 1105 | DBIFLOG * log;
|
---|
| 1106 |
|
---|
| 1107 | if(IsValid()) //ããã¯ã«ã¼ãã«æä½ãªã®ã§TLS_LOGMASKãè¦ã¦ã¯ãããªã
|
---|
| 1108 | {
|
---|
| 1109 | //é å確ä¿
|
---|
| 1110 | event_request = EventRequest::Create(EventRequest::EventLog, false, sizeof(T_RGLOG_HEADER) + sizeof(T_RGLOG_TSKSTAT));
|
---|
| 1111 | log = reinterpret_cast<DBIFLOG *>(event_request->getptr());
|
---|
| 1112 |
|
---|
| 1113 | log->header.logtype = LOG_TYPE_TSKSTAT;
|
---|
| 1114 | log->header.logtim = _kernel_systim_offset + _kernel_current_time;
|
---|
| 1115 | log->header.valid = 0xf;
|
---|
| 1116 | log->header.bufsz = 4 * sizeof(int);
|
---|
| 1117 |
|
---|
| 1118 | decode_taskstatus(tcb, &log->body.tskstat.tskid, &log->body.tskstat.tskstat, &log->body.tskstat.tskwait, &log->body.tskstat.wobjid);
|
---|
| 1119 |
|
---|
| 1120 | event_request->invoke();
|
---|
| 1121 | }
|
---|
| 1122 | }
|
---|
| 1123 |
|
---|
| 1124 | #endif
|
---|
| 1125 |
|
---|
| 1126 |
|
---|
| 1127 | static BOOL CALLBACK NotifyDialogProc(HWND hDlg,UINT Msg,WPARAM wParam,LPARAM lParam)
|
---|
| 1128 | {
|
---|
| 1129 | switch(Msg)
|
---|
| 1130 | {
|
---|
| 1131 | case WM_INITDIALOG:
|
---|
| 1132 | {
|
---|
| 1133 | LONG count;
|
---|
| 1134 | HWND hCtrl;
|
---|
| 1135 |
|
---|
| 1136 | hCtrl = ::GetDlgItem(hDlg, IDC_PROGRESS1);
|
---|
| 1137 | count = Request::getRequestCount();
|
---|
| 1138 |
|
---|
| 1139 | ::SetWindowLong(hDlg, GWL_USERDATA, count);
|
---|
| 1140 | ::SendMessage(hCtrl, PBM_SETRANGE32, 0, count);
|
---|
| 1141 | ::SendMessage(hCtrl, PBM_SETPOS, count - Request::getRequestCount(), 0);
|
---|
| 1142 |
|
---|
| 1143 | ::SetTimer(hDlg, 100, 200, NULL);
|
---|
| 1144 | break;
|
---|
| 1145 | }
|
---|
| 1146 |
|
---|
| 1147 | case WM_TIMER:
|
---|
| 1148 | if(wParam == 100)
|
---|
| 1149 | {
|
---|
| 1150 | LONG count;
|
---|
| 1151 | HWND hCtrl;
|
---|
| 1152 |
|
---|
| 1153 | hCtrl = ::GetDlgItem(hDlg, IDC_PROGRESS1);
|
---|
| 1154 | count = ::GetWindowLong(hDlg, GWL_USERDATA);
|
---|
| 1155 |
|
---|
| 1156 | ::SendMessage(hCtrl, PBM_SETPOS, count - Request::getRequestCount(), 0);
|
---|
| 1157 |
|
---|
| 1158 | if(Request::getRequestCount() <= 0)
|
---|
| 1159 | ::PostQuitMessage(0);
|
---|
| 1160 | }
|
---|
| 1161 | break;
|
---|
| 1162 | case WM_CLOSE:
|
---|
| 1163 | break;
|
---|
| 1164 |
|
---|
| 1165 | default:
|
---|
| 1166 | return FALSE;
|
---|
| 1167 | }
|
---|
| 1168 | return TRUE;
|
---|
| 1169 | }
|
---|
| 1170 |
|
---|
| 1171 | extern "C"
|
---|
| 1172 | void _cdecl InitializeComSupportModule(void)
|
---|
| 1173 | {
|
---|
| 1174 | kprintf(("InitializeComSupportModule()\n"));
|
---|
| 1175 |
|
---|
| 1176 | Request::initialize();
|
---|
| 1177 | DeviceRequest::initialize();
|
---|
| 1178 | EventRequest::initialize();
|
---|
| 1179 |
|
---|
| 1180 |
|
---|
| 1181 | request_semaphore = ::CreateSemaphore(0, 0, 65536, 0);
|
---|
| 1182 | FatalAssertion(request_semaphore != NULL, "Object Creation Error : request_semaphore");
|
---|
| 1183 |
|
---|
| 1184 | worker_thread_handle = ::CreateThread(0, 0, WorkerThreadProcess, 0, 0, 0);
|
---|
| 1185 | FatalAssertion(worker_thread_handle != NULL, "Object Creation Error : worker_thread");
|
---|
| 1186 |
|
---|
| 1187 | Request * request = Request::Create(Request::Confirmation, true);
|
---|
| 1188 | request->invoke();
|
---|
| 1189 | }
|
---|
| 1190 |
|
---|
| 1191 | extern "C"
|
---|
| 1192 | void _cdecl FinalizeComSupportModule(void)
|
---|
| 1193 | {
|
---|
| 1194 | kprintf(("FinalizeComSupportModule()\n"));
|
---|
| 1195 |
|
---|
| 1196 | if(IsValid())
|
---|
| 1197 | {
|
---|
| 1198 | HWND hDlgitem;
|
---|
| 1199 | HWND NotifyDialog;
|
---|
| 1200 | MSG msg;
|
---|
| 1201 |
|
---|
| 1202 | //ãã°ãæºã¾ããããã¨ãã°åãã«æéãããããããã°ã©ã ãæ´èµ°ããããã«è¦ããã®ã§
|
---|
| 1203 | //ããã°ãåãã¦ãããå¾
|
---|
| 1204 | ã¦ãã¨è¦åãåºãã
|
---|
| 1205 | NotifyDialog = ::CreateDialog(ProcessInstance, MAKEINTRESOURCE(QUITNOTICEDIALOG), NULL, NotifyDialogProc);
|
---|
| 1206 | hDlgitem = ::GetDlgItem(NotifyDialog, IDC_NOTIFYMSG);
|
---|
| 1207 | ::SetWindowText(hDlgitem, "ä» ä¸çæ¸å½ã«ã¼ãã«ã®ã¤ãã³ããã°ãåºãã¦ããã®ã§ãçµãã¾ã§å°ãå¾
|
---|
| 1208 | ã£ã¦ãã ãã");
|
---|
| 1209 | ::ShowWindow(NotifyDialog, SW_NORMAL);
|
---|
| 1210 |
|
---|
| 1211 | Request * request = Request::Create(Request::QuitThread, false);
|
---|
| 1212 | request->invoke();
|
---|
| 1213 |
|
---|
| 1214 | //çµäºãã¤ã¢ãã°ç¨ã®ã¡ãã»ã¼ã¸ãã³ã
|
---|
| 1215 |
|
---|
| 1216 | if(NotifyDialog != NULL) {
|
---|
| 1217 | while(GetMessage(&msg, NULL, 0, 0) != 0) {
|
---|
| 1218 | TranslateMessage(&msg);
|
---|
| 1219 | DispatchMessage(&msg);
|
---|
| 1220 | }
|
---|
| 1221 | }
|
---|
| 1222 |
|
---|
| 1223 | //ã¡ããã¨ã¹ã¬ãããçµäºããã¾ã§å¾
|
---|
| 1224 | æ©
|
---|
| 1225 | if(worker_thread_handle != NULL)
|
---|
| 1226 | ::WaitForSingleObject(worker_thread_handle, INFINITE);
|
---|
| 1227 | ::CloseHandle(request_semaphore);
|
---|
| 1228 | request_semaphore = NULL;
|
---|
| 1229 |
|
---|
| 1230 | EventRequest::finalize();
|
---|
| 1231 | DeviceRequest::finalize();
|
---|
| 1232 | Request::finalize();
|
---|
| 1233 |
|
---|
| 1234 | ::DestroyWindow(NotifyDialog);
|
---|
| 1235 | }
|
---|
| 1236 | }
|
---|
| 1237 |
|
---|
| 1238 |
|
---|
| 1239 | #else // __COM_NOT_REQUIRED__
|
---|
| 1240 |
|
---|
| 1241 | extern "C"
|
---|
| 1242 | void _cdecl InitializeComSupportModule(void)
|
---|
| 1243 | {}
|
---|
| 1244 |
|
---|
| 1245 | extern "C"
|
---|
| 1246 | void _cdecl FinalizeComSupportModule(void)
|
---|
| 1247 | {}
|
---|
| 1248 |
|
---|
| 1249 | #endif // __COM_NOT_REQUIRED__
|
---|