Commit: 5c07f033ac3fc92e04cbec32b6acd0fc8334bf0b - DebugMonitor (git)

UART通信を用いた組み込みデバッグ用途向けメモリモニタ

Commit MetaInfo

• Revision: 5c07f033ac3fc92e04cbec32b6acd0fc8334bf0b (tree)
• Time: 2018-05-14 22:32:54
• Author: Yasushi Tanaka <tanaka_yasushi2008@yaho...>
• Commiter: Yasushi Tanaka

Log Message

YMODEM送信確認

Change Summary

• modified: DebugMonitor/DebugMonitor.vcxproj
• modified: DebugMonitor/src/app/app.c
• modified: DebugMonitor/src/comm/comm.c
• modified: DebugMonitor/src/comm/comm.h
• modified: DebugMonitor/src/comm/ymodem.c
• modified: DebugMonitor/src/framework/logwin.c
• modified: DebugMonitor/src/framework/logwin.h
• modified: DebugMonitor/src/framework/monitor.c
• modified: DebugMonitor/src/framework/screen.c
• modified: DebugMonitor/src/framework/winmain.c

Incremental Difference

--- a/DebugMonitor/DebugMonitor.vcxproj
+++ b/DebugMonitor/DebugMonitor.vcxproj
@@ -63,7 +63,7 @@
   </ItemDefinitionGroup>
   <ItemDefinitionGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">
     <ClCompile>
-      <WarningLevel>Level3</WarningLevel>
+      <WarningLevel>Level4</WarningLevel>
       <PrecompiledHeader>
       </PrecompiledHeader>
       <Optimization>MaxSpeed</Optimization>
@@ -71,12 +71,15 @@
       <IntrinsicFunctions>true</IntrinsicFunctions>
       <PreprocessorDefinitions>WIN32;NDEBUG;_WINDOWS;%(PreprocessorDefinitions)</PreprocessorDefinitions>
       <SDLCheck>true</SDLCheck>
+      <AdditionalIncludeDirectories>$(ProjectDir)src\framework;$(ProjectDir)src\comm;$(ProjectDir)src\app;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
+      <RuntimeLibrary>MultiThreaded</RuntimeLibrary>
     </ClCompile>
     <Link>
       <SubSystem>Windows</SubSystem>
       <GenerateDebugInformation>true</GenerateDebugInformation>
       <EnableCOMDATFolding>true</EnableCOMDATFolding>
       <OptimizeReferences>true</OptimizeReferences>
+      <AdditionalDependencies>imm32.lib;winmm.lib;setupapi.lib;%(AdditionalDependencies)</AdditionalDependencies>
     </Link>
   </ItemDefinitionGroup>
   <ItemGroup>

--- a/DebugMonitor/src/app/app.c
+++ b/DebugMonitor/src/app/app.c
@@ -9,6 +9,7 @@
 #include "winmain.h"
 #include "logwin.h"
 #include "comm.h"
+#include "ymodem.h"
 #include "app.h"
 
 /*
@@ -17,12 +18,51 @@
  */
 void app_run(void)
 {
-    UINT count;
+    UINT portnum;
+    BYTE buf[240];
+    UINT loop;
+    BOOL result;
 
-    count = 0;
-
-    while (TRUE == do_events(1000))
+    portnum = 0;
+    while (0 == portnum)
     {
+        if (FALSE == do_events(10))
+        {
+            return;
+        }
         comm_enum();
+        portnum = comm_get_portnum();
+    }
+
+    if (2 != portnum)
+    {
+        return;
+    }
+
+    /* ポート指定 */
+    ymodem_init(0);
+
+    /* データ作成 */
+    for (loop = 0; loop < sizeof(buf); loop++)
+    {
+        buf[loop] = (BYTE)loop;
+    }
+
+    /* ファイルバッファへ転送 */
+    memcpy(ymodem_get_filebuf(), buf, sizeof(buf));
+
+    /* ファイル送信 */
+    result = ymodem_send("test.bin", sizeof(buf));
+    if (FALSE == result)
+    {
+        return;
+    }
+
+    while (YMODEM_BUSY == ymodem_get_status())
+    {
+        if (FALSE == do_events(10))
+        {
+            return;
+        }
     }
 }

--- a/DebugMonitor/src/comm/comm.c
+++ b/DebugMonitor/src/comm/comm.c
@@ -835,7 +835,7 @@ UINT comm_get_bytes(UINT index)
  * 通信ポート
  * 受信
  */
