Merge "Synchronize Existing Client Requests."

import java.io.PrintWriter;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.concurrent.ConcurrentHashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Objects;

                PACKAGE_UPDATE_POLICY_REFRESH_EAGER

                        | /*To avoid high latency*/ PACKAGE_RESTART_POLICY_REFRESH_EAGER);

        mContext = context;

        mExistingClientRequests = new ArraySet<>();

        mExistingClientRequests = ConcurrentHashMap.newKeySet();

    }

    @Override

            String callingPackage, IAmbientContextObserver observer) {

        Slog.d(TAG, "New client added: " + callingPackage);

        synchronized (mExistingClientRequests) {

            // Remove any existing ClientRequest for this user and package.

            mExistingClientRequests.removeAll(

                    findExistingRequests(userId, callingPackage));

            mExistingClientRequests.add(

                    new ClientRequest(userId, request, callingPackage, observer));

        }

    }

    void clientRemoved(int userId, String packageName) {

        Slog.d(TAG, "Remove client: " + packageName);

        synchronized (mExistingClientRequests) {

            mExistingClientRequests.removeAll(findExistingRequests(userId, packageName));

        }

    }

    private Set<ClientRequest> findExistingRequests(int userId, String packageName) {

        Set<ClientRequest> existingRequests = new ArraySet<>();

    @Nullable

    IAmbientContextObserver getClientRequestObserver(int userId, String packageName) {

        synchronized (mExistingClientRequests) {

            for (ClientRequest clientRequest : mExistingClientRequests) {

                if (clientRequest.hasUserIdAndPackageName(userId, packageName)) {

                    return clientRequest.getObserver();

                }

            }

        }

        return null;

    }