int _result, int _seq, std::weak_ptr<DataCache> rpPtr)
{
std::shared_ptr<DataCache> Ptr = rpPtr.lock();
- if(Ptr)
+ if (Ptr)
{
Ptr->onObserve(_hos, _rep, _result, _seq);
}
ObserveCB verifiedObserveCB(std::weak_ptr<DataCache> rpPtr)
{
return std::bind(verifyObserveCB,
- std::placeholders::_1, std::placeholders::_2,
- std::placeholders::_3, std::placeholders::_4, rpPtr);
+ std::placeholders::_1, std::placeholders::_2,
+ std::placeholders::_3, std::placeholders::_4, rpPtr);
}
void verifyGetCB(
- const HeaderOptions &_hos, const ResponseStatement &_rep,
- int _result, std::weak_ptr<DataCache> rpPtr)
+ const HeaderOptions &_hos, const ResponseStatement &_rep,
+ int _result, std::weak_ptr<DataCache> rpPtr)
{
std::shared_ptr<DataCache> Ptr = rpPtr.lock();
- if(Ptr)
+ if (Ptr)
{
Ptr->onGet(_hos, _rep, _result);
}
GetCB verifiedGetCB(std::weak_ptr<DataCache> rpPtr)
{
return std::bind(verifyGetCB,
- std::placeholders::_1, std::placeholders::_2,
- std::placeholders::_3, rpPtr);
+ std::placeholders::_1, std::placeholders::_2,
+ std::placeholders::_3, rpPtr);
}
}
subscriberList.release();
}
- if(mode == CACHE_MODE::OBSERVE)
+ if (mode == CACHE_MODE::OBSERVE)
{
try
{
sResource->cancelObserve();
- } catch (...)
+ }
+ catch (...)
{
// ignore the exception because data cache was released.
}
}
void DataCache::onObserve(const HeaderOptions & /*_hos*/,
- const ResponseStatement & _rep, int _result, int _seq)
+ const ResponseStatement &_rep, int _result, int _seq)
{
if (_result != OC_STACK_OK || _rep.getAttributes().empty() || lastSequenceNum > _seq)
void DataCache::onTimeOut(unsigned int /*timerID*/)
{
- if(mode == CACHE_MODE::OBSERVE)
+ if (mode == CACHE_MODE::OBSERVE)
{
sResource->cancelObserve();
mode = CACHE_MODE::FREQUENCY;
networkTimer.cancelTimer(networkTimeOutHandle);
networkTimeOutHandle = networkTimer.postTimer(
- CACHE_DEFAULT_EXPIRED_MILLITIME, pTimerCB);
+ CACHE_DEFAULT_EXPIRED_MILLITIME, pTimerCB);
pollingHandle = pollingTimer.postTimer(CACHE_DEFAULT_REPORT_MILLITIME, pPollingCB);
return;
void(const OIC::Service::HeaderOptions &, const OIC::Service::ResponseStatement &, int,
int) > ObserveCallback;
public:
- DataCache *cacheHandler;
+ std::shared_ptr<DataCache> cacheHandler;
PrimitiveResource::Ptr pResource;
CacheCB cb;
CacheID id;
{
TestWithMock::SetUp();
pResource = PrimitiveResource::Ptr(mocks.Mock< PrimitiveResource >(), [](PrimitiveResource *) {});
- cacheHandler = new DataCache();
+ cacheHandler.reset(new DataCache());
cb = ([](std::shared_ptr<PrimitiveResource >, const RCSResourceAttributes &)->OCStackResult {return OC_STACK_OK;});
}
virtual void TearDown()
{
- delete cacheHandler;
+ cacheHandler.reset();
+ pResource.reset();
TestWithMock::TearDown();
}
};
mocks.OnCall(pResource.get(), PrimitiveResource::requestGet).Do(
[](GetCallback callback)
{
- std::cout << "HelloWorld" << std::endl;
OIC::Service::HeaderOptions hos;
-
OIC::Service::RCSResourceAttributes attr;
- //attr = mocks.Mcok< OIC::Service::RCSResourceAttributes >();
OIC::Service::ResponseStatement rep(attr);
- //rep = mocks.Mock< OIC::Service::ResponseStatement >(attr);
- //fakeResource = mocks.Mock< FakeOCResource >();
- //mocks.OnCallFunc(RCSResourceAttributes::empty()).Return(false);
callback(hos, rep, OC_STACK_OK);
return;
- }
- );
+ });
mocks.OnCall(pResource.get(), PrimitiveResource::cancelObserve);
cacheHandler->initializeDataCache(pResource);