Home | History | Annotate | Download | only in core 
      1 /* Copyright (c) 2011-2014, 2016-2017 The Linux Foundation. All rights reserved.
      2  *
      3  * Redistribution and use in source and binary forms, with or without
      4  * modification, are permitted provided that the following conditions are
      5  * met:
      6  *     * Redistributions of source code must retain the above copyright
      7  *       notice, this list of conditions and the following disclaimer.
      8  *     * Redistributions in binary form must reproduce the above
      9  *       copyright notice, this list of conditions and the following
     10  *       disclaimer in the documentation and/or other materials provided
     11  *       with the distribution.
     12  *     * Neither the name of The Linux Foundation, nor the names of its
     13  *       contributors may be used to endorse or promote products derived
     14  *       from this software without specific prior written permission.
     15  *
     16  * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
     17  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
     18  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
     19  * ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
     20  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     21  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     22  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
     23  * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
     24  * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
     25  * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
     26  * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     27  *
     28  */
     29 #define LOG_NDEBUG 0
     30 #define LOG_TAG "LocSvc_DualCtx"
     31 
     32 #include <cutils/sched_policy.h>
     33 #include <unistd.h>
     34 #include <LocDualContext.h>
     35 #include <msg_q.h>
     36 #include <platform_lib_log_util.h>
     37 #include <loc_log.h>
     38 
     39 namespace loc_core {
     40 
     41 // nothing exclude for foreground
     42 const LOC_API_ADAPTER_EVENT_MASK_T
     43 LocDualContext::mFgExclMask = 0;
     44 // excluded events for background clients
     45 const LOC_API_ADAPTER_EVENT_MASK_T
     46 LocDualContext::mBgExclMask =
     47     (LOC_API_ADAPTER_BIT_SATELLITE_REPORT |
     48      LOC_API_ADAPTER_BIT_NMEA_1HZ_REPORT |
     49      LOC_API_ADAPTER_BIT_NMEA_POSITION_REPORT |
     50      LOC_API_ADAPTER_BIT_IOCTL_REPORT |
     51      LOC_API_ADAPTER_BIT_STATUS_REPORT |
     52      LOC_API_ADAPTER_BIT_GEOFENCE_GEN_ALERT |
     53      LOC_API_ADAPTER_BIT_GNSS_MEASUREMENT);
     54 
     55 const MsgTask* LocDualContext::mMsgTask = NULL;
     56 ContextBase* LocDualContext::mFgContext = NULL;
     57 ContextBase* LocDualContext::mBgContext = NULL;
     58 ContextBase* LocDualContext::mInjectContext = NULL;
     59 // the name must be shorter than 15 chars
     60 const char* LocDualContext::mLocationHalName = "Loc_hal_worker";
     61 #ifndef USE_GLIB
     62 const char* LocDualContext::mLBSLibName = "liblbs_core.so";
     63 #else
     64 const char* LocDualContext::mLBSLibName = "liblbs_core.so.1";
     65 #endif
     66 
     67 pthread_mutex_t LocDualContext::mGetLocContextMutex = PTHREAD_MUTEX_INITIALIZER;
     68 
     69 const MsgTask* LocDualContext::getMsgTask(LocThread::tCreate tCreator,
     70                                           const char* name, bool joinable)
     71 {
     72     if (NULL == mMsgTask) {
     73         mMsgTask = new MsgTask(tCreator, name, joinable);
     74     }
     75     return mMsgTask;
     76 }
     77 
     78 inline
     79 const MsgTask* LocDualContext::getMsgTask(const char* name, bool joinable) {
     80     return getMsgTask((LocThread::tCreate)NULL, name, joinable);
     81 }
     82 
     83 ContextBase* LocDualContext::getLocFgContext(LocThread::tCreate tCreator,
     84             LocMsg* firstMsg, const char* name, bool joinable)
     85 {
     86     pthread_mutex_lock(&LocDualContext::mGetLocContextMutex);
     87     LOC_LOGD("%s:%d]: querying ContextBase with tCreator", __func__, __LINE__);
     88     if (NULL == mFgContext) {
     89         LOC_LOGD("%s:%d]: creating msgTask with tCreator", __func__, __LINE__);
     90         const MsgTask* msgTask = getMsgTask(tCreator, name, joinable);
     91         mFgContext = new LocDualContext(msgTask,
     92                                         mFgExclMask);
     93     }
     94     if(NULL == mInjectContext) {
     95         LOC_LOGD("%s:%d]: mInjectContext is FgContext", __func__, __LINE__);
     96         mInjectContext = mFgContext;
     97         injectFeatureConfig(mInjectContext);
     98     }
     99     pthread_mutex_unlock(&LocDualContext::mGetLocContextMutex);
    100 
    101     if (firstMsg) {
    102         mFgContext->sendMsg(firstMsg);
    103     }
    104 
    105     return mFgContext;
    106 }
    107 
    108 ContextBase* LocDualContext::getLocBgContext(LocThread::tCreate tCreator,
    109             LocMsg* firstMsg, const char* name, bool joinable)
    110 {
    111     pthread_mutex_lock(&LocDualContext::mGetLocContextMutex);
    112     LOC_LOGD("%s:%d]: querying ContextBase with tCreator", __func__, __LINE__);
    113     if (NULL == mBgContext) {
    114         LOC_LOGD("%s:%d]: creating msgTask with tCreator", __func__, __LINE__);
    115         const MsgTask* msgTask = getMsgTask(tCreator, name, joinable);
    116         mBgContext = new LocDualContext(msgTask,
    117                                         mBgExclMask);
    118     }
    119     if(NULL == mInjectContext) {
    120         LOC_LOGD("%s:%d]: mInjectContext is BgContext", __func__, __LINE__);
    121         mInjectContext = mBgContext;
    122         injectFeatureConfig(mInjectContext);
    123     }
    124     pthread_mutex_unlock(&LocDualContext::mGetLocContextMutex);
    125 
    126     if (firstMsg) {
    127         mBgContext->sendMsg(firstMsg);
    128     }
    129 
    130     return mBgContext;
    131 }
    132 
    133 void LocDualContext :: injectFeatureConfig(ContextBase *curContext)
    134 {
    135     LOC_LOGD("%s:%d]: Enter", __func__, __LINE__);
    136     if(curContext == mInjectContext) {
    137         LOC_LOGD("%s:%d]: Calling LBSProxy (%p) to inject feature config",
    138                  __func__, __LINE__, ((LocDualContext *)mInjectContext)->mLBSProxy);
    139         ((LocDualContext *)mInjectContext)->mLBSProxy->injectFeatureConfig(curContext);
    140     }
    141     LOC_LOGD("%s:%d]: Exit", __func__, __LINE__);
    142 }
    143 
    144 LocDualContext::LocDualContext(const MsgTask* msgTask,
    145                                LOC_API_ADAPTER_EVENT_MASK_T exMask) :
    146     ContextBase(msgTask, exMask, mLBSLibName)
    147 {
    148 }
    149 
    150 }
    151