Ticket #15509: Main.c

#include <windows.h>
#include <stdio.h>
#include <stdbool.h>

enum {
    stepCnt = 100000
};

enum {
    exitOp = 1,
    stepOp = 2
};

HANDLE thread; DWORD threadId;
HANDLE reqEvt, replEvt;
int op;
int inArg, outArg;

void debugger(const char *msg)
{
    MessageBox(NULL, msg, "Error", MB_OK|MB_ICONERROR);
    ExitProcess(1);
}

DWORD WINAPI ThreadEntry(void *arg)
{
    bool run = true;
    while (run) {
        WaitForSingleObject(reqEvt, INFINITE);
        switch (op) {
        case exitOp: run = false; break;
        case stepOp: outArg = inArg + 1; break;
        default: debugger("unknown op");
        }
        SetEvent(replEvt);
    }
    return 0;
}

int main()
{
    int t1, t2;
    reqEvt = CreateEvent(NULL, FALSE, FALSE, NULL);
    replEvt = CreateEvent(NULL, FALSE, FALSE, NULL);
    thread = CreateThread(NULL, 0, ThreadEntry, NULL, 0, &threadId);
    // single core mode
#if 0
    SetThreadAffinityMask(GetCurrentThread(), 1);
    SetThreadAffinityMask(thread, 1);
#endif
    t1 = GetTickCount();
    for (int i = 0; i < stepCnt; i++) {
        inArg = i;
        op = stepOp; SetEvent(reqEvt);
        WaitForSingleObject(replEvt, INFINITE);
        if (outArg != inArg + 1) {debugger("invalid outArg");}
    }
    t2 = GetTickCount();
    printf("%f\n", stepCnt/((t2-t1)/1000.0));
    op = exitOp; SetEvent(reqEvt);
    WaitForSingleObject(replEvt, INFINITE);
    WaitForSingleObject(thread, INFINITE);
    CloseHandle(thread);
    CloseHandle(reqEvt);
    CloseHandle(replEvt);
    return 0;
}