/*
================================================================================
  FreeVMS (R)
  Copyright (C) 2010 Dr. BERTRAND Joël and all.

  This file is part of FreeVMS

  FreeVMS is free software; you can redistribute it and/or modify it
  under the terms of the CeCILL V2 License as published by the french
  CEA, CNRS and INRIA.
 
  FreeVMS is distributed in the hope that it will be useful, but WITHOUT
  ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  FITNESS FOR A PARTICULAR PURPOSE.  See the CeCILL V2 License
  for more details.
 
  You should have received a copy of the CeCILL License
  along with FreeVMS. If not, write to info@cecill.info.
================================================================================
*/

#include "freevms/freevms.h"

void
sys$loop()
{
    int                             reply;
    int                             running;

    L4_MsgBuffer_t                  buffer;
    L4_MsgTag_t                     tag;
    L4_Msg_t                        msg;
    L4_StringItem_t                 string_item;
    L4_ThreadId_t                   partner;
    L4_ThreadId_t                   tid;

    static unsigned char            string[MAX_STRINGITEM_LENGTH + 1];

    L4_Clear(&buffer);
    L4_Append(&buffer, L4_StringItem(MAX_STRINGITEM_LENGTH, &(string[0])));
    L4_Accept(L4_MapGrantItems(L4_CompleteAddressSpace)
            + L4_StringItemsAcceptor, &buffer);

    tag = L4_Wait(&partner);
    running = 1;

    while(running)
    {
        L4_Clear(&msg);
        L4_Store(tag, &msg);

        if ((tag.raw & L4_REQUEST_MASK) == L4_PAGEFAULT)
        {
            sys$pagefault(partner, L4_Get(&msg, 0), L4_Get(&msg, 1), tag.raw);
            tag = L4_ReplyWait(partner, &partner);
        }
        else
        {
            reply = 1;

            switch(L4_Label(tag))
            {
                case SYSCALL$PRINT:
                    L4_StoreMRs(1, 2, string_item.raw);
                    string[string_item.X.string_length] = 0;
                    notice("%s\n", string);
                    L4_Clear(&msg);
                    L4_Append(&msg, (L4_Word_t) 0);
                    break;

                case SYSCALL$EXIT_VALUE:
                    L4_Clear(&msg);
                    L4_Append(&msg, (L4_Word_t) 0);
                    break;

                case SYSCALL$KILL_THREAD:
                    L4_StoreMR(1, &(tid.raw));
                    L4_AbortIpc_and_stop(tid);
                    sys$thread_delete(sys$thread_lookup(tid));
                    reply = 0;
                    break;

                default:
                    PANIC(1, notice(IPC_F_UNKNOWN "unknown IPC from $%lX "
                            "with label $%lX\n", L4_ThreadNo(partner),
                            L4_Label(tag)));
            }

            if (reply)
            {
                // Returned message
                L4_Load(&msg);
                tag = L4_ReplyWait(partner, &partner);
            }
            else
            {
                tag = L4_Wait(&partner);
            }
        }

        if (L4_IpcFailed(tag))
        {
            notice(IPC_F_FAILED "IPC failed (error %ld: %s)\n", L4_ErrorCode(),
                    L4_ErrorCode_String(L4_ErrorCode()));
        }
    }

    return;
}