-UINT comm_recv(UINT index, LPBYTE buf, UINT buflen)
+UINT comm_recv(UINT index, BYTE *buf, UINT buflen)
 {
     COMM_PORT *port;
     UINT inque;
@@ -884,7 +884,7 @@ UINT comm_recv(UINT index, LPBYTE buf, UINT buflen)
  * 通信ポート
  * 送信
  */
-UINT comm_send(UINT index, LPBYTE buf, UINT buflen)
+UINT comm_send(UINT index, const BYTE *buf, UINT buflen)
 {
     COMM_PORT *port;
     DWORD written;

--- a/DebugMonitor/src/comm/comm.h
+++ b/DebugMonitor/src/comm/comm.h
@@ -59,7 +59,7 @@ void comm_close(UINT index);
 UINT comm_get_bytes(UINT index);
 
 /* 受信 */
-UINT comm_recv(UINT index, LPBYTE buf, UINT buflen);
+UINT comm_recv(UINT index, BYTE *buf, UINT buflen);
 
 /* 送信 */
-UINT comm_send(UINT index, LPBYTE buf, UINT buflen);
+UINT comm_send(UINT index, const BYTE *buf, UINT buflen);

--- a/DebugMonitor/src/comm/ymodem.c
+++ b/DebugMonitor/src/comm/ymodem.c
@@ -6,11 +6,22 @@
  */
 
 #include "header.h"
+#include "monitor.h"
 #include "logwin.h"
 #include "comm.h"
 #include "ymodem.h"
 
 /*
+ * モニタ情報
+ */
+
+/* モニタ開始位置(X) */
+#define YMODEM_MONITOR_X                0
+
+/* モニタ開始位置(Y) */
+#define YMODEM_MONITOR_Y                1
+
+/*
  * YMODEM定数
  */
 
@@ -40,7 +51,7 @@
  */
 
 /* 送信タイムアウト */
-#define YMODEM_SEND_TIMEOUT            100
+#define YMODEM_SEND_TIMEOUT            1000
 
 /* 送信リトライ回数 */
 #define YMODEM_SEND_RETRY              40
@@ -406,22 +417,23 @@ static void ymodem_discard_recv(YMODEM_OBJECT *object)
 
     assert(NULL != object);
 
-    /* 無限ループ */
-    for (;;)
+    /* 受信バイト数の取得 */
+    bytes = comm_get_bytes(object->comm_index);
+
+    /* bytesが0以上である限りループ */
+    while (0 < bytes)
     {
-        /* 受信バイト数の取得 */
-        bytes = comm_get_bytes(object->comm_index);
-        if (0 != bytes)
+        /* 1バイト以上の受信バイト数があるので、1バイトだけ読み取る */
+        result = comm_recv(object->comm_index, &buf, sizeof(buf));
+        if (0 == result)
         {
-            /* 1バイト以上の受信バイト数があるので、1バイトだけ読み取る */
-            result = comm_recv(object->comm_index, &buf, sizeof(buf));
-            if (0 == result)
-            {
-                /* 読み取りに失敗した */
-                ymodem_error_closed(object);
-                break;
-            }
+            /* 読み取りに失敗した */
+            ymodem_error_closed(object);
+            break;
         }
+
+        /* 受信バイト数の取得 */
+        bytes = comm_get_bytes(object->comm_index);
     }
 }
 
@@ -437,10 +449,12 @@ static BOOL ymodem_check_timeout(YMODEM_OBJECT *object, DWORD timeout)
 
     /* 差分時間を得る */
     diff = (DWORD)(timeGetTime() - object->start_time);
-
     /* 差分時間がパラメータ以上であればタイムアウト */
     if (diff >= timeout)
     {
+        /* 開始時間を増やす */
+        object->start_time += timeout;
+
         /* タイムアウト回数++ */
         object->timeout_cnt++;
 
@@ -800,6 +814,7 @@ static void ymodem_sendinfo_do(YMODEM_OBJECT *object)
  */
 static void ymodem_sendinfo_exit(YMODEM_OBJECT *object)
 {
+    UNREFERENCED_PARAMETER(object);
 }
 
 /*
@@ -864,6 +879,7 @@ static void ymodem_infoack_do(YMODEM_OBJECT *object)
  */
 static void ymodem_infoack_exit(YMODEM_OBJECT *object)
 {
+    UNREFERENCED_PARAMETER(object);
 }
 
 /*
@@ -897,7 +913,14 @@ static void ymodem_waitc2_do(YMODEM_OBJECT *object)
     /* 'C'であれば状態遷移 */
     if (YMODEM_C == buf)
     {
-        ymodem_object_trans(object, YMODEM_TRANS_SENDDATA);
+        if (0 < object->file_size)
+        {
+            ymodem_object_trans(object, YMODEM_TRANS_SENDDATA);
+        }
+        else
+        {
+            ymodem_object_trans(object, YMODEM_TRANS_SENDEOT);
+        }
     }
 }
 
@@ -935,15 +958,15 @@ static void ymodem_senddata_enter(YMODEM_OBJECT *object)
     memset(object->block_buf, 0, sizeof(object->block_buf));
 
     /* コピーする長さを算出(最大0x80) */
-    assert(object->block_offset < object->file_size);
-    len = object->file_size - object->block_offset;
+    assert(object->buf_offset < object->file_size);
+    len = object->file_size - object->buf_offset;
     if (0x80 < len)
     {
         len = 0x80;
     }
 
     /* ブロックオフセットからデータをコピー */
-    memcpy(&object->block_buf[3], &object->file_buf[object->block_offset], len);
+    memcpy(&object->block_buf[3], &object->file_buf[object->buf_offset], len);
 
     /* ブロック送信開始 */
     ymodem_block_sendstart(object);
@@ -978,6 +1001,7 @@ static void ymodem_senddata_do(YMODEM_OBJECT *object)
  */
 static void ymodem_senddata_exit(YMODEM_OBJECT *object)
 {
+    UNREFERENCED_PARAMETER(object);
 }
 
 /*
@@ -1013,7 +1037,7 @@ static void ymodem_dataack_do(YMODEM_OBJECT *object)
         /* ACK */
     case YMODEM_ACK:
         /* ACKは次のブロックまたはEOT送信 */
-        if ((object->block_offset + 0x80) <= object->file_size)
+        if ((object->buf_offset + 0x80) >= object->file_size)
         {
             /* リトライ回数を初期化 */
             object->retry = 0;
@@ -1029,8 +1053,8 @@ static void ymodem_dataack_do(YMODEM_OBJECT *object)
             /* ブロック番号を進める */
             object->block_no = (object->block_no + 1) & 0xff;
 
-            /* ブロックオフセットを進める */
-            object->block_offset += 0x80;
+            /* バッファオフセットを進める */
+            object->buf_offset += 0x80;
 
             /* データブロック送信 */
             ymodem_object_trans(object, YMODEM_TRANS_SENDDATA);
@@ -1067,6 +1091,7 @@ static void ymodem_dataack_do(YMODEM_OBJECT *object)
  */
 static void ymodem_dataack_exit(YMODEM_OBJECT *object)
 {
+    UNREFERENCED_PARAMETER(object);
 }
 
 /*
@@ -1076,6 +1101,7 @@ static void ymodem_dataack_exit(YMODEM_OBJECT *object)
  */
 static void ymodem_sendeot_enter(YMODEM_OBJECT *object)
 {
+    UNREFERENCED_PARAMETER(object);
 }
 
 /*
@@ -1112,6 +1138,7 @@ static void ymodem_sendeot_do(YMODEM_OBJECT *object)
  */
 static void ymodem_sendeot_exit(YMODEM_OBJECT *object)
 {
+    UNREFERENCED_PARAMETER(object);
 }
 
 /*
@@ -1151,6 +1178,7 @@ static void ymodem_eotack_do(YMODEM_OBJECT *object)
         /* ACKは送信終了 */
         object->sending = FALSE;
         object->status = YMODEM_SUCCESS;
+        object->state = YMODEM_TRANS_NONE;
         break;
 
     /* NAK */
@@ -1183,6 +1211,7 @@ static void ymodem_eotack_do(YMODEM_OBJECT *object)
  */
 static void ymodem_eotack_exit(YMODEM_OBJECT *object)
 {
+    UNREFERENCED_PARAMETER(object);
 }
 
 /*
@@ -1414,6 +1443,160 @@ static BOOL ymodem_object_send(YMODEM_OBJECT *object, const char *filename, UINT
 
 /*
  * YMODEM
+ * オブジェクトモニタ
+ */
+static void ymodem_object_monitor(YMODEM_OBJECT *object)
+{
+    assert(NULL != object);
+
+    /* 位置とクリア*/
+    monitor_locate(YMODEM_MONITOR_X, YMODEM_MONITOR_Y);
+    monitor_clear(40, 15);
+
+    /* タイトル */
+    monitor_printf("[YMODEM情報]\n");
+
+    /* 通信ポート番号 */
+    monitor_printf("通信ポート番号   %u\n", object->comm_index);
+
+    /* 送信中フラグ */
+    if (FALSE == object->sending)
+    {
+        monitor_printf("送信状態         アイドル\n");
+   }
+    else
+    {
+        monitor_printf("送信状態         送信中\n");
+    }
+
+    /* 受信中フラグ */
+    if (FALSE == object->receiving)
+    {
+        monitor_printf("受信状態         アイドル\n");
+    }
+    else
+    {
+        monitor_printf("受信状態         受信中\n");
+    }
+
+    /* ステータス */
+    switch (object->status)
+    {
+    /* 成功 */
+    case YMODEM_SUCCESS:
+        monitor_printf("ステータス       成功\n");
+        break;
+
+    /* 動作中 */
+    case YMODEM_BUSY:
+        monitor_printf("ステータス       動作中\n");
+        break;
+
+    /* バッファサイズ溢れ */
+    case YMODEM_SIZEOVER:
+        monitor_printf("ステータス       バッファサイズ溢れ\n");
+        break;
+
+    /* タイムアウト */
+    case YMODEM_TIMEOUT:
+        monitor_printf("ステータス       タイムアウト\n");
+        break;
+
+    /* リトライオーバー */
+    case YMODEM_RETRY:
+        monitor_printf("ステータス       リトライオーバー\n");
+        break;
+
+    /* キャンセル要求受信 */
+    case YMODEM_CANCEL:
+        monitor_printf("ステータス       キャンセル要求受信\n");
+        break;
+
+    /* ポートクローズ */
+    case YMODEM_CLOSED:
+        monitor_printf("ステータス       ポートクローズ\n");
+        break;
+    }
+
+    /* ファイルネーム */
+    monitor_printf("ファイルネーム   %s\n", object->file_name);
+
+    /* ファイルサイズ */
+    monitor_printf("ファイルサイズ   %u\n", object->file_size);
+
+    /* 内部状態 */
+    switch (object->state)
+    {
+    /* 初期状態 */
+    case YMODEM_TRANS_NONE:
+        monitor_printf("内部状態         初期状態\n");
+        break;
+
+    /* 受信側の'C'送信待ち(1) */
+    case YMODEM_TRANS_WAITC1:
+        monitor_printf("内部状態         受信側の'C'送信待ち(1)\n");
+        break;
+
+    /* ファイル情報送信 */
+    case YMODEM_TRANS_SENDINFO:
+        monitor_printf("内部状態         ファイル情報送信\n");
+        break;
+
+    /* ファイル情報ACK待ち */
+    case YMODEM_TRANS_INFOACK:
+        monitor_printf("内部状態         ファイル情報ACK待ち\n");
+        break;
+
+    /* 受信側の'C'送信待ち(2) */
+    case YMODEM_TRANS_WAITC2:
+        monitor_printf("内部状態         受信側の'C'送信待ち(2)\n");
+        break;
+
+    /* データブロック送信 */
+    case YMODEM_TRANS_SENDDATA:
+        monitor_printf("内部状態         データブロック送信\n");
+        break;
+
+    /* データブロックACK待ち */
+    case YMODEM_TRANS_DATAACK:
+        monitor_printf("内部状態         データブロックACK待ち\n");
+        break;
+
+    /* EOT送信 */
+    case YMODEM_TRANS_SENDEOT:
+        monitor_printf("内部状態         EOT送信\n");
+        break;
+
+    /* EOTに対するACK待ち */
+    case YMODEM_TRANS_EOTACK:
+        monitor_printf("内部状態         EOTに対するACK待ち\n");
+        break;
+    }
+
+    /* ブロック番号 */
+    monitor_printf("ブロック番号     0x%02X\n", object->block_no);
+
+    /* バッファオフセット */
+    monitor_printf("オフセット       0x%04X\n", object->buf_offset);
+
+    /* ACK送受信回数 */
+    monitor_printf("ACK送受信回数    %u\n", object->ack_cnt);
+
+    /* NAK送受信回数 */
+    monitor_printf("NAK送受信回数    %u\n", object->nak_cnt);
+
+    /* CAN送受信回数 */
+    monitor_printf("CAN送受信回数    %u\n", object->can_cnt);
+
+    /* タイムアウト回数 */
+    monitor_printf("タイムアウト回数 %u\n", object->timeout_cnt);
+
+    /* リトライ回数 */
+    monitor_printf("リトライ回数     %u\n", object->retry_cnt);
+}
+
+/*
+ * YMODEM
  * 初期化
  */
 void ymodem_init(UINT comm_index)
@@ -1430,6 +1613,9 @@ void ymodem_idle(void)
 {
     /* オブジェクトアイドル */
     ymodem_object_idle(&g_ymodem_object);
+
+    /* モニタ */
+    ymodem_object_monitor(&g_ymodem_object);
 }
 
 /*
@@ -1459,7 +1645,7 @@ BOOL ymodem_recv(void)
  */
 UINT ymodem_get_status(void)
 {
-    return 0;
+    return g_ymodem_object.status;
 }
 
 /*
@@ -1477,7 +1663,7 @@ const char* ymodem_get_filename(void)
  */
 UINT ymodem_get_filesize(void)
 {
-    return 0;
+    return g_ymodem_object.file_size;
 }
 
 /*
@@ -1486,5 +1672,5 @@ UINT ymodem_get_filesize(void)
  */
 BYTE* ymodem_get_filebuf(void)
 {
-    return NULL;
+    return g_ymodem_object.file_buf;
 }

--- a/DebugMonitor/src/framework/logwin.c
+++ b/DebugMonitor/src/framework/logwin.c
@@ -203,6 +203,16 @@ void logwin_resize(int x, int y, int width, int height)
 
 /*
  * Windowsログ
+ * キー押下
+ */
+void logwin_keydown(WPARAM wparam, LPARAM lparam)
+{
+    /* WM_KEYDOWNをポスト */
+    PostMessage(g_logwin_screen.hwnd, WM_KEYDOWN, wparam, lparam);
+}
+
+/*
+ * Windowsログ
  * ログ出力(char)
  */
 void logwin_out(const char *log)

--- a/DebugMonitor/src/framework/logwin.h
+++ b/DebugMonitor/src/framework/logwin.h
@@ -17,6 +17,9 @@ BOOL logwin_init(HWND parent, int x, int y, int width, int height);
 /* リサイズ */
 void logwin_resize(int x, int y, int width, int height);
 
+/* キー押下 */
+void logwin_keydown(WPARAM wparam, LPARAM lparam);
+
 /* ログ追加(char) */
 void logwin_out(const char *log);
 

--- a/DebugMonitor/src/framework/monitor.c
+++ b/DebugMonitor/src/framework/monitor.c
@@ -135,11 +135,12 @@ void monitor_idle(void)
 {
     SYSTEMTIME st;
 
-    monitor_locate(0, 0);
+    /* ローカルタイムを取得 */
+    GetLocalTime(&st);
 
+    /* 現在時刻を表示 */
+    monitor_locate(0, 0);
     monitor_reverse(TRUE);
-    GetLocalTime(&st);
-    monitor_printf("%02d:%02d:%02d\n", st.wHour, st.wMinute, st.wSecond);
+    monitor_printf("現在時刻 %02d:%02d:%02d\n", st.wHour, st.wMinute, st.wSecond);
     monitor_reverse(FALSE);
-
 }

--- a/DebugMonitor/src/framework/screen.c
+++ b/DebugMonitor/src/framework/screen.c
@@ -1997,9 +1997,8 @@ void screen_clear(SCREEN_OBJECT *screen, UINT width, UINT height)
     /* yループ */
     for (y_loop = 0; y_loop < height; y_loop++)
     {
-        /* x,yをセット */
+        /* xをセット */
         screen->real.x = x_real;
-        screen->real.y = y_loop;
 
         /* lineを得る */
         line = screen_real_getline(screen);
@@ -2014,6 +2013,9 @@ void screen_clear(SCREEN_OBJECT *screen, UINT width, UINT height)
             /* 文字セット */
             screen_realline_setchr(line, screen, L' ');
         }
+
+        /* 次のyへ */
+        screen->real.y++;
     }
 
     /* 現在の位置を復元 */

--- a/DebugMonitor/src/framework/winmain.c
+++ b/DebugMonitor/src/framework/winmain.c
@@ -11,6 +11,7 @@
 #include "monitor.h"
 #include "logwin.h"
 #include "comm.h"
+#include "ymodem.h"
 #include "app.h"
 #include "winmain.h"
 
@@ -501,6 +502,29 @@ static void OnUser(HWND hWnd)
 
 /*
  * WinMain
+ * WM_KEYDOWNメッセージハンドラ
+ */
+static void OnKeyDown(HWND hWnd, WPARAM wParam, LPARAM lParam)
+{
+    assert(NULL != hWnd);
+
+    /* キー別に処理 */
+    switch (wParam)
+    {
+    case VK_HOME:
+    case VK_END:
+    case VK_PRIOR:
+    case VK_NEXT:
+    case VK_UP:
+    case VK_DOWN:
+        /* Windowsログへ転送 */
+        logwin_keydown(wParam, lParam);
+        break;
+    }
+}
+
+/*
+ * WinMain
  * フレームウィンドウのウィンドウプロシージャ
  */
 static LRESULT CALLBACK FrameWindowProc(HWND hWnd, UINT uMsg, WPARAM wParam, LPARAM lParam)
@@ -560,6 +584,12 @@ static LRESULT CALLBACK FrameWindowProc(HWND hWnd, UINT uMsg, WPARAM wParam, LPA
         OnUser(hWnd);
         return 0;
 
+    /* WM_KEYDOWN */
+    case WM_KEYDOWN:
+        /* ハンドラを呼び出す */
+        OnKeyDown(hWnd, wParam, lParam);
+        return 0;
+
     /* その他 */
     default:
         break;
@@ -711,6 +741,25 @@ static void ExitInstance(void)
 
 /*
  * WinMain
+ * アイドル処理
+ */
+static void OnIdle(void)
+{
+    /* フレームウィンドウ作成前は何もしない */
+    if (NULL == g_hFrameWnd)
+    {
+        return;
+    }
+
+    /* frameworkとcommのアイドル処理 */
+    screen_idle();
+    cons_idle();
+    monitor_idle();
+    ymodem_idle();
+}
+
+/*
+ * WinMain
  * メッセージポンプ
  * ※アプリケーションを終了すべき場合はFALSEを返す
  */
@@ -736,7 +785,7 @@ BOOL do_events(DWORD dwTimeOut)
         }
 
         /* メッセージが到着しているか */
-        if (TRUE == PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE))
+        if (FALSE != PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE))
         {
             /* メッセージをキューから取得 */
             if (GetMessage(&msg, NULL, 0, 0) <= 0)
@@ -749,13 +798,13 @@ BOOL do_events(DWORD dwTimeOut)
             TranslateMessage(&msg);
             DispatchMessage(&msg);
         }
