Ticket #15509: ThreadTests.cpp

#include <OS.h>
#include <stdio.h>

enum {
    stepCnt = 100000
};

enum {
    exitOp = 1,
    stepOp = 2
};

thread_id thread;
sem_id reqSem;
sem_id replSem;
int op;
int inArg, outArg;

int32 ThreadEntry(void *arg)
{
    bool run = true;
    while (run) {
        while (acquire_sem(reqSem) == B_INTERRUPTED) {}
        switch (op) {
        case exitOp: run = false; break;
        case stepOp: outArg = inArg + 1; break;
        default: debugger("unknown op");
        }
        release_sem(replSem);
    }
    return 0;
}

int main()
{
    bigtime_t t1, t2;
    status_t res;
    reqSem = create_sem(0, "test req sem");
    replSem = create_sem(0, "test repl sem");
    thread = spawn_thread(ThreadEntry, "test thread", B_NORMAL_PRIORITY, NULL);
    resume_thread(thread);
    t1 = system_time();
    for (int i = 0; i < stepCnt; i++) {
        inArg = i;
        op = stepOp; release_sem(reqSem);
        while (acquire_sem(replSem) == B_INTERRUPTED) {}
        if (outArg != inArg + 1) {debugger("invalid outArg");}
    }
    t2 = system_time();
    printf("%f\n", stepCnt/((t2 - t1)/1000000.0));
    op = exitOp; release_sem(reqSem);
    while (acquire_sem(replSem) == B_INTERRUPTED) {}
    wait_for_thread(thread, &res);
    delete_sem(reqSem); reqSem = 0;
    delete_sem(replSem); replSem = 0;
    return 0;
}