mbed Connector Interface simplification API on top of mbed-client
Fork of mbedConnectorInterfaceV3 by
NOTE:
This repo has been replaced with https://github.com/ARMmbed/mbedConnectorInterface. No further updates will occur with this repo. Please use the github repo instead. Thanks!
source/ThreadedResourceObserver.cpp
- Committer:
- ansond
- Date:
- 2016-08-22
- Revision:
- 68:d016acf33ab4
- Parent:
- 67:0c130dc6b489
- Child:
- 69:baa167cf771b
File content as of revision 68:d016acf33ab4:
/** * @file ThreadedResourceObserver.cpp * @brief mbed CoAP DynamicResource Thread-based observer (implementation) * @author Doug Anson/Chris Paola * @version 1.0 * @see * * Copyright (c) 2014 * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // Class support #include "mbed-connector-interface/ThreadedResourceObserver.h" #ifdef CONNECTOR_USING_THREADS // constructor ThreadedResourceObserver::ThreadedResourceObserver(DynamicResource *resource,int sleep_time) : ResourceObserver(resource,sleep_time), m_observation_thread() { // default is not observing... this->setObserving(false); // DEBUG if (sleep_time > 0) { this->logger()->log("ThreadedResourceObserver being used for %s (sleep_time: %d ms)",resource->getFullName().c_str(),sleep_time); } else { this->logger()->log("ThreadedResourceObserver being used for %s",resource->getFullName().c_str()); } // start the thread by invoking the thread task... this->m_observation_thread.start(this,&ThreadedResourceObserver::observation_task); } // destructor ThreadedResourceObserver::~ThreadedResourceObserver() { this->stopObservation(); this->m_observation_thread.terminate(); } // thread task method void ThreadedResourceObserver::observation_task(ThreadedResourceObserver *me) { if (me != NULL) { while(true) { Thread::wait(me->getSleepTime()); if (me->isObserving() == true && me->getResource() != NULL && me->getResource()->isRegistered() == true) { DynamicResource *res = me->getResource(); if (res != NULL) { res->observe(); } } } } else { // instance pointer is NULL printf("ThreadedResourceObserver::observation_task(): ERROR: Instance pointer is NULL\r\n"); } } // begin observing... void ThreadedResourceObserver::beginObservation() { this->setObserving(true); } // stop observing... void ThreadedResourceObserver::stopObservation() { this->setObserving(false); } // halt the underlying observer mechanism void ThreadedResourceObserver::halt() { m_observation_thread.terminate(); } #endif // CONNECTOR_USING_THREADS