-        else
-        {
-            /* アイドル処理*/
-            screen_idle();
-            cons_idle();
-            monitor_idle();
 
+        /* アイドル処理 */
+        OnIdle();
+
+        /* メッセージが到着していなければスリープ */
+        if (FALSE == PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE))
+        {
             /* スリープ */
             Sleep(10);
         }
@@ -794,16 +843,30 @@ int WINAPI wWinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, PWSTR pCmdLine
     /* メッセージループ */
     for (;;)
     {
-        /* メッセージをキューから取得 */
-        if (GetMessage(&msg, NULL, 0, 0) <= 0)
+        /* メッセージが到着しているか */
+        if (FALSE != PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE))
         {
-            /* WM_QUITなら終了 */
-            break;
+            /* メッセージをキューから取得 */
+            if (GetMessage(&msg, NULL, 0, 0) <= 0)
+            {
+                /* WM_QUITなら終了 */
+                break;
+            }
+
+            /* メッセージをディスパッチ */
+            TranslateMessage(&msg);
+            DispatchMessage(&msg);
         }
 
-        /* メッセージをディスパッチ */
-        TranslateMessage(&msg);
-        DispatchMessage(&msg);
+        /* ユーザアプリが終了していて、WM_CLOSE到着前なら */
+        if ((FALSE != g_bUserQuit) && (g_bCloseReq == FALSE))
+        {
+            /* アイドル処理 */
+            OnIdle();
+
+            /* スリープ */
+            Sleep(10);
+        }
     }
 
     /* インスタンスの終了 */