Michael Koster / mbedConnectorInterface

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Fork of mbedConnectorInterface by Doug Anson

api/ThreadedResourceObserver.cpp@36:1c6c45584c13, 2015-04-09 (annotated)

Committer:
ansond
Date:
Thu Apr 09 03:32:11 2015 +0000
Revision:
36:1c6c45584c13
Parent:
31:bacc63106754
Child:
43:769d491a48c1
updates

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ansond 30:113c2a1d8db2 1 /**
ansond 30:113c2a1d8db2 2 * @file ThreadedResourceObserver.cpp
ansond 30:113c2a1d8db2 3 * @brief mbed CoAP DynamicResource Thread-based observer (implementation)
ansond 30:113c2a1d8db2 4 * @author Doug Anson/Chris Paola
ansond 30:113c2a1d8db2 5 * @version 1.0
ansond 30:113c2a1d8db2 6 * @see
ansond 30:113c2a1d8db2 7 *
ansond 30:113c2a1d8db2 8 * Copyright (c) 2014
ansond 30:113c2a1d8db2 9 *
ansond 30:113c2a1d8db2 10 * Licensed under the Apache License, Version 2.0 (the "License");
ansond 30:113c2a1d8db2 11 * you may not use this file except in compliance with the License.
ansond 30:113c2a1d8db2 12 * You may obtain a copy of the License at
ansond 30:113c2a1d8db2 13 *
ansond 30:113c2a1d8db2 14 * http://www.apache.org/licenses/LICENSE-2.0
ansond 30:113c2a1d8db2 15 *
ansond 30:113c2a1d8db2 16 * Unless required by applicable law or agreed to in writing, software
ansond 30:113c2a1d8db2 17 * distributed under the License is distributed on an "AS IS" BASIS,
ansond 30:113c2a1d8db2 18 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
ansond 30:113c2a1d8db2 19 * See the License for the specific language governing permissions and
ansond 30:113c2a1d8db2 20 * limitations under the License.
ansond 30:113c2a1d8db2 21 */
ansond 30:113c2a1d8db2 22
ansond 30:113c2a1d8db2 23 #include "ThreadedResourceObserver.h"
ansond 30:113c2a1d8db2 24
ansond 30:113c2a1d8db2 25 // constructor
ansond 31:bacc63106754 26 ThreadedResourceObserver::ThreadedResourceObserver(DynamicResource *resource,int sleep_time) :
ansond 31:bacc63106754 27 ResourceObserver(resource,sleep_time)
ansond 31:bacc63106754 28 #ifdef CONNECTOR_USING_THREADS
ansond 31:bacc63106754 29 ,m_observation_thread(&ThreadedResourceObserver::_observation_notifier,this)
ansond 31:bacc63106754 30 #endif
ansond 31:bacc63106754 31 {
ansond 30:113c2a1d8db2 32 }
ansond 30:113c2a1d8db2 33
ansond 30:113c2a1d8db2 34 // destructor
ansond 30:113c2a1d8db2 35 ThreadedResourceObserver::~ThreadedResourceObserver() {
ansond 31:bacc63106754 36 this->stopObservation();
ansond 31:bacc63106754 37 #ifdef CONNECTOR_USING_THREADS
ansond 30:113c2a1d8db2 38 this->m_observation_thread.terminate();
ansond 31:bacc63106754 39 #endif
ansond 30:113c2a1d8db2 40 }
ansond 30:113c2a1d8db2 41
ansond 30:113c2a1d8db2 42 // notifier
ansond 31:bacc63106754 43 void ThreadedResourceObserver::_observation_notifier(void const *instance) {
ansond 31:bacc63106754 44 #ifdef CONNECTOR_USING_THREADS
ansond 31:bacc63106754 45 ThreadedResourceObserver *me = (ThreadedResourceObserver *)instance;
ansond 30:113c2a1d8db2 46 while(true) {
ansond 31:bacc63106754 47 Thread::wait(me->getSleepTime());
ansond 36:1c6c45584c13 48 if (me->isObserving() == true && me->getResource() != NULL && nsdl_endpoint_is_registered() == true) {
ansond 31:bacc63106754 49 me->getResource()->observe();
ansond 30:113c2a1d8db2 50 }
ansond 30:113c2a1d8db2 51 }
ansond 31:bacc63106754 52 #endif
ansond 31:bacc63106754 53 }
ansond 31:bacc63106754 54
ansond 31:bacc63106754 55 // begin observing...
ansond 31:bacc63106754 56 void ThreadedResourceObserver::beginObservation() {
ansond 31:bacc63106754 57 this->setObserving(true);
ansond 30:113c2a1d8db2 58 }
ansond 30:113c2a1d8db2 59
ansond 31:bacc63106754 60 // stop observing...
ansond 31:bacc63106754 61 void ThreadedResourceObserver::stopObservation() {
ansond 31:bacc63106754 62 this->setObserving(false);
ansond 30:113c2a1d8db2 63 }