| /* Copyright (c) 2017-2020 The Linux Foundation. All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions are |
| * met: |
| * * Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * * Redistributions in binary form must reproduce the above |
| * copyright notice, this list of conditions and the following |
| * disclaimer in the documentation and/or other materials provided |
| * with the distribution. |
| * * Neither the name of The Linux Foundation nor the names of its |
| * contributors may be used to endorse or promote products derived |
| * from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED |
| * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF |
| * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT |
| * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS |
| * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR |
| * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF |
| * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR |
| * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, |
| * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE |
| * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN |
| * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| #define LOG_NDEBUG 0 |
| #define LOG_TAG "LocSvc_LocationAPI" |
| |
| #include <location_interface.h> |
| #include <dlfcn.h> |
| #include <loc_pla.h> |
| #include <log_util.h> |
| #include <pthread.h> |
| #include <map> |
| #include <loc_misc_utils.h> |
| |
| typedef const GnssInterface* (getGnssInterface)(); |
| typedef const GeofenceInterface* (getGeofenceInterface)(); |
| typedef const BatchingInterface* (getBatchingInterface)(); |
| typedef void (createOSFramework)(); |
| typedef void (destroyOSFramework)(); |
| |
| // GTP services |
| typedef uint32_t (setOptInStatusGetter)(bool userConsent, responseCallback* callback); |
| typedef void (enableProviderGetter)(); |
| typedef void (disableProviderGetter)(); |
| typedef void (getSingleNetworkLocationGetter)(trackingCallback* callback); |
| typedef void (stopNetworkLocationGetter)(trackingCallback* callback); |
| |
| typedef struct { |
| // bit mask of the adpaters that we need to wait for the removeClientCompleteCallback |
| // before we invoke the registered locationApiDestroyCompleteCallback |
| LocationAdapterTypeMask waitAdapterMask; |
| locationApiDestroyCompleteCallback destroyCompleteCb; |
| } LocationAPIDestroyCbData; |
| |
| // This is the map for the client that has requested destroy with |
| // destroy callback provided. |
| typedef std::map<LocationAPI*, LocationAPIDestroyCbData> |
| LocationClientDestroyCbMap; |
| |
| typedef std::map<LocationAPI*, LocationCallbacks> LocationClientMap; |
| typedef struct { |
| LocationClientMap clientData; |
| LocationClientDestroyCbMap destroyClientData; |
| LocationControlAPI* controlAPI; |
| LocationControlCallbacks controlCallbacks; |
| GnssInterface* gnssInterface; |
| GeofenceInterface* geofenceInterface; |
| BatchingInterface* batchingInterface; |
| } LocationAPIData; |
| |
| static LocationAPIData gData = {}; |
| static pthread_mutex_t gDataMutex = PTHREAD_MUTEX_INITIALIZER; |
| static bool gGnssLoadFailed = false; |
| static bool gBatchingLoadFailed = false; |
| static bool gGeofenceLoadFailed = false; |
| static uint32_t gOSFrameworkRefCount = 0; |
| |
| template <typename T1, typename T2> |
| static const T1* loadLocationInterface(const char* library, const char* name) { |
| void* libhandle = nullptr; |
| T2* getter = (T2*)dlGetSymFromLib(libhandle, library, name); |
| if (nullptr == getter) { |
| return (const T1*) getter; |
| }else { |
| return (*getter)(); |
| } |
| } |
| |
| static void createOSFrameworkInstance() { |
| void* libHandle = nullptr; |
| createOSFramework* getter = (createOSFramework*)dlGetSymFromLib(libHandle, |
| "liblocationservice_glue.so", "createOSFramework"); |
| if (getter != nullptr) { |
| (*getter)(); |
| } else { |
| LOC_LOGe("dlGetSymFromLib failed for liblocationservice_glue.so"); |
| } |
| } |
| |
| static void destroyOSFrameworkInstance() { |
| void* libHandle = nullptr; |
| destroyOSFramework* getter = (destroyOSFramework*)dlGetSymFromLib(libHandle, |
| "liblocationservice_glue.so", "destroyOSFramework"); |
| if (getter != nullptr) { |
| (*getter)(); |
| } else { |
| LOC_LOGe("dlGetSymFromLib failed for liblocationservice_glue.so"); |
| } |
| } |
| |
| static bool needsGnssTrackingInfo(LocationCallbacks& locationCallbacks) |
| { |
| return (locationCallbacks.gnssLocationInfoCb != nullptr || |
| locationCallbacks.engineLocationsInfoCb != nullptr || |
| locationCallbacks.gnssSvCb != nullptr || |
| locationCallbacks.gnssNmeaCb != nullptr || |
| locationCallbacks.gnssDataCb != nullptr || |
| locationCallbacks.gnssMeasurementsCb != nullptr); |
| } |
| |
| static bool isGnssClient(LocationCallbacks& locationCallbacks) |
| { |
| return (locationCallbacks.gnssNiCb != nullptr || |
| locationCallbacks.trackingCb != nullptr || |
| locationCallbacks.gnssLocationInfoCb != nullptr || |
| locationCallbacks.engineLocationsInfoCb != nullptr || |
| locationCallbacks.gnssSvCb != nullptr || |
| locationCallbacks.gnssNmeaCb != nullptr || |
| locationCallbacks.gnssDataCb != nullptr || |
| locationCallbacks.gnssMeasurementsCb != nullptr || |
| locationCallbacks.locationSystemInfoCb != nullptr); |
| } |
| |
| static bool isBatchingClient(LocationCallbacks& locationCallbacks) |
| { |
| return (locationCallbacks.batchingCb != nullptr); |
| } |
| |
| static bool isGeofenceClient(LocationCallbacks& locationCallbacks) |
| { |
| return (locationCallbacks.geofenceBreachCb != nullptr || |
| locationCallbacks.geofenceStatusCb != nullptr); |
| } |
| |
| |
| void LocationAPI::onRemoveClientCompleteCb (LocationAdapterTypeMask adapterType) |
| { |
| bool invokeCallback = false; |
| locationApiDestroyCompleteCallback destroyCompleteCb; |
| LOC_LOGd("adatper type %x", adapterType); |
| pthread_mutex_lock(&gDataMutex); |
| auto it = gData.destroyClientData.find(this); |
| if (it != gData.destroyClientData.end()) { |
| it->second.waitAdapterMask &= ~adapterType; |
| if (it->second.waitAdapterMask == 0) { |
| invokeCallback = true; |
| destroyCompleteCb = it->second.destroyCompleteCb; |
| gData.destroyClientData.erase(it); |
| } |
| } |
| pthread_mutex_unlock(&gDataMutex); |
| |
| if (invokeCallback) { |
| LOC_LOGd("invoke client destroy cb"); |
| if (!destroyCompleteCb) { |
| (destroyCompleteCb) (); |
| } |
| |
| delete this; |
| } |
| } |
| |
| void onGnssRemoveClientCompleteCb (LocationAPI* client) |
| { |
| client->onRemoveClientCompleteCb (LOCATION_ADAPTER_GNSS_TYPE_BIT); |
| } |
| |
| void onBatchingRemoveClientCompleteCb (LocationAPI* client) |
| { |
| client->onRemoveClientCompleteCb (LOCATION_ADAPTER_BATCHING_TYPE_BIT); |
| } |
| |
| void onGeofenceRemoveClientCompleteCb (LocationAPI* client) |
| { |
| client->onRemoveClientCompleteCb (LOCATION_ADAPTER_GEOFENCE_TYPE_BIT); |
| } |
| |
| LocationAPI* |
| LocationAPI::createInstance (LocationCallbacks& locationCallbacks) |
| { |
| if (nullptr == locationCallbacks.capabilitiesCb || |
| nullptr == locationCallbacks.responseCb || |
| nullptr == locationCallbacks.collectiveResponseCb) { |
| LOC_LOGe("missing mandatory callback, return null"); |
| return NULL; |
| } |
| |
| LocationAPI* newLocationAPI = new LocationAPI(); |
| bool requestedCapabilities = false; |
| |
| pthread_mutex_lock(&gDataMutex); |
| |
| gOSFrameworkRefCount++; |
| if (1 == gOSFrameworkRefCount) { |
| createOSFrameworkInstance(); |
| } |
| |
| if (isGnssClient(locationCallbacks)) { |
| if (NULL == gData.gnssInterface && !gGnssLoadFailed) { |
| gData.gnssInterface = |
| (GnssInterface*)loadLocationInterface<GnssInterface, |
| getGnssInterface>("libgnss.so", "getGnssInterface"); |
| if (NULL == gData.gnssInterface) { |
| gGnssLoadFailed = true; |
| LOC_LOGW("%s:%d]: No gnss interface available", __func__, __LINE__); |
| } else { |
| gData.gnssInterface->initialize(); |
| } |
| } |
| if (NULL != gData.gnssInterface) { |
| gData.gnssInterface->addClient(newLocationAPI, locationCallbacks); |
| if (!requestedCapabilities) { |
| gData.gnssInterface->requestCapabilities(newLocationAPI); |
| requestedCapabilities = true; |
| } |
| } |
| } |
| |
| if (isBatchingClient(locationCallbacks)) { |
| if (NULL == gData.batchingInterface && !gBatchingLoadFailed) { |
| gData.batchingInterface = |
| (BatchingInterface*)loadLocationInterface<BatchingInterface, |
| getBatchingInterface>("libbatching.so", "getBatchingInterface"); |
| if (NULL == gData.batchingInterface) { |
| gBatchingLoadFailed = true; |
| LOC_LOGW("%s:%d]: No batching interface available", __func__, __LINE__); |
| } else { |
| gData.batchingInterface->initialize(); |
| } |
| } |
| if (NULL != gData.batchingInterface) { |
| gData.batchingInterface->addClient(newLocationAPI, locationCallbacks); |
| if (!requestedCapabilities) { |
| gData.batchingInterface->requestCapabilities(newLocationAPI); |
| requestedCapabilities = true; |
| } |
| } |
| } |
| |
| if (isGeofenceClient(locationCallbacks)) { |
| if (NULL == gData.geofenceInterface && !gGeofenceLoadFailed) { |
| gData.geofenceInterface = |
| (GeofenceInterface*)loadLocationInterface<GeofenceInterface, |
| getGeofenceInterface>("libgeofencing.so", "getGeofenceInterface"); |
| if (NULL == gData.geofenceInterface) { |
| gGeofenceLoadFailed = true; |
| LOC_LOGW("%s:%d]: No geofence interface available", __func__, __LINE__); |
| } else { |
| gData.geofenceInterface->initialize(); |
| } |
| } |
| if (NULL != gData.geofenceInterface) { |
| gData.geofenceInterface->addClient(newLocationAPI, locationCallbacks); |
| if (!requestedCapabilities) { |
| gData.geofenceInterface->requestCapabilities(newLocationAPI); |
| requestedCapabilities = true; |
| } |
| } |
| } |
| |
| gData.clientData[newLocationAPI] = locationCallbacks; |
| |
| pthread_mutex_unlock(&gDataMutex); |
| |
| return newLocationAPI; |
| } |
| |
| void |
| LocationAPI::destroy(locationApiDestroyCompleteCallback destroyCompleteCb) |
| { |
| bool invokeDestroyCb = false; |
| |
| pthread_mutex_lock(&gDataMutex); |
| auto it = gData.clientData.find(this); |
| if (it != gData.clientData.end()) { |
| bool removeFromGnssInf = (NULL != gData.gnssInterface); |
| bool removeFromBatchingInf = (NULL != gData.batchingInterface); |
| bool removeFromGeofenceInf = (NULL != gData.geofenceInterface); |
| bool needToWait = (removeFromGnssInf || removeFromBatchingInf || removeFromGeofenceInf); |
| LOC_LOGe("removeFromGnssInf: %d, removeFromBatchingInf: %d, removeFromGeofenceInf: %d," |
| "needToWait: %d", removeFromGnssInf, removeFromBatchingInf, removeFromGeofenceInf, |
| needToWait); |
| |
| if ((NULL != destroyCompleteCb) && (true == needToWait)) { |
| LocationAPIDestroyCbData destroyCbData = {}; |
| destroyCbData.destroyCompleteCb = destroyCompleteCb; |
| // record down from which adapter we need to wait for the destroy complete callback |
| // only when we have received all the needed callbacks from all the associated stacks, |
| // we shall notify the client. |
| destroyCbData.waitAdapterMask = |
| (removeFromGnssInf ? LOCATION_ADAPTER_GNSS_TYPE_BIT : 0); |
| destroyCbData.waitAdapterMask |= |
| (removeFromBatchingInf ? LOCATION_ADAPTER_BATCHING_TYPE_BIT : 0); |
| destroyCbData.waitAdapterMask |= |
| (removeFromGeofenceInf ? LOCATION_ADAPTER_GEOFENCE_TYPE_BIT : 0); |
| gData.destroyClientData[this] = destroyCbData; |
| LOC_LOGi("destroy data stored in the map: 0x%x", destroyCbData.waitAdapterMask); |
| } |
| |
| if (removeFromGnssInf) { |
| gData.gnssInterface->removeClient(it->first, |
| onGnssRemoveClientCompleteCb); |
| } |
| if (removeFromBatchingInf) { |
| gData.batchingInterface->removeClient(it->first, |
| onBatchingRemoveClientCompleteCb); |
| } |
| if (removeFromGeofenceInf) { |
| gData.geofenceInterface->removeClient(it->first, |
| onGeofenceRemoveClientCompleteCb); |
| } |
| |
| gData.clientData.erase(it); |
| |
| if (!needToWait) { |
| invokeDestroyCb = true; |
| } |
| } else { |
| LOC_LOGE("%s:%d]: Location API client %p not found in client data", |
| __func__, __LINE__, this); |
| } |
| |
| if (1 == gOSFrameworkRefCount) { |
| destroyOSFrameworkInstance(); |
| } |
| gOSFrameworkRefCount--; |
| |
| pthread_mutex_unlock(&gDataMutex); |
| if (invokeDestroyCb) { |
| if (!destroyCompleteCb) { |
| (destroyCompleteCb) (); |
| } |
| delete this; |
| } |
| } |
| |
| LocationAPI::LocationAPI() |
| { |
| LOC_LOGD("LOCATION API CONSTRUCTOR"); |
| } |
| |
| // private destructor |
| LocationAPI::~LocationAPI() |
| { |
| LOC_LOGD("LOCATION API DESTRUCTOR"); |
| } |
| |
| void |
| LocationAPI::updateCallbacks(LocationCallbacks& locationCallbacks) |
| { |
| if (nullptr == locationCallbacks.capabilitiesCb || |
| nullptr == locationCallbacks.responseCb || |
| nullptr == locationCallbacks.collectiveResponseCb) { |
| return; |
| } |
| |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (isGnssClient(locationCallbacks)) { |
| if (NULL == gData.gnssInterface && !gGnssLoadFailed) { |
| gData.gnssInterface = |
| (GnssInterface*)loadLocationInterface<GnssInterface, |
| getGnssInterface>("libgnss.so", "getGnssInterface"); |
| if (NULL == gData.gnssInterface) { |
| gGnssLoadFailed = true; |
| LOC_LOGW("%s:%d]: No gnss interface available", __func__, __LINE__); |
| } else { |
| gData.gnssInterface->initialize(); |
| } |
| } |
| if (NULL != gData.gnssInterface) { |
| // either adds new Client or updates existing Client |
| gData.gnssInterface->addClient(this, locationCallbacks); |
| } |
| } |
| |
| if (isBatchingClient(locationCallbacks)) { |
| if (NULL == gData.batchingInterface && !gBatchingLoadFailed) { |
| gData.batchingInterface = |
| (BatchingInterface*)loadLocationInterface<BatchingInterface, |
| getBatchingInterface>("libbatching.so", "getBatchingInterface"); |
| if (NULL == gData.batchingInterface) { |
| gBatchingLoadFailed = true; |
| LOC_LOGW("%s:%d]: No batching interface available", __func__, __LINE__); |
| } else { |
| gData.batchingInterface->initialize(); |
| } |
| } |
| if (NULL != gData.batchingInterface) { |
| // either adds new Client or updates existing Client |
| gData.batchingInterface->addClient(this, locationCallbacks); |
| } |
| } |
| |
| if (isGeofenceClient(locationCallbacks)) { |
| if (NULL == gData.geofenceInterface && !gGeofenceLoadFailed) { |
| gData.geofenceInterface = |
| (GeofenceInterface*)loadLocationInterface<GeofenceInterface, |
| getGeofenceInterface>("libgeofencing.so", "getGeofenceInterface"); |
| if (NULL == gData.geofenceInterface) { |
| gGeofenceLoadFailed = true; |
| LOC_LOGW("%s:%d]: No geofence interface available", __func__, __LINE__); |
| } else { |
| gData.geofenceInterface->initialize(); |
| } |
| } |
| if (NULL != gData.geofenceInterface) { |
| // either adds new Client or updates existing Client |
| gData.geofenceInterface->addClient(this, locationCallbacks); |
| } |
| } |
| |
| gData.clientData[this] = locationCallbacks; |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| uint32_t |
| LocationAPI::startTracking(TrackingOptions& trackingOptions) |
| { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| auto it = gData.clientData.find(this); |
| if (it != gData.clientData.end()) { |
| if (NULL != gData.gnssInterface) { |
| id = gData.gnssInterface->startTracking(this, trackingOptions); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| } else { |
| LOC_LOGE("%s:%d]: Location API client %p not found in client data", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| void |
| LocationAPI::stopTracking(uint32_t id) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| auto it = gData.clientData.find(this); |
| if (it != gData.clientData.end()) { |
| if (gData.gnssInterface != NULL) { |
| gData.gnssInterface->stopTracking(this, id); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| } else { |
| LOC_LOGE("%s:%d]: Location API client %p not found in client data", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void |
| LocationAPI::updateTrackingOptions( |
| uint32_t id, TrackingOptions& trackingOptions) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| auto it = gData.clientData.find(this); |
| if (it != gData.clientData.end()) { |
| if (gData.gnssInterface != NULL) { |
| gData.gnssInterface->updateTrackingOptions(this, id, trackingOptions); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| } else { |
| LOC_LOGE("%s:%d]: Location API client %p not found in client data", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| uint32_t |
| LocationAPI::startBatching(BatchingOptions &batchingOptions) |
| { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (NULL != gData.batchingInterface) { |
| id = gData.batchingInterface->startBatching(this, batchingOptions); |
| } else { |
| LOC_LOGE("%s:%d]: No batching interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| void |
| LocationAPI::stopBatching(uint32_t id) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (NULL != gData.batchingInterface) { |
| gData.batchingInterface->stopBatching(this, id); |
| } else { |
| LOC_LOGE("%s:%d]: No batching interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void |
| LocationAPI::updateBatchingOptions(uint32_t id, BatchingOptions& batchOptions) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (NULL != gData.batchingInterface) { |
| gData.batchingInterface->updateBatchingOptions(this, id, batchOptions); |
| } else { |
| LOC_LOGE("%s:%d]: No batching interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void |
| LocationAPI::getBatchedLocations(uint32_t id, size_t count) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.batchingInterface != NULL) { |
| gData.batchingInterface->getBatchedLocations(this, id, count); |
| } else { |
| LOC_LOGE("%s:%d]: No batching interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| uint32_t* |
| LocationAPI::addGeofences(size_t count, GeofenceOption* options, GeofenceInfo* info) |
| { |
| uint32_t* ids = NULL; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.geofenceInterface != NULL) { |
| ids = gData.geofenceInterface->addGeofences(this, count, options, info); |
| } else { |
| LOC_LOGE("%s:%d]: No geofence interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return ids; |
| } |
| |
| void |
| LocationAPI::removeGeofences(size_t count, uint32_t* ids) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.geofenceInterface != NULL) { |
| gData.geofenceInterface->removeGeofences(this, count, ids); |
| } else { |
| LOC_LOGE("%s:%d]: No geofence interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void |
| LocationAPI::modifyGeofences(size_t count, uint32_t* ids, GeofenceOption* options) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.geofenceInterface != NULL) { |
| gData.geofenceInterface->modifyGeofences(this, count, ids, options); |
| } else { |
| LOC_LOGE("%s:%d]: No geofence interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void |
| LocationAPI::pauseGeofences(size_t count, uint32_t* ids) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.geofenceInterface != NULL) { |
| gData.geofenceInterface->pauseGeofences(this, count, ids); |
| } else { |
| LOC_LOGE("%s:%d]: No geofence interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void |
| LocationAPI::resumeGeofences(size_t count, uint32_t* ids) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.geofenceInterface != NULL) { |
| gData.geofenceInterface->resumeGeofences(this, count, ids); |
| } else { |
| LOC_LOGE("%s:%d]: No geofence interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void |
| LocationAPI::gnssNiResponse(uint32_t id, GnssNiResponse response) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| gData.gnssInterface->gnssNiResponse(this, id, response); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| void LocationAPI::enableNetworkProvider() { |
| void* libHandle = nullptr; |
| enableProviderGetter* setter = (enableProviderGetter*)dlGetSymFromLib(libHandle, |
| "liblocationservice_glue.so", "enableNetworkProvider"); |
| if (setter != nullptr) { |
| (*setter)(); |
| } else { |
| LOC_LOGe("dlGetSymFromLib failed for liblocationservice_glue.so"); |
| } |
| } |
| |
| void LocationAPI::disableNetworkProvider() { |
| void* libHandle = nullptr; |
| disableProviderGetter* setter = (disableProviderGetter*)dlGetSymFromLib(libHandle, |
| "liblocationservice_glue.so", "disableNetworkProvider"); |
| if (setter != nullptr) { |
| (*setter)(); |
| } else { |
| LOC_LOGe("dlGetSymFromLib failed for liblocationservice_glue.so"); |
| } |
| } |
| |
| void LocationAPI::startNetworkLocation(trackingCallback* callback) { |
| void* libHandle = nullptr; |
| getSingleNetworkLocationGetter* setter = |
| (getSingleNetworkLocationGetter*)dlGetSymFromLib(libHandle, |
| "liblocationservice_glue.so", "startNetworkLocation"); |
| if (setter != nullptr) { |
| (*setter)(callback); |
| } else { |
| LOC_LOGe("dlGetSymFromLib failed for liblocationservice_glue.so"); |
| } |
| } |
| |
| void LocationAPI::stopNetworkLocation(trackingCallback* callback) { |
| void* libHandle = nullptr; |
| stopNetworkLocationGetter* setter = (stopNetworkLocationGetter*)dlGetSymFromLib(libHandle, |
| "liblocationservice_glue.so", "stopNetworkLocation"); |
| if (setter != nullptr) { |
| LOC_LOGe("called"); |
| (*setter)(callback); |
| } else { |
| LOC_LOGe("dlGetSymFromLib failed for liblocationservice_glue.so"); |
| } |
| } |
| |
| LocationControlAPI* |
| LocationControlAPI::createInstance(LocationControlCallbacks& locationControlCallbacks) |
| { |
| LocationControlAPI* controlAPI = NULL; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (nullptr != locationControlCallbacks.responseCb && NULL == gData.controlAPI) { |
| if (NULL == gData.gnssInterface && !gGnssLoadFailed) { |
| gData.gnssInterface = |
| (GnssInterface*)loadLocationInterface<GnssInterface, |
| getGnssInterface>("libgnss.so", "getGnssInterface"); |
| if (NULL == gData.gnssInterface) { |
| gGnssLoadFailed = true; |
| LOC_LOGW("%s:%d]: No gnss interface available", __func__, __LINE__); |
| } else { |
| gData.gnssInterface->initialize(); |
| } |
| } |
| if (NULL != gData.gnssInterface) { |
| gData.controlAPI = new LocationControlAPI(); |
| gData.controlCallbacks = locationControlCallbacks; |
| gData.gnssInterface->setControlCallbacks(locationControlCallbacks); |
| controlAPI = gData.controlAPI; |
| } |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return controlAPI; |
| } |
| |
| void |
| LocationControlAPI::destroy() |
| { |
| delete this; |
| } |
| |
| LocationControlAPI::LocationControlAPI() |
| { |
| LOC_LOGD("LOCATION CONTROL API CONSTRUCTOR"); |
| } |
| |
| LocationControlAPI::~LocationControlAPI() |
| { |
| LOC_LOGD("LOCATION CONTROL API DESTRUCTOR"); |
| pthread_mutex_lock(&gDataMutex); |
| |
| gData.controlAPI = NULL; |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| uint32_t |
| LocationControlAPI::enable(LocationTechnologyType techType) |
| { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->enable(techType); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location Control API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| void |
| LocationControlAPI::disable(uint32_t id) |
| { |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| gData.gnssInterface->disable(id); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location Control API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| } |
| |
| uint32_t* |
| LocationControlAPI::gnssUpdateConfig(const GnssConfig& config) |
| { |
| uint32_t* ids = NULL; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| ids = gData.gnssInterface->gnssUpdateConfig(config); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location Control API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return ids; |
| } |
| |
| uint32_t* LocationControlAPI::gnssGetConfig(GnssConfigFlagsMask mask) { |
| |
| uint32_t* ids = NULL; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (NULL != gData.gnssInterface) { |
| ids = gData.gnssInterface->gnssGetConfig(mask); |
| } else { |
| LOC_LOGe("No gnss interface available for Control API client %p", this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return ids; |
| } |
| |
| uint32_t |
| LocationControlAPI::gnssDeleteAidingData(GnssAidingData& data) |
| { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->gnssDeleteAidingData(data); |
| } else { |
| LOC_LOGE("%s:%d]: No gnss interface available for Location Control API client %p ", |
| __func__, __LINE__, this); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configConstellations( |
| const GnssSvTypeConfig& constellationEnablementConfig, |
| const GnssSvIdConfig& blacklistSvConfig) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->gnssUpdateSvConfig( |
| constellationEnablementConfig, blacklistSvConfig); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configConstellationSecondaryBand( |
| const GnssSvTypeConfig& secondaryBandConfig) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->gnssUpdateSecondaryBandConfig(secondaryBandConfig); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configConstrainedTimeUncertainty( |
| bool enable, float tuncThreshold, uint32_t energyBudget) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->setConstrainedTunc(enable, |
| tuncThreshold, |
| energyBudget); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configPositionAssistedClockEstimator(bool enable) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->setPositionAssistedClockEstimator(enable); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configLeverArm(const LeverArmConfigInfo& configInfo) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->configLeverArm(configInfo); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configRobustLocation(bool enable, bool enableForE911) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->configRobustLocation(enable, enableForE911); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configMinGpsWeek(uint16_t minGpsWeek) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->configMinGpsWeek(minGpsWeek); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configDeadReckoningEngineParams( |
| const DeadReckoningEngineConfig& dreConfig) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->configDeadReckoningEngineParams(dreConfig); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::configEngineRunState( |
| PositioningEngineMask engType, LocEngineRunState engState) { |
| uint32_t id = 0; |
| pthread_mutex_lock(&gDataMutex); |
| |
| if (gData.gnssInterface != NULL) { |
| id = gData.gnssInterface->configEngineRunState(engType, engState); |
| } else { |
| LOC_LOGe("No gnss interface available for Location Control API"); |
| } |
| |
| pthread_mutex_unlock(&gDataMutex); |
| return id; |
| } |
| |
| uint32_t LocationControlAPI::setOptInStatus(bool userConsent) { |
| void* libHandle = nullptr; |
| uint32_t sessionId = 0; |
| setOptInStatusGetter* setter = (setOptInStatusGetter*)dlGetSymFromLib(libHandle, |
| "liblocationservice_glue.so", "setOptInStatus"); |
| if (setter != nullptr) { |
| sessionId = (*setter)(userConsent, &gData.controlCallbacks.responseCb); |
| } else { |
| LOC_LOGe("dlGetSymFromLib failed for liblocationservice_glue.so"); |
| } |
| return sessionId; |
| } |