main.cpp

MONA是为数不多的C++语言编写的一个很小的操作系统

#include <monapi/messages.h>

#include "Shell.h"

using namespace MonAPI;

static dword my_tid;

static void StdoutMessageLoop()
{
    Message::send(my_tid, MSG_SERVER_START_OK);

    for (MessageInfo msg;;)
    {
        if (Message::receive(&msg) != 0) continue;

        switch (msg.header)
        {
            case MSG_PROCESS_STDOUT_DATA:
            {
#if 0  /// DEBUG for message
                char buf[256];
                sprintf(buf, "!%d!", msg.from);
                syscall_print(buf);
#endif
                monapi_call_mouse_set_cursor(0);
                msg.str[127] = '\0';
                syscall_print(msg.str);
                monapi_call_mouse_set_cursor(1);
#if 0  /// DEBUG for message
                syscall_print("!E!");
#endif
                Message::reply(&msg);
                break;
            }
        }
    }
}

int MonaMain(List<char*>* pekoe)
{
    if (!monapi_register_to_server(ID_KEYBOARD_SERVER, 1)) exit(1);
    if (!monapi_register_to_server(ID_PROCESS_SERVER, 1)) exit(1);

    /* grab stdout */
    my_tid = syscall_get_tid();
    dword id = syscall_mthread_create((dword)StdoutMessageLoop);
    syscall_mthread_join(id);
    MessageInfo msg, src;
    src.header = MSG_SERVER_START_OK;
    Message::receive(&msg, &src, Message::equalsHeader);
    dword stdout_tid = msg.from;
    dword svr_tid = monapi_get_server_thread_id(ID_PROCESS_SERVER);
    if (svr_tid != THREAD_UNKNOWN)
    {
        Message::sendReceive(NULL, svr_tid + 1, MSG_PROCESS_GRAB_STDOUT, stdout_tid);
    }

    /* Server start ok */
    bool callAutoExec = true;
    dword targetID = Message::lookupMainThread("MONITOR.BIN");
    if (targetID == THREAD_UNKNOWN)
    {
        targetID = MonAPI::System::getParentThreadID();
        callAutoExec = false;
    }

    /* send */
    if (targetID != THREAD_UNKNOWN && Message::send(targetID, MSG_SERVER_START_OK))
    {
        printf("%s: MONITOR error\n", SVR);
    }

    /* service loop */
    Shell shell(callAutoExec);
    shell.run();

    if (svr_tid != THREAD_UNKNOWN)
    {
        Message::sendReceive(NULL, svr_tid + 1, MSG_PROCESS_UNGRAB_STDOUT, stdout_tid);
    }
    syscall_kill_thread(stdout_tid);
    monapi_register_to_server(ID_KEYBOARD_SERVER, 0);
    monapi_register_to_server(ID_PROCESS_SERVER, 0);
    return 0;
}