{
void verifyObserveCB(
const HeaderOptions &_hos, const ResponseStatement &_rep,
- int _result, int _seq, std::weak_ptr<DataCache> rpPtr)
+ int _result, unsigned int _seq, std::weak_ptr<DataCache> rpPtr)
{
- std::shared_ptr<DataCache> Ptr = rpPtr.lock();
- if (Ptr)
+ std::shared_ptr<DataCache> ptr = rpPtr.lock();
+ if (ptr)
{
- Ptr->onObserve(_hos, _rep, _result, _seq);
+ ptr->onObserve(_hos, _rep, _result, _seq);
}
}
subscriberList.release();
}
- if (mode == CACHE_MODE::OBSERVE)
+ if (sResource->isObservable())
{
try
{
const PrimitiveResourcePtr DataCache::getPrimitiveResource() const
{
- return (sResource != nullptr) ? sResource : nullptr;
+ return sResource;
}
const RCSResourceAttributes DataCache::getCachedData() const
}
void DataCache::onObserve(const HeaderOptions & /*_hos*/,
- const ResponseStatement &_rep, int _result, int _seq)
+ const ResponseStatement &_rep, int _result, unsigned int _seq)
{
if (_result != OC_STACK_OK || _rep.getAttributes().empty() || lastSequenceNum > _seq)