80e09f69b6
There are a couple of issues. NetworkInfoDataItemBase objects might be from OsAgent or GnssLocationProvider. The two sources actually have mTypes defined differently. In addtion, when there are different types of connections such as wifi / mobile, getting connected / disconnected independently, clients need to be all notified correctly. Right now, if mConnected hasn't changed, no updates are send. For exmple, if mobile is connected, later wifi gets connected too, clients won't know. SystemStatus is also updated to get updated / colated informtion. In the above example, SystemStatus's top record would record as both mobile and wifi are connected. Change-Id: I1825902247fe1d4e6363f5e24a75be7e984d0dc4 CRs-Fixed: 2221114
261 lines
8.1 KiB
C++
261 lines
8.1 KiB
C++
/* Copyright (c) 2017, 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_TAG "LocSvc_XtraSystemStatusObs"
|
|
|
|
#include <sys/stat.h>
|
|
#include <sys/un.h>
|
|
#include <errno.h>
|
|
#include <ctype.h>
|
|
#include <cutils/properties.h>
|
|
#include <math.h>
|
|
#include <arpa/inet.h>
|
|
#include <netinet/in.h>
|
|
#include <netdb.h>
|
|
#include <string>
|
|
#include <loc_log.h>
|
|
#include <loc_nmea.h>
|
|
#include <SystemStatus.h>
|
|
#include <vector>
|
|
#include <sstream>
|
|
#include <XtraSystemStatusObserver.h>
|
|
#include <LocAdapterBase.h>
|
|
#include <DataItemId.h>
|
|
#include <DataItemsFactoryProxy.h>
|
|
#include <DataItemConcreteTypesBase.h>
|
|
|
|
using namespace loc_core;
|
|
|
|
#ifdef LOG_TAG
|
|
#undef LOG_TAG
|
|
#endif
|
|
#define LOG_TAG "LocSvc_XSSO"
|
|
|
|
bool XtraSystemStatusObserver::updateLockStatus(uint32_t lock) {
|
|
mGpsLock = lock;
|
|
|
|
if (!mReqStatusReceived) {
|
|
return true;
|
|
}
|
|
|
|
stringstream ss;
|
|
ss << "gpslock";
|
|
ss << " " << lock;
|
|
return ( send(LOC_IPC_XTRA, ss.str()) );
|
|
}
|
|
|
|
bool XtraSystemStatusObserver::updateConnections(uint64_t allConnections) {
|
|
mIsConnectivityStatusKnown = true;
|
|
mConnections = allConnections;
|
|
|
|
if (!mReqStatusReceived) {
|
|
return true;
|
|
}
|
|
|
|
stringstream ss;
|
|
ss << "connection";
|
|
ss << " " << mConnections;
|
|
return ( send(LOC_IPC_XTRA, ss.str()) );
|
|
}
|
|
|
|
bool XtraSystemStatusObserver::updateTac(const string& tac) {
|
|
mTac = tac;
|
|
|
|
if (!mReqStatusReceived) {
|
|
return true;
|
|
}
|
|
|
|
stringstream ss;
|
|
ss << "tac";
|
|
ss << " " << tac.c_str();
|
|
return ( send(LOC_IPC_XTRA, ss.str()) );
|
|
}
|
|
|
|
bool XtraSystemStatusObserver::updateMccMnc(const string& mccmnc) {
|
|
mMccmnc = mccmnc;
|
|
|
|
if (!mReqStatusReceived) {
|
|
return true;
|
|
}
|
|
|
|
stringstream ss;
|
|
ss << "mncmcc";
|
|
ss << " " << mccmnc.c_str();
|
|
return ( send(LOC_IPC_XTRA, ss.str()) );
|
|
}
|
|
|
|
bool XtraSystemStatusObserver::updateXtraThrottle(const bool enabled) {
|
|
mXtraThrottle = enabled;
|
|
|
|
if (!mReqStatusReceived) {
|
|
return true;
|
|
}
|
|
|
|
stringstream ss;
|
|
ss << "xtrathrottle";
|
|
ss << " " << (enabled ? 1 : 0);
|
|
return ( send(LOC_IPC_XTRA, ss.str()) );
|
|
}
|
|
|
|
inline bool XtraSystemStatusObserver::onStatusRequested(int32_t xtraStatusUpdated) {
|
|
mReqStatusReceived = true;
|
|
|
|
if (xtraStatusUpdated) {
|
|
return true;
|
|
}
|
|
|
|
stringstream ss;
|
|
|
|
ss << "respondStatus" << endl;
|
|
(mGpsLock == -1 ? ss : ss << mGpsLock) << endl << mConnections << endl
|
|
<< mTac << endl << mMccmnc << endl << mIsConnectivityStatusKnown;
|
|
|
|
return ( send(LOC_IPC_XTRA, ss.str()) );
|
|
}
|
|
|
|
void XtraSystemStatusObserver::onReceive(const std::string& data) {
|
|
if (!strncmp(data.c_str(), "ping", sizeof("ping") - 1)) {
|
|
LOC_LOGd("ping received");
|
|
|
|
#ifdef USE_GLIB
|
|
} else if (!strncmp(data.c_str(), "connectBackhaul", sizeof("connectBackhaul") - 1)) {
|
|
mSystemStatusObsrvr->connectBackhaul();
|
|
|
|
} else if (!strncmp(data.c_str(), "disconnectBackhaul", sizeof("disconnectBackhaul") - 1)) {
|
|
mSystemStatusObsrvr->disconnectBackhaul();
|
|
#endif
|
|
|
|
} else if (!strncmp(data.c_str(), "requestStatus", sizeof("requestStatus") - 1)) {
|
|
int32_t xtraStatusUpdated = 0;
|
|
sscanf(data.c_str(), "%*s %d", &xtraStatusUpdated);
|
|
|
|
struct HandleStatusRequestMsg : public LocMsg {
|
|
XtraSystemStatusObserver& mXSSO;
|
|
int32_t mXtraStatusUpdated;
|
|
inline HandleStatusRequestMsg(XtraSystemStatusObserver& xsso,
|
|
int32_t xtraStatusUpdated) :
|
|
mXSSO(xsso), mXtraStatusUpdated(xtraStatusUpdated) {}
|
|
inline void proc() const override { mXSSO.onStatusRequested(mXtraStatusUpdated); }
|
|
};
|
|
mMsgTask->sendMsg(new (nothrow) HandleStatusRequestMsg(*this, xtraStatusUpdated));
|
|
|
|
} else {
|
|
LOC_LOGw("unknown event: %s", data.c_str());
|
|
}
|
|
}
|
|
|
|
void XtraSystemStatusObserver::subscribe(bool yes)
|
|
{
|
|
// Subscription data list
|
|
list<DataItemId> subItemIdList;
|
|
subItemIdList.push_back(NETWORKINFO_DATA_ITEM_ID);
|
|
subItemIdList.push_back(MCCMNC_DATA_ITEM_ID);
|
|
|
|
if (yes) {
|
|
mSystemStatusObsrvr->subscribe(subItemIdList, this);
|
|
|
|
list<DataItemId> reqItemIdList;
|
|
reqItemIdList.push_back(TAC_DATA_ITEM_ID);
|
|
|
|
mSystemStatusObsrvr->requestData(reqItemIdList, this);
|
|
|
|
} else {
|
|
mSystemStatusObsrvr->unsubscribe(subItemIdList, this);
|
|
}
|
|
}
|
|
|
|
// IDataItemObserver overrides
|
|
void XtraSystemStatusObserver::getName(string& name)
|
|
{
|
|
name = "XtraSystemStatusObserver";
|
|
}
|
|
|
|
void XtraSystemStatusObserver::notify(const list<IDataItemCore*>& dlist)
|
|
{
|
|
struct HandleOsObserverUpdateMsg : public LocMsg {
|
|
XtraSystemStatusObserver* mXtraSysStatObj;
|
|
list <IDataItemCore*> mDataItemList;
|
|
|
|
inline HandleOsObserverUpdateMsg(XtraSystemStatusObserver* xtraSysStatObs,
|
|
const list<IDataItemCore*>& dataItemList) :
|
|
mXtraSysStatObj(xtraSysStatObs) {
|
|
for (auto eachItem : dataItemList) {
|
|
IDataItemCore* dataitem = DataItemsFactoryProxy::createNewDataItem(
|
|
eachItem->getId());
|
|
if (NULL == dataitem) {
|
|
break;
|
|
}
|
|
// Copy the contents of the data item
|
|
dataitem->copy(eachItem);
|
|
|
|
mDataItemList.push_back(dataitem);
|
|
}
|
|
}
|
|
|
|
inline ~HandleOsObserverUpdateMsg() {
|
|
for (auto each : mDataItemList) {
|
|
delete each;
|
|
}
|
|
}
|
|
|
|
inline void proc() const {
|
|
for (auto each : mDataItemList) {
|
|
switch (each->getId())
|
|
{
|
|
case NETWORKINFO_DATA_ITEM_ID:
|
|
{
|
|
NetworkInfoDataItemBase* networkInfo =
|
|
static_cast<NetworkInfoDataItemBase*>(each);
|
|
mXtraSysStatObj->updateConnections(networkInfo->getAllTypes());
|
|
}
|
|
break;
|
|
|
|
case TAC_DATA_ITEM_ID:
|
|
{
|
|
TacDataItemBase* tac =
|
|
static_cast<TacDataItemBase*>(each);
|
|
mXtraSysStatObj->updateTac(tac->mValue);
|
|
}
|
|
break;
|
|
|
|
case MCCMNC_DATA_ITEM_ID:
|
|
{
|
|
MccmncDataItemBase* mccmnc =
|
|
static_cast<MccmncDataItemBase*>(each);
|
|
mXtraSysStatObj->updateMccMnc(mccmnc->mValue);
|
|
}
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
};
|
|
mMsgTask->sendMsg(new (nothrow) HandleOsObserverUpdateMsg(this, dlist));
|
|
}
|