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

Commit 745eaa39 authored by Cody Kesting's avatar Cody Kesting Committed by Automerger Merge Worker
Browse files

Merge "Move Data Stall logic to CS from NetworkMonitorCallbacks." am:...

Merge "Move Data Stall logic to CS from NetworkMonitorCallbacks." am: ec00ab6d am: b1623b89 am: 2499d839 am: 99e570e3 am: 6d2d05ed

Change-Id: Ib8fc96e69847c073aa4dcc81506376e7132334a6
parents 1349c629 6d2d05ed
Loading
Loading
Loading
Loading
+26 −23
Original line number Diff line number Diff line
@@ -3088,6 +3088,21 @@ public class ConnectivityService extends IConnectivityManager.Stub

        @Override
        public void notifyDataStallSuspected(DataStallReportParcelable p) {
            ConnectivityService.this.notifyDataStallSuspected(p, mNetId);
        }

        @Override
        public int getInterfaceVersion() {
            return this.VERSION;
        }

        @Override
        public String getInterfaceHash() {
            return this.HASH;
        }
    }

    private void notifyDataStallSuspected(DataStallReportParcelable p, int netId) {
        final PersistableBundle extras = new PersistableBundle();
        switch (p.detectionMethod) {
            case DETECTION_METHOD_DNS_EVENTS:
@@ -3099,30 +3114,19 @@ public class ConnectivityService extends IConnectivityManager.Stub
                        p.tcpMetricsCollectionPeriodMillis);
                break;
            default:
                // TODO(b/156294356): update for new data stall detection methods
                log("Unknown data stall detection method, ignoring: " + p.detectionMethod);
                return;
        }

            proxyDataStallToConnectivityDiagnosticsHandler(
                    p.detectionMethod, mNetId, p.timestampMillis, extras);
        notifyDataStallSuspected(p.detectionMethod, netId, p.timestampMillis, extras);
    }

        @Override
        public int getInterfaceVersion() {
            return this.VERSION;
        }

        @Override
        public String getInterfaceHash() {
            return this.HASH;
        }
    }

    private void proxyDataStallToConnectivityDiagnosticsHandler(int detectionMethod, int netId,
            long timestampMillis, @NonNull PersistableBundle extras) {
    private void notifyDataStallSuspected(int detectionMethod, int netId, long timestampMillis,
            @NonNull PersistableBundle extras) {
        final Message msg = mConnectivityDiagnosticsHandler.obtainMessage(
                    ConnectivityDiagnosticsHandler.EVENT_DATA_STALL_SUSPECTED,
                    detectionMethod, netId, timestampMillis);
                ConnectivityDiagnosticsHandler.EVENT_DATA_STALL_SUSPECTED, detectionMethod, netId,
                timestampMillis);
        msg.setData(new Bundle(extras));

        // NetworkStateTrackerHandler currently doesn't take any actions based on data
@@ -8190,7 +8194,6 @@ public class ConnectivityService extends IConnectivityManager.Stub
                + "creators");
        }

        proxyDataStallToConnectivityDiagnosticsHandler(
                detectionMethod, network.netId, timestampMillis, extras);
        notifyDataStallSuspected(detectionMethod, network.netId, timestampMillis, extras);
    }
}