Merge "ShellSubscriber: install SIGPIPE handler" into rvc-dev am: 9d411d7d am: acdb4a7a

shared_ptr<StatsService> gStatsService = nullptr;

void sigHandler(int sig) {

    if (gStatsService != nullptr) {

        gStatsService->Terminate();

void signalHandler(int sig) {

    if (sig == SIGPIPE) {

        // ShellSubscriber uses SIGPIPE as a signal to detect the end of the

        // client process. Don't prematurely exit(1) here. Instead, ignore the

        // signal and allow the write call to return EPIPE.

        ALOGI("statsd received SIGPIPE. Ignoring signal.");

        return;

    }

    if (gStatsService != nullptr) gStatsService->Terminate();

    ALOGW("statsd terminated on receiving signal %d.", sig);

    exit(1);

}

void registerSigHandler()

void registerSignalHandlers()

{

    struct sigaction sa;

    sigemptyset(&sa.sa_mask);

    sa.sa_flags = 0;

    sa.sa_handler = sigHandler;

    sa.sa_handler = signalHandler;

    sigaction(SIGPIPE, &sa, nullptr);

    sigaction(SIGHUP, &sa, nullptr);

    sigaction(SIGINT, &sa, nullptr);

    sigaction(SIGQUIT, &sa, nullptr);

        return -1;

    }

    registerSigHandler();

    registerSignalHandlers();

    gStatsService->sayHiToStatsCompanion();