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

Commit 69432a81 authored by Devi Sandeep Endluri V V's avatar Devi Sandeep Endluri V V Committed by Gerrit - the friendly Code Review server
Browse files

frameworks: Added listener for NETSTATS_GLOBAL_ALERT_BYTES URI 

Add listener for NETSTATS_GLOBAL_ALERT_BYTES URI and Update the
mGlobalAlert bytes when there is a change.

CRs-Fixed: 1037558
Change-Id: I4578e91764e4f4d4a387ac2bdc851a391acc7986
parent a3238fe9

services/core/java/com/android/server/net/NetworkStatsService.java

+23 −0
Original line number Diff line number Diff line
@@ -73,6 +73,7 @@ import android.content.Intent; 
import android.content.IntentFilter;

import android.content.pm.ApplicationInfo;

import android.content.pm.PackageManager;

import android.database.ContentObserver;

import android.net.DataUsageRequest;

import android.net.IConnectivityManager;

import android.net.INetworkManagementEventObserver;
@@ -243,6 +244,7 @@ public class NetworkStatsService extends INetworkStatsService.Stub { 
    /** Must be set in factory by calling #setHandler. */

    private Handler mHandler;

    private Handler.Callback mHandlerCallback;

    private Handler mStatsHandler = null;



    private boolean mSystemReady;

    private long mPersistThreshold = 2 * MB_IN_BYTES;
@@ -275,6 +277,11 @@ public class NetworkStatsService extends INetworkStatsService.Stub { 
        handlerThread.start();

        Handler handler = new Handler(handlerThread.getLooper(), callback);

        service.setHandler(handler, callback);



        HandlerThread mStatsThread = new HandlerThread("StatsObserver");

        mStatsThread.start();

        Handler mStatsHandler = new Handler(mStatsThread.getLooper());



        return service;

    }
@@ -293,6 +300,10 @@ public class NetworkStatsService extends INetworkStatsService.Stub { 
        mStatsObservers = checkNotNull(statsObservers, "missing NetworkStatsObservers");

        mSystemDir = checkNotNull(systemDir, "missing systemDir");

        mBaseDir = checkNotNull(baseDir, "missing baseDir");



        ContentResolver contentResolver = context.getContentResolver();

        contentResolver.registerContentObserver(Settings.Global.getUriFor(

               NETSTATS_GLOBAL_ALERT_BYTES), false, mGlobalAlertBytesObserver);

    }



    @VisibleForTesting
@@ -456,6 +467,18 @@ public class NetworkStatsService extends INetworkStatsService.Stub { 
        }

    }



    private final ContentObserver mGlobalAlertBytesObserver =

        new ContentObserver(mStatsHandler) {

        public void onChange(boolean selfChange) {

            long GlobalAlertBytes = mSettings.getGlobalAlertBytes(mPersistThreshold);

            if (GlobalAlertBytes > 0) {

                mGlobalAlertBytes = GlobalAlertBytes;

            } else {

                mGlobalAlertBytes = mPersistThreshold;

            }

        };

    };



    @Override

    public INetworkStatsSession openSession() {

        return createSession(null, /* poll on create */ false);