/*

* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:  SignalHandler

*

*/

#include <sys/types.h>

#include <sys/wait.h>

#include <pthread.h>

#include <signal.h>

#include "logger.h"

#include "comms.h"

#include "commsclientendpoint.h"

#include "signalhandler.h"

#include "signalhandlermessages.h"

namespace java

{

namespace captain

{

SignalHandler::SignalHandler():mThreadId(0)

{

}

SignalHandler::~SignalHandler()

{

}

void SignalHandler::start()

{

    if (pthread_create(&mThreadId, 0, SignalHandler::signalHandlerThread, NULL))

    {

        ELOG(EJavaCaptain, "pthread_create failed for signal handler thread");

    }

}

void SignalHandler::stop()

{

    kill(getpid(), SIGINT);

    pthread_join(mThreadId, NULL);

}

void* SignalHandler::signalHandlerThread(void* /*aParams*/)

{

    CommsClientEndpoint comms;

    if (comms.connect(IPC_ADDRESS_JAVA_CAPTAIN_C))

    {

        ELOG(EJavaCaptain, "Connect to main message loop failed!");

        return NULL;

    }

    sigset_t    ss;

    sigemptyset(&ss);

    sigaddset(&ss, SIGCHLD);

    sigaddset(&ss, SIGALRM);

    sigaddset(&ss, SIGINT);

    int signal = 0;

    bool keepWaiting = true;

    while (keepWaiting && !sigwait(&ss, &signal))

    {

        CommsMessage msg;

        switch (signal)

        {

        case SIGCHLD:

            LOG(EJavaCaptain, EInfo, "SIGCHLD received");

            {

                int status = 0;

                pid_t pidi = 0;

                while ((pidi=waitpid(-1, &status, WNOHANG))  > 0)

                {

                    LOG2(EJavaCaptain, EInfo, "SIGCHLD received - waitpid returns pid=%d status=%d", (int)pidi, status);

                    LOG1(EJavaCaptain, EInfo, "WIFEXITED(status) returns %d", WIFEXITED(status));

                    if (WIFEXITED(status))

                    {

                        LOG1(EJavaCaptain, EInfo, "WEXITSTATUS(status) returns %d", WEXITSTATUS(status));

                    }

                    LOG1(EJavaCaptain, EInfo, "WIFSIGNALED(status) returns %d", WIFSIGNALED(status));

                    if (WIFSIGNALED(status))

                    {

                        LOG1(EJavaCaptain, EInfo, "WTERMSIG(status) returns %d", WTERMSIG(status));

                    }

                    LOG1(EJavaCaptain, EInfo, "WIFSTOPPED(status) returns %d", WIFSTOPPED(status));

                    if (WIFSTOPPED(status))

                    {

                        LOG1(EJavaCaptain, EInfo, "WSTOPSIG(status) returns %d", WSTOPSIG(status));

                    }

                    LOG2(EJavaCaptain, EInfo, "initiating pmcTerminated event (pid=%d, status=%d)", (int)pidi, status);

                    setSignalChildMessage(msg, pidi, status);

                    comms.send(msg);

                    LOG2(EJavaCaptain, EInfo, "initiated pmcTerminated event (pid=%d, status=%d)", (int)pidi, status);

                }

            }

            break;

        case SIGALRM:

            LOG(EJavaCaptain, EInfo, "SIGALRM received");

            setSignalAlarmMessage(msg);

            comms.send(msg);

            break;

        case SIGINT:

            LOG(EJavaCaptain, EInfo, "SIGINT received");

            setSignalInterruptMessage(msg);

            comms.send(msg);

            keepWaiting = false;

            break;

        default:

            ELOG1(EJavaCaptain, "Unknown signal %d sigwaited!", signal);

        }

    }

    return NULL;

}

} // namespace captain

} // namespace java