Implement RCS Dedicated Bearer metrics - fix not reporting case (319890b0) · Commits · e / devices / smdk4412 / android_frameworks_opt_telephony

src/java/com/android/internal/telephony/data/QosCallbackTracker.java

+56 −34

Original line number	Original line	Diff line number	Diff line
	@@ -39,6 +39,7 @@ import java.net.InetAddress;
	import java.net.InetSocketAddress;		import java.net.InetSocketAddress;
	import java.util.ArrayList;		import java.util.ArrayList;
	import java.util.HashMap;		import java.util.HashMap;
			import java.util.HashSet;
	import java.util.List;		import java.util.List;
	import java.util.Map;		import java.util.Map;

	@@ -184,13 +185,15 @@ public class QosCallbackTracker extends Handler {
	log("updateSessions: sessions size=" + sessions.size());		log("updateSessions: sessions size=" + sessions.size());

	int bearerState = DEDICATED_BEARER_EVENT_STATE_NONE;		int bearerState = DEDICATED_BEARER_EVENT_STATE_NONE;

	final List<QosBearerSession> sessionsToAdd = new ArrayList<>();		final List<QosBearerSession> sessionsToAdd = new ArrayList<>();
	final Map<Integer, QosBearerSession> incomingSessions = new HashMap<>();		final Map<Integer, QosBearerSession> incomingSessions = new HashMap<>();
			final HashSet<Integer> sessionsReportedToMetric = new HashSet<>();
	for (final QosBearerSession incomingSession : sessions) {		for (final QosBearerSession incomingSession : sessions) {
	incomingSessions.put(incomingSession.getQosBearerSessionId(), incomingSession);		int sessionId = incomingSession.getQosBearerSessionId();
			incomingSessions.put(sessionId, incomingSession);

	final QosBearerSession existingSession = mQosBearerSessions.get(		final QosBearerSession existingSession = mQosBearerSessions.get(sessionId);
	incomingSession.getQosBearerSessionId());
	for (final int callbackId : mCallbacksToFilter.keySet()) {		for (final int callbackId : mCallbacksToFilter.keySet()) {
	final IFilter filter = mCallbacksToFilter.get(callbackId);		final IFilter filter = mCallbacksToFilter.get(callbackId);

	@@ -214,15 +217,31 @@ public class QosCallbackTracker extends Handler {
	}		}
	}		}

	notifyMetricDedicatedBearerEvent(incomingSession, filter, bearerState);		// this QosBearerSession has registered QosCallbackId
			if (!sessionsReportedToMetric.contains(sessionId) && incomingSessionMatch) {
			// this session has listener
			notifyMetricDedicatedBearerEvent(incomingSession, bearerState, true);
			sessionsReportedToMetric.add(sessionId);
			}
			}

			// this QosBearerSession does not have registered QosCallbackId
			if (!sessionsReportedToMetric.contains(sessionId)) {
			// no listener is registered to this session
			bearerState = DEDICATED_BEARER_EVENT_STATE_ADDED;
			notifyMetricDedicatedBearerEvent(incomingSession, bearerState, false);
			sessionsReportedToMetric.add(sessionId);
	}		}
	sessionsToAdd.add(incomingSession);		sessionsToAdd.add(incomingSession);
	}		}

	final List<Integer> sessionsToRemove = new ArrayList<>();		final List<Integer> sessionsToRemove = new ArrayList<>();
			sessionsReportedToMetric.clear();
			bearerState = DEDICATED_BEARER_EVENT_STATE_DELETED;
	// Find sessions that no longer exist		// Find sessions that no longer exist
	for (final QosBearerSession existingSession : mQosBearerSessions.values()) {		for (final QosBearerSession existingSession : mQosBearerSessions.values()) {
	if (!incomingSessions.containsKey(existingSession.getQosBearerSessionId())) {		final int sessionId = existingSession.getQosBearerSessionId();
			if (!incomingSessions.containsKey(sessionId)) {
	for (final int callbackId : mCallbacksToFilter.keySet()) {		for (final int callbackId : mCallbacksToFilter.keySet()) {
	final IFilter filter = mCallbacksToFilter.get(callbackId);		final IFilter filter = mCallbacksToFilter.get(callbackId);
	// The filter matches which means it was previously available, and now is		// The filter matches which means it was previously available, and now is
	@@ -230,10 +249,15 @@ public class QosCallbackTracker extends Handler {
	if (doFiltersMatch(existingSession, filter)) {		if (doFiltersMatch(existingSession, filter)) {
	bearerState = DEDICATED_BEARER_EVENT_STATE_DELETED;		bearerState = DEDICATED_BEARER_EVENT_STATE_DELETED;
	sendSessionLost(callbackId, existingSession);		sendSessionLost(callbackId, existingSession);
	notifyMetricDedicatedBearerEvent(existingSession, filter, bearerState);		notifyMetricDedicatedBearerEvent(existingSession, bearerState, true);
			sessionsReportedToMetric.add(sessionId);
			}
	}		}
			sessionsToRemove.add(sessionId);
			if (!sessionsReportedToMetric.contains(sessionId)) {
			notifyMetricDedicatedBearerEvent(existingSession, bearerState, false);
			sessionsReportedToMetric.add(sessionId);
	}		}
	sessionsToRemove.add(existingSession.getQosBearerSessionId());
	}		}
	}		}

	@@ -410,38 +434,36 @@ public class QosCallbackTracker extends Handler {
	return 0;		return 0;
	}		}

	private void notifyMetricDedicatedBearerEvent(final QosBearerSession session,		private boolean doesLocalConnectionInfoExist(final QosBearerSession qosBearerSession) {
	final IFilter filter, final int bearerState) {		for (final QosBearerFilter sessionFilter : qosBearerSession.getQosBearerFilterList()) {
			if (!sessionFilter.getLocalAddresses().isEmpty()
	int ratAtEnd;		&& sessionFilter.getLocalPortRange().isValid()) {
	int qci;		return true;
	boolean localConnectionInfoReceived = false;		}
	boolean remoteConnectionInfoReceived = false;		}
			return false;
	QosBearerFilter qosBearerFilter = getMatchingQosBearerFilter(session, filter);
	if (session.getQos() instanceof EpsQos) {
	ratAtEnd = TelephonyManager.NETWORK_TYPE_LTE;
	qci = ((EpsQos) session.getQos()).getQci();
	} else if (session.getQos() instanceof NrQos) {
	ratAtEnd = TelephonyManager.NETWORK_TYPE_NR;
	qci = ((NrQos) session.getQos()).get5Qi();
	} else {
	return;
	}		}

	if (qosBearerFilter != null) {		private boolean doesRemoteConnectionInfoExist(final QosBearerSession qosBearerSession) {
	if (!qosBearerFilter.getLocalAddresses().isEmpty()		for (final QosBearerFilter sessionFilter : qosBearerSession.getQosBearerFilterList()) {
	&& qosBearerFilter.getLocalPortRange().isValid()) {		if (!sessionFilter.getRemoteAddresses().isEmpty()
	localConnectionInfoReceived = true;		&& sessionFilter.getRemotePortRange().isValid()) {
			return true;
	}		}
	if (!qosBearerFilter.getRemoteAddresses().isEmpty()
	&& qosBearerFilter.getRemotePortRange().isValid()) {
	remoteConnectionInfoReceived = true;
	}		}
			return false;
	}		}

	mRcsStats.onImsDedicatedBearerEvent(mPhoneId, ratAtEnd, qci, bearerState,		private void notifyMetricDedicatedBearerEvent(final QosBearerSession session,
	localConnectionInfoReceived, remoteConnectionInfoReceived, true);		final int bearerState, final boolean hasListener) {
			final int slotId = mPhoneId;
			int ratAtEnd = getRatInfoFromSessionInfo(session);
			int qci = getQCIFromSessionInfo(session);
			boolean localConnectionInfoReceived = doesLocalConnectionInfoExist(session);
			boolean remoteConnectionInfoReceived = doesRemoteConnectionInfoExist(session);

			mRcsStats.onImsDedicatedBearerEvent(slotId, ratAtEnd, qci, bearerState,
			localConnectionInfoReceived, remoteConnectionInfoReceived, hasListener);
	}		}

	/**		/**