Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 658bc0e0 authored by Yang Lu's avatar Yang Lu Committed by Vincent Palomares
Browse files

Persist data to disk when system shuts down 

This is a cherry-pick from master to pi-dev.

Test: local test

BUG: b/112432890
Change-Id: Ie360f5c8df53d3b5b04f23df43ab8dc14b69ae26
Merged-In: Iaed318671a719cc366d4e6be9f77270147ba6596
parent 91d12f15

cmds/statsd/src/StatsLogProcessor.h

+2 −1
Original line number Diff line number Diff line
@@ -40,7 +40,8 @@ enum DumpReportReason { 
    GET_DATA_CALLED = 4,

    ADB_DUMP = 5,

    CONFIG_RESET = 6,

    STATSCOMPANION_DIED = 7

    STATSCOMPANION_DIED = 7,

    TERMINATION_SIGNAL_RECEIVED = 8

};



class StatsLogProcessor : public ConfigListener {

cmds/statsd/src/StatsService.cpp

+7 −0
Original line number Diff line number Diff line
@@ -881,6 +881,13 @@ void StatsService::Startup() { 
    mConfigManager->Startup();

}



void StatsService::Terminate() {

    ALOGI("StatsService::Terminating");

    if (mProcessor != nullptr) {

        mProcessor->WriteDataToDisk(TERMINATION_SIGNAL_RECEIVED);

    }

}



void StatsService::OnLogEvent(LogEvent* event, bool reconnectionStarts) {

    mProcessor->OnLogEvent(event, reconnectionStarts);

}

cmds/statsd/src/StatsService.h

+5 −0
Original line number Diff line number Diff line
@@ -73,6 +73,11 @@ public: 
     */

    void Startup();



    /**

     * Called when terminiation signal received.

     */

    void Terminate();



    /**

     * Called by LogReader when there's a log event to process.

     */

cmds/statsd/src/main.cpp

+30 −6
Original line number Diff line number Diff line
@@ -96,6 +96,27 @@ static status_t start_log_reader_thread(const sp<StatsService>& service) { 
    return NO_ERROR;

}





sp<StatsService> gStatsService = nullptr;



void sigHandler(int sig) {

    if (gStatsService != nullptr) {

        gStatsService->Terminate();

    }

}



void registerSigHandler()

{

    struct sigaction sa;

    sigemptyset(&sa.sa_mask);

    sa.sa_flags = 0;

    sa.sa_handler = sigHandler;

    sigaction(SIGHUP, &sa, nullptr);

    sigaction(SIGINT, &sa, nullptr);

    sigaction(SIGQUIT, &sa, nullptr);

    sigaction(SIGTERM, &sa, nullptr);

}



int main(int /*argc*/, char** /*argv*/) {

    // Set up the looper

    sp<Looper> looper(Looper::prepare(0 /* opts */));
@@ -108,21 +129,24 @@ int main(int /*argc*/, char** /*argv*/) { 
    IPCThreadState::self()->disableBackgroundScheduling(true);



    // Create the service

    sp<StatsService> service = new StatsService(looper);

    if (defaultServiceManager()->addService(String16("stats"), service) != 0) {

    gStatsService = new StatsService(looper);

    if (defaultServiceManager()->addService(String16("stats"), gStatsService) != 0) {

        ALOGE("Failed to add service");

        return -1;

    }

    service->sayHiToStatsCompanion();



    service->Startup();

    registerSigHandler();



    gStatsService->sayHiToStatsCompanion();



    gStatsService->Startup();



    sp<StatsSocketListener> socketListener = new StatsSocketListener(service);

    sp<StatsSocketListener> socketListener = new StatsSocketListener(gStatsService);



    if (kUseLogd) {

        ALOGI("using logd");

        // Start the log reader thread

        status_t err = start_log_reader_thread(service);

        status_t err = start_log_reader_thread(gStatsService);

        if (err != NO_ERROR) {

            return 1;

        }

cmds/statsd/src/stats_log.proto

+1 −0
Original line number Diff line number Diff line
@@ -265,6 +265,7 @@ message ConfigMetricsReport { 
      ADB_DUMP = 5;

      CONFIG_RESET = 6;

      STATSCOMPANION_DIED = 7;

      TERMINATION_SIGNAL_RECEIVED = 8;

  }

  optional DumpReportReason dump_report_reason = 8;